DasuImpl

ACK the alarm if the ASCE that produces it runs in this DASU.

The DASU delegates the acknowledgment to the ASCE that produces the alarm.

This function checks if the id of the DASU in the alarm identifier matches with its own identifier and if the ASCE (again from the Identifier of the alarm) is actually running in this DASU before forwarding the ack to the ASCE.

Calculate the validity of the output depending on its last update time. The DASU consider that the IASIO is valid if it has been generated resh validityThreshold milliseconds before.

Release all the resources before exiting

Enable/disable the automatic update of the output in case no new inputs arrive.

Most likely, the value of the output remains the same while the validity could change.

Check if there are inputs to process

Check if the a task for processing inputs has been scheduled

New inputs have been received from the BSDB: the recalculation of the output is performed by a thread: the method returns immediately after scheduling the recalculation

This method is not invoked while automatically re-sending the last computed value. Such value is in fact stored into lastSentOutput and does not trigger a recalculation by the DASU.

This method gets the inputs received from the BSDB and calculate the output running a thread. The calculation of the output is delayed if the throttling is in place by scheduling a task to be run after the end of the throttling window. If the throttling is not in place, the output is calculated concurrently by running a task immediately.

This method only schedules the thread to recalculate the output when new inputs are received and the thread has not been already scheduled or is running.

There is one case that is not covered here:

• the thread is running and new inputs arrive before it terminates
• no new inputs arrive This case is corner case the likely will never happens when many inputs are continously produced. However if it happens the inputs recived in this situation will never be processsed (they will only as soon as a new inputs arrives). For this reason, when the thread that calculates the new output terminates, it checks if there are new inputs and in that case it schedules a new execution of the output calculation.

Check if the new output must be sent to the BSDB i.e if its mode or value or validity has changed

Schedule the next recalculation of the output based on

• the presence of new inputs
• the point in time when the last calculation ended and the throttling time.

No recalulcalation is scheduled if there are no new inputs to process. The delay depends on the time when the last calculation ended and the throttling time.

Start getting events from the inputs subscriber to produce the output

The configuration of the ASCEs that run in the DASU

The ASCE that produces the output

The task that timely send the last computed output when no new inputs arrived: initially disabled, must be enabled invoking enableAutoRefreshOfOutput.

If a new output is generated before this time interval elapses, this task is delayed of the duration of autoSendTimeInterval msecs.

The point in time when the DASU finished calculating the output for the last time.

It is used to schedulate the next generation of the output against the throttling time

Together with calcStartTime can be used to calculate how long does the DASU take to generate the output

The point in time when the DASU started calculating the output for the last time

Together with calcEndTime can be used to calculate how long does the DASU take to generate the output

Closed: the DASU does not process inputs

The Runnable to update the output when it is delayed by the throttling

The fullRuning Ids of the received inputs

This map must be taken synchronized because it is accessed by several threads

The last calculated output by ASCEs

The last sent output and validity this is sent again if no new inputs arrives and the autoSendTimerTask is running and the validity did not change since the last sending

The point in time when the output has been sent to the BSDB either due to new inputs or auto-refresh

It is better to initialize at the actual timestamp for the calculation of the throttling in inputsReceived

The point in time of the last time when the output has been generated and published

Values that have been received in input from plugins or other DASUs (BSDB) and not yet processed by the ASCEs

This map must be taken synchronized because it is accessed by several threads

The thread executor service

True if the DASU has been started

The generator of statistics

The task to delay the generation the output when new inputs must be processed

It is defined only when a task is running or scheduled to run in a near future.

True if the automatic re-sending of the output has been enabled

Auto send time interval in milliseconds

True if the DASU has been generated from a template, False otherwise

The ID of the DASU

The number of the instance if the DASU has been generated from a template; empty otherwise

The minimum allowed refresh rate when a flow of inputs arrive (i.e. the throttiling) is given by Dasu.DefaultMinAllowedRefreshRate, if not overridden by a java property

The validityThreshold in milliseconds