Package org.opendaylight.openflowplugin.applications.frsync.impl.strategy

Class SyncPlanPushStrategyIncrementalImpl

java.lang.Object

org.opendaylight.openflowplugin.applications.frsync.impl.strategy.SyncPlanPushStrategyIncrementalImpl

All Implemented Interfaces:

SyncPlanPushStrategy

public class SyncPlanPushStrategyIncrementalImpl
extends Object
implements SyncPlanPushStrategy

Execute CRUD API for flow + group + meter involving one-by-one (incremental) strategy.

Constructor Summary

Constructors

Constructor	Description
SyncPlanPushStrategyIncrementalImpl()

Method Summary

Modifier and Type	Method	Description
com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<Void>>	executeSyncStrategy(com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<Void>> resultVehicle, SynchronizationDiffInput diffInput, SyncCrudCounters counters)	Invoked to execute the synchronization strategy.
SyncPlanPushStrategyIncrementalImpl	setFlowForwarder(FlowForwarder flowForwarder)
SyncPlanPushStrategyIncrementalImpl	setGroupForwarder(GroupForwarder groupForwarder)
SyncPlanPushStrategyIncrementalImpl	setMeterForwarder(MeterForwarder meterForwarder)
SyncPlanPushStrategyIncrementalImpl	setTableForwarder(TableForwarder tableForwarder)
SyncPlanPushStrategyIncrementalImpl	setTransactionService(FlowCapableTransactionService transactionService)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

SyncPlanPushStrategyIncrementalImpl

public SyncPlanPushStrategyIncrementalImpl()

Method Detail

executeSyncStrategy

public com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<Void>> executeSyncStrategy(com.google.common.util.concurrent.ListenableFuture<org.opendaylight.yangtools.yang.common.RpcResult<Void>> resultVehicle,
                                                                                                                                      SynchronizationDiffInput diffInput,
                                                                                                                                      SyncCrudCounters counters)

Description copied from interface: SyncPlanPushStrategy

Invoked to execute the synchronization strategy.

Specified by:

executeSyncStrategy in interface SyncPlanPushStrategy

Parameters:

resultVehicle - bootstrap future - execution will chain it's async calls to this one

diffInput - wraps all diff data required for any strategy ({add,remove,update} x {flow,group,meter})

counters - reference to internal one-shot statistics - summary off successfully pushed items shall be recorded here

Returns:

last future of the chain

setFlowForwarder

public SyncPlanPushStrategyIncrementalImpl setFlowForwarder(FlowForwarder flowForwarder)

setTableForwarder

public SyncPlanPushStrategyIncrementalImpl setTableForwarder(TableForwarder tableForwarder)

setMeterForwarder

public SyncPlanPushStrategyIncrementalImpl setMeterForwarder(MeterForwarder meterForwarder)

setGroupForwarder

public SyncPlanPushStrategyIncrementalImpl setGroupForwarder(GroupForwarder groupForwarder)

setTransactionService

public SyncPlanPushStrategyIncrementalImpl setTransactionService(FlowCapableTransactionService transactionService)