Class FlowWriterConcurrent

java.lang.Object
org.opendaylight.openflowplugin.applications.bulk.o.matic.FlowWriterConcurrent
All Implemented Interfaces:
FlowCounterMBean

public class FlowWriterConcurrent extends Object implements FlowCounterMBean
  • Field Details

    • USING_CONCURRENT_IMPLEMENTATION_OF_FLOW_WRITER

      public static final String USING_CONCURRENT_IMPLEMENTATION_OF_FLOW_WRITER
      See Also:
  • Constructor Details

    • FlowWriterConcurrent

      public FlowWriterConcurrent(org.opendaylight.mdsal.binding.api.DataBroker dataBroker, ExecutorService flowPusher)
  • Method Details

    • addFlows

      public void addFlows(Integer dpnCount, Integer flowsPerDPN, int batchSize, int sleepMillis, int sleepAfter, short startTableId, short endTableId, boolean isCreateParents)
    • deleteFlows

      public void deleteFlows(Integer dpnCount, Integer flowsPerDPN, int batchSize, short startTableId, short endTableId)
    • getWriteOpStatus

      public int getWriteOpStatus()
      Specified by:
      getWriteOpStatus in interface FlowCounterMBean
    • getTaskCompletionTime

      public long getTaskCompletionTime()
      Specified by:
      getTaskCompletionTime in interface FlowCounterMBean