| java.lang.Object seda.sandStorm.internal.SinkProxy
SinkProxy | public class SinkProxy implements SinkIF,ProfilableIF(Code) | | Used as a proxy to observe and measure communication behavior between
stages. By handing out a SinkProxy instead of a FiniteQueue, it is
possible to gather statistics on event communication between stages.
This is used by StageGraph to construct a graph of the communication
patterns between stages.
author: Matt Welsh |
Field Summary | |
public int | enqueueCount Maintains a running sum of the number of elements enqueued onto
this sink. | public int | enqueueSuccessCount Maintains a running sum of the number of elements successfully
enqueued onto this sink (that is, not rejected by the enqueue predicate). | public SinkIF | thesink | public long | timer Used to maintain a timer for statistics gathering. |
enqueueCount | public int enqueueCount(Code) | | Maintains a running sum of the number of elements enqueued onto
this sink.
|
enqueueSuccessCount | public int enqueueSuccessCount(Code) | | Maintains a running sum of the number of elements successfully
enqueued onto this sink (that is, not rejected by the enqueue predicate).
|
timer | public long timer(Code) | | Used to maintain a timer for statistics gathering.
|
SinkProxy | public SinkProxy(SinkIF sink, ManagerIF mgr, StageWrapperIF toStage)(Code) | | Create a SinkProxy for the given sink.
Parameters: sink - The sink to create a proxy for. Parameters: mgr - The associated manager. Parameters: toStage - The stage which this sink pushes events to. |
profileSize | public int profileSize()(Code) | | Return the profile size of the queue.
|
size | public int size()(Code) | | Return the size of the queue.
|
|
|