Searched refs:updateToReplayQueue (Results 1 - 18 of 18) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/
H A DReplayThread.java58 private final BlockingQueue<UpdateToReplay> updateToReplayQueue; field in class:ReplayThread
65 * @param updateToReplayQueue The queue of update messages we have to replay
67 public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue) argument
70 this.updateToReplayQueue = updateToReplayQueue;
97 // Loop getting an updateToReplayQueue from the update message queue and
100 ((updateToreplay = updateToReplayQueue.poll(1L,
H A DMultimasterReplication.java80 private static final BlockingQueue<UpdateToReplay> updateToReplayQueue = field in class:MultimasterReplication
183 domain = new LDAPReplicationDomain(configuration, updateToReplayQueue);
304 ReplayThread replayThread = new ReplayThread(updateToReplayQueue);
H A DLDAPReplicationDomain.java174 private final BlockingQueue<UpdateToReplay> updateToReplayQueue; field in class:LDAPReplicationDomain
487 * @param updateToReplayQueue The queue for update messages to replay.
491 BlockingQueue<UpdateToReplay> updateToReplayQueue)
513 this.updateToReplayQueue = updateToReplayQueue;
4896 if (updateToReplayQueue.offer(updateToReplay, 1, TimeUnit.SECONDS))
490 LDAPReplicationDomain(ReplicationDomainCfg configuration, BlockingQueue<UpdateToReplay> updateToReplayQueue) argument
/forgerock/opendj2/src/server/org/opends/server/replication/plugin/
H A DReplayThread.java57 private final BlockingQueue<UpdateToReplay> updateToReplayQueue; field in class:ReplayThread
64 * @param updateToReplayQueue The queue of update messages we have to replay
66 public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue) argument
69 this.updateToReplayQueue = updateToReplayQueue;
96 // Loop getting an updateToReplayQueue from the update message queue and
99 ((updateToreplay = updateToReplayQueue.poll(1L,
H A DMultimasterReplication.java111 private static final BlockingQueue<UpdateToReplay> updateToReplayQueue = field in class:MultimasterReplication
219 configuration, updateToReplayQueue, dsrsShutdownSync);
331 ReplayThread replayThread = new ReplayThread(updateToReplayQueue);
H A DLDAPReplicationDomain.java191 private final BlockingQueue<UpdateToReplay> updateToReplayQueue; field in class:LDAPReplicationDomain
456 * @param updateToReplayQueue The queue for update messages to replay.
461 BlockingQueue<UpdateToReplay> updateToReplayQueue,
466 this.updateToReplayQueue = updateToReplayQueue;
4386 if (updateToReplayQueue.offer(updateToReplay, 1, TimeUnit.SECONDS))
460 LDAPReplicationDomain(ReplicationDomainCfg configuration, BlockingQueue<UpdateToReplay> updateToReplayQueue, DSRSShutdownSync dsrsShutdownSync) argument
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/
H A DReplayThread.java58 private final BlockingQueue<UpdateToReplay> updateToReplayQueue; field in class:ReplayThread
65 * @param updateToReplayQueue The queue of update messages we have to replay
67 public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue) argument
70 this.updateToReplayQueue = updateToReplayQueue;
97 // Loop getting an updateToReplayQueue from the update message queue and
100 ((updateToreplay = updateToReplayQueue.poll(1L,
H A DMultimasterReplication.java78 private static final BlockingQueue<UpdateToReplay> updateToReplayQueue = field in class:MultimasterReplication
178 domain = new LDAPReplicationDomain(configuration, updateToReplayQueue);
299 ReplayThread replayThread = new ReplayThread(updateToReplayQueue);
H A DLDAPReplicationDomain.java175 private final BlockingQueue<UpdateToReplay> updateToReplayQueue; field in class:LDAPReplicationDomain
507 * @param updateToReplayQueue The queue for update messages to replay.
511 BlockingQueue<UpdateToReplay> updateToReplayQueue)
533 this.updateToReplayQueue = updateToReplayQueue;
4991 if (updateToReplayQueue.offer(updateToReplay, 1, TimeUnit.SECONDS))
510 LDAPReplicationDomain(ReplicationDomainCfg configuration, BlockingQueue<UpdateToReplay> updateToReplayQueue) argument
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/
H A DReplayThread.java58 private final BlockingQueue<UpdateToReplay> updateToReplayQueue; field in class:ReplayThread
65 * @param updateToReplayQueue The queue of update messages we have to replay
67 public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue) argument
70 this.updateToReplayQueue = updateToReplayQueue;
97 // Loop getting an updateToReplayQueue from the update message queue and
100 ((updateToreplay = updateToReplayQueue.poll(1L,
H A DMultimasterReplication.java80 private static final BlockingQueue<UpdateToReplay> updateToReplayQueue = field in class:MultimasterReplication
183 domain = new LDAPReplicationDomain(configuration, updateToReplayQueue);
304 ReplayThread replayThread = new ReplayThread(updateToReplayQueue);
H A DLDAPReplicationDomain.java174 private final BlockingQueue<UpdateToReplay> updateToReplayQueue; field in class:LDAPReplicationDomain
487 * @param updateToReplayQueue The queue for update messages to replay.
491 BlockingQueue<UpdateToReplay> updateToReplayQueue)
513 this.updateToReplayQueue = updateToReplayQueue;
4896 if (updateToReplayQueue.offer(updateToReplay, 1, TimeUnit.SECONDS))
490 LDAPReplicationDomain(ReplicationDomainCfg configuration, BlockingQueue<UpdateToReplay> updateToReplayQueue) argument
/forgerock/opendj2-hg/src/server/org/opends/server/replication/plugin/
H A DReplayThread.java57 private final BlockingQueue<UpdateToReplay> updateToReplayQueue; field in class:ReplayThread
64 * @param updateToReplayQueue The queue of update messages we have to replay
66 public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue) argument
69 this.updateToReplayQueue = updateToReplayQueue;
96 // Loop getting an updateToReplayQueue from the update message queue and
99 ((updateToreplay = updateToReplayQueue.poll(1L,
H A DMultimasterReplication.java111 private static final BlockingQueue<UpdateToReplay> updateToReplayQueue = field in class:MultimasterReplication
219 configuration, updateToReplayQueue, dsrsShutdownSync);
331 ReplayThread replayThread = new ReplayThread(updateToReplayQueue);
H A DLDAPReplicationDomain.java191 private final BlockingQueue<UpdateToReplay> updateToReplayQueue; field in class:LDAPReplicationDomain
456 * @param updateToReplayQueue The queue for update messages to replay.
461 BlockingQueue<UpdateToReplay> updateToReplayQueue,
466 this.updateToReplayQueue = updateToReplayQueue;
4386 if (updateToReplayQueue.offer(updateToReplay, 1, TimeUnit.SECONDS))
460 LDAPReplicationDomain(ReplicationDomainCfg configuration, BlockingQueue<UpdateToReplay> updateToReplayQueue, DSRSShutdownSync dsrsShutdownSync) argument
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/
H A DReplayThread.java51 private final BlockingQueue<UpdateToReplay> updateToReplayQueue; field in class:ReplayThread
58 * @param updateToReplayQueue The queue of update messages we have to replay
60 public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue) argument
63 this.updateToReplayQueue = updateToReplayQueue;
90 // Loop getting an updateToReplayQueue from the update message queue and
93 ((updateToreplay = updateToReplayQueue.poll(1L,
H A DMultimasterReplication.java110 private static final BlockingQueue<UpdateToReplay> updateToReplayQueue = new LinkedBlockingQueue<>(10000); field in class:MultimasterReplication
205 configuration, updateToReplayQueue, dsrsShutdownSync);
322 ReplayThread replayThread = new ReplayThread(updateToReplayQueue);
H A DLDAPReplicationDomain.java238 private final BlockingQueue<UpdateToReplay> updateToReplayQueue; field in class:LDAPReplicationDomain
475 * @param updateToReplayQueue The queue for update messages to replay.
480 BlockingQueue<UpdateToReplay> updateToReplayQueue,
485 this.updateToReplayQueue = updateToReplayQueue;
4265 if (updateToReplayQueue.offer(updateToReplay, 1, TimeUnit.SECONDS))
479 LDAPReplicationDomain(ReplicationDomainCfg configuration, BlockingQueue<UpdateToReplay> updateToReplayQueue, DSRSShutdownSync dsrsShutdownSync) argument

Completed in 152 milliseconds