Class DropTestRpcSenderImpl
java.lang.Object
org.opendaylight.openflowplugin.testcommon.DropTestRpcSenderImpl
- All Implemented Interfaces:
AutoCloseable
,org.opendaylight.mdsal.binding.api.NotificationService.Listener<PacketReceived>
,DropTest
,DropTestRpcSender
Provides cbench responder behavior: upon packetIn arrival addFlow action is sent out to device using
AddFlow
strategy.-
Field Summary
Modifier and TypeFieldDescriptionprotected static final org.opendaylight.yangtools.yang.common.Uint32
protected int
protected int
protected static final org.opendaylight.yangtools.yang.common.Uint16
protected static final org.opendaylight.yangtools.yang.common.Uint16
protected static final org.opendaylight.yangtools.yang.common.Uint16
protected static final AtomicIntegerFieldUpdater
<org.opendaylight.openflowplugin.testcommon.AbstractDropTest> protected static final AtomicIntegerFieldUpdater
<org.opendaylight.openflowplugin.testcommon.AbstractDropTest> protected static final AtomicIntegerFieldUpdater
<org.opendaylight.openflowplugin.testcommon.AbstractDropTest> protected static final AtomicIntegerFieldUpdater
<org.opendaylight.openflowplugin.testcommon.AbstractDropTest> protected int
protected int
protected static final org.opendaylight.yangtools.yang.common.Uint8
-
Constructor Summary
ConstructorDescriptionDropTestRpcSenderImpl
(org.opendaylight.mdsal.binding.api.NotificationService notificationService, org.opendaylight.mdsal.binding.api.RpcService rpcService) -
Method Summary
Modifier and TypeMethodDescriptionfinal void
void
close()
void
void
final DropTestStats
getStats()
final void
onNotification
(PacketReceived notification) protected void
processPacket
(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<Node> node, Match match, Instructions instructions) boolean
start()
boolean
stop()
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.opendaylight.openflowplugin.testcommon.DropTest
clearStats, getStats
-
Field Details
-
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 Details
-
DropTestRpcSenderImpl
@Inject public DropTestRpcSenderImpl(org.opendaylight.mdsal.binding.api.NotificationService notificationService, org.opendaylight.mdsal.binding.api.RpcService rpcService)
-
-
Method Details
-
close
@PreDestroy public void close()- Specified by:
close
in interfaceAutoCloseable
-
start
public boolean start() -
stop
public boolean stop() -
processPacket
protected void processPacket(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<Node> node, Match match, Instructions instructions) -
getStats
-
clearStats
public final void clearStats()- Specified by:
clearStats
in interfaceDropTest
-
onNotification
- Specified by:
onNotification
in interfaceorg.opendaylight.mdsal.binding.api.NotificationService.Listener<PacketReceived>
-
countFutureSuccess
public void countFutureSuccess() -
countFutureError
public void countFutureError()
-