Examples of drainPermits()

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

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

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

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

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

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

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

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

48
49
50
51
52
53
54
55
56
57
58
                lockBefore.release();
            } catch (InterruptedException ex) {
                ex.printStackTrace();
                throw new VoltAbortException(ex.getMessage());
            } finally {
                if (notifyBefore != null) notifyBefore.drainPermits();
            }
        }
       
        // Let 'er rip!
        voltQueueSQL(updateSubscriber, marker, s_id);
View Full Code Here

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

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

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

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

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

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

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

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

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
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.