Package org.apache.zookeeper.server.quorum

Examples of org.apache.zookeeper.server.quorum.QuorumPeer.start()

121
122
123
124
125
126
127
128
129
130
131
        if (leaderSid != 3)qb.s3.start(); else leader = qb.s3;
        if (leaderSid != 4)qb.s4.start(); else leader = qb.s4;
        if (leaderSid != 5)qb.s5.start(); else leader = qb.s5;

        try {
            leader.start();
            Assert.assertTrue(false);
        } catch(RuntimeException re) {
            LOG.info("Got an error: expected", re);
        }
        //wait for servers to be up
View Full Code Here
206
207
208
209
210
211
212
213
214
215
216
        peers.put(Long.valueOf(3), new QuorumServer(3, new InetSocketAddress("127.0.0.1", port3 + 1000),
            new InetSocketAddress("127.0.0.1", port3 + 2000),
            new InetSocketAddress("127.0.0.1", port3 + 3000)));

        QuorumPeer s2 = new QuorumPeer(peers, dataDir2, dataDir2, port2, 0, 2, tickTime, initLimit, syncLimit);
        s2.start();
        QuorumPeer s3 = new QuorumPeer(peers, dataDir3, dataDir3, port3, 0, 3, tickTime, initLimit, syncLimit);
        s3.start();
        connected = false;
        zk = new ZooKeeper("127.0.0.1:" + port2, 15000, nullWatcher);
        while(!connected) {
View Full Code Here
208
209
210
211
212
213
214
215
216
217
218
            new InetSocketAddress("127.0.0.1", port3 + 3000)));

        QuorumPeer s2 = new QuorumPeer(peers, dataDir2, dataDir2, port2, 0, 2, tickTime, initLimit, syncLimit);
        s2.start();
        QuorumPeer s3 = new QuorumPeer(peers, dataDir3, dataDir3, port3, 0, 3, tickTime, initLimit, syncLimit);
        s3.start();
        connected = false;
        zk = new ZooKeeper("127.0.0.1:" + port2, 15000, nullWatcher);
        while(!connected) {
            Thread.sleep(1000);
        }
View Full Code Here
228
229
230
231
232
233
234
235
236
237
238
            Assert.fail("Should have gotten an error");
        } catch(KeeperException.NoNodeException e) {
            // this is what we want
        }
        QuorumPeer s1 = new QuorumPeer(peers, dataDir1, dataDir1, port1, 0, 1, tickTime, initLimit, syncLimit);
        s1.start();

        connected = false;
        ZooKeeper zk1 = new ZooKeeper("127.0.0.1:" + port1, 15000, nullWatcher);
        while(!connected) {
            Thread.sleep(1000);
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.