X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=opendaylight%2Fmd-sal%2Fsal-distributed-datastore%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fshardmanager%2FShardPeerAddressResolver.java;h=a05548b1a4209f10bc3b4387009c24c52d34a4dc;hb=95c296a7c1e8e186a88a0a0dc82e080b2185db33;hp=62b8e93fb545de80ef4faa9ed765238c0f1bfe8f;hpb=dc6370feeb5fc47be3e267bf85d6354013d0409b;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardPeerAddressResolver.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardPeerAddressResolver.java index 62b8e93fb5..a05548b1a4 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardPeerAddressResolver.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardPeerAddressResolver.java @@ -33,7 +33,7 @@ class ShardPeerAddressResolver implements PeerAddressResolver { private final String shardManagerType; private final MemberName localMemberName; - public ShardPeerAddressResolver(String shardManagerType, MemberName localMemberName) { + ShardPeerAddressResolver(String shardManagerType, MemberName localMemberName) { this.shardManagerIdentifier = ShardManagerIdentifier.builder().type(shardManagerType).build().toString(); this.shardManagerType = shardManagerType; this.localMemberName = Preconditions.checkNotNull(localMemberName); @@ -53,8 +53,8 @@ class ShardPeerAddressResolver implements PeerAddressResolver { Collection getShardManagerPeerActorAddresses() { Collection peerAddresses = new ArrayList<>(); - for(Map.Entry entry: memberNameToAddress.entrySet()) { - if(!localMemberName.equals(entry.getKey())) { + for (Map.Entry entry: memberNameToAddress.entrySet()) { + if (!localMemberName.equals(entry.getKey())) { peerAddresses.add(getShardManagerActorPathBuilder(entry.getValue()).toString()); } } @@ -68,7 +68,7 @@ class ShardPeerAddressResolver implements PeerAddressResolver { String getShardActorAddress(String shardName, MemberName memberName) { Address memberAddress = memberNameToAddress.get(memberName); - if(memberAddress != null) { + if (memberAddress != null) { return getShardManagerActorPathBuilder(memberAddress).append("/").append( getShardIdentifier(memberName, shardName)).toString(); }