X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=openflowplugin-api%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fopenflowplugin%2Fapi%2Fopenflow%2Fdevice%2FDeviceContext.java;h=413131105b20f17b2c972a0a15f1f410f8118ec6;hb=9899c3134d7cc24e9c8d57b34d9c19b111e00e33;hp=807e7212046dc04501d4c2b678f3d581f3acab38;hpb=feb756b15ece1618ec8864b062e20e75dcc39e8b;p=openflowplugin.git diff --git a/openflowplugin-api/src/main/java/org/opendaylight/openflowplugin/api/openflow/device/DeviceContext.java b/openflowplugin-api/src/main/java/org/opendaylight/openflowplugin/api/openflow/device/DeviceContext.java index 807e721204..676c21c780 100644 --- a/openflowplugin-api/src/main/java/org/opendaylight/openflowplugin/api/openflow/device/DeviceContext.java +++ b/openflowplugin-api/src/main/java/org/opendaylight/openflowplugin/api/openflow/device/DeviceContext.java @@ -8,31 +8,21 @@ package org.opendaylight.openflowplugin.api.openflow.device; +import com.google.common.util.concurrent.ListenableFuture; import io.netty.util.Timeout; import java.math.BigInteger; +import java.util.List; import org.opendaylight.controller.md.sal.binding.api.NotificationPublishService; -import org.opendaylight.controller.md.sal.binding.api.NotificationService; -import org.opendaylight.controller.md.sal.binding.api.ReadTransaction; -import org.opendaylight.controller.md.sal.common.api.data.LogicalDatastoreType; -import org.opendaylight.openflowplugin.api.openflow.OpenFlowPluginTimer; +import org.opendaylight.openflowplugin.api.openflow.OFPContext; import org.opendaylight.openflowplugin.api.openflow.connection.ConnectionContext; -import org.opendaylight.openflowplugin.api.openflow.device.handlers.DeviceContextClosedHandler; -import org.opendaylight.openflowplugin.api.openflow.device.handlers.DeviceDisconnectedHandler; import org.opendaylight.openflowplugin.api.openflow.device.handlers.DeviceReplyProcessor; -import org.opendaylight.openflowplugin.api.openflow.device.handlers.MessageHandler; import org.opendaylight.openflowplugin.api.openflow.device.handlers.MultiMsgCollector; -import org.opendaylight.openflowplugin.api.openflow.device.handlers.OutstandingMessageExtractor; -import org.opendaylight.openflowplugin.api.openflow.device.listener.OpenflowMessageListenerFacade; -import org.opendaylight.openflowplugin.api.openflow.registry.flow.DeviceFlowRegistry; -import org.opendaylight.openflowplugin.api.openflow.registry.group.DeviceGroupRegistry; -import org.opendaylight.openflowplugin.api.openflow.registry.meter.DeviceMeterRegistry; +import org.opendaylight.openflowplugin.api.openflow.lifecycle.LifecycleService; +import org.opendaylight.openflowplugin.api.openflow.registry.ItemLifeCycleRegistry; import org.opendaylight.openflowplugin.api.openflow.statistics.ofpspecific.MessageSpy; -import org.opendaylight.openflowplugin.api.openflow.translator.TranslatorLibrarian; -import org.opendaylight.yangtools.yang.binding.DataObject; -import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; +import org.opendaylight.yang.gen.v1.urn.opendaylight.openflow.protocol.rev130731.MultipartReply; /** - *
* The central entity of OFP is the Device Context, which encapsulate the logical state of a switch * as seen by the controller. Each OpenFlow session is tracked by a Connection Context. * These attach to a particular Device Context in such a way, that there is at most one primary @@ -45,32 +35,30 @@ import org.opendaylight.yangtools.yang.binding.InstanceIdentifier; * which is enforced by keeping a cap on the number of outstanding requests a particular Request * Context can have at any point in time. Should this quota be exceeded, any further attempt to make * a request to the switch will fail immediately, with proper error indication. - *
- * Created by Martin Bobak <mbobak@cisco.com> on 25.2.2015. */ -public interface DeviceContext extends AutoCloseable, - OpenFlowPluginTimer, - MessageHandler, - TranslatorLibrarian, - OutstandingMessageExtractor, +public interface DeviceContext extends + OFPContext, + AutoCloseable, DeviceReplyProcessor, - DeviceDisconnectedHandler { + TxFacade, + DeviceRegistry{ + /** + * Method close all auxiliary connections and primary connection. + */ + void shutdownConnection(); /** * Method add auxiliary connection contexts to this context representing single device connection. - * - * @param connectionContext + * @param connectionContext new connection context */ - void addAuxiliaryConenctionContext(ConnectionContext connectionContext); + void addAuxiliaryConnectionContext(ConnectionContext connectionContext); /** * Method removes auxiliary connection context from this context representing single device connection. - * - * @param connectionContext + * @param connectionContext connection which need to be removed */ - void removeAuxiliaryConenctionContext(ConnectionContext connectionContext); - + void removeAuxiliaryConnectionContext(ConnectionContext connectionContext); /** * Method provides state of device represented by this device context. @@ -80,127 +68,69 @@ public interface DeviceContext extends AutoCloseable, DeviceState getDeviceState(); /** - * Method creates put operation using provided data in underlying transaction chain. + * Method has to close TxManager ASAP we are notified about Closed Connection + * @return sync. future for Slave and MD-SAL completition for Master */ -