Package org.opendaylight.openflowplugin.testcommon

Class DropTestCommiter

java.lang.Object
org.opendaylight.openflowplugin.testcommon.DropTestCommiter
All Implemented Interfaces:
AutoCloseable, EventListener, org.opendaylight.mdsal.binding.api.NotificationService.Listener<PacketReceived>
public class DropTestCommiter extends Object
Provides cbench responder behavior: upon packetIn arrival addFlow action is sent out to device using dataStore strategy (FRM involved).

  • 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

    • DropTestCommiter

      public DropTestCommiter()

  • Method Details

    • start

      public void start()
      start listening on packetIn.

    • setDataService

      public void setDataService(org.opendaylight.mdsal.binding.api.DataBroker dataService)

    • processPacket

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

    • close

      public void close()
      Specified by:
      close in interface AutoCloseable

    • setNotificationService

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

    • getStats

      public final DropTestStats getStats()

    • clearStats

      public final void clearStats()

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