/forgerock/openam-v13/openam-shared/src/test/java/org/forgerock/openam/shared/concurrency/ |
H A D | ResizableLinkedBlockingQueueTest.java | 27 ResizableLinkedBlockingQueue<Object> queue = new ResizableLinkedBlockingQueue<>(10); 29 queue.resizeQueue(6); 31 int queueSize = queue.getMaximumQueueSize(); 37 ResizableLinkedBlockingQueue<Object> queue = new ResizableLinkedBlockingQueue<>(10); 39 queue.resizeQueue(14); 41 int queueSize = queue.getMaximumQueueSize();
|
/forgerock/openam/openam-shared/src/test/java/org/forgerock/openam/shared/concurrency/ |
H A D | ResizableLinkedBlockingQueueTest.java | 27 ResizableLinkedBlockingQueue<Object> queue = new ResizableLinkedBlockingQueue<>(10); 29 queue.resizeQueue(6); 31 int queueSize = queue.getMaximumQueueSize(); 37 ResizableLinkedBlockingQueue<Object> queue = new ResizableLinkedBlockingQueue<>(10); 39 queue.resizeQueue(14); 41 int queueSize = queue.getMaximumQueueSize();
|
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/config/ |
H A D | package-info.java | 21 package org.forgerock.openam.cts.impl.queue.config;
|
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/ |
H A D | package-info.java | 18 * Classes responsible for managing the asynchronous task queue which is used by the CTS to 23 package org.forgerock.openam.cts.impl.queue;
|
H A D | QueueSelector.java | 16 package org.forgerock.openam.cts.impl.queue; 21 * QueueSelector is responsible for selecting an appropriate asynchronous queue for 25 * are processed by the same queue. By enforcing this invariant, we can be certain that
|
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/config/ |
H A D | package-info.java | 21 package org.forgerock.openam.cts.impl.queue.config;
|
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/impl/queue/ |
H A D | package-info.java | 18 * Classes responsible for managing the asynchronous task queue which is used by the CTS to 23 package org.forgerock.openam.cts.impl.queue;
|
H A D | QueueSelector.java | 16 package org.forgerock.openam.cts.impl.queue; 21 * QueueSelector is responsible for selecting an appropriate asynchronous queue for 25 * are processed by the same queue. By enforcing this invariant, we can be certain that
|
/forgerock/openam-v13/openam-shared/src/main/java/com/sun/identity/shared/ |
H A D | BufferedIterator.java | 44 private final BlockingQueue<T> queue = new LinkedBlockingQueue<T>(); field in class:BufferedIterator 48 queue.add(entry); 52 queue.addAll(entry); 62 return queue.take(); 71 return !(done && queue.isEmpty());
|
/forgerock/openam/openam-shared/src/main/java/com/sun/identity/shared/ |
H A D | BufferedIterator.java | 44 private final BlockingQueue<T> queue = new LinkedBlockingQueue<T>(); field in class:BufferedIterator 48 queue.add(entry); 52 queue.addAll(entry); 62 return queue.take(); 71 return !(done && queue.isEmpty());
|
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/cts/impl/queue/ |
H A D | TaskDispatcherTest.java | 16 package org.forgerock.openam.cts.impl.queue; 34 private TaskDispatcher queue; field in class:TaskDispatcherTest 49 queue = new TaskDispatcher( 56 queue.startDispatcher(); 62 queue.create(null, mockHandler); 67 queue.update(null, mockHandler); 72 queue.delete(null, mockHandler); 77 queue.read(null, null); 82 queue.query(null, null); 87 queue [all...] |
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/reaper/ |
H A D | TokenDeletion.java | 20 import org.forgerock.openam.cts.impl.queue.TaskDispatcher; 34 private final TaskDispatcher queue; field in class:TokenDeletion 37 public TokenDeletion(TaskDispatcher queue) { argument 38 this.queue = queue; 57 queue.delete(token, handler);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/loggers/ |
H A D | AsynchronousTextWriter.java | 57 private final LinkedBlockingQueue<String> queue; field in class:AsynchronousTextWriter 59 /** The capacity for the queue. */ 72 * @param capacity the size of the queue before it gets flushed. 74 * after the queue is flushed. 84 this.queue = new LinkedBlockingQueue<String>(capacity); 96 * The publisher thread is responsible for emptying the queue of log records 106 * the run method of the writerThread. Run until queue is empty 114 while (!stopRequested.get() || !queue.isEmpty()) { 117 queue.drainTo(drainList, capacity); 120 message = queue [all...] |
H A D | ParallelTextWriter.java | 46 * parallel unbound ie there is no queue size cap imposed. 57 private final ConcurrentLinkedQueue<String> queue; field in class:ParallelTextWriter 72 * after the queue is flushed. 81 this.queue = new ConcurrentLinkedQueue<String>(); 92 * The publisher thread is responsible for emptying the queue of log records 102 * the run method of the writerThread. Run until queue is empty 116 String message = queue.poll(); 152 // Put request on queue for writer 153 queue.add(record); 234 // The writer writerThread SHOULD have drained the queue [all...] |
/forgerock/opendj2/src/server/org/opends/server/loggers/ |
H A D | AsynchronousTextWriter.java | 52 private final LinkedBlockingQueue<String> queue; field in class:AsynchronousTextWriter 54 /** The capacity for the queue. */ 67 * @param capacity the size of the queue before it gets flushed. 69 * after the queue is flushed. 79 this.queue = new LinkedBlockingQueue<String>(capacity); 91 * The publisher thread is responsible for emptying the queue of log records 102 * the run method of the writerThread. Run until queue is empty 111 while (!stopRequested.get() || !queue.isEmpty()) { 114 queue.drainTo(drainList, capacity); 117 message = queue [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/loggers/ |
H A D | AsynchronousTextWriter.java | 57 private final LinkedBlockingQueue<String> queue; field in class:AsynchronousTextWriter 59 /** The capacity for the queue. */ 72 * @param capacity the size of the queue before it gets flushed. 74 * after the queue is flushed. 84 this.queue = new LinkedBlockingQueue<String>(capacity); 96 * The publisher thread is responsible for emptying the queue of log records 106 * the run method of the writerThread. Run until queue is empty 114 while (!stopRequested.get() || !queue.isEmpty()) { 117 queue.drainTo(drainList, capacity); 120 message = queue [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/loggers/ |
H A D | AsynchronousTextWriter.java | 57 private final LinkedBlockingQueue<String> queue; field in class:AsynchronousTextWriter 59 /** The capacity for the queue. */ 72 * @param capacity the size of the queue before it gets flushed. 74 * after the queue is flushed. 84 this.queue = new LinkedBlockingQueue<String>(capacity); 96 * The publisher thread is responsible for emptying the queue of log records 106 * the run method of the writerThread. Run until queue is empty 114 while (!stopRequested.get() || !queue.isEmpty()) { 117 queue.drainTo(drainList, capacity); 120 message = queue [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/loggers/ |
H A D | AsynchronousTextWriter.java | 52 private final LinkedBlockingQueue<String> queue; field in class:AsynchronousTextWriter 54 /** The capacity for the queue. */ 67 * @param capacity the size of the queue before it gets flushed. 69 * after the queue is flushed. 79 this.queue = new LinkedBlockingQueue<String>(capacity); 91 * The publisher thread is responsible for emptying the queue of log records 102 * the run method of the writerThread. Run until queue is empty 111 while (!stopRequested.get() || !queue.isEmpty()) { 114 queue.drainTo(drainList, capacity); 117 message = queue [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/loggers/ |
H A D | AsynchronousTextWriter.java | 52 private final LinkedBlockingQueue<String> queue; field in class:AsynchronousTextWriter 54 /** The capacity for the queue. */ 67 * @param capacity the size of the queue before it gets flushed. 69 * after the queue is flushed. 79 this.queue = new LinkedBlockingQueue<>(capacity); 91 * The publisher thread is responsible for emptying the queue of log records 102 * The run method of the writerThread. Run until queue is empty 111 while (!stopRequested.get() || !queue.isEmpty()) { 114 queue.drainTo(drainList, capacity); 117 message = queue [all...] |
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/worker/process/ |
H A D | CTSWorkerProcessGuiceModule.java | 29 import org.forgerock.openam.cts.impl.queue.TaskDispatcher; 47 SessionExpiryBatchHandler getMaxSessionExpiryBatchHandler(TaskDispatcher queue, argument 49 return new SessionExpiryBatchHandler(queue, MAX_TIMEOUT, stateChangeResultHandlerFactory); 55 SessionExpiryBatchHandler getIdleTimeoutExpiryBatchHandler(TaskDispatcher queue, argument 57 return new SessionExpiryBatchHandler(queue, IDLE_TIMEOUT, stateChangeResultHandlerFactory);
|
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SeriesTaskExecutorThreadFactory.java | 44 * @param queue Non null BlockingQueue to assign. 48 public SeriesTaskExecutorThread create(BlockingQueue<Task> queue) { argument 49 Reject.ifNull(queue); 51 processor.setQueue(queue);
|
H A D | SeriesTaskExecutorThread.java | 34 * makes no assumptions about the nature of the task, or the queue from which 48 private BlockingQueue<Task> queue; field in class:SeriesTaskExecutorThread 67 * @param queue Non null BlockingQueue implementation to use for asynchronous processing. 69 public void setQueue(BlockingQueue<Task> queue) { argument 70 this.queue = queue; 76 * @throws java.lang.IllegalStateException If the queue has not been assigned. 80 if (queue == null) throw new IllegalStateException("Must assign a queue before starting."); 91 Task task = queue [all...] |
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SeriesTaskExecutorThreadFactory.java | 44 * @param queue Non null BlockingQueue to assign. 48 public SeriesTaskExecutorThread create(BlockingQueue<Task> queue) { argument 49 Reject.ifNull(queue); 51 processor.setQueue(queue);
|
H A D | SeriesTaskExecutorThread.java | 34 * makes no assumptions about the nature of the task, or the queue from which 48 private BlockingQueue<Task> queue; field in class:SeriesTaskExecutorThread 67 * @param queue Non null BlockingQueue implementation to use for asynchronous processing. 69 public void setQueue(BlockingQueue<Task> queue) { argument 70 this.queue = queue; 76 * @throws java.lang.IllegalStateException If the queue has not been assigned. 80 if (queue == null) throw new IllegalStateException("Must assign a queue before starting."); 91 Task task = queue [all...] |
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/impl/queue/ |
H A D | TaskDispatcherTest.java | 16 package org.forgerock.openam.cts.impl.queue; 38 private TaskDispatcher queue; field in class:TaskDispatcherTest 55 queue = new TaskDispatcher( 62 queue.startDispatcher(); 104 queue.create(token, options, handler); 110 queue.update(token, options, handler); 116 queue.delete(tokenId, handler); 122 queue.read(tokenId, options, handler); 128 queue.query(tokenFilter, handler); 134 queue [all...] |