Class DropTestRpcSenderImpl

java.lang.Object
org.opendaylight.openflowplugin.testcommon.DropTestRpcSenderImpl
All Implemented Interfaces:
AutoCloseable, org.opendaylight.mdsal.binding.api.NotificationService.Listener<PacketReceived>, DropTest, DropTestRpcSender

@Singleton public final class DropTestRpcSenderImpl extends Object implements DropTestRpcSender
Provides cbench responder behavior: upon packetIn arrival addFlow action is sent out to device using AddFlow strategy.
  • 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 interface AutoCloseable
    • start

      public boolean start()
      Specified by:
      start in interface DropTest
    • stop

      public boolean stop()
      Specified by:
      stop in interface DropTest
    • 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()