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 and Description
static String	USING_CONCURRENT_IMPLEMENTATION_OF_FLOW_WRITER

Constructor Summary

Constructors

Constructor and Description
FlowWriterConcurrent(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker, ExecutorService flowPusher)

Method Summary

Modifier and Type	Method and 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 Detail

USING_CONCURRENT_IMPLEMENTATION_OF_FLOW_WRITER

public static final String USING_CONCURRENT_IMPLEMENTATION_OF_FLOW_WRITER

See Also:

Constant Field Values

Constructor Detail

FlowWriterConcurrent

public FlowWriterConcurrent(org.opendaylight.controller.md.sal.binding.api.DataBroker dataBroker,
                            ExecutorService flowPusher)

Method Detail

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