|
@@ -33,7 +33,7 @@ import org.apache.zookeeper.KeeperException;
|
|
import org.apache.zookeeper.ZKTestCase;
|
|
import org.apache.zookeeper.ZKTestCase;
|
|
import org.apache.zookeeper.AsyncCallback.DataCallback;
|
|
import org.apache.zookeeper.AsyncCallback.DataCallback;
|
|
import org.apache.zookeeper.data.Stat;
|
|
import org.apache.zookeeper.data.Stat;
|
|
-import org.apache.zookeeper.jmx.CommonNames;
|
|
|
|
|
|
+import org.apache.zookeeper.jmx.MBeanRegistry;
|
|
import org.apache.zookeeper.server.quorum.QuorumPeer;
|
|
import org.apache.zookeeper.server.quorum.QuorumPeer;
|
|
import org.apache.zookeeper.server.quorum.QuorumPeer.QuorumServer;
|
|
import org.apache.zookeeper.server.quorum.QuorumPeer.QuorumServer;
|
|
import org.apache.zookeeper.server.quorum.QuorumPeer.ServerState;
|
|
import org.apache.zookeeper.server.quorum.QuorumPeer.ServerState;
|
|
@@ -920,7 +920,7 @@ public class ReconfigTest extends ZKTestCase implements DataCallback{
|
|
int replica2 = 2;
|
|
int replica2 = 2;
|
|
QuorumPeer peer2 = qu.getPeer(replica2).peer;
|
|
QuorumPeer peer2 = qu.getPeer(replica2).peer;
|
|
QuorumServer leavingQS2 = peer2.getView().get(new Long(leavingIndex));
|
|
QuorumServer leavingQS2 = peer2.getView().get(new Long(leavingIndex));
|
|
- String remotePeerBean2 = CommonNames.DOMAIN
|
|
|
|
|
|
+ String remotePeerBean2 = MBeanRegistry.DOMAIN
|
|
+ ":name0=ReplicatedServer_id" + replica2 + ",name1=replica."
|
|
+ ":name0=ReplicatedServer_id" + replica2 + ",name1=replica."
|
|
+ leavingIndex;
|
|
+ leavingIndex;
|
|
assertRemotePeerMXBeanAttributes(leavingQS2, remotePeerBean2);
|
|
assertRemotePeerMXBeanAttributes(leavingQS2, remotePeerBean2);
|
|
@@ -929,7 +929,7 @@ public class ReconfigTest extends ZKTestCase implements DataCallback{
|
|
int replica3 = 3;
|
|
int replica3 = 3;
|
|
QuorumPeer peer3 = qu.getPeer(replica3).peer;
|
|
QuorumPeer peer3 = qu.getPeer(replica3).peer;
|
|
QuorumServer leavingQS3 = peer3.getView().get(new Long(leavingIndex));
|
|
QuorumServer leavingQS3 = peer3.getView().get(new Long(leavingIndex));
|
|
- String remotePeerBean3 = CommonNames.DOMAIN
|
|
|
|
|
|
+ String remotePeerBean3 = MBeanRegistry.DOMAIN
|
|
+ ":name0=ReplicatedServer_id" + replica3 + ",name1=replica."
|
|
+ ":name0=ReplicatedServer_id" + replica3 + ",name1=replica."
|
|
+ leavingIndex;
|
|
+ leavingIndex;
|
|
assertRemotePeerMXBeanAttributes(leavingQS3, remotePeerBean3);
|
|
assertRemotePeerMXBeanAttributes(leavingQS3, remotePeerBean3);
|
|
@@ -952,7 +952,7 @@ public class ReconfigTest extends ZKTestCase implements DataCallback{
|
|
|
|
|
|
// localPeerBean.1 of ReplicatedServer_1
|
|
// localPeerBean.1 of ReplicatedServer_1
|
|
QuorumPeer removedPeer = qu.getPeer(leavingIndex).peer;
|
|
QuorumPeer removedPeer = qu.getPeer(leavingIndex).peer;
|
|
- String localPeerBean = CommonNames.DOMAIN
|
|
|
|
|
|
+ String localPeerBean = MBeanRegistry.DOMAIN
|
|
+ ":name0=ReplicatedServer_id" + leavingIndex
|
|
+ ":name0=ReplicatedServer_id" + leavingIndex
|
|
+ ",name1=replica." + leavingIndex;
|
|
+ ",name1=replica." + leavingIndex;
|
|
assertLocalPeerMXBeanAttributes(removedPeer, localPeerBean, false);
|
|
assertLocalPeerMXBeanAttributes(removedPeer, localPeerBean, false);
|
|
@@ -998,7 +998,7 @@ public class ReconfigTest extends ZKTestCase implements DataCallback{
|
|
int replica2 = 2;
|
|
int replica2 = 2;
|
|
QuorumPeer peer2 = qu.getPeer(replica2).peer;
|
|
QuorumPeer peer2 = qu.getPeer(replica2).peer;
|
|
QuorumServer changingQS2 = peer2.getView().get(new Long(changingIndex));
|
|
QuorumServer changingQS2 = peer2.getView().get(new Long(changingIndex));
|
|
- String remotePeerBean2 = CommonNames.DOMAIN
|
|
|
|
|
|
+ String remotePeerBean2 = MBeanRegistry.DOMAIN
|
|
+ ":name0=ReplicatedServer_id" + replica2 + ",name1=replica."
|
|
+ ":name0=ReplicatedServer_id" + replica2 + ",name1=replica."
|
|
+ changingIndex;
|
|
+ changingIndex;
|
|
assertRemotePeerMXBeanAttributes(changingQS2, remotePeerBean2);
|
|
assertRemotePeerMXBeanAttributes(changingQS2, remotePeerBean2);
|
|
@@ -1007,7 +1007,7 @@ public class ReconfigTest extends ZKTestCase implements DataCallback{
|
|
int replica3 = 3;
|
|
int replica3 = 3;
|
|
QuorumPeer peer3 = qu.getPeer(replica3).peer;
|
|
QuorumPeer peer3 = qu.getPeer(replica3).peer;
|
|
QuorumServer changingQS3 = peer3.getView().get(new Long(changingIndex));
|
|
QuorumServer changingQS3 = peer3.getView().get(new Long(changingIndex));
|
|
- String remotePeerBean3 = CommonNames.DOMAIN
|
|
|
|
|
|
+ String remotePeerBean3 = MBeanRegistry.DOMAIN
|
|
+ ":name0=ReplicatedServer_id" + replica3 + ",name1=replica."
|
|
+ ":name0=ReplicatedServer_id" + replica3 + ",name1=replica."
|
|
+ changingIndex;
|
|
+ changingIndex;
|
|
assertRemotePeerMXBeanAttributes(changingQS3, remotePeerBean3);
|
|
assertRemotePeerMXBeanAttributes(changingQS3, remotePeerBean3);
|
|
@@ -1034,7 +1034,7 @@ public class ReconfigTest extends ZKTestCase implements DataCallback{
|
|
Assert.assertTrue(qu.getPeer(changingIndex).peer.getPeerState() == ServerState.OBSERVING);
|
|
Assert.assertTrue(qu.getPeer(changingIndex).peer.getPeerState() == ServerState.OBSERVING);
|
|
|
|
|
|
QuorumPeer qp = qu.getPeer(changingIndex).peer;
|
|
QuorumPeer qp = qu.getPeer(changingIndex).peer;
|
|
- String localPeerBeanName = CommonNames.DOMAIN
|
|
|
|
|
|
+ String localPeerBeanName = MBeanRegistry.DOMAIN
|
|
+ ":name0=ReplicatedServer_id" + changingIndex
|
|
+ ":name0=ReplicatedServer_id" + changingIndex
|
|
+ ",name1=replica." + changingIndex;
|
|
+ ",name1=replica." + changingIndex;
|
|
|
|
|