org.opendaylight.openflowplugin.testcommon

Class DropTestRpcSender

java.lang.Object

org.opendaylight.openflowplugin.testcommon.DropTestRpcSender

All Implemented Interfaces:

AutoCloseable, EventListener, PacketProcessingListener, org.opendaylight.yangtools.yang.binding.NotificationListener

public class DropTestRpcSender
extends Object

Provides cbench responder behavior: upon packetIn arrival addFlow action is sent out to device using SalFlowService strategy.

Field Summary

Fields

Modifier and Type	Field and Description
protected static Long	BUFFER_ID
protected int	ftrFailed
protected int	ftrSuccess
protected static Integer	HARD_TIMEOUT
protected static Integer	IDLE_TIMEOUT
protected static Integer	PRIORITY
protected static AtomicIntegerFieldUpdater<org.opendaylight.openflowplugin.testcommon.AbstractDropTest>	RPC_FUTURE_FAIL_UPDATER
protected static AtomicIntegerFieldUpdater<org.opendaylight.openflowplugin.testcommon.AbstractDropTest>	RPC_FUTURE_SUCCESS_UPDATER
protected static AtomicIntegerFieldUpdater<org.opendaylight.openflowplugin.testcommon.AbstractDropTest>	RUNABLES_EXECUTED
protected static AtomicIntegerFieldUpdater<org.opendaylight.openflowplugin.testcommon.AbstractDropTest>	RUNABLES_REJECTED
protected int	runablesExecuted
protected int	runablesRejected
protected static short	TABLE_ID

Constructor Summary

Constructors

Constructor and Description
DropTestRpcSender()

Method Summary

Modifier and Type	Method and Description
void	clearStats()
void	close()
void	countFutureError()
void	countFutureSuccess()
DropTestStats	getStats()
void	onPacketReceived(PacketReceived notification) Delivery of incoming packet wrapped in openflow structure.
protected void	processPacket(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node> node, Match match, Instructions instructions)
void	setFlowService(SalFlowService flowService)
void	setNotificationService(org.opendaylight.mdsal.binding.api.NotificationService notificationService)
void	start() Start listening on packetIn.

Methods inherited from class java.lang.Object

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

Field Detail

PRIORITY

protected static final Integer PRIORITY

BUFFER_ID

protected static final Long BUFFER_ID

HARD_TIMEOUT

protected static final Integer HARD_TIMEOUT

IDLE_TIMEOUT

protected static final Integer IDLE_TIMEOUT

TABLE_ID

protected static final short TABLE_ID

See Also:

Constant Field Values

RPC_FUTURE_SUCCESS_UPDATER

protected static final AtomicIntegerFieldUpdater<org.opendaylight.openflowplugin.testcommon.AbstractDropTest> RPC_FUTURE_SUCCESS_UPDATER

ftrSuccess

protected volatile int ftrSuccess

RPC_FUTURE_FAIL_UPDATER

protected static final AtomicIntegerFieldUpdater<org.opendaylight.openflowplugin.testcommon.AbstractDropTest> RPC_FUTURE_FAIL_UPDATER

ftrFailed

protected volatile int ftrFailed

RUNABLES_EXECUTED

protected static final AtomicIntegerFieldUpdater<org.opendaylight.openflowplugin.testcommon.AbstractDropTest> RUNABLES_EXECUTED

runablesExecuted

protected volatile int runablesExecuted

RUNABLES_REJECTED

protected static final AtomicIntegerFieldUpdater<org.opendaylight.openflowplugin.testcommon.AbstractDropTest> RUNABLES_REJECTED

runablesRejected

protected volatile int runablesRejected

Constructor Detail

DropTestRpcSender

public DropTestRpcSender()

Method Detail

setFlowService

public void setFlowService(SalFlowService flowService)

start

public void start()

Start listening on packetIn.

processPacket

protected void processPacket(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node> node,
                             Match match,
                             Instructions instructions)

setNotificationService

public void setNotificationService(org.opendaylight.mdsal.binding.api.NotificationService notificationService)

close

public void close()

Specified by:

close in interface AutoCloseable

getStats

public final DropTestStats getStats()

clearStats

public final void clearStats()

onPacketReceived

public final void onPacketReceived(PacketReceived notification)

Description copied from interface: PacketProcessingListener

Delivery of incoming packet wrapped in openflow structure.

Specified by:

onPacketReceived in interface PacketProcessingListener

countFutureSuccess

public void countFutureSuccess()

countFutureError

public void countFutureError()