X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?p=controller.git;a=blobdiff_plain;f=opendaylight%2Fmd-sal%2Fsal-cluster-admin%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fadmin%2FClusterAdminRpcServiceTest.java;fp=opendaylight%2Fmd-sal%2Fsal-cluster-admin%2Fsrc%2Ftest%2Fjava%2Forg%2Fopendaylight%2Fcontroller%2Fcluster%2Fdatastore%2Fadmin%2FClusterAdminRpcServiceTest.java;h=38368dbd52a561646fc6e3f884cd1f49efedde67;hp=af2b4a9df613d204bbfeb824ab8b53a443a5d0bf;hb=0c165317c86dff04fdca1bba3412a1f4ec292e0a;hpb=be4b483bccdc167c01c78860cb2ecc632156b656 diff --git a/opendaylight/md-sal/sal-cluster-admin/src/test/java/org/opendaylight/controller/cluster/datastore/admin/ClusterAdminRpcServiceTest.java b/opendaylight/md-sal/sal-cluster-admin/src/test/java/org/opendaylight/controller/cluster/datastore/admin/ClusterAdminRpcServiceTest.java index af2b4a9df6..38368dbd52 100644 --- a/opendaylight/md-sal/sal-cluster-admin/src/test/java/org/opendaylight/controller/cluster/datastore/admin/ClusterAdminRpcServiceTest.java +++ b/opendaylight/md-sal/sal-cluster-admin/src/test/java/org/opendaylight/controller/cluster/datastore/admin/ClusterAdminRpcServiceTest.java @@ -543,6 +543,7 @@ public class ClusterAdminRpcServiceTest { moduleShardsConfig(moduleShardsConfig).build(); leaderNode1.configDataStore().waitTillReady(); + replicaNode3.configDataStore().waitTillReady(); verifyRaftPeersPresent(leaderNode1.configDataStore(), "cars", "member-2", "member-3"); verifyRaftPeersPresent(replicaNode2.configDataStore(), "cars", "member-1", "member-3"); verifyRaftPeersPresent(replicaNode3.configDataStore(), "cars", "member-1", "member-2"); @@ -609,6 +610,8 @@ public class ClusterAdminRpcServiceTest { leaderNode1.configDataStore().waitTillReady(); leaderNode1.operDataStore().waitTillReady(); + replicaNode3.configDataStore().waitTillReady(); + replicaNode3.operDataStore().waitTillReady(); verifyRaftPeersPresent(leaderNode1.configDataStore(), "cars", "member-2", "member-3"); verifyRaftPeersPresent(replicaNode2.configDataStore(), "cars", "member-1", "member-3"); verifyRaftPeersPresent(replicaNode3.configDataStore(), "cars", "member-1", "member-2"); @@ -661,6 +664,8 @@ public class ClusterAdminRpcServiceTest { leaderNode1.configDataStore().waitTillReady(); leaderNode1.operDataStore().waitTillReady(); + replicaNode3.configDataStore().waitTillReady(); + replicaNode3.operDataStore().waitTillReady(); verifyVotingStates(leaderNode1.configDataStore(), "cars", new SimpleEntry<>("member-1", true), new SimpleEntry<>("member-2", true), new SimpleEntry<>("member-3", false));