Package ca.uqac.lif.cep.diagnostics

Class ThroughputMeter

java.lang.Object
ca.uqac.lif.cep.Processor
ca.uqac.lif.cep.SynchronousProcessor
ca.uqac.lif.cep.tmf.Sink
ca.uqac.lif.cep.diagnostics.ThroughputMeter
All Implemented Interfaces:
ca.uqac.lif.cep.Contextualizable, ca.uqac.lif.cep.Duplicable, ca.uqac.lif.cep.DuplicableProcessor
public class ThroughputMeter extends ca.uqac.lif.cep.tmf.Sink

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Class
    Description
    protected class 
    ThroughputMeter.ThroughputCallback
     

    Nested classes/interfaces inherited from class ca.uqac.lif.cep.SynchronousProcessor

    ca.uqac.lif.cep.SynchronousProcessor.InputPushable, ca.uqac.lif.cep.SynchronousProcessor.OutputPullable

    Nested classes/interfaces inherited from class ca.uqac.lif.cep.Processor

    ca.uqac.lif.cep.Processor.InternalProcessorState

  • Field Summary

    Fields
    Modifier and Type
    Field
    Description
    protected DiagnosticsCallback
    m_callback
     
    protected long
    m_eventsReceived
     
    protected long
    m_refreshInterval
     
    protected Timer
    m_timer
     

    Fields inherited from class ca.uqac.lif.cep.SynchronousProcessor

    m_inputPushables, m_outputPullables, m_tempQueue

    Fields inherited from class ca.uqac.lif.cep.Processor

    m_context, m_hasBeenNotifiedOfEndOfTrace, m_inputArity, m_inputPullables, m_inputQueues, m_notifiedEndOfTraceDownstream, m_outputArity, m_outputPushables, m_outputQueues, MAX_PULL_RETRIES, s_versionString

  • Constructor Summary

    Constructors
    Constructor
    Description
    ThroughputMeter(DiagnosticsCallback callback, long refresh_interval)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    protected boolean
    compute(Object[] inputs, Queue<Object[]> outputs)
     
    ca.uqac.lif.cep.Processor
    duplicate(boolean with_state)
     
    void
    start()
     
    void
    stop()
     

    Methods inherited from class ca.uqac.lif.cep.tmf.Sink

    pull, pullHard

    Methods inherited from class ca.uqac.lif.cep.SynchronousProcessor

    getPullableOutput, getPushableInput

    Methods inherited from class ca.uqac.lif.cep.Processor

    allNotifiedEndOfTrace, allNull, copyInputQueue, copyOutputQueue, duplicate, duplicateInto, equals, getAt, getContext, getContext, getEmptyQueue, getId, getInputArity, getInputQueue, getInputType, getInputTypesFor, getOutputArity, getOutputQueue, getOutputType, getPullableInput, getPullableOutput, getPushableInput, getPushableOutput, hashCode, leftShift, newContext, onEndOfTrace, or, or, or, printState, readState, reset, rightShift, setContext, setContext, setPullableInput, setPushableOutput, startAll, stopAll

    Methods inherited from class java.lang.Object

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

  • Field Details

    • m_callback

      protected DiagnosticsCallback m_callback

    • m_refreshInterval

      protected long m_refreshInterval

    • m_timer

      protected Timer m_timer

    • m_eventsReceived

      protected long m_eventsReceived

  • Constructor Details

    • ThroughputMeter

      public ThroughputMeter(DiagnosticsCallback callback, long refresh_interval)

  • Method Details

    • start

      public void start() throws ca.uqac.lif.cep.ProcessorException
      Overrides:
      start in class ca.uqac.lif.cep.Processor
      Throws:
      ca.uqac.lif.cep.ProcessorException

    • stop

      public void stop() throws ca.uqac.lif.cep.ProcessorException
      Overrides:
      stop in class ca.uqac.lif.cep.Processor
      Throws:
      ca.uqac.lif.cep.ProcessorException

    • compute

      protected boolean compute(Object[] inputs, Queue<Object[]> outputs) throws ca.uqac.lif.cep.ProcessorException
      Specified by:
      compute in class ca.uqac.lif.cep.SynchronousProcessor
      Throws:
      ca.uqac.lif.cep.ProcessorException

    • duplicate

      public ca.uqac.lif.cep.Processor duplicate(boolean with_state)
      Specified by:
      duplicate in interface ca.uqac.lif.cep.Duplicable
      Specified by:
      duplicate in class ca.uqac.lif.cep.Processor