Searched refs:UpdateMsg (Results 1 - 25 of 245) sorted by relevance

12345678910

/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/
H A DSequentialDBCursor.java32 import org.opends.server.replication.protocol.UpdateMsg;
36 class SequentialDBCursor implements DBCursor<UpdateMsg>
39 private final List<UpdateMsg> msgs;
40 private UpdateMsg current;
49 public SequentialDBCursor(UpdateMsg... msgs)
51 this.msgs = new ArrayList<UpdateMsg>(Arrays.asList(msgs));
54 public void add(UpdateMsg msg)
61 public UpdateMsg getRecord()
H A DFakeUpdateMsg.java28 import org.opends.server.replication.protocol.UpdateMsg;
31 class FakeUpdateMsg extends UpdateMsg
45 return "UpdateMsg(" + t + ")";
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/
H A DSequentialDBCursor.java32 import org.opends.server.replication.protocol.UpdateMsg;
36 class SequentialDBCursor implements DBCursor<UpdateMsg>
39 private final List<UpdateMsg> msgs;
40 private UpdateMsg current;
49 public SequentialDBCursor(UpdateMsg... msgs)
51 this.msgs = new ArrayList<UpdateMsg>(Arrays.asList(msgs));
54 public void add(UpdateMsg msg)
61 public UpdateMsg getRecord()
H A DFakeUpdateMsg.java28 import org.opends.server.replication.protocol.UpdateMsg;
31 class FakeUpdateMsg extends UpdateMsg
45 return "UpdateMsg(" + t + ")";
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DUpdateComparator.java32 import org.opends.server.replication.protocol.UpdateMsg;
37 public class UpdateComparator implements Comparator<UpdateMsg>
55 * @param msg1 first UpdateMsg to compare
56 * @param msg2 second UpdateMsg to compare
61 public int compare(UpdateMsg msg1, UpdateMsg msg2)
H A DReplicationData.java36 import org.opends.server.replication.protocol.UpdateMsg;
47 * Creates a new ReplicationData object from an UpdateMsg.
49 * @param change the UpdateMsg used to create the ReplicationData.
51 public ReplicationData(UpdateMsg change)
67 * Generate an UpdateMsg from its byte[] form.
69 * @param data The DatabaseEntry used to generate the UpdateMsg.
75 public static UpdateMsg generateChange(byte[] data)
78 return (UpdateMsg) ReplicationMsg.generateMsg(
H A DMsgQueue.java38 import org.opends.server.replication.protocol.UpdateMsg;
41 * This class is used to build ordered lists of UpdateMsg.
42 * The order is defined by the order of the ChangeNumber of the UpdateMsg.
47 private SortedMap<ChangeNumber, UpdateMsg> map =
48 new TreeMap<ChangeNumber, UpdateMsg>();
55 * Return the first UpdateMsg in the MsgQueue.
57 * @return The first UpdateMsg in the MsgQueue.
59 public UpdateMsg first()
94 * Returns <tt>true</tt> if this MsgQueue contains no UpdateMsg.
96 * @return <tt>true</tt> if this MsgQueue contains no UpdateMsg
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DUpdateComparator.java32 import org.opends.server.replication.protocol.UpdateMsg;
37 public class UpdateComparator implements Comparator<UpdateMsg>
55 * @param msg1 first UpdateMsg to compare
56 * @param msg2 second UpdateMsg to compare
61 public int compare(UpdateMsg msg1, UpdateMsg msg2)
H A DReplicationData.java36 import org.opends.server.replication.protocol.UpdateMsg;
47 * Creates a new ReplicationData object from an UpdateMsg.
49 * @param change the UpdateMsg used to create the ReplicationData.
51 public ReplicationData(UpdateMsg change)
67 * Generate an UpdateMsg from its byte[] form.
69 * @param data The DatabaseEntry used to generate the UpdateMsg.
75 public static UpdateMsg generateChange(byte[] data)
78 return (UpdateMsg) ReplicationMsg.generateMsg(
H A DMsgQueue.java38 import org.opends.server.replication.protocol.UpdateMsg;
41 * This class is used to build ordered lists of UpdateMsg.
42 * The order is defined by the order of the ChangeNumber of the UpdateMsg.
47 private SortedMap<ChangeNumber, UpdateMsg> map =
48 new TreeMap<ChangeNumber, UpdateMsg>();
55 * Return the first UpdateMsg in the MsgQueue.
57 * @return The first UpdateMsg in the MsgQueue.
59 public UpdateMsg first()
94 * Returns <tt>true</tt> if this MsgQueue contains no UpdateMsg.
96 * @return <tt>true</tt> if this MsgQueue contains no UpdateMsg
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DUpdateComparator.java32 import org.opends.server.replication.protocol.UpdateMsg;
37 public class UpdateComparator implements Comparator<UpdateMsg>
55 * @param msg1 first UpdateMsg to compare
56 * @param msg2 second UpdateMsg to compare
61 public int compare(UpdateMsg msg1, UpdateMsg msg2)
H A DReplicationData.java36 import org.opends.server.replication.protocol.UpdateMsg;
47 * Creates a new ReplicationData object from an UpdateMsg.
49 * @param change the UpdateMsg used to create the ReplicationData.
51 public ReplicationData(UpdateMsg change)
67 * Generate an UpdateMsg from its byte[] form.
69 * @param data The DatabaseEntry used to generate the UpdateMsg.
75 public static UpdateMsg generateChange(byte[] data)
78 return (UpdateMsg) ReplicationMsg.generateMsg(
H A DMsgQueue.java38 import org.opends.server.replication.protocol.UpdateMsg;
41 * This class is used to build ordered lists of UpdateMsg.
42 * The order is defined by the order of the ChangeNumber of the UpdateMsg.
47 private SortedMap<ChangeNumber, UpdateMsg> map =
48 new TreeMap<ChangeNumber, UpdateMsg>();
55 * Return the first UpdateMsg in the MsgQueue.
57 * @return The first UpdateMsg in the MsgQueue.
59 public UpdateMsg first()
94 * Returns <tt>true</tt> if this MsgQueue contains no UpdateMsg.
96 * @return <tt>true</tt> if this MsgQueue contains no UpdateMsg
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/
H A DSequentialDBCursor.java30 import org.opends.server.replication.protocol.UpdateMsg;
35 class SequentialDBCursor implements DBCursor<UpdateMsg>
38 private final List<UpdateMsg> msgs;
39 private UpdateMsg current;
48 public SequentialDBCursor(UpdateMsg... msgs)
53 public void add(UpdateMsg msg)
60 public UpdateMsg getRecord()
H A DFakeUpdateMsg.java28 import org.opends.server.replication.protocol.UpdateMsg;
31 class FakeUpdateMsg extends UpdateMsg
45 return "UpdateMsg(" + t + ")";
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/changelog/file/
H A DCompositeDBCursor.java36 import org.opends.server.replication.protocol.UpdateMsg;
50 abstract class CompositeDBCursor<T> implements DBCursor<UpdateMsg>
64 private final Map<DBCursor<UpdateMsg>, T> exhaustedCursors = new HashMap<>();
74 private final TreeMap<DBCursor<UpdateMsg>, T> cursors = new TreeMap<>(
75 new Comparator<DBCursor<UpdateMsg>>()
78 public int compare(DBCursor<UpdateMsg> o1, DBCursor<UpdateMsg> o2)
109 // (which UpdateMsg has been consumed).
112 final Entry<DBCursor<UpdateMsg>, T> cursorToAdvance =
130 final Map<DBCursor<UpdateMsg>,
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/je/
H A DCompositeDBCursor.java32 import org.opends.server.replication.protocol.UpdateMsg;
48 abstract class CompositeDBCursor<T> implements DBCursor<UpdateMsg>
66 private final Map<DBCursor<UpdateMsg>, T> exhaustedCursors =
67 new HashMap<DBCursor<UpdateMsg>, T>();
77 private final TreeMap<DBCursor<UpdateMsg>, T> cursors =
78 new TreeMap<DBCursor<UpdateMsg>, T>(
79 new Comparator<DBCursor<UpdateMsg>>()
82 public int compare(DBCursor<UpdateMsg> o1, DBCursor<UpdateMsg> o2)
100 // (which UpdateMsg ha
[all...]
H A DECLMultiDomainDBCursor.java31 import org.opends.server.replication.protocol.UpdateMsg;
42 public final class ECLMultiDomainDBCursor implements DBCursor<UpdateMsg>
64 public UpdateMsg getRecord()
123 * @return a list of (DN, UpdateMsg) pairs, containing all base DNs enabled
126 List<Pair<DN, UpdateMsg>> getSnapshot()
128 final List<Pair<DN, UpdateMsg>> snapshot = cursor.getSnapshot();
129 final List<Pair<DN, UpdateMsg>> eclSnapshot = new ArrayList<Pair<DN,UpdateMsg>>();
130 for (Pair<DN, UpdateMsg> pair : snapshot)
149 List<Pair<DN, UpdateMsg>> snapsho
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/je/
H A DCompositeDBCursor.java32 import org.opends.server.replication.protocol.UpdateMsg;
48 abstract class CompositeDBCursor<T> implements DBCursor<UpdateMsg>
66 private final Map<DBCursor<UpdateMsg>, T> exhaustedCursors =
67 new HashMap<DBCursor<UpdateMsg>, T>();
77 private final TreeMap<DBCursor<UpdateMsg>, T> cursors =
78 new TreeMap<DBCursor<UpdateMsg>, T>(
79 new Comparator<DBCursor<UpdateMsg>>()
82 public int compare(DBCursor<UpdateMsg> o1, DBCursor<UpdateMsg> o2)
100 // (which UpdateMsg ha
[all...]
H A DECLMultiDomainDBCursor.java31 import org.opends.server.replication.protocol.UpdateMsg;
42 public final class ECLMultiDomainDBCursor implements DBCursor<UpdateMsg>
64 public UpdateMsg getRecord()
123 * @return a list of (DN, UpdateMsg) pairs, containing all base DNs enabled
126 List<Pair<DN, UpdateMsg>> getSnapshot()
128 final List<Pair<DN, UpdateMsg>> snapshot = cursor.getSnapshot();
129 final List<Pair<DN, UpdateMsg>> eclSnapshot = new ArrayList<Pair<DN,UpdateMsg>>();
130 for (Pair<DN, UpdateMsg> pair : snapshot)
149 List<Pair<DN, UpdateMsg>> snapsho
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DMsgQueue.java32 import org.opends.server.replication.protocol.UpdateMsg;
38 * This class is used to build ordered lists of UpdateMsg.
39 * The order is defined by the order of the CSN of the UpdateMsg.
44 private TreeMap<CSN, UpdateMsg> map = new TreeMap<CSN, UpdateMsg>();
58 * Return the first UpdateMsg in the MsgQueue.
60 * @return The first UpdateMsg in the MsgQueue.
62 public UpdateMsg first()
97 * Returns <tt>true</tt> if this MsgQueue contains no UpdateMsg.
99 * @return <tt>true</tt> if this MsgQueue contains no UpdateMsg
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DMsgQueue.java32 import org.opends.server.replication.protocol.UpdateMsg;
38 * This class is used to build ordered lists of UpdateMsg.
39 * The order is defined by the order of the CSN of the UpdateMsg.
44 private TreeMap<CSN, UpdateMsg> map = new TreeMap<CSN, UpdateMsg>();
58 * Return the first UpdateMsg in the MsgQueue.
60 * @return The first UpdateMsg in the MsgQueue.
62 public UpdateMsg first()
97 * Returns <tt>true</tt> if this MsgQueue contains no UpdateMsg.
99 * @return <tt>true</tt> if this MsgQueue contains no UpdateMsg
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DMsgQueue.java33 import org.opends.server.replication.protocol.UpdateMsg;
38 * This class is used to build ordered lists of UpdateMsg.
39 * The order is defined by the order of the CSN of the UpdateMsg.
46 private TreeMap<CSN, UpdateMsg> map = new TreeMap<>();
60 * Return the first UpdateMsg in the MsgQueue.
62 * @return The first UpdateMsg in the MsgQueue.
64 public UpdateMsg first()
99 * Returns <tt>true</tt> if this MsgQueue contains no UpdateMsg.
101 * @return <tt>true</tt> if this MsgQueue contains no UpdateMsg.
112 * Add an UpdateMsg t
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/server/changelog/file/
H A DFileReplicaDBCursor.java32 import org.opends.server.replication.protocol.UpdateMsg;
62 class FileReplicaDBCursor implements DBCursor<UpdateMsg>
65 private final RepositionableCursor<CSN, UpdateMsg> cursor;
68 private Record<CSN, UpdateMsg> nextRecord;
88 final RepositionableCursor<CSN, UpdateMsg> cursor,
98 public UpdateMsg getRecord()
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/changelog/file/
H A DFileReplicaDBCursor.java32 import org.opends.server.replication.protocol.UpdateMsg;
62 class FileReplicaDBCursor implements DBCursor<UpdateMsg>
65 private final RepositionableCursor<CSN, UpdateMsg> cursor;
68 private Record<CSN, UpdateMsg> nextRecord;
88 final RepositionableCursor<CSN, UpdateMsg> cursor,
98 public UpdateMsg getRecord()

Completed in 1662 milliseconds

12345678910