/forgerock/opendj2/src/server/org/opends/server/loggers/ |
H A D | ParallelTextWriter.java | 45 * parallel unbound ie there is no queue size cap imposed. 56 private final ConcurrentLinkedQueue<String> queue; field in class:ParallelTextWriter 71 * after the queue is flushed. 80 this.queue = new ConcurrentLinkedQueue<String>(); 91 * The publisher thread is responsible for emptying the queue of log records 101 * the run method of the writerThread. Run until queue is empty 115 String message = queue.poll(); 151 // Put request on queue for writer 152 queue.add(record); 233 // The writer writerThread SHOULD have drained the queue [all...] |
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | FakeReplicationDomain.java | 52 * A blocking queue that is used to send the UpdateMsg received from the 55 private BlockingQueue<UpdateMsg> queue = null; field in class:FakeReplicationDomain 76 BlockingQueue<UpdateMsg> queue) throws ConfigException 81 this.queue = queue; 156 if (queue != null) 157 queue.add(updateMsg); 70 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
|
H A D | FakeStressReplicationDomain.java | 52 * A blocking queue that is used to send the UpdateMsg received from the 55 private BlockingQueue<UpdateMsg> queue = null; field in class:FakeStressReplicationDomain 63 BlockingQueue<UpdateMsg> queue) throws ConfigException 68 this.queue = queue; 140 if (queue != null) 141 queue.add(updateMsg); 57 FakeStressReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | FakeStressReplicationDomain.java | 52 * A blocking queue that is used to send the UpdateMsg received from the 55 private final BlockingQueue<UpdateMsg> queue; field in class:FakeStressReplicationDomain 59 BlockingQueue<UpdateMsg> queue) throws ConfigException 64 this.queue = queue; 140 if (queue != null) 141 queue.add(updateMsg); 57 FakeStressReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
|
H A D | FakeReplicationDomain.java | 52 * A blocking queue that is used to send the UpdateMsg received from the 55 private BlockingQueue<UpdateMsg> queue; field in class:FakeReplicationDomain 96 BlockingQueue<UpdateMsg> queue) throws ConfigException 99 this.queue = queue; 166 if (queue != null) 167 queue.add(updateMsg); 94 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
|
/forgerock/opendj2.6.2/src/server/org/opends/server/loggers/ |
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.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | FakeReplicationDomain.java | 52 * A blocking queue that is used to send the UpdateMsg received from the 55 private BlockingQueue<UpdateMsg> queue = null; field in class:FakeReplicationDomain 76 BlockingQueue<UpdateMsg> queue) throws ConfigException 81 this.queue = queue; 156 if (queue != null) 157 queue.add(updateMsg); 70 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
|
H A D | FakeStressReplicationDomain.java | 52 * A blocking queue that is used to send the UpdateMsg received from the 55 private BlockingQueue<UpdateMsg> queue = null; field in class:FakeStressReplicationDomain 63 BlockingQueue<UpdateMsg> queue) throws ConfigException 68 this.queue = queue; 140 if (queue != null) 141 queue.add(updateMsg); 57 FakeStressReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | FakeStressReplicationDomain.java | 52 * A blocking queue that is used to send the UpdateMsg received from the 55 private final BlockingQueue<UpdateMsg> queue; field in class:FakeStressReplicationDomain 59 BlockingQueue<UpdateMsg> queue) throws ConfigException 64 this.queue = queue; 140 if (queue != null) 141 queue.add(updateMsg); 57 FakeStressReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
|
H A D | FakeReplicationDomain.java | 52 * A blocking queue that is used to send the UpdateMsg received from the 55 private BlockingQueue<UpdateMsg> queue; field in class:FakeReplicationDomain 96 BlockingQueue<UpdateMsg> queue) throws ConfigException 99 this.queue = queue; 166 if (queue != null) 167 queue.add(updateMsg); 94 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/service/ |
H A D | FakeReplicationDomain.java | 52 * A blocking queue that is used to send the UpdateMsg received from the 55 private BlockingQueue<UpdateMsg> queue = null; field in class:FakeReplicationDomain 76 BlockingQueue<UpdateMsg> queue) throws ConfigException 81 this.queue = queue; 156 if (queue != null) 157 queue.add(updateMsg); 70 FakeReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
|
H A D | FakeStressReplicationDomain.java | 52 * A blocking queue that is used to send the UpdateMsg received from the 55 private BlockingQueue<UpdateMsg> queue = null; field in class:FakeStressReplicationDomain 63 BlockingQueue<UpdateMsg> queue) throws ConfigException 68 this.queue = queue; 140 if (queue != null) 141 queue.add(updateMsg); 57 FakeStressReplicationDomain( String serviceID, int serverID, Collection<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/loggers/ |
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-hg/src/server/org/opends/server/loggers/ |
H A D | ParallelTextWriter.java | 45 * parallel unbound ie there is no queue size cap imposed. 56 private final ConcurrentLinkedQueue<String> queue; field in class:ParallelTextWriter 71 * after the queue is flushed. 80 this.queue = new ConcurrentLinkedQueue<String>(); 91 * The publisher thread is responsible for emptying the queue of log records 101 * the run method of the writerThread. Run until queue is empty 115 String message = queue.poll(); 151 // Put request on queue for writer 152 queue.add(record); 233 // The writer writerThread SHOULD have drained the queue [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/service/ |
H A D | FakeStressReplicationDomain.java | 52 * A blocking queue that is used to send the UpdateMsg received from the 55 private final BlockingQueue<UpdateMsg> queue; field in class:FakeStressReplicationDomain 59 BlockingQueue<UpdateMsg> queue) throws ConfigException 64 this.queue = queue; 140 if (queue != null) 142 queue.add(updateMsg); 57 FakeStressReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
|
H A D | FakeReplicationDomain.java | 52 * A blocking queue that is used to send the UpdateMsg received from the 55 private BlockingQueue<UpdateMsg> queue; field in class:FakeReplicationDomain 96 BlockingQueue<UpdateMsg> queue) throws ConfigException 99 this.queue = queue; 168 if (queue != null) 170 queue.add(updateMsg); 94 FakeReplicationDomain(DN baseDN, int serverID, SortedSet<String> replicationServers, int window, long heartbeatInterval, BlockingQueue<UpdateMsg> queue) argument
|
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/worker/process/ |
H A D | CTSWorkerDeleteProcess.java | 28 import org.forgerock.openam.cts.impl.queue.TaskDispatcher; 92 private final TaskDispatcher queue; field in class:CTSWorkerDeleteProcess.TokenDeletion 95 public TokenDeletion(TaskDispatcher queue) { argument 96 this.queue = queue; 116 queue.delete(tokenId, handler);
|
/forgerock/openidm-v4/openidm-smartevent/src/main/java/org/forgerock/openidm/smartevent/core/ |
H A D | BlockingPublisher.java | 29 * Publisher that uses the blocking linked queue to process events. 42 private static BlockingQueue queue = new LinkedBlockingQueue(QUEUE_CAPACITY); field in class:BlockingPublisher 50 EventEntry entry = (EventEntry) queue.take(); 54 logger.debug("Stop processing event queue: {}", ex.getMessage()); 102 queue.put(entry);
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | NamingConflictTest.java | 79 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue(); 84 MultimasterReplication.createNewDomain(conf, queue); 124 // Put the message in the replay queue 127 // Make the domain replay the change from the replay queue 128 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN); 138 // Put the message in the replay queue 141 // Make the domain replay the change from the replay queue 143 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN); 168 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue(); 173 MultimasterReplication.createNewDomain(conf, queue); [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | NamingConflictTest.java | 78 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue(); 83 MultimasterReplication.createNewDomain(conf, queue); 123 // Put the message in the replay queue 126 // Make the domain replay the change from the replay queue 127 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN); 137 // Put the message in the replay queue 140 // Make the domain replay the change from the replay queue 142 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN); 167 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue(); 172 MultimasterReplication.createNewDomain(conf, queue); [all...] |
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | NamingConflictTest.java | 79 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue(); 84 MultimasterReplication.createNewDomain(conf, queue); 124 // Put the message in the replay queue 127 // Make the domain replay the change from the replay queue 128 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN); 138 // Put the message in the replay queue 141 // Make the domain replay the change from the replay queue 143 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN); 168 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue(); 173 MultimasterReplication.createNewDomain(conf, queue); [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | NamingConflictTest.java | 78 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue(); 83 MultimasterReplication.createNewDomain(conf, queue); 123 // Put the message in the replay queue 126 // Make the domain replay the change from the replay queue 127 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN); 137 // Put the message in the replay queue 140 // Make the domain replay the change from the replay queue 142 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN); 167 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue(); 172 MultimasterReplication.createNewDomain(conf, queue); [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | NamingConflictTest.java | 79 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue(); 84 MultimasterReplication.createNewDomain(conf, queue); 124 // Put the message in the replay queue 127 // Make the domain replay the change from the replay queue 128 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN); 138 // Put the message in the replay queue 141 // Make the domain replay the change from the replay queue 143 domain.replay(queue.take().getUpdateMessage(), SHUTDOWN); 168 TestSynchronousReplayQueue queue = new TestSynchronousReplayQueue(); 173 MultimasterReplication.createNewDomain(conf, queue); [all...] |
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SeriesTaskExecutor.java | 32 import org.forgerock.openam.cts.impl.queue.QueueSelector; 33 import org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration; 48 * This task queue has some specific behaviours which allow for consistent 63 * that when this queue is full, the caller is required to block. 70 * @see org.forgerock.openam.cts.impl.queue.config.CTSQueueConfiguration#getQueueTimeout() 108 BlockingQueue<Task> queue = getQueue(tokenId); 109 offer(queue, task); 144 * Select a random queue to use for the query operation. 153 * Select the appropriate queue based on the given Token ID. 170 * Assign the task to the queue wit 175 offer(BlockingQueue<Task> queue, Task task) argument [all...] |
/forgerock/openam-v13/openam-core/src/test/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | SeriesTaskExecutorThreadTest.java | 80 BlockingQueue<Task> queue = mock(BlockingQueue.class); 81 given(queue.take()).willAnswer(new Answer<Object>() { 88 return queue;
|