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=f67657f6927801931fae2fd0434481169f2f3de8;hpb=3927509ec3ecfa32a51b725d2b7155d425f5b877;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 f67657f692..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,6 +13,7 @@ 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; @@ -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 + '}'; } }