Class NetworkInterfaceSource

java.lang.Object

ca.uqac.lif.cep.Processor

ca.uqac.lif.cep.SynchronousProcessor

ca.uqac.lif.cep.tmf.Source

netp.NetworkInterfaceSource

All Implemented Interfaces:

ca.uqac.lif.cep.Contextualizable, ca.uqac.lif.cep.Duplicable, ca.uqac.lif.cep.DuplicableProcessor

public class NetworkInterfaceSource
extends ca.uqac.lif.cep.tmf.Source

Outputs packets captured live from a network interface

Nested Class Summary

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 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
NetworkInterfaceSource(String interfaceName)

Method Summary

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

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

push

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, start, startAll, stop, stopAll

Methods inherited from class Object

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

Constructor Details

NetworkInterfaceSource

public NetworkInterfaceSource(String interfaceName)
                       throws Exception

Throws:

Exception

Method Details

compute

protected boolean compute(Object[] inputs,
 Queue<Object[]> outputs)

Specified by:

compute in class ca.uqac.lif.cep.SynchronousProcessor

clone

public ca.uqac.lif.cep.Processor clone()

Overrides:

clone in class Object

getInterfaceName

public String getInterfaceName()

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