Searched defs:msg2 (Results 1 - 25 of 26) sorted by relevance

12

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DUpdateComparator.java56 * @param msg2 second UpdateMsg to compare
57 * @return -1 if msg1 < msg2
58 * 0 if msg1 == msg2
59 * 1 if msg1 > msg2
61 public int compare(UpdateMsg msg1, UpdateMsg msg2) argument
63 return ChangeNumber.compare(msg1.getChangeNumber(), msg2.getChangeNumber());
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DUpdateComparator.java56 * @param msg2 second UpdateMsg to compare
57 * @return -1 if msg1 < msg2
58 * 0 if msg1 == msg2
59 * 1 if msg1 > msg2
61 public int compare(UpdateMsg msg1, UpdateMsg msg2) argument
63 return ChangeNumber.compare(msg1.getChangeNumber(), msg2.getChangeNumber());
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DUpdateComparator.java56 * @param msg2 second UpdateMsg to compare
57 * @return -1 if msg1 < msg2
58 * 0 if msg1 == msg2
59 * 1 if msg1 > msg2
61 public int compare(UpdateMsg msg1, UpdateMsg msg2) argument
63 return ChangeNumber.compare(msg1.getChangeNumber(), msg2.getChangeNumber());
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DUpdateComparatorTest.java87 DeleteMsg msg2 = new DeleteMsg(op);
92 {msg1, msg2, -1},
93 {msg2, msg1, 1},
94 {msg2, msg2, 0}
103 UpdateMsg msg1, UpdateMsg msg2, int expected) throws Exception
105 assertEquals(UpdateComparator.comparator.compare(msg1, msg2), expected);
102 updateMessageTest( UpdateMsg msg1, UpdateMsg msg2, int expected) argument
H A DReplicationServerTest.java267 ReplicationMsg msg2 = server2.receive();
269 assertDeleteMsgBodyEquals(msg, msg2);
276 msg2 = server2.receive();
278 assertDeleteMsgBodyEquals(msg, msg2);
287 msg2 = server1.receive();
289 assertDeleteMsgBodyEquals(msg, msg2);
296 msg2 = server1.receive();
298 assertDeleteMsgBodyEquals(msg, msg2);
311 private void assertDeleteMsgBodyEquals(DeleteMsg msg, ReplicationMsg msg2) argument
313 if (msg2 instanceo
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DUpdateComparatorTest.java87 DeleteMsg msg2 = new DeleteMsg(op);
92 {msg1, msg2, -1},
93 {msg2, msg1, 1},
94 {msg2, msg2, 0}
103 UpdateMsg msg1, UpdateMsg msg2, int expected) throws Exception
105 assertEquals(UpdateComparator.comparator.compare(msg1, msg2), expected);
102 updateMessageTest( UpdateMsg msg1, UpdateMsg msg2, int expected) argument
H A DReplicationServerTest.java267 ReplicationMsg msg2 = server2.receive();
269 assertDeleteMsgBodyEquals(msg, msg2);
276 msg2 = server2.receive();
278 assertDeleteMsgBodyEquals(msg, msg2);
287 msg2 = server1.receive();
289 assertDeleteMsgBodyEquals(msg, msg2);
296 msg2 = server1.receive();
298 assertDeleteMsgBodyEquals(msg, msg2);
311 private void assertDeleteMsgBodyEquals(DeleteMsg msg, ReplicationMsg msg2) argument
313 if (msg2 instanceo
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DUpdateComparatorTest.java87 DeleteMsg msg2 = new DeleteMsg(op);
92 {msg1, msg2, -1},
93 {msg2, msg1, 1},
94 {msg2, msg2, 0}
103 UpdateMsg msg1, UpdateMsg msg2, int expected) throws Exception
105 assertEquals(UpdateComparator.comparator.compare(msg1, msg2), expected);
102 updateMessageTest( UpdateMsg msg1, UpdateMsg msg2, int expected) argument
H A DReplicationServerTest.java267 ReplicationMsg msg2 = server2.receive();
269 assertDeleteMsgBodyEquals(msg, msg2);
276 msg2 = server2.receive();
278 assertDeleteMsgBodyEquals(msg, msg2);
287 msg2 = server1.receive();
289 assertDeleteMsgBodyEquals(msg, msg2);
296 msg2 = server1.receive();
298 assertDeleteMsgBodyEquals(msg, msg2);
311 private void assertDeleteMsgBodyEquals(DeleteMsg msg, ReplicationMsg msg2) argument
313 if (msg2 instanceo
[all...]
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/
H A DECLMultiDomainDBCursorTest.java123 final UpdateMsg msg2 = new FakeUpdateMsg(2);
127 addDomainCursorToCursor(baseDN2, new SequentialDBCursor(msg2, msg3));
142 private void assertMessagesInOrder(DN baseDN, UpdateMsg msg1, UpdateMsg msg2) throws Exception argument
153 if (msg2 != null)
156 assertThat(eclCursor.getRecord()).isEqualTo(msg2);
H A DCompositeDBCursorTest.java54 private UpdateMsg msg2; field in class:CompositeDBCursorTest
66 msg2 = new FakeUpdateMsg(2);
93 newCompositeDBCursor(of(new SequentialDBCursor(msg1, msg2), baseDN1));
96 of(msg2, baseDN1));
103 newCompositeDBCursor(of(new SequentialDBCursor(msg1, msg2, msg3), baseDN1));
106 of(msg2, baseDN1),
123 of(new SequentialDBCursor(msg2), baseDN1),
127 of(msg2, baseDN1));
134 of(new SequentialDBCursor(msg2, msg3), baseDN1),
138 of(msg2, baseDN
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/changelog/je/
H A DECLMultiDomainDBCursorTest.java123 final UpdateMsg msg2 = new FakeUpdateMsg(2);
127 addDomainCursorToCursor(baseDN2, new SequentialDBCursor(msg2, msg3));
142 private void assertMessagesInOrder(DN baseDN, UpdateMsg msg1, UpdateMsg msg2) throws Exception argument
153 if (msg2 != null)
156 assertThat(eclCursor.getRecord()).isEqualTo(msg2);
H A DCompositeDBCursorTest.java54 private UpdateMsg msg2; field in class:CompositeDBCursorTest
66 msg2 = new FakeUpdateMsg(2);
93 newCompositeDBCursor(of(new SequentialDBCursor(msg1, msg2), baseDN1));
96 of(msg2, baseDN1));
103 newCompositeDBCursor(of(new SequentialDBCursor(msg1, msg2, msg3), baseDN1));
106 of(msg2, baseDN1),
123 of(new SequentialDBCursor(msg2), baseDN1),
127 of(msg2, baseDN1));
134 of(new SequentialDBCursor(msg2, msg3), baseDN1),
138 of(msg2, baseDN
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/changelog/file/
H A DCompositeDBCursorTest.java53 private UpdateMsg msg2; field in class:CompositeDBCursorTest
65 msg2 = new FakeUpdateMsg(2);
92 newCompositeDBCursor(of(new SequentialDBCursor(msg1, msg2), baseDN1));
95 of(msg2, baseDN1));
102 newCompositeDBCursor(of(new SequentialDBCursor(msg1, msg2, msg3), baseDN1));
105 of(msg2, baseDN1),
122 of(new SequentialDBCursor(msg2), baseDN1),
126 of(msg2, baseDN1));
133 of(new SequentialDBCursor(msg2, msg3), baseDN1),
137 of(msg2, baseDN
[all...]
H A DECLMultiDomainDBCursorTest.java180 private void assertMessagesInOrder(DN baseDN, UpdateMsg msg1, UpdateMsg msg2) throws Exception argument
191 if (msg2 != null)
194 assertThat(eclCursor.getRecord()).isEqualTo(msg2);
/forgerock/opendj2/ext/xalan-j/
H A Dserializer.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/xml/ org/apache/xml/serializer/ ...
/forgerock/opendj-b2.6/ext/xalan-j/
H A Dserializer.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/xml/ org/apache/xml/serializer/ ...
/forgerock/opendj2.6.2/ext/xalan-j/
H A Dserializer.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/xml/ org/apache/xml/serializer/ ...
/forgerock/opendj2-jel-hg/ext/xalan-j/
H A Dserializer.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/xml/ org/apache/xml/serializer/ ...
/forgerock/opendj2-hg/ext/xalan-j/
H A Dserializer.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/xml/ org/apache/xml/serializer/ ...
/forgerock/opendj-v3/opendj-server-legacy/ext/xalan-j/
H A Dserializer.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/xml/ org/apache/xml/serializer/ ...
/forgerock/opendj2/ext/ant/lib/
H A Dant.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/tools/ org/apache/tools/ant/ ...
/forgerock/opendj-b2.6/ext/ant/lib/
H A Dant.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/tools/ org/apache/tools/ant/ ...
/forgerock/opendj2.6.2/ext/ant/lib/
H A Dant.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/tools/ org/apache/tools/ant/ ...
/forgerock/opendj2-hg/ext/ant/lib/
H A Dant.jarMETA-INF/ META-INF/MANIFEST.MF org/ org/apache/ org/apache/tools/ org/apache/tools/ant/ ...

Completed in 107 milliseconds

12