Searched refs:queueSemaphore (Results 1 - 11 of 11) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/loggers/
H A DParallelTextWriter.java59 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 DParallelTextWriter.java58 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 DParallelTextWriter.java59 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 DParallelTextWriter.java59 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 DParallelTextWriter.java58 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 DParallelWorkQueue.java120 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 DParallelWorkQueue.java119 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 DParallelWorkQueue.java120 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 DParallelWorkQueue.java120 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 DParallelWorkQueue.java119 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 DParallelWorkQueue.java109 private final Semaphore queueSemaphore = new Semaphore(0, false); field in class:ParallelWorkQueue
253 queueSemaphore.release();
355 if (queueSemaphore.tryAcquire(5, TimeUnit.SECONDS)) {

Completed in 37 milliseconds