alma.ACS.impl

Class CommonMonitorImpl

java.lang.Object

alma.ACS.impl.CommonMonitorImpl

All Implemented Interfaces:

BACIDispatchAction.DispatchFailedListener, BACITimer.TimerRunnable, PrioritizedRunnable, java.lang.Runnable

Direct Known Subclasses:

CommonComparableMonitorImpl, HistoryMonitorImpl

public class CommonMonitorImpl
extends java.lang.Object
implements BACITimer.TimerRunnable, PrioritizedRunnable, BACIDispatchAction.DispatchFailedListener

Implementation of common monitor.

Author:

Matej Sekoranja

Field Summary

Fields

Modifier and Type	Field and Description
protected BACIDispatchAction	dispatchAction Dispatch action.
protected boolean	isDestroyed Destruction status.
protected boolean	isSuspended Suspend/resume status.
protected java.lang.Object	monitorTimerTask Monitor timer task.
protected CommonPropertyImpl	property Monitorized property.
protected java.util.concurrent.atomic.AtomicLong	queuedKeyTime Key time to process, 0 means none.
protected long	startTime Start time (java time).
protected long	timeTrigger Time trigger (monitoring interval in ms).
protected boolean	userControlledStartTime Start time control status.

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	CommonMonitorImpl() Default constructor.
	CommonMonitorImpl(CommonPropertyImpl property, Callback callback, CBDescIn descIn) Constructor with immediate monitor notification (synchronized monitors supported).
	CommonMonitorImpl(CommonPropertyImpl property, Callback callback, CBDescIn descIn, long startTime) Constructor.

Method Summary

Modifier and Type	Method and Description
protected void	alignStartTime() If userControlledStartTime == false aligns (fixes) start time required for synchronized monitors.
void	destroy()
void	dispatchFailed(BACIDispatchAction action, BACIDispatchAction.DispatchRequest failedRequest) Called when dispatching of particulat request failed.
void	get_timer_trigger(org.omg.CORBA.LongHolder timeIntervalHolder)
BACIPriority	getPriority() Return priority of the task.
protected void	initialize() Initialize monitor.
void	resume()
protected void	retrieveValueAndDispatch(long keyTime, boolean done) Retrieve property value via cached mnemonicValue and add response to BACIDispatchAction.
void	run()
void	schedule() Schedule monitor using fixed rate interval timeTrigger starting from startTime paramterer.
void	set_timer_trigger(long timeInterval)
protected void	setTimeTrigger(long timeInterval) Set time trigger.
long	start_time()
void	suspend()
void	timeout(long timeToRun) Timer implementation - it stores time when triggered and delegates value retrival to BACIExecutor.

Methods inherited from class java.lang.Object

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

Field Detail

monitorTimerTask

protected java.lang.Object monitorTimerTask

Monitor timer task.

property

protected CommonPropertyImpl property

Monitorized property.

dispatchAction

protected BACIDispatchAction dispatchAction

Dispatch action.

timeTrigger

protected long timeTrigger

Time trigger (monitoring interval in ms).

startTime

protected long startTime

Start time (java time).

isSuspended

protected boolean isSuspended

Suspend/resume status.

isDestroyed

protected boolean isDestroyed

Destruction status.

userControlledStartTime

protected boolean userControlledStartTime

Start time control status.

queuedKeyTime

protected java.util.concurrent.atomic.AtomicLong queuedKeyTime

Key time to process, 0 means none.

Constructor Detail

CommonMonitorImpl

protected CommonMonitorImpl()

Default constructor.

CommonMonitorImpl

public CommonMonitorImpl(CommonPropertyImpl property,
                         Callback callback,
                         CBDescIn descIn)

Constructor with immediate monitor notification (synchronized monitors supported).

Parameters:

property - property to be monitored, non-null.

callback - callback, non-null.

descIn - callback in-descriptor.

CommonMonitorImpl

public CommonMonitorImpl(CommonPropertyImpl property,
                         Callback callback,
                         CBDescIn descIn,
                         long startTime)

Constructor.

Parameters:

property - property to be monitored, non-null.

callback - callback, non-null.

descIn - callback in-descriptor.

startTime - startTime (OMG time), values less or equal to current time mean immediately, value 0 means that start time should be controlled automatically (synchronized monitors).

Method Detail

initialize

protected void initialize()

Initialize monitor.

dispatchFailed

public void dispatchFailed(BACIDispatchAction action,
                           BACIDispatchAction.DispatchRequest failedRequest)

Description copied from interface: BACIDispatchAction.DispatchFailedListener

Called when dispatching of particulat request failed.

Specified by:

dispatchFailed in interface BACIDispatchAction.DispatchFailedListener

Parameters:

action - instance of BACIDispatchAction dispatching request.

failedRequest - failed request.

See Also:

BACIDispatchAction.DispatchFailedListener.dispatchFailed(alma.ACS.jbaci.BACIDispatchAction, alma.ACS.jbaci.BACIDispatchAction.DispatchRequest)

schedule

public void schedule()

Schedule monitor using fixed rate interval timeTrigger starting from startTime paramterer.

setTimeTrigger

protected void setTimeTrigger(long timeInterval)

Set time trigger. If userControlledStartTime == false also aligns (fixes) start time required for synchronized monitors.

Parameters:

timeTtrigger - time trigger (monitor interval in ms), if <= 0 monitoring is disabled but not resumed since there still might be on-change trigger enabled. timeTrigger is limited with lower bound property.min_timer_trigger().

alignStartTime

protected void alignStartTime()

If userControlledStartTime == false aligns (fixes) start time required for synchronized monitors.

getPriority

public BACIPriority getPriority()

Description copied from interface: PrioritizedRunnable

Return priority of the task.

Specified by:

getPriority in interface PrioritizedRunnable

Returns:

priority of the task.

See Also:

PrioritizedRunnable.getPriority()

timeout

public void timeout(long timeToRun)

Timer implementation - it stores time when triggered and delegates value retrival to BACIExecutor.

Specified by:

timeout in interface BACITimer.TimerRunnable

See Also:

BACITimer.TimerRunnable.timeout(long)

run

public void run()

Specified by:

run in interface java.lang.Runnable

See Also:

Runnable.run()

retrieveValueAndDispatch

protected void retrieveValueAndDispatch(long keyTime,
                                        boolean done)

Retrieve property value via cached mnemonicValue and add response to BACIDispatchAction.

start_time

public long start_time()

See Also:

alma.ACS.MonitorOperations#start_time()

set_timer_trigger

public void set_timer_trigger(long timeInterval)

See Also:

alma.ACS.MonitorOperations#set_timer_trigger(long)

get_timer_trigger

public void get_timer_trigger(org.omg.CORBA.LongHolder timeIntervalHolder)

See Also:

alma.ACS.MonitorOperations#get_timer_trigger(org.omg.CORBA.LongHolder)

suspend

public void suspend()

See Also:

alma.ACS.SubscriptionOperations#suspend()

resume

public void resume()

See Also:

alma.ACS.SubscriptionOperations#resume()

destroy

public void destroy()

See Also:

alma.ACS.SubscriptionOperations#destroy()