Searched refs:WindowMsg (Results 1 - 25 of 42) sorted by relevance

12

/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DWindowMsg.java40 public class WindowMsg extends ReplicationMsg class in inherits:ReplicationMsg
45 * Create a new WindowMsg.
50 public WindowMsg(int numAck) method in class:WindowMsg
56 * Creates a new WindowMsg from its encoded form.
59 * WindowMsg.
61 * encoded form of the WindowMsg.
63 WindowMsg(byte[] in) throws DataFormatException method in class:WindowMsg
99 return "WindowMsg : " + "numAck: " + numAck;
H A DReplicationMsg.java166 return new WindowMsg(buffer);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DWindowMsg.java40 public class WindowMsg extends ReplicationMsg class in inherits:ReplicationMsg
45 * Create a new WindowMsg.
50 public WindowMsg(int numAck) method in class:WindowMsg
56 * Creates a new WindowMsg from its encoded form.
59 * WindowMsg.
61 * encoded form of the WindowMsg.
63 WindowMsg(byte[] in) throws DataFormatException method in class:WindowMsg
99 return "WindowMsg : " + "numAck: " + numAck;
H A DReplicationMsg.java166 return new WindowMsg(buffer);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DWindowMsg.java40 public class WindowMsg extends ReplicationMsg class in inherits:ReplicationMsg
45 * Create a new WindowMsg.
50 public WindowMsg(int numAck) method in class:WindowMsg
56 * Creates a new WindowMsg from its encoded form.
59 * WindowMsg.
61 * encoded form of the WindowMsg.
63 WindowMsg(byte[] in) throws DataFormatException method in class:WindowMsg
99 return "WindowMsg : " + "numAck: " + numAck;
H A DReplicationMsg.java166 return new WindowMsg(buffer);
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DWindowMsg.java43 public class WindowMsg extends ReplicationMsg class in inherits:ReplicationMsg
49 * Create a new WindowMsg.
54 public WindowMsg(int numAck) method in class:WindowMsg
60 * Creates a new WindowMsg from its encoded form.
63 * WindowMsg.
65 * encoded form of the WindowMsg.
67 public WindowMsg(byte[] in) throws DataFormatException method in class:WindowMsg
69 /* The WindowMsg is encoded in the form :
100 * WindowMsg contains.
141 return "WindowMsg
[all...]
H A DReplicationMsg.java171 return new WindowMsg(buffer);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DWindowMsg.java43 public class WindowMsg extends ReplicationMsg class in inherits:ReplicationMsg
49 * Create a new WindowMsg.
54 public WindowMsg(int numAck) method in class:WindowMsg
60 * Creates a new WindowMsg from its encoded form.
63 * WindowMsg.
65 * encoded form of the WindowMsg.
67 public WindowMsg(byte[] in) throws DataFormatException method in class:WindowMsg
69 /* The WindowMsg is encoded in the form :
100 * WindowMsg contains.
141 return "WindowMsg
[all...]
H A DReplicationMsg.java171 return new WindowMsg(buffer);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DWindowMsg.java43 public class WindowMsg extends ReplicationMsg class in inherits:ReplicationMsg
49 * Create a new WindowMsg.
54 public WindowMsg(int numAck) method in class:WindowMsg
60 * Creates a new WindowMsg from its encoded form.
63 * WindowMsg.
65 * encoded form of the WindowMsg.
67 public WindowMsg(byte[] in) throws DataFormatException method in class:WindowMsg
69 /* The WindowMsg is encoded in the form :
100 * WindowMsg contains.
141 return "WindowMsg
[all...]
H A DReplicationMsg.java171 return new WindowMsg(buffer);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DServerReader.java116 else if (msg instanceof WindowMsg)
118 handler.updateWindow((WindowMsg) msg);
H A DServerHandler.java240 * Check the protocol window and send WindowMsg if necessary.
248 WindowMsg msg = new WindowMsg(rcvWindowSizeHalf);
256 * to send a WindowMsg and send it.
831 session.publish(new WindowMsg(rcvWindow));
997 public void updateWindow(WindowMsg windowMsg)
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DServerReader.java185 } else if (msg instanceof WindowMsg)
187 WindowMsg windowMsg = (WindowMsg) msg;
H A DServerHandler.java63 import org.opends.server.replication.protocol.WindowMsg;
297 * Check the protocol window and send WindowMsg if necessary.
305 WindowMsg msg = new WindowMsg(rcvWindowSizeHalf);
313 * to send a WindowMsg and send it.
957 WindowMsg msg = new WindowMsg(rcvWindow);
1141 public void updateWindow(WindowMsg windowMsg)
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DServerReader.java185 } else if (msg instanceof WindowMsg)
187 WindowMsg windowMsg = (WindowMsg) msg;
H A DServerHandler.java63 import org.opends.server.replication.protocol.WindowMsg;
297 * Check the protocol window and send WindowMsg if necessary.
305 WindowMsg msg = new WindowMsg(rcvWindowSizeHalf);
313 * to send a WindowMsg and send it.
957 WindowMsg msg = new WindowMsg(rcvWindow);
1141 public void updateWindow(WindowMsg windowMsg)
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DServerHandler.java65 import org.opends.server.replication.protocol.WindowMsg;
299 * Check the protocol window and send WindowMsg if necessary.
307 WindowMsg msg = new WindowMsg(rcvWindowSizeHalf);
315 * to send a WindowMsg and send it.
983 WindowMsg msg = new WindowMsg(rcvWindow);
1158 public void updateWindow(WindowMsg windowMsg)
H A DServerReader.java185 } else if (msg instanceof WindowMsg)
187 handler.updateWindow((WindowMsg) msg);
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DServerHandler.java256 * Check the protocol window and send WindowMsg if necessary.
264 WindowMsg msg = new WindowMsg(rcvWindowSizeHalf);
272 * to send a WindowMsg and send it.
868 session.publish(new WindowMsg(rcvWindow));
1020 public void updateWindow(WindowMsg windowMsg)
H A DServerReader.java122 else if (msg instanceof WindowMsg)
124 handler.updateWindow((WindowMsg) msg);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DServerHandler.java256 * Check the protocol window and send WindowMsg if necessary.
264 WindowMsg msg = new WindowMsg(rcvWindowSizeHalf);
272 * to send a WindowMsg and send it.
868 session.publish(new WindowMsg(rcvWindow));
1020 public void updateWindow(WindowMsg windowMsg)
H A DServerReader.java122 else if (msg instanceof WindowMsg)
124 handler.updateWindow((WindowMsg) msg);
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplicationServerTest.java1006 WindowMsg windowMsg = (WindowMsg)waitForSpecificMsg(session, WindowMsg.class.getName());
1013 windowMsg = (WindowMsg)waitForSpecificMsg(session, WindowMsg.class.getName());
1099 // may prevent to process a WindowMsg that would unblock the dual

Completed in 109 milliseconds

12