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%2Fshardmanager%2FShardManager.java;h=38fed0722fcec025d5101405936d0b1658426785;hb=4447f81c26b851e46acd3f111768bb498f0d553f;hp=4ae15407763d494156431da07a9f159ff87f57c1;hpb=be338c9e1dab83e2a5ff21819b92b934ef32faee;p=controller.git diff --git a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardManager.java b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardManager.java index 4ae1540776..38fed0722f 100644 --- a/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardManager.java +++ b/opendaylight/md-sal/sal-distributed-datastore/src/main/java/org/opendaylight/controller/cluster/datastore/shardmanager/ShardManager.java @@ -298,7 +298,7 @@ class ShardManager extends AbstractUntypedPersistentActorWithMetering { } private void onInitConfigListener() { - LOG.debug("{}: Initializing config listener.", persistenceId()); + LOG.debug("{}: Initializing config listener on {}", persistenceId(), cluster.getCurrentMemberName()); final org.opendaylight.mdsal.common.api.LogicalDatastoreType type = org.opendaylight.mdsal.common.api.LogicalDatastoreType @@ -559,7 +559,7 @@ class ShardManager extends AbstractUntypedPersistentActorWithMetering { .storeRoot(config.getPrefix().getRootIdentifier()); DatastoreContext shardDatastoreContext = builder.build(); - final Map peerAddresses = Collections.emptyMap(); + final Map peerAddresses = getPeerAddresses(shardName); final boolean isActiveMember = true; LOG.debug("{} doCreatePrefixShard: shardId: {}, memberNames: {}, peerAddresses: {}, isActiveMember: {}",