Package io.openems.edge.controller.api.backend

Class ResendHistoricDataWorker

java.lang.Object

io.openems.common.worker.AbstractWorker

io.openems.edge.controller.api.backend.ResendHistoricDataWorker

public final class ResendHistoricDataWorker
extends AbstractWorker

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final record	ResendHistoricDataWorker.Config
protected static enum	ResendHistoricDataWorker.TriggerState

Field Summary

Fields

Modifier and Type	Field	Description
protected static final int	DELAY_TRIGGER_TIME	This worker only starts resending data, after it got explicit triggered with AbstractWorker.triggerNextRun() and also after this delay time.
protected final AtomicReference<ResendHistoricDataWorker.TriggerState>	triggerState	Trigger helper variable to delay execution of the forever method by DELAY_TRIGGER_TIME.

Fields inherited from class io.openems.common.worker.AbstractWorker

ALWAYS_WAIT_FOR_TRIGGER_NEXT_RUN, DO_NOT_WAIT, thread

Constructor Summary

Constructors

Constructor	Description
ResendHistoricDataWorker()

Method Summary

Modifier and Type	Method	Description
protected void	bindTimedata(Timedata timedata)
void	deactivate()	Stops the worker thread.
protected void	forever()	This method is called in a loop forever until the Thread gets interrupted.
protected int	getCycleTime()	Gets the cycleTime of this worker in [ms].
protected static com.google.common.collect.TreeBasedTable<Long,String,com.google.gson.JsonElement>	mapResendData(SortedMap<Long,SortedMap<ChannelAddress,com.google.gson.JsonElement>> resendData)
void	setConfig(ResendHistoricDataWorker.Config config)
void	triggerNextRun()	Allows the next execution of the forever() method.
protected void	unbindTimedata(Timedata timedata)

Methods inherited from class io.openems.common.worker.AbstractWorker

activate, activate, modified, modified, setPriority

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

DELAY_TRIGGER_TIME

protected static final int DELAY_TRIGGER_TIME

This worker only starts resending data, after it got explicit triggered with AbstractWorker.triggerNextRun() and also after this delay time.

See Also:

• Constant Field Values

triggerState

protected final AtomicReference<ResendHistoricDataWorker.TriggerState> triggerState

Trigger helper variable to delay execution of the forever method by DELAY_TRIGGER_TIME. If during the forever method timedata or the configuration is not set the state changes into either ResendHistoricDataWorker.TriggerState.WAITING_FOR_TIMEDATA or ResendHistoricDataWorker.TriggerState.WAITING_FOR_CONFIG and continues with the execution when the one missing got set.

 triggerState = INIT
 tiggerNextRun();
 -> triggerState = AFTER_TRIGGER; 
 -> forever();
 -> if(triggerState == 1) triggerState = SKIP_FIRST_FOREVER;
 -> getCycleTime() = DELAY_TRIGGER_TIME; triggerState = INIT;
 -> forever();
 

Constructor Details

ResendHistoricDataWorker

public ResendHistoricDataWorker()

Method Details

deactivate

public void deactivate()

Description copied from class: AbstractWorker

Stops the worker thread.

Overrides:

deactivate in class AbstractWorker

forever

protected void forever()
                throws Throwable

Description copied from class: AbstractWorker

This method is called in a loop forever until the Thread gets interrupted.

Specified by:

forever in class AbstractWorker

Throws:

Throwable

bindTimedata

protected void bindTimedata(Timedata timedata)

unbindTimedata

protected void unbindTimedata(Timedata timedata)

getCycleTime

protected int getCycleTime()

Description copied from class: AbstractWorker

Gets the cycleTime of this worker in [ms].

• > 0 sets the minimum execution time of one Cycle
• = 0 never wait between two consecutive executions of forever()
• < 0 causes the Cycle to sleep forever until 'triggerNextRun()' is called

Specified by:

getCycleTime in class AbstractWorker

Returns:

the cycleTime

triggerNextRun

public void triggerNextRun()

Description copied from class: AbstractWorker

Allows the next execution of the forever() method.

Overrides:

triggerNextRun in class AbstractWorker

setConfig

public void setConfig(ResendHistoricDataWorker.Config config)

mapResendData

protected static com.google.common.collect.TreeBasedTable<Long,String,com.google.gson.JsonElement> mapResendData(SortedMap<Long,SortedMap<ChannelAddress,com.google.gson.JsonElement>> resendData)