+/*
+ * Copyright (c) 2015 Cisco Systems, Inc. and others. All rights reserved.
+ *
+ * This program and the accompanying materials are made available under the
+ * terms of the Eclipse Public License v1.0 which accompanies this distribution,
+ * and is available at http://www.eclipse.org/legal/epl-v10.html
+ */
package org.opendaylight.controller.remote.rpc.registry.mbeans;
import akka.actor.Address;
-import org.opendaylight.controller.md.sal.common.util.jmx.AbstractMXBean;
-import org.opendaylight.controller.remote.rpc.registry.RoutingTable;
-import org.opendaylight.controller.remote.rpc.registry.RpcRegistry;
-import org.opendaylight.controller.remote.rpc.registry.gossip.Bucket;
-import org.opendaylight.controller.sal.connector.api.RpcRouter;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
+import akka.util.Timeout;
import java.util.HashMap;
import java.util.HashSet;
import java.util.Map;
+import java.util.Map.Entry;
import java.util.Set;
+import org.opendaylight.controller.remote.rpc.registry.RoutingTable;
+import org.opendaylight.controller.remote.rpc.registry.gossip.Bucket;
+import org.opendaylight.controller.remote.rpc.registry.gossip.BucketStoreAccess;
+import org.opendaylight.mdsal.dom.api.DOMRpcIdentifier;
-
-public class RemoteRpcRegistryMXBeanImpl extends AbstractMXBean implements RemoteRpcRegistryMXBean {
-
- protected final Logger log = LoggerFactory.getLogger(getClass());
-
- private final String NULL_CONSTANT = "null";
-
- private final String LOCAL_CONSTANT = "local";
-
- private final String ROUTE_CONSTANT = "route:";
-
- private final String NAME_CONSTANT = " | name:";
-
- private final RpcRegistry rpcRegistry;
-
- public RemoteRpcRegistryMXBeanImpl(final RpcRegistry rpcRegistry) {
- super("RemoteRpcRegistry", "RemoteRpcBroker", null);
- this.rpcRegistry = rpcRegistry;
- registerMBean();
+public class RemoteRpcRegistryMXBeanImpl extends AbstractRegistryMXBean<RoutingTable, DOMRpcIdentifier>
+ implements RemoteRpcRegistryMXBean {
+ public RemoteRpcRegistryMXBeanImpl(final BucketStoreAccess rpcRegistryAccess, final Timeout timeout) {
+ super("RemoteRpcRegistry", "RemoteRpcBroker", rpcRegistryAccess, timeout);
}
@Override
public Set<String> getGlobalRpc() {
- RoutingTable table = rpcRegistry.getLocalBucket().getData();
- Set<String> globalRpc = new HashSet<>(table.getRoutes().size());
- for(RpcRouter.RouteIdentifier<?, ?, ?> route : table.getRoutes()){
- if(route.getRoute() == null) {
- globalRpc.add(route.getType() != null ? route.getType().toString() : NULL_CONSTANT);
+ RoutingTable table = localData();
+ Set<String> globalRpc = new HashSet<>(table.getItems().size());
+ for (DOMRpcIdentifier route : table.getItems()) {
+ if (route.getContextReference().isEmpty()) {
+ globalRpc.add(route.getType().toString());
}
}
- if(log.isDebugEnabled()) {
- log.debug("Locally registered global RPCs {}", globalRpc);
- }
+
+ log.debug("Locally registered global RPCs {}", globalRpc);
return globalRpc;
}
@Override
public Set<String> getLocalRegisteredRoutedRpc() {
- RoutingTable table = rpcRegistry.getLocalBucket().getData();
- Set<String> routedRpc = new HashSet<>(table.getRoutes().size());
- for(RpcRouter.RouteIdentifier<?, ?, ?> route : table.getRoutes()){
- if(route.getRoute() != null) {
- StringBuilder builder = new StringBuilder(ROUTE_CONSTANT);
- builder.append(route.getRoute().toString()).append(NAME_CONSTANT).append(route.getType() != null ?
- route.getType().toString() : NULL_CONSTANT);
- routedRpc.add(builder.toString());
+ RoutingTable table = localData();
+ Set<String> routedRpc = new HashSet<>(table.getItems().size());
+ for (DOMRpcIdentifier route : table.getItems()) {
+ if (!route.getContextReference().isEmpty()) {
+ routedRpc.add(ROUTE_CONSTANT + route.getContextReference() + NAME_CONSTANT + route.getType());
}
}
- if(log.isDebugEnabled()) {
- log.debug("Locally registered routed RPCs {}", routedRpc);
- }
+
+ log.debug("Locally registered routed RPCs {}", routedRpc);
return routedRpc;
}
@Override
public Map<String, String> findRpcByName(final String name) {
- RoutingTable localTable = rpcRegistry.getLocalBucket().getData();
+ RoutingTable localTable = localData();
// Get all RPCs from local bucket
Map<String, String> rpcMap = new HashMap<>(getRpcMemberMapByName(localTable, name, LOCAL_CONSTANT));
// Get all RPCs from remote bucket
- Map<Address, Bucket<RoutingTable>> buckets = rpcRegistry.getRemoteBuckets();
- for(Address address : buckets.keySet()) {
- RoutingTable table = buckets.get(address).getData();
- rpcMap.putAll(getRpcMemberMapByName(table, name, address.toString()));
- }
- if(log.isDebugEnabled()) {
- log.debug("list of RPCs {} searched by name {}", rpcMap, name);
+ Map<Address, Bucket<RoutingTable>> buckets = remoteBuckets();
+ for (Entry<Address, Bucket<RoutingTable>> entry : buckets.entrySet()) {
+ RoutingTable table = entry.getValue().getData();
+ rpcMap.putAll(getRpcMemberMapByName(table, name, entry.getKey().toString()));
}
+
+ log.debug("list of RPCs {} searched by name {}", rpcMap, name);
return rpcMap;
}
@Override
- public Map<String, String> findRpcByRoute(String routeId) {
- RoutingTable localTable = rpcRegistry.getLocalBucket().getData();
+ public Map<String, String> findRpcByRoute(final String routeId) {
+ RoutingTable localTable = localData();
Map<String, String> rpcMap = new HashMap<>(getRpcMemberMapByRoute(localTable, routeId, LOCAL_CONSTANT));
- Map<Address, Bucket<RoutingTable>> buckets = rpcRegistry.getRemoteBuckets();
- for(Address address : buckets.keySet()) {
- RoutingTable table = buckets.get(address).getData();
- rpcMap.putAll(getRpcMemberMapByRoute(table, routeId, address.toString()));
-
- }
- if(log.isDebugEnabled()) {
- log.debug("list of RPCs {} searched by route {}", rpcMap, routeId);
+ Map<Address, Bucket<RoutingTable>> buckets = remoteBuckets();
+ for (Entry<Address, Bucket<RoutingTable>> entry : buckets.entrySet()) {
+ RoutingTable table = entry.getValue().getData();
+ rpcMap.putAll(getRpcMemberMapByRoute(table, routeId, entry.getKey().toString()));
}
+
+ log.debug("list of RPCs {} searched by route {}", rpcMap, routeId);
return rpcMap;
}
/**
- * Search if the routing table route String contains routeName
+ * Search if the routing table route String contains routeName.
*/
-
- private Map<String,String> getRpcMemberMapByRoute(final RoutingTable table, final String routeName,
- final String address) {
- Set<RpcRouter.RouteIdentifier<?, ?, ?>> routes = table.getRoutes();
+ private static Map<String,String> getRpcMemberMapByRoute(final RoutingTable table, final String routeName,
+ final String address) {
+ Set<DOMRpcIdentifier> routes = table.getItems();
Map<String, String> rpcMap = new HashMap<>(routes.size());
- for(RpcRouter.RouteIdentifier<?, ?, ?> route : table.getRoutes()){
- if(route.getRoute() != null) {
- String routeString = route.getRoute().toString();
- if(routeString.contains(routeName)) {
- StringBuilder builder = new StringBuilder(ROUTE_CONSTANT);
- builder.append(routeString).append(NAME_CONSTANT).append(route.getType() != null ?
- route.getType().toString() : NULL_CONSTANT);
- rpcMap.put(builder.toString(), address);
+ for (DOMRpcIdentifier route : routes) {
+ if (!route.getContextReference().isEmpty()) {
+ String routeString = route.getContextReference().toString();
+ if (routeString.contains(routeName)) {
+ rpcMap.put(ROUTE_CONSTANT + routeString + NAME_CONSTANT + route.getType(), address);
}
}
}
}
/**
- * Search if the routing table route type contains name
+ * Search if the routing table route type contains name.
*/
- private Map<String, String> getRpcMemberMapByName(final RoutingTable table, final String name,
- final String address) {
- Set<RpcRouter.RouteIdentifier<?, ?, ?>> routes = table.getRoutes();
+ private static Map<String, String> getRpcMemberMapByName(final RoutingTable table, final String name,
+ final String address) {
+ Set<DOMRpcIdentifier> routes = table.getItems();
Map<String, String> rpcMap = new HashMap<>(routes.size());
- for(RpcRouter.RouteIdentifier<?, ?, ?> route : routes){
- if(route.getType() != null) {
+ for (DOMRpcIdentifier route : routes) {
+ if (!route.getContextReference().isEmpty()) {
String type = route.getType().toString();
- if(type.contains(name)) {
- StringBuilder builder = new StringBuilder(ROUTE_CONSTANT);
- builder.append(route.getRoute() != null ? route.getRoute().toString(): NULL_CONSTANT)
- .append(NAME_CONSTANT).append(type);
- rpcMap.put(builder.toString(), address);
+ if (type.contains(name)) {
+ rpcMap.put(ROUTE_CONSTANT + route.getContextReference() + NAME_CONSTANT + type, address);
}
}
}
return rpcMap;
}
-
-
@Override
public String getBucketVersions() {
- return rpcRegistry.getVersions().toString();
+ return bucketVersions();
}
-
-}
\ No newline at end of file
+}
Code Review / controller.git / blobdiff