/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | InitializeTargetMsg.java | 38 public class InitializeTargetMsg extends RoutableMsg class in inherits:RoutableMsg 55 * Creates a InitializeTargetMsg. 64 public InitializeTargetMsg(DN baseDN, int serverID, method in class:InitializeTargetMsg 75 * Creates an InitializeTargetMsg by decoding the provided byte array. 81 InitializeTargetMsg(byte[] in, short version) throws DataFormatException method in class:InitializeTargetMsg
|
H A D | ReplicationMsg.java | 88 // EntryMsg, InitializeRequestMsg, InitializeTargetMsg, ErrorMsg 172 return new InitializeTargetMsg(buffer, protocolVersion);
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | InitializeTargetMsg.java | 38 public class InitializeTargetMsg extends RoutableMsg class in inherits:RoutableMsg 55 * Creates a InitializeTargetMsg. 64 public InitializeTargetMsg(DN baseDN, int serverID, method in class:InitializeTargetMsg 75 * Creates an InitializeTargetMsg by decoding the provided byte array. 81 InitializeTargetMsg(byte[] in, short version) throws DataFormatException method in class:InitializeTargetMsg
|
H A D | ReplicationMsg.java | 88 // EntryMsg, InitializeRequestMsg, InitializeTargetMsg, ErrorMsg 172 return new InitializeTargetMsg(buffer, protocolVersion);
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
H A D | InitializeTargetMsg.java | 38 public class InitializeTargetMsg extends RoutableMsg class in inherits:RoutableMsg 55 * Creates a InitializeTargetMsg. 64 public InitializeTargetMsg(DN baseDN, int serverID, method in class:InitializeTargetMsg 75 * Creates an InitializeTargetMsg by decoding the provided byte array. 81 InitializeTargetMsg(byte[] in, short version) throws DataFormatException method in class:InitializeTargetMsg
|
H A D | ReplicationMsg.java | 88 // EntryMsg, InitializeRequestMsg, InitializeTargetMsg, ErrorMsg 172 return new InitializeTargetMsg(buffer, protocolVersion);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | InitializeTargetMsg.java | 38 public class InitializeTargetMsg extends RoutableMsg class in inherits:RoutableMsg 54 * Creates a InitializeTargetMsg. 63 public InitializeTargetMsg(String baseDN, int serverID, method in class:InitializeTargetMsg 74 * Creates an InitializeTargetMsg by decoding the provided byte array. 80 public InitializeTargetMsg(byte[] in, short version) method in class:InitializeTargetMsg
|
H A D | ReplicationMsg.java | 87 // EntryMsg, InitializeRequestMsg, InitializeTargetMsg, ErrorMsg 177 return new InitializeTargetMsg(buffer, protocolVersion);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | InitializeTargetMsg.java | 38 public class InitializeTargetMsg extends RoutableMsg class in inherits:RoutableMsg 54 * Creates a InitializeTargetMsg. 63 public InitializeTargetMsg(String baseDN, int serverID, method in class:InitializeTargetMsg 74 * Creates an InitializeTargetMsg by decoding the provided byte array. 80 public InitializeTargetMsg(byte[] in, short version) method in class:InitializeTargetMsg
|
H A D | ReplicationMsg.java | 87 // EntryMsg, InitializeRequestMsg, InitializeTargetMsg, ErrorMsg 177 return new InitializeTargetMsg(buffer, protocolVersion);
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | InitializeTargetMsg.java | 38 public class InitializeTargetMsg extends RoutableMsg class in inherits:RoutableMsg 54 * Creates a InitializeTargetMsg. 63 public InitializeTargetMsg(String baseDN, int serverID, method in class:InitializeTargetMsg 74 * Creates an InitializeTargetMsg by decoding the provided byte array. 80 public InitializeTargetMsg(byte[] in, short version) method in class:InitializeTargetMsg
|
H A D | ReplicationMsg.java | 87 // EntryMsg, InitializeRequestMsg, InitializeTargetMsg, ErrorMsg 177 return new InitializeTargetMsg(buffer, protocolVersion);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | ServerReader.java | 199 } else if (msg instanceof InitializeTargetMsg) 201 InitializeTargetMsg initializeMsg = (InitializeTargetMsg) msg;
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | ServerReader.java | 199 } else if (msg instanceof InitializeTargetMsg) 201 InitializeTargetMsg initializeMsg = (InitializeTargetMsg) msg;
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | InitOnLineTest.java | 72 import org.opends.server.replication.protocol.InitializeTargetMsg; 503 new InitializeTargetMsg( 547 if (msg instanceof InitializeTargetMsg) 1283 while(!(msgrcv instanceof InitializeTargetMsg)); 1284 assertTrue(msgrcv instanceof InitializeTargetMsg, msgrcv.getClass().getCanonicalName()); 1364 log(testCase + " Wait for InitializeTargetMsg"); 1372 while (!(msgrcv instanceof InitializeTargetMsg)); 1373 assertTrue(msgrcv instanceof InitializeTargetMsg,msgrcv.getClass().getCanonicalName() +
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | InitOnLineTest.java | 72 import org.opends.server.replication.protocol.InitializeTargetMsg; 503 new InitializeTargetMsg( 547 if (msg instanceof InitializeTargetMsg) 1283 while(!(msgrcv instanceof InitializeTargetMsg)); 1284 assertTrue(msgrcv instanceof InitializeTargetMsg, msgrcv.getClass().getCanonicalName()); 1364 log(testCase + " Wait for InitializeTargetMsg"); 1372 while (!(msgrcv instanceof InitializeTargetMsg)); 1373 assertTrue(msgrcv instanceof InitializeTargetMsg,msgrcv.getClass().getCanonicalName() +
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | InitOnLineTest.java | 72 import org.opends.server.replication.protocol.InitializeTargetMsg; 503 new InitializeTargetMsg( 547 if (msg instanceof InitializeTargetMsg) 1283 while(!(msgrcv instanceof InitializeTargetMsg)); 1284 assertTrue(msgrcv instanceof InitializeTargetMsg, msgrcv.getClass().getCanonicalName()); 1364 log(testCase + " Wait for InitializeTargetMsg"); 1372 while (!(msgrcv instanceof InitializeTargetMsg)); 1373 assertTrue(msgrcv instanceof InitializeTargetMsg,msgrcv.getClass().getCanonicalName() +
|
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 1319 InitializeTargetMsg msg = new InitializeTargetMsg(baseDn, sender, dest, 1326 InitializeTargetMsg newMsg = new InitializeTargetMsg(v3MsgBytes, ProtocolVersion.REPLICATION_PROTOCOL_V3); 1342 InitializeTargetMsg vlastMsg = new InitializeTargetMsg( 1408 InitializeTargetMsg msg = new InitializeTargetMsg(hexStringToByteArray(pduV3),
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 1223 InitializeTargetMsg msg = new InitializeTargetMsg(baseDN, sender, dest, 1230 InitializeTargetMsg newMsg = new InitializeTargetMsg(v3MsgBytes, ProtocolVersion.REPLICATION_PROTOCOL_V3); 1246 InitializeTargetMsg vlastMsg = new InitializeTargetMsg( 1311 InitializeTargetMsg msg = new InitializeTargetMsg(hexStringToByteArray(pduV3),
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 1319 InitializeTargetMsg msg = new InitializeTargetMsg(baseDn, sender, dest, 1326 InitializeTargetMsg newMsg = new InitializeTargetMsg(v3MsgBytes, ProtocolVersion.REPLICATION_PROTOCOL_V3); 1342 InitializeTargetMsg vlastMsg = new InitializeTargetMsg( 1408 InitializeTargetMsg msg = new InitializeTargetMsg(hexStringToByteArray(pduV3),
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 1223 InitializeTargetMsg msg = new InitializeTargetMsg(baseDN, sender, dest, 1230 InitializeTargetMsg newMsg = new InitializeTargetMsg(v3MsgBytes, ProtocolVersion.REPLICATION_PROTOCOL_V3); 1246 InitializeTargetMsg vlastMsg = new InitializeTargetMsg( 1311 InitializeTargetMsg msg = new InitializeTargetMsg(hexStringToByteArray(pduV3),
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 1319 InitializeTargetMsg msg = new InitializeTargetMsg(baseDn, sender, dest, 1326 InitializeTargetMsg newMsg = new InitializeTargetMsg(v3MsgBytes, ProtocolVersion.REPLICATION_PROTOCOL_V3); 1342 InitializeTargetMsg vlastMsg = new InitializeTargetMsg( 1408 InitializeTargetMsg msg = new InitializeTargetMsg(hexStringToByteArray(pduV3),
|
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 1227 InitializeTargetMsg msg = new InitializeTargetMsg(baseDN, sender, dest, 1234 InitializeTargetMsg newMsg = new InitializeTargetMsg(v3MsgBytes, ProtocolVersion.REPLICATION_PROTOCOL_V3); 1250 InitializeTargetMsg vlastMsg = new InitializeTargetMsg( 1315 InitializeTargetMsg msg = new InitializeTargetMsg(hexStringToByteArray(pduV3),
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | InitOnLineTest.java | 396 new InitializeTargetMsg(baseDN, server2ID, destinationServerID, 428 if (msg instanceof InitializeTargetMsg) 1044 while (!(msgrcv instanceof InitializeTargetMsg)); 1045 Assertions.assertThat(msgrcv).isInstanceOf(InitializeTargetMsg.class);
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | InitOnLineTest.java | 396 new InitializeTargetMsg(baseDN, server2ID, destinationServerID, 428 if (msg instanceof InitializeTargetMsg) 1044 while (!(msgrcv instanceof InitializeTargetMsg)); 1045 Assertions.assertThat(msgrcv).isInstanceOf(InitializeTargetMsg.class);
|