/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | ChangeStatusMsg.java | 38 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 D | ReplicationMsg.java | 197 return new ChangeStatusMsg(buffer);
|
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | ChangeStatusMsg.java | 38 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 D | ReplicationMsg.java | 192 return new ChangeStatusMsg(buffer);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | ChangeStatusMsg.java | 38 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 D | ReplicationMsg.java | 197 return new ChangeStatusMsg(buffer);
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | ChangeStatusMsg.java | 38 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 D | ReplicationMsg.java | 197 return new ChangeStatusMsg(buffer);
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | ChangeStatusMsg.java | 38 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 D | ReplicationMsg.java | 192 return new ChangeStatusMsg(buffer);
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
H A D | ChangeStatusMsg.java | 38 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 D | ReplicationMsg.java | 192 return new ChangeStatusMsg(buffer);
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
H A D | ServerReader.java | 151 else if (msg instanceof ChangeStatusMsg) 153 ChangeStatusMsg csMsg = (ChangeStatusMsg) msg;
|
H A D | DataServerHandler.java | 137 + " 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 D | DataServerHandler.java | 176 " 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 D | ServerReader.java | 228 } else if (msg instanceof ChangeStatusMsg) 230 ChangeStatusMsg csMsg = (ChangeStatusMsg) msg;
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | DataServerHandler.java | 175 " 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 D | ServerReader.java | 219 } else if (msg instanceof ChangeStatusMsg) 221 ChangeStatusMsg csMsg = (ChangeStatusMsg) msg;
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | DataServerHandler.java | 176 " 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 D | ServerReader.java | 228 } else if (msg instanceof ChangeStatusMsg) 230 ChangeStatusMsg csMsg = (ChangeStatusMsg) msg;
|
/forgerock/opendj2/src/server/org/opends/server/replication/server/ |
H A D | ServerReader.java | 153 } else if (msg instanceof ChangeStatusMsg) 155 ChangeStatusMsg csMsg = (ChangeStatusMsg) msg;
|
H A D | DataServerHandler.java | 140 + " 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 D | ServerReader.java | 153 } else if (msg instanceof ChangeStatusMsg) 155 ChangeStatusMsg csMsg = (ChangeStatusMsg) msg;
|
H A D | DataServerHandler.java | 140 + " 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 D | GenerationIdTest.java | 895 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" +
|