| /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)) {
|