X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=openflowplugin-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fopenflowplugin%2Fimpl%2Fconnection%2FConnectionContextImpl.java;h=aebb3fe3d3221034a1291f9f1c7688aedf0d6657;hb=867da8f64fbc12f407db3d41e96b216f7f62eb5b;hp=d81d47a80dd1e8286ed80e423222972824621e0e;hpb=9f162b87886b2bb3917fb5aa8aa3b37f49215516;p=openflowplugin.git diff --git a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/connection/ConnectionContextImpl.java b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/connection/ConnectionContextImpl.java index d81d47a80d..aebb3fe3d3 100644 --- a/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/connection/ConnectionContextImpl.java +++ b/openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/connection/ConnectionContextImpl.java @@ -17,6 +17,7 @@ import java.util.concurrent.Executors; import java.util.concurrent.Future; import java.util.concurrent.TimeUnit; import java.util.concurrent.TimeoutException; +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.connection.OutboundQueueHandlerRegistration; @@ -249,6 +250,7 @@ public class ConnectionContextImpl implements ConnectionContext { final private KeyedInstanceIdentifier nodeII; final private Short version; final private BigInteger datapathId; + final private ServiceGroupIdentifier serviceGroupIdentifier; DeviceInfoImpl( final NodeId nodeId, @@ -259,6 +261,7 @@ public class ConnectionContextImpl implements ConnectionContext { this.nodeII = nodeII; this.version = version; this.datapathId = datapathId; + this.serviceGroupIdentifier = ServiceGroupIdentifier.create(this.nodeId.getValue()); } @Override @@ -281,6 +284,11 @@ public class ConnectionContextImpl implements ConnectionContext { return datapathId; } + @Override + public ServiceGroupIdentifier getServiceIdentifier() { + return this.serviceGroupIdentifier; + } + @Override public boolean equals(Object o) { if (this == o) {