Package java.util.concurrent

Examples of java.util.concurrent.Semaphore.drainPermits()

96
97
98
99
100
101
102
103
104
105
106
            provider.start();

            Assert.assertEquals(provider.getConnectionString(), "localhost:2");

            connectionString.set(null);
            semaphore.drainPermits();
            semaphore.acquire();    // wait for next poll
            Assert.assertEquals(provider.getConnectionString(), "backup1:1");

            backupConnectionString.set("backup2:2");
            semaphore.drainPermits();
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
            semaphore.drainPermits();
            semaphore.acquire();    // wait for next poll
            Assert.assertEquals(provider.getConnectionString(), "backup1:1");

            backupConnectionString.set("backup2:2");
            semaphore.drainPermits();
            semaphore.acquire();    // wait for next poll
            Assert.assertEquals(provider.getConnectionString(), "backup2:2");

            connectionString.set("count=1&port=3&server0=localhost3");
            semaphore.drainPermits();
View Full Code Here
106
107
108
109
110
111
112
113
114
115
116
            semaphore.drainPermits();
            semaphore.acquire();    // wait for next poll
            Assert.assertEquals(provider.getConnectionString(), "backup2:2");

            connectionString.set("count=1&port=3&server0=localhost3");
            semaphore.drainPermits();
            semaphore.acquire();    // wait for next poll
            Assert.assertEquals(provider.getConnectionString(), "localhost3:3");
        }
        finally
        {
View Full Code Here
160
161
162
163
164
165
166
167
168
169
170
                        }
                    }
                );

                connectionString.set(secondConnectionString);
                semaphore.drainPermits();
                semaphore.acquire();

                server.stop();  // create situation where the current zookeeper gets a sys-disconnected

                Stat        stat = RetryLoop.callWithRetry
View Full Code Here
375
376
377
378
379
380
381
382
383
384
385
            // test foreground retry
            client.checkExists().forPath("/hey");
            Assert.assertTrue(semaphore.tryAcquire(MAX_RETRIES, 10, TimeUnit.SECONDS));

            semaphore.drainPermits();
            retries.set(0);

            server.stop();

            // test background retry
View Full Code Here
201
202
203
204
205
206
207
208
209
210
211
      // Create a semaphore to track task completion, and acquire all its
      // permits initially. Each URLProcessor object releases one permit
      // when
      // it finishes.
      final Semaphore sem = new Semaphore(fileUrls.size());
      sem.drainPermits();
      for (IProgress progress : progresses) {
        progress.setRange(0, fileUrls.size());
      }
      for (URL url : fileUrls) {
        service.execute(new URLResourceProcessor(url, sem, map,
View Full Code Here
385
386
387
388
389
390
391
392
393
394
395
            // make sure we're reconnected
            client.getZookeeperClient().setRetryPolicy(new RetryOneTime(100));
            client.checkExists().forPath("/hey");

            client.getZookeeperClient().setRetryPolicy(policy);
            semaphore.drainPermits();
            retries.set(0);

            server.stop();

            // test background retry
View Full Code Here
96
97
98
99
100
101
102
103
104
105
106
            provider.start();

            Assert.assertEquals(provider.getConnectionString(), "localhost:2");

            connectionString.set(null);
            semaphore.drainPermits();
            semaphore.acquire();    // wait for next poll
            Assert.assertEquals(provider.getConnectionString(), "backup1:1");

            backupConnectionString.set("backup2:2");
            semaphore.drainPermits();
View Full Code Here
101
102
103
104
105
106
107
108
109
110
111
            semaphore.drainPermits();
            semaphore.acquire();    // wait for next poll
            Assert.assertEquals(provider.getConnectionString(), "backup1:1");

            backupConnectionString.set("backup2:2");
            semaphore.drainPermits();
            semaphore.acquire();    // wait for next poll
            Assert.assertEquals(provider.getConnectionString(), "backup2:2");

            connectionString.set("count=1&port=3&server0=localhost3");
            semaphore.drainPermits();
View Full Code Here
106
107
108
109
110
111
112
113
114
115
116
            semaphore.drainPermits();
            semaphore.acquire();    // wait for next poll
            Assert.assertEquals(provider.getConnectionString(), "backup2:2");

            connectionString.set("count=1&port=3&server0=localhost3");
            semaphore.drainPermits();
            semaphore.acquire();    // wait for next poll
            Assert.assertEquals(provider.getConnectionString(), "localhost3:3");
        }
        finally
        {
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.