X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2FConfigurationImpl.java;h=4d83dea96f89af07d76c72fd21bb7ecd8d481f75;hb=1280c1ce40241738edd5ebae40bf5dfddec68198;hp=0541e3a48bb1aab6cef1843e429ff700949d7688;hpb=3c298061e7c22390eaf790aae977decfe0f94ad1;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ConfigurationImpl.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ConfigurationImpl.java index 0541e3a48b..4d83dea96f 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ConfigurationImpl.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/ConfigurationImpl.java @@ -21,8 +21,10 @@ import com.typesafe.config.ConfigFactory; import com.typesafe.config.ConfigObject; import java.io.File; import java.util.ArrayList; +import java.util.Collection; import java.util.Collections; import java.util.HashMap; +import java.util.HashSet; import java.util.List; import java.util.Map; import java.util.Set; @@ -198,6 +200,16 @@ public class ConfigurationImpl implements Configuration { return allShardNames; } + @Override + public Collection getUniqueMemberNamesForAllShards() { + Set allNames = new HashSet<>(); + for(String shardName: allShardNames) { + allNames.addAll(getMembersFromShardName(shardName)); + } + + return allNames; + } + private List readModules(final Config modulesConfig) { List modulesConfigObjectList = modulesConfig.getObjectList("modules");