Classes | Public Member Functions | Protected Member Functions | Static Protected Member Functions | Protected Attributes | Static Protected Attributes

alma.ACS.jbaci.BACIDispatchAction Class Reference

Inheritance diagram for alma.ACS.jbaci.BACIDispatchAction:
alma.ACS.jbaci.PrioritizedRunnable

List of all members.

Classes

interface  DispatchFailedListener
class  DispatchRequest

Public Member Functions

 BACIDispatchAction (CBvoid callback, CBDescIn descIn)
 BACIDispatchAction (Callback callback, CBDescIn descIn, CallbackDispatcher callbackDispatcher)
 BACIDispatchAction (CBvoid callback, CBDescIn descIn, BACIPriority priority)
 BACIDispatchAction (Callback callback, CBDescIn descIn, CallbackDispatcher callbackDispatcher, BACIPriority priority)
void dispatchWorkingRequest (Completion completion)
void dispatchWorkingRequest (Completion completion, Object value)
void dispatchDoneRequest (Completion completion)
void dispatchDoneRequest (Completion completion, Object value)
void dispatchRequest (int type, Completion completion, Object value)
BACIPriority getPriority ()
final void run ()
CBDescOut getDescOut ()
boolean isOverridePolicy ()
void setOverridePolicy (boolean b)
void setPriority (BACIPriority priority)
void addDispatchFailedListener (DispatchFailedListener listener)
void removeDispatchFailedListener (DispatchFailedListener listener)

Protected Member Functions

void dispatchRequest (DispatchRequest request)
boolean failed ()
boolean dispatch ()
void submit ()

Static Protected Member Functions

static CBDescOut generateCBDescOut (CBDescIn descIn)

Protected Attributes

BACIPriority priority
CBDescOut descOut
Callback callback
CallbackDispatcher callbackDispatcher
int failureCountLimit
int failureCount = 0
LinkedList queue = new LinkedList()
DispatchRequest pendingRequest = null
boolean submitPending = false
boolean overridePolicy = false
ArrayList< DispatchFailedListener > listeners = new ArrayList<DispatchFailedListener>()

Static Protected Attributes

static final int DEFAULT_FAILURE_COUNT_LIMIT = 3

Detailed Description

BACI dispatch action.

Author:
Matej Sekoranja
Version:
$id$

Constructor & Destructor Documentation

alma.ACS.jbaci.BACIDispatchAction.BACIDispatchAction ( CBvoid  callback,
CBDescIn  descIn 
)

Constructor of NORMAL priority action (CBvoid callback).

Parameters:
callback action callback.
descIn action callback in descriptor.
alma.ACS.jbaci.BACIDispatchAction.BACIDispatchAction ( Callback  callback,
CBDescIn  descIn,
CallbackDispatcher  callbackDispatcher 
)

Constructor of NORMAL priority action.

Parameters:
callback action callback.
descIn action callback in descriptor.
callbackDispatcher callback dispatcher (value dependend).
alma.ACS.jbaci.BACIDispatchAction.BACIDispatchAction ( CBvoid  callback,
CBDescIn  descIn,
BACIPriority  priority 
)

Constructor.

Parameters:
callback action callback.
descIn action in descriptor.
priority action priority.
alma.ACS.jbaci.BACIDispatchAction.BACIDispatchAction ( Callback  callback,
CBDescIn  descIn,
CallbackDispatcher  callbackDispatcher,
BACIPriority  priority 
)

Constructor.

Parameters:
callback action callback.
descIn action in descriptor.
callbackDispatcher callback dispatcher (value dependend).
priority action priority.

References alma.ACS.jbaci.BACIDispatchAction.DEFAULT_FAILURE_COUNT_LIMIT, alma.ACS.jbaci.BACIDispatchAction.descOut, alma.ACS.jbaci.BACIDispatchAction.failureCountLimit, and alma.ACS.jbaci.BACIDispatchAction.generateCBDescOut().

Member Function Documentation

void alma.ACS.jbaci.BACIDispatchAction.addDispatchFailedListener ( DispatchFailedListener  listener  ) 

Add dispatch failed listener.

Parameters:
listener listener to listen failed dispatch notifications.

References alma.ACS.jbaci.BACIDispatchAction.listeners.

Referenced by alma.ACS.impl.CommonMonitorImpl.CommonMonitorImpl().

boolean alma.ACS.jbaci.BACIDispatchAction.dispatch (  )  [protected]

Dispatch method. Dispatches pendingRequest, should be non-null.

Returns:
true if successfully dispatched.

References alma.ACS.jbaci.BACIDispatchAction.callback, alma.ACS.jbaci.BACIDispatchAction.callbackDispatcher, alma.ACS.jbaci.BACIDispatchAction.DispatchRequest.completion, alma.ACS.jbaci.BACIDispatchAction.descOut, alma.ACS.jbaci.CallbackDispatcher.dispatchCallback(), alma.ACS.jbaci.BACIDispatchAction.pendingRequest, alma.ACS.jbaci.BACIDispatchAction.DispatchRequest.type, and alma.ACS.jbaci.BACIDispatchAction.DispatchRequest.value.

