/forgerock/opendj-b2.6/src/server/org/opends/server/loggers/ |
H A D | ParallelTextWriter.java | 59 private final Semaphore queueSemaphore = new Semaphore(0, false); field in class:ParallelTextWriter 112 if (queueSemaphore.tryAcquire(10, TimeUnit.SECONDS)) 114 for (int i = (queueSemaphore.drainPermits() + 1); i > 0; i--) 154 queueSemaphore.release();
|
/forgerock/opendj2/src/server/org/opends/server/loggers/ |
H A D | ParallelTextWriter.java | 58 private final Semaphore queueSemaphore = new Semaphore(0, false); field in class:ParallelTextWriter 111 if (queueSemaphore.tryAcquire(10, TimeUnit.SECONDS)) 113 for (int i = (queueSemaphore.drainPermits() + 1); i > 0; i--) 153 queueSemaphore.release();
|
/forgerock/opendj2.6.2/src/server/org/opends/server/loggers/ |
H A D | ParallelTextWriter.java | 59 private final Semaphore queueSemaphore = new Semaphore(0, false); field in class:ParallelTextWriter 112 if (queueSemaphore.tryAcquire(10, TimeUnit.SECONDS)) 114 for (int i = (queueSemaphore.drainPermits() + 1); i > 0; i--) 154 queueSemaphore.release();
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/loggers/ |
H A D | ParallelTextWriter.java | 59 private final Semaphore queueSemaphore = new Semaphore(0, false); field in class:ParallelTextWriter 112 if (queueSemaphore.tryAcquire(10, TimeUnit.SECONDS)) 114 for (int i = (queueSemaphore.drainPermits() + 1); i > 0; i--) 154 queueSemaphore.release();
|
/forgerock/opendj2-hg/src/server/org/opends/server/loggers/ |
H A D | ParallelTextWriter.java | 58 private final Semaphore queueSemaphore = new Semaphore(0, false); field in class:ParallelTextWriter 111 if (queueSemaphore.tryAcquire(10, TimeUnit.SECONDS)) 113 for (int i = (queueSemaphore.drainPermits() + 1); i > 0; i--) 153 queueSemaphore.release();
|
/forgerock/opendj-b2.6/src/server/org/opends/server/extensions/ |
H A D | ParallelWorkQueue.java | 120 private final Semaphore queueSemaphore = new Semaphore(0, false); field in class:ParallelWorkQueue 285 queueSemaphore.release(); 391 if (queueSemaphore.tryAcquire(5, TimeUnit.SECONDS)) {
|
/forgerock/opendj2/src/server/org/opends/server/extensions/ |
H A D | ParallelWorkQueue.java | 119 private final Semaphore queueSemaphore = new Semaphore(0, false); field in class:ParallelWorkQueue 284 queueSemaphore.release(); 390 if (queueSemaphore.tryAcquire(5, TimeUnit.SECONDS)) {
|
/forgerock/opendj2.6.2/src/server/org/opends/server/extensions/ |
H A D | ParallelWorkQueue.java | 120 private final Semaphore queueSemaphore = new Semaphore(0, false); field in class:ParallelWorkQueue 285 queueSemaphore.release(); 391 if (queueSemaphore.tryAcquire(5, TimeUnit.SECONDS)) {
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/extensions/ |
H A D | ParallelWorkQueue.java | 120 private final Semaphore queueSemaphore = new Semaphore(0, false); field in class:ParallelWorkQueue 285 queueSemaphore.release(); 391 if (queueSemaphore.tryAcquire(5, TimeUnit.SECONDS)) {
|
/forgerock/opendj2-hg/src/server/org/opends/server/extensions/ |
H A D | ParallelWorkQueue.java | 119 private final Semaphore queueSemaphore = new Semaphore(0, false); field in class:ParallelWorkQueue 284 queueSemaphore.release(); 390 if (queueSemaphore.tryAcquire(5, TimeUnit.SECONDS)) {
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/extensions/ |
H A D | ParallelWorkQueue.java | 109 private final Semaphore queueSemaphore = new Semaphore(0, false); field in class:ParallelWorkQueue 253 queueSemaphore.release(); 355 if (queueSemaphore.tryAcquire(5, TimeUnit.SECONDS)) {
|