Searched refs:ReplayThread (Results 1 - 12 of 12) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/
H A DReplayThread.java51 public class ReplayThread extends DirectoryThread class in inherits:DirectoryThread
63 * Constructor for the ReplayThread.
67 public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue) method in class:ReplayThread
H A DMultimasterReplication.java77 * The queue of received update messages, to be treated by the ReplayThread
84 * The list of ReplayThread threads.
86 private static List<ReplayThread> replayThreads =
87 new ArrayList<ReplayThread>();
304 ReplayThread replayThread = new ReplayThread(updateToReplayQueue);
316 for (ReplayThread replayThread : replayThreads)
321 for (ReplayThread replayThread : replayThreads)
/forgerock/opendj2/src/server/org/opends/server/replication/plugin/
H A DReplayThread.java50 public class ReplayThread extends DirectoryThread class in inherits:DirectoryThread
62 * Constructor for the ReplayThread.
66 public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue) method in class:ReplayThread
H A DMultimasterReplication.java108 * The queue of received update messages, to be treated by the ReplayThread
115 * The list of ReplayThread threads.
117 private static final List<ReplayThread> replayThreads =
118 new ArrayList<ReplayThread>();
331 ReplayThread replayThread = new ReplayThread(updateToReplayQueue);
343 for (ReplayThread replayThread : replayThreads)
348 for (ReplayThread replayThread : replayThreads)
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/
H A DReplayThread.java51 public class ReplayThread extends DirectoryThread class in inherits:DirectoryThread
63 * Constructor for the ReplayThread.
67 public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue) method in class:ReplayThread
H A DMultimasterReplication.java75 * The queue of received update messages, to be treated by the ReplayThread
82 * The list of ReplayThread threads.
84 private static List<ReplayThread> replayThreads =
85 new ArrayList<ReplayThread>();
299 ReplayThread replayThread = new ReplayThread(updateToReplayQueue);
311 for (ReplayThread replayThread : replayThreads)
316 for (ReplayThread replayThread : replayThreads)
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/
H A DReplayThread.java51 public class ReplayThread extends DirectoryThread class in inherits:DirectoryThread
63 * Constructor for the ReplayThread.
67 public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue) method in class:ReplayThread
H A DMultimasterReplication.java77 * The queue of received update messages, to be treated by the ReplayThread
84 * The list of ReplayThread threads.
86 private static List<ReplayThread> replayThreads =
87 new ArrayList<ReplayThread>();
304 ReplayThread replayThread = new ReplayThread(updateToReplayQueue);
316 for (ReplayThread replayThread : replayThreads)
321 for (ReplayThread replayThread : replayThreads)
/forgerock/opendj2-hg/src/server/org/opends/server/replication/plugin/
H A DReplayThread.java50 public class ReplayThread extends DirectoryThread class in inherits:DirectoryThread
62 * Constructor for the ReplayThread.
66 public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue) method in class:ReplayThread
H A DMultimasterReplication.java108 * The queue of received update messages, to be treated by the ReplayThread
115 * The list of ReplayThread threads.
117 private static final List<ReplayThread> replayThreads =
118 new ArrayList<ReplayThread>();
331 ReplayThread replayThread = new ReplayThread(updateToReplayQueue);
343 for (ReplayThread replayThread : replayThreads)
348 for (ReplayThread replayThread : replayThreads)
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/
H A DReplayThread.java47 public class ReplayThread extends DirectoryThread class in inherits:DirectoryThread
56 * Constructor for the ReplayThread.
60 public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue) method in class:ReplayThread
H A DMultimasterReplication.java109 /** The queue of received update messages, to be treated by the ReplayThread threads. */
111 /** The list of ReplayThread threads. */
112 private static final List<ReplayThread> replayThreads = new ArrayList<>();
322 ReplayThread replayThread = new ReplayThread(updateToReplayQueue);
334 for (ReplayThread replayThread : replayThreads)
339 for (ReplayThread replayThread : replayThreads)

Completed in 680 milliseconds