Searched refs:ChangeStatusMsg (Results 1 - 25 of 54) sorted by relevance

123

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DChangeStatusMsg.java38 public class ChangeStatusMsg extends ReplicationMsg class in inherits:ReplicationMsg
46 * Create a new ChangeStatusMsg.
51 public ChangeStatusMsg(ServerStatus requestedStatus, ServerStatus newStatus) method in class:ChangeStatusMsg
58 * Creates a new ChangeStatusMsg from its encoded form.
61 * ChangeStatusMsg.
63 * encoded form of the ChangeStatusMsg.
65 public ChangeStatusMsg(byte[] encodedMsg) throws DataFormatException method in class:ChangeStatusMsg
139 return "ChangeStatusMsg content:" +
H A DReplicationMsg.java197 return new ChangeStatusMsg(buffer);
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DChangeStatusMsg.java38 public class ChangeStatusMsg extends ReplicationMsg class in inherits:ReplicationMsg
46 * Create a new ChangeStatusMsg.
51 public ChangeStatusMsg(ServerStatus requestedStatus, ServerStatus newStatus) method in class:ChangeStatusMsg
58 * Creates a new ChangeStatusMsg from its encoded form.
61 * ChangeStatusMsg.
63 * encoded form of the ChangeStatusMsg.
65 ChangeStatusMsg(byte[] encodedMsg) throws DataFormatException method in class:ChangeStatusMsg
123 return "ChangeStatusMsg content:" +
H A DReplicationMsg.java192 return new ChangeStatusMsg(buffer);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DChangeStatusMsg.java38 public class ChangeStatusMsg extends ReplicationMsg class in inherits:ReplicationMsg
46 * Create a new ChangeStatusMsg.
51 public ChangeStatusMsg(ServerStatus requestedStatus, ServerStatus newStatus) method in class:ChangeStatusMsg
58 * Creates a new ChangeStatusMsg from its encoded form.
61 * ChangeStatusMsg.
63 * encoded form of the ChangeStatusMsg.
65 public ChangeStatusMsg(byte[] encodedMsg) throws DataFormatException method in class:ChangeStatusMsg
139 return "ChangeStatusMsg content:" +
H A DReplicationMsg.java197 return new ChangeStatusMsg(buffer);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DChangeStatusMsg.java38 public class ChangeStatusMsg extends ReplicationMsg class in inherits:ReplicationMsg
46 * Create a new ChangeStatusMsg.
51 public ChangeStatusMsg(ServerStatus requestedStatus, ServerStatus newStatus) method in class:ChangeStatusMsg
58 * Creates a new ChangeStatusMsg from its encoded form.
61 * ChangeStatusMsg.
63 * encoded form of the ChangeStatusMsg.
65 public ChangeStatusMsg(byte[] encodedMsg) throws DataFormatException method in class:ChangeStatusMsg
139 return "ChangeStatusMsg content:" +
H A DReplicationMsg.java197 return new ChangeStatusMsg(buffer);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DChangeStatusMsg.java38 public class ChangeStatusMsg extends ReplicationMsg class in inherits:ReplicationMsg
46 * Create a new ChangeStatusMsg.
51 public ChangeStatusMsg(ServerStatus requestedStatus, ServerStatus newStatus) method in class:ChangeStatusMsg
58 * Creates a new ChangeStatusMsg from its encoded form.
61 * ChangeStatusMsg.
63 * encoded form of the ChangeStatusMsg.
65 ChangeStatusMsg(byte[] encodedMsg) throws DataFormatException method in class:ChangeStatusMsg
123 return "ChangeStatusMsg content:" +
H A DReplicationMsg.java192 return new ChangeStatusMsg(buffer);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DChangeStatusMsg.java38 public class ChangeStatusMsg extends ReplicationMsg class in inherits:ReplicationMsg
46 * Create a new ChangeStatusMsg.
51 public ChangeStatusMsg(ServerStatus requestedStatus, ServerStatus newStatus) method in class:ChangeStatusMsg
58 * Creates a new ChangeStatusMsg from its encoded form.
61 * ChangeStatusMsg.
63 * encoded form of the ChangeStatusMsg.
65 ChangeStatusMsg(byte[] encodedMsg) throws DataFormatException method in class:ChangeStatusMsg
123 return "ChangeStatusMsg content:" +
H A DReplicationMsg.java192 return new ChangeStatusMsg(buffer);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DServerReader.java151 else if (msg instanceof ChangeStatusMsg)
153 ChangeStatusMsg csMsg = (ChangeStatusMsg) msg;
H A DDataServerHandler.java137 + " so no ChangeStatusMsg sent to him.");
210 ChangeStatusMsg csMsg = new ChangeStatusMsg(newStatus, INVALID_STATUS);
303 public ServerStatus processNewStatus(ChangeStatusMsg csMsg)
623 public void receiveNewStatus(ChangeStatusMsg csMsg)
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DDataServerHandler.java176 " so no ChangeStatusMsg sent to him.");
215 ChangeStatusMsg csMsg = new ChangeStatusMsg(newStatus,
258 ChangeStatusMsg csMsg = new ChangeStatusMsg(newStatus,
377 public ServerStatus processNewStatus(ChangeStatusMsg csMsg)
773 public void receiveNewStatus(ChangeStatusMsg csMsg)
H A DServerReader.java228 } else if (msg instanceof ChangeStatusMsg)
230 ChangeStatusMsg csMsg = (ChangeStatusMsg) msg;
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DDataServerHandler.java175 " so no ChangeStatusMsg sent to him.");
214 ChangeStatusMsg csMsg = new ChangeStatusMsg(newStatus,
257 ChangeStatusMsg csMsg = new ChangeStatusMsg(newStatus,
368 public ServerStatus processNewStatus(ChangeStatusMsg csMsg)
737 public void receiveNewStatus(ChangeStatusMsg csMsg)
H A DServerReader.java219 } else if (msg instanceof ChangeStatusMsg)
221 ChangeStatusMsg csMsg = (ChangeStatusMsg) msg;
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DDataServerHandler.java176 " so no ChangeStatusMsg sent to him.");
215 ChangeStatusMsg csMsg = new ChangeStatusMsg(newStatus,
258 ChangeStatusMsg csMsg = new ChangeStatusMsg(newStatus,
377 public ServerStatus processNewStatus(ChangeStatusMsg csMsg)
773 public void receiveNewStatus(ChangeStatusMsg csMsg)
H A DServerReader.java228 } else if (msg instanceof ChangeStatusMsg)
230 ChangeStatusMsg csMsg = (ChangeStatusMsg) msg;
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DServerReader.java153 } else if (msg instanceof ChangeStatusMsg)
155 ChangeStatusMsg csMsg = (ChangeStatusMsg) msg;
H A DDataServerHandler.java140 + " so no ChangeStatusMsg sent to him.");
216 ChangeStatusMsg csMsg = new ChangeStatusMsg(newStatus, INVALID_STATUS);
316 public ServerStatus processNewStatus(ChangeStatusMsg csMsg)
655 public void receiveNewStatus(ChangeStatusMsg csMsg)
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DServerReader.java153 } else if (msg instanceof ChangeStatusMsg)
155 ChangeStatusMsg csMsg = (ChangeStatusMsg) msg;
H A DDataServerHandler.java140 + " so no ChangeStatusMsg sent to him.");
216 ChangeStatusMsg csMsg = new ChangeStatusMsg(newStatus, INVALID_STATUS);
316 public ServerStatus processNewStatus(ChangeStatusMsg csMsg)
655 public void receiveNewStatus(ChangeStatusMsg csMsg)
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DGenerationIdTest.java895 ChangeStatusMsg csMsg = (ChangeStatusMsg)waitForSpecificMsg(broker2,
896 ChangeStatusMsg.class.getName());
899 fail("Broker 2 connection is expected to receive 1 ChangeStatusMsg" +
903 csMsg = (ChangeStatusMsg)waitForSpecificMsg(broker3,
904 ChangeStatusMsg.class.getName());
907 fail("Broker 2 connection is expected to receive 1 ChangeStatusMsg" +

Completed in 114 milliseconds

123