import org.opendaylight.openflowplugin.api.openflow.device.DeviceContext;
import org.opendaylight.openflowplugin.api.openflow.device.DeviceInfo;
import org.opendaylight.openflowplugin.api.openflow.device.DeviceState;
+import org.opendaylight.openflowplugin.api.openflow.lifecycle.ReconciliationFrameworkRegistrar;
import org.opendaylight.openflowplugin.api.openflow.rpc.ItemLifeCycleSource;
import org.opendaylight.openflowplugin.api.openflow.statistics.StatisticsContext;
import org.opendaylight.openflowplugin.api.openflow.statistics.StatisticsManager;
private BindingAwareBroker.RpcRegistration<StatisticsManagerControlService> controlServiceRegistration;
private final HashedWheelTimer hashedWheelTimer;
private boolean istStatisticsFullyDisabled;
+ private ReconciliationFrameworkRegistrar reconciliationFrameworkRegistrar;
public StatisticsManagerImpl(@Nonnull final OpenflowProviderConfig config,
@Nonnull final RpcProviderRegistry rpcProviderRegistry,
}
}
+ @Override
+ public void setReconciliationFrameworkRegistrar(@Nonnull ReconciliationFrameworkRegistrar rfRegistrar) {
+ this.reconciliationFrameworkRegistrar = rfRegistrar;
+ }
+
@Override
public StatisticsContext createContext(@Nonnull final DeviceContext deviceContext) {
converterExecutor,
this,
statisticsWriterProvider,
- config.isUsingReconciliationFramework()) :
+ reconciliationFrameworkRegistrar.isReconciliationFrameworkRegistered()) :
new StatisticsContextImpl<org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731
.MultipartReply>(
isStatisticsEnabled(),
converterExecutor,
this,
statisticsWriterProvider,
- config.isUsingReconciliationFramework());
+ reconciliationFrameworkRegistrar.isReconciliationFrameworkRegistered());
contexts.putIfAbsent(deviceContext.getDeviceInfo(), statisticsContext);
return statisticsContext;