Class DropTestCommiterImpl
java.lang.Object
org.opendaylight.openflowplugin.testcommon.DropTestCommiterImpl
- All Implemented Interfaces:
AutoCloseable
,org.opendaylight.mdsal.binding.api.NotificationService.Listener<PacketReceived>
,DropTest
,DropTestCommiter
Provides cbench responder behavior: upon packetIn arrival addFlow action is sent out to device using dataStore
strategy (FRM involved).
-
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
ConstructorDescriptionDropTestCommiterImpl
(org.opendaylight.mdsal.binding.api.DataBroker dataBroker, org.opendaylight.mdsal.binding.api.NotificationService notificationService) -
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()
Start listening on packetIn.boolean
stop()
Stop listening on packetIn.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
-
DropTestCommiterImpl
@Inject public DropTestCommiterImpl(org.opendaylight.mdsal.binding.api.DataBroker dataBroker, org.opendaylight.mdsal.binding.api.NotificationService notificationService)
-
-
Method Details
-
close
@PreDestroy public void close()- Specified by:
close
in interfaceAutoCloseable
-
start
public boolean start()Start listening on packetIn. -
stop
public boolean stop()Stop listening on packetIn. -
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()
-