Searched refs:ReplServerStartDSMsg (Results 26 - 36 of 36) sorted by relevance

12

/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java379 * ReplServerStartMsg (V3) or a ReplServerStartDSMsg (V4). This can also be
435 else if (msg instanceof ReplServerStartDSMsg)
438 return new ReplicationServerInfo((ReplServerStartDSMsg) msg);
468 * {@link ReplServerStartDSMsg}.
471 * The {@link ReplServerStartDSMsg} this object will wrap.
473 private ReplicationServerInfo(ReplServerStartDSMsg msg)
737 * DS <--- ReplServerStartDSMsg --- RS
1107 // Read the ReplServerStartMsg or ReplServerStartDSMsg that should
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationBroker.java370 * ReplServerStartMsg (V3) or a ReplServerStartDSMsg (V4). This can also be
426 else if (msg instanceof ReplServerStartDSMsg)
429 return new ReplicationServerInfo((ReplServerStartDSMsg) msg);
459 * {@link ReplServerStartDSMsg}.
462 * The {@link ReplServerStartDSMsg} this object will wrap.
464 private ReplicationServerInfo(ReplServerStartDSMsg msg)
727 * DS <--- ReplServerStartDSMsg --- RS
1092 // Read the ReplServerStartMsg or ReplServerStartDSMsg that should
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java920 * Test that ReplServerStartDSMsg encoding and decoding works
928 ReplServerStartDSMsg msg = new ReplServerStartDSMsg(serverId,
931 ReplServerStartDSMsg newMsg = new ReplServerStartDSMsg(msg.getBytes(getCurrentVersion()));
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java920 * Test that ReplServerStartDSMsg encoding and decoding works
928 ReplServerStartDSMsg msg = new ReplServerStartDSMsg(serverId,
931 ReplServerStartDSMsg newMsg = new ReplServerStartDSMsg(msg.getBytes(getCurrentVersion()));
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/
H A DSynchronizationMsgTest.java920 * Test that ReplServerStartDSMsg encoding and decoding works
928 ReplServerStartDSMsg msg = new ReplServerStartDSMsg(serverId,
931 ReplServerStartDSMsg newMsg = new ReplServerStartDSMsg(msg.getBytes(getCurrentVersion()));
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java981 // Read the Replication Server state from the ReplServerStartDSMsg that
983 ReplServerStartDSMsg replStartDSMsg =
984 (ReplServerStartDSMsg) session.receive();
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java981 // Read the Replication Server state from the ReplServerStartDSMsg that
983 ReplServerStartDSMsg replStartDSMsg =
984 (ReplServerStartDSMsg) session.receive();
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java981 // Read the Replication Server state from the ReplServerStartDSMsg that
983 ReplServerStartDSMsg replStartDSMsg =
984 (ReplServerStartDSMsg) session.receive();
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DECLServerHandler.java373 // Peer DS uses protocol V4 : send it a ReplServerStartDSMsg
374 startMsg = new ReplServerStartDSMsg(replicationServerId,
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DECLServerHandler.java373 // Peer DS uses protocol V4 : send it a ReplServerStartDSMsg
374 startMsg = new ReplServerStartDSMsg(replicationServerId,
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DECLServerHandler.java373 // Peer DS uses protocol V4 : send it a ReplServerStartDSMsg
374 startMsg = new ReplServerStartDSMsg(replicationServerId,

Completed in 629 milliseconds

12