Package org.opendaylight.openflowplugin.testcommon

Class DropTestCommiterImpl

java.lang.Object

org.opendaylight.openflowplugin.testcommon.DropTestCommiterImpl

All Implemented Interfaces:

AutoCloseable, org.opendaylight.mdsal.binding.api.NotificationService.Listener<PacketReceived>, DropTest, DropTestCommiter

@Singleton
public final class DropTestCommiterImpl
extends Object
implements DropTestCommiter

Provides cbench responder behavior: upon packetIn arrival addFlow action is sent out to device using dataStore strategy (FRM involved).

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.opendaylight.yangtools.yang.common.Uint32	BUFFER_ID
protected int	ftrFailed
protected int	ftrSuccess
protected static final org.opendaylight.yangtools.yang.common.Uint16	HARD_TIMEOUT
protected static final org.opendaylight.yangtools.yang.common.Uint16	IDLE_TIMEOUT
protected static final org.opendaylight.yangtools.yang.common.Uint16	PRIORITY
protected static final AtomicIntegerFieldUpdater<org.opendaylight.openflowplugin.testcommon.AbstractDropTest>	RPC_FUTURE_FAIL_UPDATER
protected static final AtomicIntegerFieldUpdater<org.opendaylight.openflowplugin.testcommon.AbstractDropTest>	RPC_FUTURE_SUCCESS_UPDATER
protected static final AtomicIntegerFieldUpdater<org.opendaylight.openflowplugin.testcommon.AbstractDropTest>	RUNABLES_EXECUTED
protected static final AtomicIntegerFieldUpdater<org.opendaylight.openflowplugin.testcommon.AbstractDropTest>	RUNABLES_REJECTED
protected int	runablesExecuted
protected int	runablesRejected
protected static final org.opendaylight.yangtools.yang.common.Uint8	TABLE_ID

Constructor Summary

Constructors

Constructor	Description
DropTestCommiterImpl(org.opendaylight.mdsal.binding.api.DataBroker dataBroker, org.opendaylight.mdsal.binding.api.NotificationService notificationService)

Method Summary

Modifier and Type	Method	Description
final void	clearStats()
void	close()
void	countFutureError()
void	countFutureSuccess()
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 interface AutoCloseable

start

public boolean start()

Start listening on packetIn.

Specified by:

start in interface DropTest

Returns:

false if already started

stop

public boolean stop()

Stop listening on packetIn.

Specified by:

stop in interface DropTest

Returns:

false if already stopped

processPacket

protected void processPacket(org.opendaylight.yangtools.yang.binding.InstanceIdentifier<Node> node,
 Match match,
 Instructions instructions)

getStats

public final DropTestStats getStats()

Specified by:

getStats in interface DropTest

clearStats

public final void clearStats()

Specified by:

clearStats in interface DropTest

onNotification

public final void onNotification(PacketReceived notification)

Specified by:

onNotification in interface org.opendaylight.mdsal.binding.api.NotificationService.Listener<PacketReceived>

countFutureSuccess

public void countFutureSuccess()

countFutureError

public void countFutureError()