Package org.opendaylight.openflowplugin.applications.bulk.o.matic

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 Summary

Fields

Modifier and Type	Field	Description
static final String	USING_CONCURRENT_IMPLEMENTATION_OF_FLOW_WRITER

Constructor Summary

Constructors

Constructor	Description
FlowWriterConcurrent(org.opendaylight.mdsal.binding.api.DataBroker dataBroker, ExecutorService flowPusher)

Method Summary

Modifier and Type	Method	Description
void	addFlows(Integer dpnCount, Integer flowsPerDPN, int batchSize, int sleepMillis, int sleepAfter, short startTableId, short endTableId, boolean isCreateParents)
void	deleteFlows(Integer dpnCount, Integer flowsPerDPN, int batchSize, short startTableId, short endTableId)
long	getTaskCompletionTime()
int	getWriteOpStatus()

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.applications.bulk.o.matic.FlowCounterMBean

getFlowCount, getReadOpStatus, getTableCount, getUnits

Field Details

USING_CONCURRENT_IMPLEMENTATION_OF_FLOW_WRITER

public static final String USING_CONCURRENT_IMPLEMENTATION_OF_FLOW_WRITER

See Also:

• Constant Field Values

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