Package 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	Description
protected static org.opendaylight.yangtools.yang.common.Uint32	BUFFER_ID
protected int	ftrFailed
protected int	ftrSuccess
protected static org.opendaylight.yangtools.yang.common.Uint16	HARD_TIMEOUT
protected static org.opendaylight.yangtools.yang.common.Uint16	IDLE_TIMEOUT
protected static org.opendaylight.yangtools.yang.common.Uint16	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 org.opendaylight.yangtools.yang.common.Uint8	TABLE_ID

Constructor Summary

Constructors

Constructor	Description
DropTestRpcSender()

Method Summary

Modifier and Type	Method	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 org.opendaylight.yangtools.yang.common.Uint16 PRIORITY

BUFFER_ID

protected static final org.opendaylight.yangtools.yang.common.Uint32 BUFFER_ID

HARD_TIMEOUT

protected static final org.opendaylight.yangtools.yang.common.Uint16 HARD_TIMEOUT

IDLE_TIMEOUT

protected static final org.opendaylight.yangtools.yang.common.Uint16 IDLE_TIMEOUT

TABLE_ID

protected static final org.opendaylight.yangtools.yang.common.Uint8 TABLE_ID

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()