Searched refs:InitializeTargetMsg (Results 1 - 25 of 52) sorted by relevance

123

/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DInitializeTargetMsg.java38 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 DReplicationMsg.java88 // EntryMsg, InitializeRequestMsg, InitializeTargetMsg, ErrorMsg
172 return new InitializeTargetMsg(buffer, protocolVersion);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DInitializeTargetMsg.java38 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 DReplicationMsg.java88 // 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 DInitializeTargetMsg.java38 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 DReplicationMsg.java88 // EntryMsg, InitializeRequestMsg, InitializeTargetMsg, ErrorMsg
172 return new InitializeTargetMsg(buffer, protocolVersion);
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DInitializeTargetMsg.java38 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 DReplicationMsg.java87 // EntryMsg, InitializeRequestMsg, InitializeTargetMsg, ErrorMsg
177 return new InitializeTargetMsg(buffer, protocolVersion);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DInitializeTargetMsg.java38 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 DReplicationMsg.java87 // EntryMsg, InitializeRequestMsg, InitializeTargetMsg, ErrorMsg
177 return new InitializeTargetMsg(buffer, protocolVersion);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DInitializeTargetMsg.java38 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 DReplicationMsg.java87 // EntryMsg, InitializeRequestMsg, InitializeTargetMsg, ErrorMsg
177 return new InitializeTargetMsg(buffer, protocolVersion);
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DServerReader.java199 } else if (msg instanceof InitializeTargetMsg)
201 InitializeTargetMsg initializeMsg = (InitializeTargetMsg) msg;
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DServerReader.java199 } 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 DInitOnLineTest.java72 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 DInitOnLineTest.java72 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 DInitOnLineTest.java72 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 DProtocolCompatibilityTest.java1319 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 DProtocolCompatibilityTest.java1223 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 DProtocolCompatibilityTest.java1319 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 DProtocolCompatibilityTest.java1223 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 DProtocolCompatibilityTest.java1319 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 DProtocolCompatibilityTest.java1227 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 DInitOnLineTest.java396 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 DInitOnLineTest.java396 new InitializeTargetMsg(baseDN, server2ID, destinationServerID,
428 if (msg instanceof InitializeTargetMsg)
1044 while (!(msgrcv instanceof InitializeTargetMsg));
1045 Assertions.assertThat(msgrcv).isInstanceOf(InitializeTargetMsg.class);

Completed in 146 milliseconds

123