X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=openflowplugin-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fopenflowplugin%2Fimpl%2Fdevice%2FDeviceContextImpl.java;h=63f97c73afcd8f04e90a77758e2048e324f9f121;hb=d8cc382a8dbdcb7c89b68457b3ae0b6d576ee28f;hp=28f0bf1499ff5e320b61c9bebfac3df61aac5f21;hpb=3a0af22809e1996fb02016197759017faa0b3ac3;p=openflowplugin.git diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/DeviceContextImpl.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/DeviceContextImpl.java index 28f0bf1499..63f97c73af 100644 --- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/DeviceContextImpl.java +++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/device/DeviceContextImpl.java @@ -8,10 +8,8 @@ package org.opendaylight.openflowplugin.impl.device; import com.google.common.annotations.VisibleForTesting; -import com.google.common.base.Function; import com.google.common.base.Preconditions; import com.google.common.base.Verify; -import com.google.common.util.concurrent.AsyncFunction; import com.google.common.util.concurrent.FutureCallback; import com.google.common.util.concurrent.Futures; import com.google.common.util.concurrent.ListenableFuture; @@ -20,14 +18,14 @@ import java.math.BigInteger; import java.util.HashMap; import java.util.List; import java.util.Map; -import java.util.concurrent.ConcurrentHashMap; -import java.util.concurrent.atomic.AtomicLong; -import javax.annotation.CheckForNull; +import java.util.concurrent.ExecutionException; import javax.annotation.Nonnull; import org.opendaylight.controller.md.sal.binding.api.DataBroker; import org.opendaylight.controller.md.sal.binding.api.NotificationPublishService; import org.opendaylight.controller.md.sal.binding.api.ReadOnlyTransaction; import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType; +import org.opendaylight.controller.md.sal.common.api.data.TransactionChainClosedException; +import org.opendaylight.mdsal.singleton.common.api.ServiceGroupIdentifier; import org.opendaylight.openflowjava.protocol.api.connection.ConnectionAdapter; import org.opendaylight.openflowjava.protocol.api.connection.OutboundQueue; import org.opendaylight.openflowjava.protocol.api.keys.MessageTypeKey; @@ -35,6 +33,7 @@ import org.opendaylight.openflowplugin.api.openflow.connection.ConnectionContext import org.opendaylight.openflowplugin.api.openflow.connection.OutboundQueueProvider; import org.opendaylight.openflowplugin.api.openflow.device.DeviceContext; import org.opendaylight.openflowplugin.api.openflow.device.DeviceInfo; +import org.opendaylight.openflowplugin.api.openflow.device.DeviceManager; import org.opendaylight.openflowplugin.api.openflow.device.DeviceState; import org.opendaylight.openflowplugin.api.openflow.device.MessageTranslator; import org.opendaylight.openflowplugin.api.openflow.device.RequestContext; @@ -51,9 +50,7 @@ import org.opendaylight.openflowplugin.api.openflow.registry.flow.FlowRegistryKe import org.opendaylight.openflowplugin.api.openflow.registry.group.DeviceGroupRegistry; import org.opendaylight.openflowplugin.api.openflow.registry.meter.DeviceMeterRegistry; import org.opendaylight.openflowplugin.api.openflow.rpc.ItemLifeCycleKeeper; -import org.opendaylight.openflowplugin.api.openflow.rpc.RpcContext; import org.opendaylight.openflowplugin.api.openflow.rpc.listener.ItemLifecycleListener; -import org.opendaylight.openflowplugin.api.openflow.statistics.StatisticsContext; import org.opendaylight.openflowplugin.api.openflow.statistics.ofpspecific.MessageSpy; import org.opendaylight.openflowplugin.extension.api.ConvertorMessageFromOFJava; import org.opendaylight.openflowplugin.extension.api.ExtensionConverterProviderKeeper; @@ -68,7 +65,7 @@ import org.opendaylight.openflowplugin.impl.registry.flow.FlowRegistryKeyFactory import org.opendaylight.openflowplugin.impl.registry.group.DeviceGroupRegistryImpl; import org.opendaylight.openflowplugin.impl.registry.meter.DeviceMeterRegistryImpl; import org.opendaylight.openflowplugin.impl.util.DeviceInitializationUtils; -import org.opendaylight.openflowplugin.impl.util.MdSalRegistrationUtils; +import org.opendaylight.openflowplugin.openflow.md.core.sal.convertor.ConvertorExecutor; import org.opendaylight.openflowplugin.openflow.md.core.session.SwitchConnectionCookieOFImpl; import org.opendaylight.yang.gen.v1.urn.opendaylight.experimenter.message.service.rev151020.ExperimenterMessageFromDevBuilder; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.FlowCapableNode; @@ -77,7 +74,6 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.ta import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow; import org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.FlowKey; import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorId; -import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeConnectorRef; import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeRef; import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnector; import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.node.NodeConnectorBuilder; @@ -98,7 +94,6 @@ import org.opendaylight.yang.gen.v1.urn.opendaylight.openflowplugin.experimenter import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketReceived; import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.FlowCapableNodeConnectorStatisticsData; import org.opendaylight.yang.gen.v1.urn.opendaylight.port.statistics.rev131214.FlowCapableNodeConnectorStatisticsDataBuilder; -import org.opendaylight.yang.gen.v1.urn.opendaylight.role.service.rev150727.OfpRole; import org.opendaylight.yangtools.yang.binding.DataObject; import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; import org.opendaylight.yangtools.yang.binding.KeyedInstanceIdentifier; @@ -108,7 +103,7 @@ import org.slf4j.LoggerFactory; /** * */ -public class DeviceContextImpl implements DeviceContext, ExtensionConverterProviderKeeper { +public class DeviceContextImpl implements DeviceContext, ExtensionConverterProviderKeeper{ private static final Logger LOG = LoggerFactory.getLogger(DeviceContextImpl.class); @@ -137,67 +132,61 @@ public class DeviceContextImpl implements DeviceContext, ExtensionConverterProvi private final MessageTranslator packetInTranslator; private final MessageTranslator flowRemovedTranslator; private final TranslatorLibrary translatorLibrary; - private final Map nodeConnectorCache; private final ItemLifeCycleRegistry itemLifeCycleSourceRegistry; - private RpcContext rpcContext; private ExtensionConverterProvider extensionConverterProvider; + private final DeviceManager deviceManager; - private final boolean switchFeaturesMandatory; - private StatisticsContext statisticsContext; - + private boolean switchFeaturesMandatory; private final DeviceInfo deviceInfo; - - private volatile DEVICE_CONTEXT_STATE deviceCtxState; - private boolean isStatisticsRpcEnabled; - - - @VisibleForTesting - DeviceContextImpl(@Nonnull final ConnectionContext primaryConnectionContext, - @Nonnull final DeviceState deviceState, - @Nonnull final DataBroker dataBroker, - @Nonnull final LifecycleConductor conductor, - @Nonnull final OutboundQueueProvider outboundQueueProvider, - @Nonnull final TranslatorLibrary translatorLibrary, - final boolean switchFeaturesMandatory) { - this.switchFeaturesMandatory = switchFeaturesMandatory; + private final ConvertorExecutor convertorExecutor; + private volatile CONTEXT_STATE state; + + public DeviceContextImpl( + @Nonnull final ConnectionContext primaryConnectionContext, + @Nonnull final DataBroker dataBroker, + @Nonnull final LifecycleConductor conductor, + @Nonnull final OutboundQueueProvider outboundQueueProvider, + @Nonnull final TranslatorLibrary translatorLibrary, + @Nonnull final DeviceManager manager, + final ConvertorExecutor convertorExecutor) { this.primaryConnectionContext = Preconditions.checkNotNull(primaryConnectionContext); - this.deviceState = Preconditions.checkNotNull(deviceState); + this.deviceInfo = primaryConnectionContext.getDeviceInfo(); + this.deviceState = new DeviceStateImpl(); this.dataBroker = Preconditions.checkNotNull(dataBroker); Preconditions.checkNotNull(conductor); this.outboundQueueProvider = Preconditions.checkNotNull(outboundQueueProvider); - this.transactionChainManager = new TransactionChainManager(dataBroker, deviceState, conductor); + this.transactionChainManager = new TransactionChainManager(dataBroker, deviceInfo , conductor); auxiliaryConnectionContexts = new HashMap<>(); - deviceFlowRegistry = new DeviceFlowRegistryImpl(); + deviceFlowRegistry = new DeviceFlowRegistryImpl(dataBroker, deviceInfo.getNodeInstanceIdentifier()); deviceGroupRegistry = new DeviceGroupRegistryImpl(); deviceMeterRegistry = new DeviceMeterRegistryImpl(); messageSpy = conductor.getMessageIntelligenceAgency(); + this.deviceManager = Preconditions.checkNotNull(manager); packetInLimiter = new PacketInRateLimiter(primaryConnectionContext.getConnectionAdapter(), /*initial*/ 1000, /*initial*/2000, messageSpy, REJECTED_DRAIN_FACTOR); this.translatorLibrary = translatorLibrary; portStatusTranslator = translatorLibrary.lookupTranslator( - new TranslatorKey(deviceState.getVersion(), PortGrouping.class.getName())); + new TranslatorKey(deviceInfo.getVersion(), PortGrouping.class.getName())); packetInTranslator = translatorLibrary.lookupTranslator( - new TranslatorKey(deviceState.getVersion(), PacketIn.class.getName())); + new TranslatorKey(deviceInfo.getVersion(), PacketIn.class.getName())); flowRemovedTranslator = translatorLibrary.lookupTranslator( - new TranslatorKey(deviceState.getVersion(), FlowRemoved.class.getName())); - - - nodeConnectorCache = new ConcurrentHashMap<>(); + new TranslatorKey(deviceInfo.getVersion(), FlowRemoved.class.getName())); itemLifeCycleSourceRegistry = new ItemLifeCycleRegistryImpl(); flowLifeCycleKeeper = new ItemLifeCycleSourceImpl(); itemLifeCycleSourceRegistry.registerLifeCycleSource(flowLifeCycleKeeper); - deviceCtxState = DEVICE_CONTEXT_STATE.INITIALIZATION; - deviceInfo = primaryConnectionContext.getDeviceInfo(); + this.state = CONTEXT_STATE.INITIALIZATION; + this.convertorExecutor = convertorExecutor; } /** * This method is called from {@link DeviceManagerImpl} only. So we could say "posthandshake process finish" * and we are able to set a scheduler for an automatic transaction submitting by time (0,5sec). */ - void initialSubmitTransaction() { + @Override + public void initialSubmitTransaction() { transactionChainManager.initialSubmitWriteTransaction(); } @@ -220,7 +209,7 @@ public class DeviceContextImpl implements DeviceContext, ExtensionConverterProvi public void removeAuxiliaryConnectionContext(final ConnectionContext connectionContext) { final SwitchConnectionDistinguisher connectionDistinguisher = createConnectionDistinguisher(connectionContext); LOG.debug("auxiliary connection dropped: {}, nodeId:{}", connectionContext.getConnectionAdapter() - .getRemoteAddress(), deviceInfo.getNodeId()); + .getRemoteAddress(), getDeviceInfo().getNodeId()); auxiliaryConnectionContexts.remove(connectionDistinguisher); } @@ -234,113 +223,22 @@ public class DeviceContextImpl implements DeviceContext, ExtensionConverterProvi return dataBroker.newReadOnlyTransaction(); } - @Override - public ListenableFuture onClusterRoleChange(final OfpRole oldRole, @CheckForNull final OfpRole role) { - LOG.trace("onClusterRoleChange {} for node:", role, deviceInfo.getNodeId()); - Preconditions.checkArgument(role != null); - if (role.equals(oldRole)) { - LOG.debug("Demanded role change for device {} is not changed. OldRole: {}, NewRole {}", deviceInfo.getNodeId(), oldRole, role); - return Futures.immediateFuture(null); - } - if (OfpRole.BECOMEMASTER.equals(role)) { - return onDeviceTakeClusterLeadership(); - } else if (OfpRole.BECOMESLAVE.equals(role)) { - return onDeviceLostClusterLeadership(); - } else { - LOG.warn("Unknown OFCluster Role {} for Node {}", role, deviceInfo.getNodeId()); - if (null != rpcContext) { - MdSalRegistrationUtils.unregisterServices(rpcContext); - } - return transactionChainManager.deactivateTransactionManager(); - } - } - - @Override - public ListenableFuture onDeviceLostClusterLeadership() { - LOG.trace("onDeviceLostClusterLeadership for node: {}", deviceInfo.getNodeId()); - if (null != rpcContext) { - MdSalRegistrationUtils.registerSlaveServices(rpcContext, OfpRole.BECOMESLAVE); - } - return transactionChainManager.deactivateTransactionManager(); - } - - @Override - public ListenableFuture onDeviceTakeClusterLeadership() { - LOG.trace("onDeviceTakeClusterLeadership for node: {}", deviceInfo.getNodeId()); - /* validation */ - if (statisticsContext == null) { - final String errMsg = String.format("DeviceCtx %s is up but we are missing StatisticsContext", deviceInfo.getDatapathId()); - LOG.warn(errMsg); - return Futures.immediateFailedFuture(new IllegalStateException(errMsg)); - } - if (rpcContext == null) { - final String errMsg = String.format("DeviceCtx %s is up but we are missing RpcContext", deviceInfo.getDatapathId()); - LOG.warn(errMsg); - return Futures.immediateFailedFuture(new IllegalStateException(errMsg)); - } - /* Routed RPC registration */ - MdSalRegistrationUtils.registerMasterServices(getRpcContext(), DeviceContextImpl.this, OfpRole.BECOMEMASTER); - - if (isStatisticsRpcEnabled) { - MdSalRegistrationUtils.registerStatCompatibilityServices(getRpcContext(), this, - notificationPublishService, new AtomicLong()); - } - - /* Prepare init info collecting */ - getDeviceState().setDeviceSynchronized(false); - transactionChainManager.activateTransactionManager(); - /* Init Collecting NodeInfo */ - final ListenableFuture initCollectingDeviceInfo = DeviceInitializationUtils.initializeNodeInformation( - DeviceContextImpl.this, switchFeaturesMandatory); - /* Init Collecting StatInfo */ - final ListenableFuture statPollFuture = Futures.transform(initCollectingDeviceInfo, - new AsyncFunction() { - - @Override - public ListenableFuture apply(@Nonnull final Void input) throws Exception { - getStatisticsContext().statListForCollectingInitialization(); - return getStatisticsContext().gatherDynamicData(); - } - }); - - return Futures.transform(statPollFuture, new Function() { - - @Override - public Void apply(final Boolean input) { - if (ConnectionContext.CONNECTION_STATE.RIP.equals(getPrimaryConnectionContext().getConnectionState())) { - final String errMsg = String.format("We lost connection for Device %s, context has to be closed.", - getDeviceState().getNodeId()); - LOG.warn(errMsg); - throw new IllegalStateException(errMsg); - } - if (!input) { - final String errMsg = String.format("Get Initial Device %s information fails", - getDeviceState().getNodeId()); - LOG.warn(errMsg); - throw new IllegalStateException(errMsg); - } - LOG.debug("Get Initial Device {} information is successful", deviceInfo.getNodeId()); - getDeviceState().setDeviceSynchronized(true); - initialSubmitTransaction(); - getDeviceState().setStatisticsPollingEnabledProp(true); - return null; - } - }); - } - @Override public void writeToTransaction(final LogicalDatastoreType store, - final InstanceIdentifier path, final T data) throws Exception { + final InstanceIdentifier path, + final T data){ transactionChainManager.writeToTransaction(store, path, data, false); } @Override - public void writeToTransactionWithParentsSlow(LogicalDatastoreType store, InstanceIdentifier path, T data) throws Exception { + public void writeToTransactionWithParentsSlow(final LogicalDatastoreType store, + final InstanceIdentifier path, + final T data){ transactionChainManager.writeToTransaction(store, path, data, true); } @Override - public void addDeleteToTxChain(final LogicalDatastoreType store, final InstanceIdentifier path) throws Exception { + public void addDeleteToTxChain(final LogicalDatastoreType store, final InstanceIdentifier path) throws TransactionChainClosedException { transactionChainManager.addDeleteOperationTotTxChain(store, path); } @@ -392,11 +290,19 @@ public class DeviceContextImpl implements DeviceContext, ExtensionConverterProvi @Override public void processFlowRemovedMessage(final FlowRemoved flowRemoved) { + //1. translate to general flow (table, priority, match, cookie) + final org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.FlowRemoved flowRemovedNotification = + flowRemovedTranslator.translate(flowRemoved, deviceInfo, null); + + if(!deviceManager.getIsNotificationFlowRemovedOff()) { + // Trigger off a notification + notificationPublishService.offerNotification(flowRemovedNotification); + } else if(LOG.isDebugEnabled()) { + LOG.debug("For nodeId={} isNotificationFlowRemovedOff={}", getDeviceInfo().getNodeId(), deviceManager.getIsNotificationFlowRemovedOff()); + } + final ItemLifecycleListener itemLifecycleListener = flowLifeCycleKeeper.getItemLifecycleListener(); if (itemLifecycleListener != null) { - //1. translate to general flow (table, priority, match, cookie) - final org.opendaylight.yang.gen.v1.urn.opendaylight.flow.service.rev130819.FlowRemoved flowRemovedNotification = - flowRemovedTranslator.translate(flowRemoved, this.getDeviceState(), null); //2. create registry key final FlowRegistryKey flowRegKey = FlowRegistryKeyFactory.create(flowRemovedNotification); //3. lookup flowId @@ -404,17 +310,15 @@ public class DeviceContextImpl implements DeviceContext, ExtensionConverterProvi //4. if flowId present: if (flowDescriptor != null) { // a) construct flow path - final KeyedInstanceIdentifier flowPath = getDeviceState().getNodeInstanceIdentifier() + final KeyedInstanceIdentifier flowPath = getDeviceInfo().getNodeInstanceIdentifier() .augmentation(FlowCapableNode.class) .child(Table.class, flowDescriptor.getTableKey()) .child(Flow.class, new FlowKey(flowDescriptor.getFlowId())); // b) notify listener itemLifecycleListener.onRemoved(flowPath); - // c) trigger off a notification - notificationPublishService.offerNotification(flowRemovedNotification); } else { LOG.debug("flow id not found: nodeId={} tableId={}, priority={}", - getDeviceState().getNodeId(), flowRegKey.getTableId(), flowRemovedNotification.getPriority()); + getDeviceInfo().getNodeId(), flowRegKey.getTableId(), flowRemovedNotification.getPriority()); } } } @@ -422,7 +326,7 @@ public class DeviceContextImpl implements DeviceContext, ExtensionConverterProvi @Override public void processPortStatusMessage(final PortStatusMessage portStatus) { messageSpy.spyMessage(portStatus.getImplementedInterface(), MessageSpy.STATISTIC_GROUP.FROM_SWITCH_PUBLISHED_SUCCESS); - final FlowCapableNodeConnector flowCapableNodeConnector = portStatusTranslator.translate(portStatus, this.getDeviceState(), null); + final FlowCapableNodeConnector flowCapableNodeConnector = portStatusTranslator.translate(portStatus, getDeviceInfo(), null); final KeyedInstanceIdentifier iiToNodeConnector = provideIIToNodeConnector(portStatus.getPortNo(), portStatus.getVersion()); try { @@ -437,13 +341,13 @@ public class DeviceContextImpl implements DeviceContext, ExtensionConverterProvi } submitTransaction(); } catch (final Exception e) { - LOG.warn("Error processing port status message: {}", e.getMessage()); + LOG.warn("Error processing port status message: ", e); } } private KeyedInstanceIdentifier provideIIToNodeConnector(final long portNo, final short version) { - final InstanceIdentifier iiToNodes = deviceState.getNodeInstanceIdentifier(); - final BigInteger dataPathId = deviceState.getFeatures().getDatapathId(); + final InstanceIdentifier iiToNodes = getDeviceInfo().getNodeInstanceIdentifier(); + final BigInteger dataPathId = getDeviceInfo().getDatapathId(); final NodeConnectorId nodeConnectorId = NodeStaticReplyTranslatorUtil.nodeConnectorId(dataPathId.toString(), portNo, version); return iiToNodes.child(NodeConnector.class, new NodeConnectorKey(nodeConnectorId)); } @@ -452,7 +356,7 @@ public class DeviceContextImpl implements DeviceContext, ExtensionConverterProvi public void processPacketInMessage(final PacketInMessage packetInMessage) { messageSpy.spyMessage(packetInMessage.getImplementedInterface(), MessageSpy.STATISTIC_GROUP.FROM_SWITCH); final ConnectionAdapter connectionAdapter = getPrimaryConnectionContext().getConnectionAdapter(); - final PacketReceived packetReceived = packetInTranslator.translate(packetInMessage, this.getDeviceState(), null); + final PacketReceived packetReceived = packetInTranslator.translate(packetInMessage, getDeviceInfo(), null); if (packetReceived == null) { LOG.debug("Received a null packet from switch {}", connectionAdapter.getRemoteAddress()); @@ -500,13 +404,13 @@ public class DeviceContextImpl implements DeviceContext, ExtensionConverterProvi // lookup converter final ExperimenterDataOfChoice vendorData = notification.getExperimenterDataOfChoice(); final MessageTypeKey key = new MessageTypeKey<>( - deviceState.getVersion(), + getDeviceInfo().getVersion(), (Class) vendorData.getImplementedInterface()); final ConvertorMessageFromOFJava messageConverter = extensionConverterProvider.getMessageConverter(key); if (messageConverter == null) { LOG.warn("custom converter for {}[OF:{}] not found", notification.getExperimenterDataOfChoice().getImplementedInterface(), - deviceState.getVersion()); + getDeviceInfo().getVersion()); return; } // build notification @@ -514,7 +418,7 @@ public class DeviceContextImpl implements DeviceContext, ExtensionConverterProvi try { messageOfChoice = messageConverter.convert(vendorData, MessagePath.MESSAGE_NOTIFICATION); final ExperimenterMessageFromDevBuilder experimenterMessageFromDevBld = new ExperimenterMessageFromDevBuilder() - .setNode(new NodeRef(deviceState.getNodeInstanceIdentifier())) + .setNode(new NodeRef(getDeviceInfo().getNodeInstanceIdentifier())) .setExperimenterMessageOfChoice(messageOfChoice); // publish notificationPublishService.offerNotification(experimenterMessageFromDevBld.build()); @@ -532,7 +436,7 @@ public class DeviceContextImpl implements DeviceContext, ExtensionConverterProvi public synchronized void close() { LOG.debug("closing deviceContext: {}, nodeId:{}", getPrimaryConnectionContext().getConnectionAdapter().getRemoteAddress(), - getDeviceState().getNodeId()); + getDeviceInfo().getNodeId()); // NOOP throw new UnsupportedOperationException("Autocloseble.close will be removed soon"); } @@ -559,8 +463,8 @@ public class DeviceContextImpl implements DeviceContext, ExtensionConverterProvi @Override public void onPublished() { - Verify.verify(DEVICE_CONTEXT_STATE.INITIALIZATION.equals(deviceCtxState)); - deviceCtxState = DEVICE_CONTEXT_STATE.WORKING; + Verify.verify(CONTEXT_STATE.INITIALIZATION.equals(getState())); + setState(CONTEXT_STATE.WORKING); primaryConnectionContext.getConnectionAdapter().setPacketInFiltering(false); for (final ConnectionContext switchAuxConnectionContext : auxiliaryConnectionContexts.values()) { switchAuxConnectionContext.getConnectionAdapter().setPacketInFiltering(false); @@ -572,18 +476,6 @@ public class DeviceContextImpl implements DeviceContext, ExtensionConverterProvi return new MultiMsgCollectorImpl(this, requestContext); } - @Override - public NodeConnectorRef lookupNodeConnectorRef(final Long portNumber) { - return nodeConnectorCache.get(portNumber); - } - - @Override - public void storeNodeConnectorRef(@Nonnull final Long portNumber, @Nonnull final NodeConnectorRef nodeConnectorRef) { - nodeConnectorCache.put( - Preconditions.checkNotNull(portNumber), - Preconditions.checkNotNull(nodeConnectorRef)); - } - @Override public void updatePacketInRateLimit(final long upperBound) { packetInLimiter.changeWaterMarks((int) (LOW_WATERMARK_FACTOR * upperBound), (int) (HIGH_WATERMARK_FACTOR * upperBound)); @@ -594,16 +486,6 @@ public class DeviceContextImpl implements DeviceContext, ExtensionConverterProvi return itemLifeCycleSourceRegistry; } - @Override - public void setRpcContext(final RpcContext rpcContext) { - this.rpcContext = rpcContext; - } - - @Override - public RpcContext getRpcContext() { - return rpcContext; - } - @Override public void setExtensionConverterProvider(final ExtensionConverterProvider extensionConverterProvider) { this.extensionConverterProvider = extensionConverterProvider; @@ -614,28 +496,17 @@ public class DeviceContextImpl implements DeviceContext, ExtensionConverterProvi return extensionConverterProvider; } - @Override - public void setStatisticsContext(final StatisticsContext statisticsContext) { - this.statisticsContext = statisticsContext; - } - - @Override - public StatisticsContext getStatisticsContext() { - return statisticsContext; - } - @Override public synchronized void shutdownConnection() { - LOG.debug("Shutdown method for node {}", deviceInfo.getNodeId()); - deviceState.setValid(false); - if (DEVICE_CONTEXT_STATE.TERMINATION.equals(deviceCtxState)) { - LOG.debug("DeviceCtx for Node {} is in termination process.", deviceInfo.getNodeId()); + LOG.debug("Shutdown method for node {}", getDeviceInfo().getNodeId()); + if (CONTEXT_STATE.TERMINATION.equals(getState())) { + LOG.debug("DeviceCtx for Node {} is in termination process.", getDeviceInfo().getNodeId()); return; } - deviceCtxState = DEVICE_CONTEXT_STATE.TERMINATION; + setState(CONTEXT_STATE.TERMINATION); if (ConnectionContext.CONNECTION_STATE.RIP.equals(getPrimaryConnectionContext().getConnectionState())) { - LOG.debug("ConnectionCtx for Node {} is in RIP state.", deviceState.getNodeId()); + LOG.debug("ConnectionCtx for Node {} is in RIP state.", getDeviceInfo().getNodeId()); return; } /* Terminate Auxiliary Connection */ @@ -652,23 +523,50 @@ public class DeviceContextImpl implements DeviceContext, ExtensionConverterProvi } @Override - public void setStatisticsRpcEnabled(boolean isStatisticsRpcEnabled) { - this.isStatisticsRpcEnabled = isStatisticsRpcEnabled; + public ListenableFuture shuttingDownDataStoreTransactions() { + return transactionChainManager.shuttingDown(); + } + + @VisibleForTesting + TransactionChainManager getTransactionChainManager() { + return this.transactionChainManager; } @Override - public DEVICE_CONTEXT_STATE getDeviceContextState() { - return deviceCtxState; + public void setSwitchFeaturesMandatory(boolean switchFeaturesMandatory) { + this.switchFeaturesMandatory = switchFeaturesMandatory; } @Override - public ListenableFuture shuttingDownDataStoreTransactions() { - deviceState.setValid(false); - return transactionChainManager.shuttingDown(); + public CONTEXT_STATE getState() { + return this.state; } - @VisibleForTesting - TransactionChainManager getTransactionChainManager() { - return this.transactionChainManager; + @Override + public void setState(CONTEXT_STATE state) { + this.state = state; + } + + @Override + public void startupClusterServices() throws ExecutionException, InterruptedException { + LOG.debug("Initializing transaction chain manager for node {}", getDeviceInfo().getNodeId()); + this.transactionChainManager.activateTransactionManager(); + LOG.debug("Waiting to get node {} information", getDeviceInfo().getNodeId()); + DeviceInitializationUtils.initializeNodeInformation(this, switchFeaturesMandatory, this.convertorExecutor).get(); + } + + @Override + public ListenableFuture stopClusterServices() { + return this.transactionChainManager.deactivateTransactionManager(); + } + + @Override + public ServiceGroupIdentifier getServiceIdentifier() { + return this.deviceInfo.getServiceIdentifier(); + } + + @Override + public DeviceInfo getDeviceInfo() { + return this.deviceInfo; } }