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

Class SyncPlanPushStrategyFlatBatchImpl

java.lang.Object

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

All Implemented Interfaces:

SyncPlanPushStrategy

public class SyncPlanPushStrategyFlatBatchImpl
extends Object
implements SyncPlanPushStrategy

Execute CRUD API for flow + group + meter involving flat-batch strategy.

Constructor Summary

Constructors

Constructor	Description
SyncPlanPushStrategyFlatBatchImpl()

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.
SyncPlanPushStrategyFlatBatchImpl	setFlatBatchService(SalFlatBatchService flatBatchService)
SyncPlanPushStrategyFlatBatchImpl	setTableForwarder(TableForwarder tableForwarder)

Methods inherited from class java.lang.Object

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

Constructor Details

SyncPlanPushStrategyFlatBatchImpl

public SyncPlanPushStrategyFlatBatchImpl()

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

setFlatBatchService

public SyncPlanPushStrategyFlatBatchImpl setFlatBatchService(SalFlatBatchService flatBatchService)

setTableForwarder

public SyncPlanPushStrategyFlatBatchImpl setTableForwarder(TableForwarder tableForwarder)