/forgerock/openam-v13/openam-shared/src/main/java/org/forgerock/openam/shared/concurrency/ |
H A D | ResizableLinkedBlockingQueue.java | 114 public boolean offer(E e) { method in class:ResizableLinkedBlockingQueue 115 Reject.ifNull(e, "Element to offer cannot be null."); 120 if (super.offer(e)) { 124 //If the queue.offer(e) fails, the availablePlaces.tryAcquire() will still have occurred, so we'll have 136 public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException { method in class:ResizableLinkedBlockingQueue 137 Reject.ifNull(e, "Element to offer cannot be null."); 142 if (super.offer(e)) { 146 //If the queue.offer(e) fails, the availablePlaces.tryAcquire(timeout, unit) will still have occurred,
|
/forgerock/openam/openam-shared/src/main/java/org/forgerock/openam/shared/concurrency/ |
H A D | ResizableLinkedBlockingQueue.java | 114 public boolean offer(E e) { method in class:ResizableLinkedBlockingQueue 115 Reject.ifNull(e, "Element to offer cannot be null."); 120 if (super.offer(e)) { 124 //If the queue.offer(e) fails, the availablePlaces.tryAcquire() will still have occurred, so we'll have 136 public boolean offer(E e, long timeout, TimeUnit unit) throws InterruptedException { method in class:ResizableLinkedBlockingQueue 137 Reject.ifNull(e, "Element to offer cannot be null."); 142 if (super.offer(e)) { 146 //If the queue.offer(e) fails, the availablePlaces.tryAcquire(timeout, unit) will still have occurred,
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | TestSynchronousReplayQueue.java | 72 public boolean offer(UpdateToReplay e) method in class:TestSynchronousReplayQueue 78 public boolean offer(UpdateToReplay e, long timeout, TimeUnit unit) method in class:TestSynchronousReplayQueue
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | TestSynchronousReplayQueue.java | 71 public boolean offer(UpdateToReplay e) method in class:TestSynchronousReplayQueue 77 public boolean offer(UpdateToReplay e, long timeout, TimeUnit unit) method in class:TestSynchronousReplayQueue
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | TestSynchronousReplayQueue.java | 72 public boolean offer(UpdateToReplay e) method in class:TestSynchronousReplayQueue 78 public boolean offer(UpdateToReplay e, long timeout, TimeUnit unit) method in class:TestSynchronousReplayQueue
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | TestSynchronousReplayQueue.java | 71 public boolean offer(UpdateToReplay e) method in class:TestSynchronousReplayQueue 77 public boolean offer(UpdateToReplay e, long timeout, TimeUnit unit) method in class:TestSynchronousReplayQueue
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | TestSynchronousReplayQueue.java | 72 public boolean offer(UpdateToReplay e) method in class:TestSynchronousReplayQueue 78 public boolean offer(UpdateToReplay e, long timeout, TimeUnit unit) method in class:TestSynchronousReplayQueue
|
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SeriesTaskExecutor.java | 109 offer(queue, task); 175 private void offer(BlockingQueue<Task> queue, Task task) throws QueueTimeoutException { method in class:SeriesTaskExecutor 178 if (!queue.offer(wrap(task), configuration.getQueueTimeout(), TimeUnit.SECONDS)) {
|
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/ |
H A D | TestSynchronousReplayQueue.java | 70 public boolean offer(UpdateToReplay e) method in class:TestSynchronousReplayQueue 76 public boolean offer(UpdateToReplay e, long timeout, TimeUnit unit) method in class:TestSynchronousReplayQueue
|
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SeriesTaskExecutor.java | 109 offer(queue, task); 175 private void offer(BlockingQueue<Task> queue, Task task) throws QueueTimeoutException { method in class:SeriesTaskExecutor 178 if (!queue.offer(wrap(task), configuration.getQueueTimeout(), TimeUnit.SECONDS)) {
|