Referenced by alma.ACS.jbaci.BACIDispatchAction.run().

void alma.ACS.jbaci.BACIDispatchAction.dispatchDoneRequest ( Completion  completion  ) 

Added done callback request to dispatch queue.

Parameters:
completion completion.

References alma.ACS.jbaci.BACIDispatchAction.dispatchRequest().

Referenced by alma.ACS.impl.CommonMonitorImpl.retrieveValueAndDispatch().

void alma.ACS.jbaci.BACIDispatchAction.dispatchDoneRequest ( Completion  completion,
Object  value 
)

Added done callback request to dispatch queue.

Parameters:
completion completion.
value value.

References alma.ACS.jbaci.BACIDispatchAction.dispatchRequest().

void alma.ACS.jbaci.BACIDispatchAction.dispatchRequest ( int  type,
Completion  completion,
Object  value 
)

Added request to dispatch queue.

Referenced by alma.ACS.jbaci.BACIDispatchAction.dispatchDoneRequest(), and alma.ACS.jbaci.BACIDispatchAction.dispatchWorkingRequest().

void alma.ACS.jbaci.BACIDispatchAction.dispatchRequest ( DispatchRequest  request  )  [protected]

Added request to dispatch queue (internal).

References alma.ACS.jbaci.BACIDispatchAction.overridePolicy, alma.ACS.jbaci.BACIDispatchAction.queue, alma.ACS.jbaci.BACIDispatchAction.submit(), and alma.ACS.jbaci.BACIDispatchAction.submitPending.

void alma.ACS.jbaci.BACIDispatchAction.dispatchWorkingRequest ( Completion  completion,
Object  value 
)

Added working callback request to dispatch queue.

Parameters:
completion completion.

References alma.ACS.jbaci.BACIDispatchAction.dispatchRequest().

void alma.ACS.jbaci.BACIDispatchAction.dispatchWorkingRequest ( Completion  completion  ) 

Added working callback request to dispatch queue.

Parameters:
completion completion.
value value.

References alma.ACS.jbaci.BACIDispatchAction.dispatchRequest().

Referenced by alma.ACS.impl.CommonMonitorImpl.retrieveValueAndDispatch(), and alma.ACS.impl.CommonComparableMonitorImpl.valueChanged().

boolean alma.ACS.jbaci.BACIDispatchAction.failed (  )  [protected]

Call this metod to notify dispatch failure.

Returns:
true, if dispaching is to be canceled (e.g. failure counter reached its failure limit)

References alma.ACS.jbaci.BACIDispatchAction.failureCount, and alma.ACS.jbaci.BACIDispatchAction.failureCountLimit.

Referenced by alma.ACS.jbaci.BACIDispatchAction.run().

static CBDescOut alma.ACS.jbaci.BACIDispatchAction.generateCBDescOut ( CBDescIn  descIn  )  [static, protected]

Generates callback out descriptor from in descriptor.

Parameters:
descIn callback in descriptor.
Returns:
generated callback out descriptor.

Referenced by alma.ACS.jbaci.BACIDispatchAction.BACIDispatchAction().

CBDescOut alma.ACS.jbaci.BACIDispatchAction.getDescOut (  ) 

Get callback out-descriptor.

Returns:
callback out-descriptor.

References alma.ACS.jbaci.BACIDispatchAction.descOut.

BACIPriority alma.ACS.jbaci.BACIDispatchAction.getPriority (  ) 
See also:
alma.ACS.jbaci.PrioritizedRunnable.getPriority()

Implements alma.ACS.jbaci.PrioritizedRunnable.

References alma.ACS.jbaci.BACIDispatchAction.priority.

boolean alma.ACS.jbaci.BACIDispatchAction.isOverridePolicy (  ) 

Get current override policy.

Returns:
current override policy.

References alma.ACS.jbaci.BACIDispatchAction.overridePolicy.

Referenced by alma.ACS.jbaci.BACIDispatchAction.run().

void alma.ACS.jbaci.BACIDispatchAction.removeDispatchFailedListener ( DispatchFailedListener  listener  ) 

Remove dispatch failed listener.

Parameters:
listener listener to remove.

References alma.ACS.jbaci.BACIDispatchAction.listeners.

Referenced by alma.ACS.impl.CommonMonitorImpl.destroy().

final void alma.ACS.jbaci.BACIDispatchAction.run (  ) 

NOT TO BE CHANGED. Dispatching is done one by one - to achieve better fairness.

References alma.ACS.jbaci.BACIDispatchAction.dispatch(), alma.ACS.jbaci.BACIDispatchAction.DispatchFailedListener.dispatchFailed(), alma.ACS.jbaci.BACIDispatchAction.failed(), alma.ACS.jbaci.BACIDispatchAction.failureCount, alma.ACS.jbaci.BACIDispatchAction.isOverridePolicy(), alma.ACS.jbaci.BACIDispatchAction.listeners, alma.ACS.jbaci.BACIDispatchAction.pendingRequest, alma.ACS.jbaci.BACIDispatchAction.queue, alma.ACS.jbaci.BACIDispatchAction.submit(), and alma.ACS.jbaci.BACIDispatchAction.submitPending.

