Searched refs:UpdateToReplay (Results 1 - 25 of 30) sorted by relevance

12

/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DTestSynchronousReplayQueue.java43 public class TestSynchronousReplayQueue implements BlockingQueue<UpdateToReplay>
45 private LinkedList<UpdateToReplay> list = new LinkedList<UpdateToReplay>();
48 public boolean add(UpdateToReplay e)
60 public int drainTo(Collection<? super UpdateToReplay> c)
66 public int drainTo(Collection<? super UpdateToReplay> c, int maxElements)
72 public boolean offer(UpdateToReplay e)
78 public boolean offer(UpdateToReplay e, long timeout, TimeUnit unit)
85 public UpdateToReplay poll(long timeout, TimeUnit unit)
92 public void put(UpdateToReplay
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DTestSynchronousReplayQueue.java42 public class TestSynchronousReplayQueue implements BlockingQueue<UpdateToReplay>
44 private LinkedList<UpdateToReplay> list = new LinkedList<UpdateToReplay>();
47 public boolean add(UpdateToReplay e)
59 public int drainTo(Collection<? super UpdateToReplay> c)
65 public int drainTo(Collection<? super UpdateToReplay> c, int maxElements)
71 public boolean offer(UpdateToReplay e)
77 public boolean offer(UpdateToReplay e, long timeout, TimeUnit unit)
84 public UpdateToReplay poll(long timeout, TimeUnit unit)
91 public void put(UpdateToReplay
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DTestSynchronousReplayQueue.java43 public class TestSynchronousReplayQueue implements BlockingQueue<UpdateToReplay>
45 private LinkedList<UpdateToReplay> list = new LinkedList<UpdateToReplay>();
48 public boolean add(UpdateToReplay e)
60 public int drainTo(Collection<? super UpdateToReplay> c)
66 public int drainTo(Collection<? super UpdateToReplay> c, int maxElements)
72 public boolean offer(UpdateToReplay e)
78 public boolean offer(UpdateToReplay e, long timeout, TimeUnit unit)
85 public UpdateToReplay poll(long timeout, TimeUnit unit)
92 public void put(UpdateToReplay
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DTestSynchronousReplayQueue.java42 public class TestSynchronousReplayQueue implements BlockingQueue<UpdateToReplay>
44 private LinkedList<UpdateToReplay> list = new LinkedList<UpdateToReplay>();
47 public boolean add(UpdateToReplay e)
59 public int drainTo(Collection<? super UpdateToReplay> c)
65 public int drainTo(Collection<? super UpdateToReplay> c, int maxElements)
71 public boolean offer(UpdateToReplay e)
77 public boolean offer(UpdateToReplay e, long timeout, TimeUnit unit)
84 public UpdateToReplay poll(long timeout, TimeUnit unit)
91 public void put(UpdateToReplay
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DTestSynchronousReplayQueue.java43 public class TestSynchronousReplayQueue implements BlockingQueue<UpdateToReplay>
45 private LinkedList<UpdateToReplay> list = new LinkedList<UpdateToReplay>();
48 public boolean add(UpdateToReplay e)
60 public int drainTo(Collection<? super UpdateToReplay> c)
66 public int drainTo(Collection<? super UpdateToReplay> c, int maxElements)
72 public boolean offer(UpdateToReplay e)
78 public boolean offer(UpdateToReplay e, long timeout, TimeUnit unit)
85 public UpdateToReplay poll(long timeout, TimeUnit unit)
92 public void put(UpdateToReplay
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/
H A DTestSynchronousReplayQueue.java41 public class TestSynchronousReplayQueue implements BlockingQueue<UpdateToReplay>
43 private LinkedList<UpdateToReplay> list = new LinkedList<>();
46 public boolean add(UpdateToReplay e)
58 public int drainTo(Collection<? super UpdateToReplay> c)
64 public int drainTo(Collection<? super UpdateToReplay> c, int maxElements)
70 public boolean offer(UpdateToReplay e)
76 public boolean offer(UpdateToReplay e, long timeout, TimeUnit unit)
83 public UpdateToReplay poll(long timeout, TimeUnit unit)
90 public void put(UpdateToReplay e) throws InterruptedException
107 public UpdateToReplay tak
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/
H A DUpdateToReplay.java37 public class UpdateToReplay class
49 public UpdateToReplay(LDAPUpdateMsg updateMessage, method in class:UpdateToReplay
H A DReplayThread.java51 private final BlockingQueue<UpdateToReplay> updateToReplayQueue;
60 public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue)
89 UpdateToReplay updateToreplay;
H A DMultimasterReplication.java110 private static final BlockingQueue<UpdateToReplay> updateToReplayQueue = new LinkedBlockingQueue<>(10000);
237 BlockingQueue<UpdateToReplay> queue)
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/plugin/
H A DUpdateToReplay.java37 public class UpdateToReplay class
49 public UpdateToReplay(LDAPUpdateMsg updateMessage, method in class:UpdateToReplay
H A DReplayThread.java58 private final BlockingQueue<UpdateToReplay> updateToReplayQueue;
67 public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue)
96 UpdateToReplay updateToreplay;
H A DMultimasterReplication.java80 private static final BlockingQueue<UpdateToReplay> updateToReplayQueue =
81 new LinkedBlockingQueue<UpdateToReplay>(10000);
217 BlockingQueue<UpdateToReplay> queue)
H A DLDAPReplicationDomain.java174 private final BlockingQueue<UpdateToReplay> updateToReplayQueue;
491 BlockingQueue<UpdateToReplay> updateToReplayQueue)
4890 final UpdateToReplay updateToReplay = new UpdateToReplay(msg, this);
/forgerock/opendj2/src/server/org/opends/server/replication/plugin/
H A DUpdateToReplay.java36 public class UpdateToReplay class
48 public UpdateToReplay(LDAPUpdateMsg updateMessage, method in class:UpdateToReplay
H A DReplayThread.java57 private final BlockingQueue<UpdateToReplay> updateToReplayQueue;
66 public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue)
95 UpdateToReplay updateToreplay;
H A DMultimasterReplication.java111 private static final BlockingQueue<UpdateToReplay> updateToReplayQueue =
112 new LinkedBlockingQueue<UpdateToReplay>(10000);
252 BlockingQueue<UpdateToReplay> queue)
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/plugin/
H A DUpdateToReplay.java37 public class UpdateToReplay class
49 public UpdateToReplay(LDAPUpdateMsg updateMessage, method in class:UpdateToReplay
H A DReplayThread.java58 private final BlockingQueue<UpdateToReplay> updateToReplayQueue;
67 public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue)
96 UpdateToReplay updateToreplay;
H A DMultimasterReplication.java78 private static final BlockingQueue<UpdateToReplay> updateToReplayQueue =
79 new LinkedBlockingQueue<UpdateToReplay>(10000);
212 BlockingQueue<UpdateToReplay> queue)
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/plugin/
H A DUpdateToReplay.java37 public class UpdateToReplay class
49 public UpdateToReplay(LDAPUpdateMsg updateMessage, method in class:UpdateToReplay
H A DReplayThread.java58 private final BlockingQueue<UpdateToReplay> updateToReplayQueue;
67 public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue)
96 UpdateToReplay updateToreplay;
H A DMultimasterReplication.java80 private static final BlockingQueue<UpdateToReplay> updateToReplayQueue =
81 new LinkedBlockingQueue<UpdateToReplay>(10000);
217 BlockingQueue<UpdateToReplay> queue)
/forgerock/opendj2-hg/src/server/org/opends/server/replication/plugin/
H A DUpdateToReplay.java36 public class UpdateToReplay class
48 public UpdateToReplay(LDAPUpdateMsg updateMessage, method in class:UpdateToReplay
H A DReplayThread.java57 private final BlockingQueue<UpdateToReplay> updateToReplayQueue;
66 public ReplayThread(BlockingQueue<UpdateToReplay> updateToReplayQueue)
95 UpdateToReplay updateToreplay;
H A DMultimasterReplication.java111 private static final BlockingQueue<UpdateToReplay> updateToReplayQueue =
112 new LinkedBlockingQueue<UpdateToReplay>(10000);
252 BlockingQueue<UpdateToReplay> queue)

Completed in 261 milliseconds

12