Examples of org.apache.curator.test.Timing.acquireSemaphore()

org.apache.curator.test.Timing.acquireSemaphore()
Wait on the given semaphore @param semaphore the semaphore @return result of {@link Semaphore#tryAcquire()}

                }
            };
            selector = new LeaderSelector(client, "/leader", listener);
            selector.start();


            timing.acquireSemaphore(semaphore);


            server.close();


            timing.acquireSemaphore(semaphore);
        }

View Full Code Here


            timing.acquireSemaphore(semaphore);


            server.close();


            timing.acquireSemaphore(semaphore);
        }
        finally
        {
            CloseableUtils.closeQuietly(selector);
            CloseableUtils.closeQuietly(client);

View Full Code Here

            boolean leaderSelector2Closed = false;


            leaderSelector1.start();
            leaderSelector2.start();


            Assert.assertTrue(timing.acquireSemaphore(semaphore, 1));


            KillSession.kill(client.getZookeeperClient().getZooKeeper(), server.getConnectString());


            Assert.assertTrue(timing.awaitLatch(interruptedLatch));
            timing.sleepABit();

View Full Code Here

            boolean requeued1 = leaderSelector1.requeue();
            boolean requeued2 = leaderSelector2.requeue();
            Assert.assertTrue(requeued1);
            Assert.assertTrue(requeued2);


            Assert.assertTrue(timing.acquireSemaphore(semaphore, 1));
            Assert.assertEquals(leaderCount.get(), 1);


            if ( leaderSelector1.hasLeadership() )
            {
                leaderSelector1.close();

View Full Code Here

            {
                fail("No leaderselector has leadership!");
            }


            // Verify that the other leader took over leadership.
            Assert.assertTrue(timing.acquireSemaphore(semaphore, 1));
            Assert.assertEquals(leaderCount.get(), 1);


            if ( !leaderSelector1Closed )
            {
                leaderSelector1.close();

View Full Code Here

            };
            closeables.add(discovery);
            discovery.start();
            discovery.registerService(instance2);


            timing.acquireSemaphore(semaphore, 2);
            Assert.assertEquals(discovery.queryForInstances("test").size(), 2);


            KillSession.kill(client.getZookeeperClient().getZooKeeper(), server.getConnectString());
            server.stop();

View Full Code Here

            server.stop();


            server = new TestingServer(server.getPort(), server.getTempDirectory());
            closeables.add(server);


            timing.acquireSemaphore(semaphore, 2);
            Assert.assertEquals(discovery.queryForInstances("test").size(), 2);
        }
        finally
        {
            for ( Closeable c : closeables )

View Full Code Here

                }
            };
            closeables.add(discovery);
            discovery.start();


            timing.acquireSemaphore(semaphore);
            Assert.assertEquals(discovery.queryForInstances("test").size(), 1);


            KillSession.kill(client.getZookeeperClient().getZooKeeper(), server.getConnectString());
            server.stop();

View Full Code Here

            server.stop();


            server = new TestingServer(server.getPort(), server.getTempDirectory());
            closeables.add(server);


            timing.acquireSemaphore(semaphore);
            Assert.assertEquals(discovery.queryForInstances("test").size(), 1);
        }
        finally
        {
            for ( Closeable c : closeables )

View Full Code Here

                }
            };
            client.getConnectionStateListenable().addListener(listener);
            server.stop();


            Assert.assertTrue(timing.acquireSemaphore(semaphore));
            try
            {
                client.delete().guaranteed().forPath("/test-me");
                Assert.fail();
            }

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.