void alma.ACS.jbaci.BACIDispatchAction.setOverridePolicy ( boolean  b  ) 

Set current override policy.

Parameters:
b override policy to set.

References alma.ACS.jbaci.BACIDispatchAction.overridePolicy.

void alma.ACS.jbaci.BACIDispatchAction.setPriority ( BACIPriority  priority  ) 

Set dispatching priority.

Parameters:
priority dispatching priority to set.
void alma.ACS.jbaci.BACIDispatchAction.submit (  )  [protected]

Sumbit action to be BACIExecutor to be executed.

References alma.ACS.jbaci.BACIDispatchAction.queue, and alma.ACS.jbaci.BACIDispatchAction.submitPending.

Referenced by alma.ACS.jbaci.BACIDispatchAction.dispatchRequest(), and alma.ACS.jbaci.BACIDispatchAction.run().

Member Data Documentation

Callback alma.ACS.jbaci.BACIDispatchAction.callback [protected]

Callback.

Referenced by alma.ACS.jbaci.BACIDispatchAction.dispatch().

CallbackDispatcher alma.ACS.jbaci.BACIDispatchAction.callbackDispatcher [protected]

Callback dispatcher (used to dispatch non-CBvoid callbacks).

Referenced by alma.ACS.jbaci.BACIDispatchAction.dispatch().

final int alma.ACS.jbaci.BACIDispatchAction.DEFAULT_FAILURE_COUNT_LIMIT = 3 [static, protected]

Failure limit.

Referenced by alma.ACS.jbaci.BACIDispatchAction.BACIDispatchAction().

CBDescOut alma.ACS.jbaci.BACIDispatchAction.descOut [protected]

Callback out descriptor.

Referenced by alma.ACS.jbaci.BACIDispatchAction.BACIDispatchAction(), alma.ACS.jbaci.BACIDispatchAction.dispatch(), and alma.ACS.jbaci.BACIDispatchAction.getDescOut().

int alma.ACS.jbaci.BACIDispatchAction.failureCount = 0 [protected]

Failure count.

Referenced by alma.ACS.jbaci.BACIDispatchAction.failed(), and alma.ACS.jbaci.BACIDispatchAction.run().

int alma.ACS.jbaci.BACIDispatchAction.failureCountLimit [protected]

Failure limit (number of retries), 0 means until successfull.

Referenced by alma.ACS.jbaci.BACIDispatchAction.BACIDispatchAction(), and alma.ACS.jbaci.BACIDispatchAction.failed().

ArrayList<DispatchFailedListener> alma.ACS.jbaci.BACIDispatchAction.listeners = new ArrayList<DispatchFailedListener>() [protected]

List of registered listeners.

Referenced by alma.ACS.jbaci.BACIDispatchAction.addDispatchFailedListener(), alma.ACS.jbaci.BACIDispatchAction.removeDispatchFailedListener(), and alma.ACS.jbaci.BACIDispatchAction.run().

boolean alma.ACS.jbaci.BACIDispatchAction.overridePolicy = false [protected]

Override policy for request queue. If true newer request will override request in the queue. If false (default) requests will form a linked list.

Referenced by alma.ACS.jbaci.BACIDispatchAction.dispatchRequest(), alma.ACS.jbaci.BACIDispatchAction.isOverridePolicy(), and alma.ACS.jbaci.BACIDispatchAction.setOverridePolicy().

DispatchRequest alma.ACS.jbaci.BACIDispatchAction.pendingRequest = null [protected]

Pending request. NOTE: synchronized on queue's monitor.

Referenced by alma.ACS.jbaci.BACIDispatchAction.dispatch(), and alma.ACS.jbaci.BACIDispatchAction.run().

BACIPriority alma.ACS.jbaci.BACIDispatchAction.priority [protected]

Action priority.

Referenced by alma.ACS.jbaci.BACIDispatchAction.getPriority().

LinkedList alma.ACS.jbaci.BACIDispatchAction.queue = new LinkedList() [protected]

Ordered dispatch queue.

Referenced by alma.ACS.jbaci.BACIDispatchAction.dispatchRequest(), alma.ACS.jbaci.BACIDispatchAction.run(), and alma.ACS.jbaci.BACIDispatchAction.submit().

boolean alma.ACS.jbaci.BACIDispatchAction.submitPending = false [protected]

Flag indicating pending submit. NOTE: synchronized on queue's monitor.

Referenced by alma.ACS.jbaci.BACIDispatchAction.dispatchRequest(), alma.ACS.jbaci.BACIDispatchAction.run(), and alma.ACS.jbaci.BACIDispatchAction.submit().

The documentation for this class was generated from the following file:
 All Classes Namespaces Files Functions Variables Enumerations Properties
Generated on Thu Jan 12 2012 23:15:14 for ACS-10.0 Java API by  doxygen 1.7.0