X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=openflowplugin-api%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fopenflowplugin%2Fapi%2Fopenflow%2Flifecycle%2FLifecycleConductor.java;h=fcddb2cd4bfff4d83388de0cd527e795463f1700;hb=69c82be6d14782e3a38b58cf40d87529db480703;hp=d544c2c791a53d08fee5e10ec5dad711f5b2d9c1;hpb=88b532987af9b9e3149614fc63cc58c9e769f55a;p=openflowplugin.git diff --git a/openflowplugin-api/src/main/java/org/opendaylight/openflowplugin/api/openflow/lifecycle/LifecycleConductor.java b/openflowplugin-api/src/main/java/org/opendaylight/openflowplugin/api/openflow/lifecycle/LifecycleConductor.java index d544c2c791..fcddb2cd4b 100644 --- a/openflowplugin-api/src/main/java/org/opendaylight/openflowplugin/api/openflow/lifecycle/LifecycleConductor.java +++ b/openflowplugin-api/src/main/java/org/opendaylight/openflowplugin/api/openflow/lifecycle/LifecycleConductor.java @@ -10,17 +10,15 @@ package org.opendaylight.openflowplugin.api.openflow.lifecycle; import io.netty.util.Timeout; import io.netty.util.TimerTask; +import java.util.concurrent.TimeUnit; +import javax.annotation.Nonnull; import org.opendaylight.controller.md.sal.binding.api.NotificationPublishService; import org.opendaylight.openflowplugin.api.openflow.OFPManager; +import org.opendaylight.openflowplugin.api.openflow.connection.ConnectionContext; 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.statistics.StatisticsManager; +import org.opendaylight.openflowplugin.api.openflow.statistics.StatisticsContext; import org.opendaylight.openflowplugin.api.openflow.statistics.ofpspecific.MessageIntelligenceAgency; -import org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.NodeId; - -import javax.annotation.Nonnull; -import java.util.concurrent.TimeUnit; /** * This class is a binder between all managers @@ -49,6 +47,13 @@ public interface LifecycleConductor { */ void addOneTimeListenerWhenServicesChangesDone(final ServiceChangeListener manager, final DeviceInfo deviceInfo); + /** + * Returns statistics context from statistics managers contexts maps + * + * @param deviceInfo@return null if context doesn't exists + */ + StatisticsContext getStatisticsContext(DeviceInfo deviceInfo); + /** * Set new timeout for {@link io.netty.util.HashedWheelTimer} * @param task timer task @@ -70,6 +75,8 @@ public interface LifecycleConductor { */ void closeConnection(final DeviceInfo deviceInfo); + ConnectionContext.CONNECTION_STATE gainConnectionStateSafely(DeviceInfo deviceInfo); + /** * Xid from outboundqueue * @param deviceInfo