Examples of sleepABit()

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

113
114
115
116
117
118
119
120
121
122
123
            latch.debugResetWaitLatch = new CountDownLatch(1);
            latch.start();  // will call reset()
            latch.reset();  // should not result in two nodes

            timing.sleepABit();

            latch.debugResetWaitLatch.countDown();

            timing.sleepABit();
View Full Code Here

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

117
118
119
120
121
122
123
124
125
126
127
            timing.sleepABit();

            latch.debugResetWaitLatch.countDown();

            timing.sleepABit();

            Assert.assertEquals(client.getChildren().forPath(PATH_NAME).size(), 1);
        }
        finally
        {
View Full Code Here

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

145
146
147
148
149
150
151
152
153
154
155
            latch.debugResetWaitLatch = new CountDownLatch(1);

            latch.start();
            latch.close();

            timing.sleepABit();

            latch.debugResetWaitLatch.countDown();

            timing.sleepABit();
View Full Code Here

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

149
150
151
152
153
154
155
156
157
158
159
            timing.sleepABit();

            latch.debugResetWaitLatch.countDown();

            timing.sleepABit();

            Assert.assertEquals(client.getChildren().forPath(PATH_NAME).size(), 0);

        }
        finally
View Full Code Here

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

552
553
554
555
556
557
558
559
560
561
562
        {
            client.start();

            leader.start();

            timing.sleepABit();

            notifiedLeader.start();

            timing.sleepABit();
View Full Code Here

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

556
557
558
559
560
561
562
563
564
565
566
            timing.sleepABit();

            notifiedLeader.start();

            timing.sleepABit();

            notifiedLeader.close();

            timing.sleepABit();
View Full Code Here

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

560
561
562
563
564
565
566
567
568
569
570
            timing.sleepABit();

            notifiedLeader.close();

            timing.sleepABit();

            // Test the close override
            leader.close(LeaderLatch.CloseMode.NOTIFY_LEADER);

            Assert.assertEquals(leader.getState(), LeaderLatch.State.CLOSED);
View Full Code Here

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

620
621
622
623
624
625
626
627
628
629
630
        try
        {
            leader.start();

            timing.sleepABit();

            // Start the new server
            server = new TestingServer(server.getPort(), server.getTempDirectory());

            Assert.assertTrue(timing.awaitLatch(leaderCounter), "Not elected leader");
View Full Code Here

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

237
238
239
240
241
242
243
244
245
246
247
            queue.getPutListenerContainer().addListener(listener);

            Assert.assertTrue(queue.put("1", timing.milliseconds(), TimeUnit.MILLISECONDS));   // should end up in consumer
            Assert.assertTrue(queue.put("2", timing.milliseconds(), TimeUnit.MILLISECONDS));   // should sit blocking in DistributedQueue
            Assert.assertTrue(timing.awaitLatch(latch));
            timing.sleepABit();
            Assert.assertFalse(queue.put("3", timing.multiple(.5).milliseconds(), TimeUnit.MILLISECONDS));

            semaphore.release(100);
            Assert.assertTrue(queue.put("3", timing.milliseconds(), TimeUnit.MILLISECONDS));
            Assert.assertTrue(queue.put("4", timing.milliseconds(), TimeUnit.MILLISECONDS));
View Full Code Here

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

251
252
253
254
255
256
257
258
259
260
261
            {
                if ( messages.size() == 3 )
                {
                    break;
                }
                timing.sleepABit();
            }
            timing.sleepABit();

            Assert.assertEquals(messages, Arrays.asList("1", "2", "3", "4", "5"));
        }
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.