X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-remoterpc-connector%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fremote%2Frpc%2Fregistry%2FRoutingTable.java;h=09a987f7e31d289c4f02656e6d187f641d23140e;hb=a81d98f692b80c45bce3fe6a87e731abfb012a9f;hp=52b1106c873872609e4300abe52d558ee89a6011;hpb=b0648268f5f85e2533d39e37b01b35487823cac3;p=controller.git diff --git a/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/registry/RoutingTable.java b/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/registry/RoutingTable.java index 52b1106c87..09a987f7e3 100644 --- a/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/registry/RoutingTable.java +++ b/opendaylight/md-sal/sal-remoterpc-connector/src/main/java/org/opendaylight/controller/remote/rpc/registry/RoutingTable.java @@ -13,11 +13,12 @@ import akka.japi.Pair; import java.io.Serializable; import java.util.HashMap; import java.util.Map; +import java.util.Set; import org.opendaylight.controller.remote.rpc.registry.gossip.Copier; import org.opendaylight.controller.sal.connector.api.RpcRouter; public class RoutingTable implements Copier, Serializable { - private static final long serialVersionUID = 1L; + private static final long serialVersionUID = 5592610415175278760L; private final Map, Long> table = new HashMap<>(); private ActorRef router; @@ -31,7 +32,7 @@ public class RoutingTable implements Copier, Serializable { return copy; } - public Option> getRouterFor(RpcRouter.RouteIdentifier routeId){ + public Option> getRouterFor(RpcRouter.RouteIdentifier routeId) { Long updatedTime = table.get(routeId); if (updatedTime == null || router == null) { @@ -41,19 +42,23 @@ public class RoutingTable implements Copier, Serializable { } } - public void addRoute(RpcRouter.RouteIdentifier routeId){ + public Set> getRoutes() { + return table.keySet(); + } + + public void addRoute(RpcRouter.RouteIdentifier routeId) { table.put(routeId, System.currentTimeMillis()); } - public void removeRoute(RpcRouter.RouteIdentifier routeId){ + public void removeRoute(RpcRouter.RouteIdentifier routeId) { table.remove(routeId); } - public boolean contains(RpcRouter.RouteIdentifier routeId){ + public boolean contains(RpcRouter.RouteIdentifier routeId) { return table.containsKey(routeId); } - public boolean isEmpty(){ + public boolean isEmpty() { return table.isEmpty(); } @@ -71,9 +76,6 @@ public class RoutingTable implements Copier, Serializable { @Override public String toString() { - return "RoutingTable{" + - "table=" + table + - ", router=" + router + - '}'; + return "RoutingTable{" + "table=" + table + ", router=" + router + '}'; } }