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(FlowForwarder flowForwarder, MeterForwarder meterForwarder, GroupForwarder groupForwarder, SendBarrier sendBarrier)

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.

Methods inherited from class java.lang.Object

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

Constructor Details

SyncPlanPushStrategyIncrementalImpl

public SyncPlanPushStrategyIncrementalImpl(FlowForwarder flowForwarder,
 MeterForwarder meterForwarder,
 GroupForwarder groupForwarder,
 SendBarrier sendBarrier)

Method Details

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