Searched defs:numAck (Results 1 - 18 of 18) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DInitializeRcvAckMsg.java45 private final int numAck; field in class:InitializeRcvAckMsg
53 * @param numAck The number of acknowledged messages.
56 public InitializeRcvAckMsg(int sender, int destination, int numAck) argument
59 this.numAck = numAck;
96 numAck = Integer.parseInt(numAckStr);
112 byte[] byteNumAck = String.valueOf(numAck).getBytes("UTF-8");
149 " msgID=" + this.numAck + "]";
159 return numAck;
H A DWindowMsg.java45 private final int numAck; field in class:WindowMsg
51 * @param numAck The number of acknowledged messages.
54 public WindowMsg(int numAck) argument
56 this.numAck = numAck;
70 * <numAck>
86 numAck = Integer.parseInt(numAckStr);
101 * <numAck>
104 byte[] byteNumAck = String.valueOf(numAck).getBytes("UTF-8");
132 return numAck;
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DInitializeRcvAckMsg.java42 private final int numAck; field in class:InitializeRcvAckMsg
49 * @param numAck The number of acknowledged messages.
52 public InitializeRcvAckMsg(int sender, int destination, int numAck) argument
55 this.numAck = numAck;
76 numAck = scanner.nextIntUTF8();
87 builder.appendIntUTF8(numAck);
98 " msgID=" + this.numAck + "]";
108 return numAck;
H A DWindowMsg.java42 private final int numAck; field in class:WindowMsg
47 * @param numAck The number of acknowledged messages.
50 public WindowMsg(int numAck) argument
52 this.numAck = numAck;
72 numAck = scanner.nextIntUTF8();
81 builder.appendIntUTF8(numAck);
92 return numAck;
99 return "WindowMsg : " + "numAck: " + numAck;
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DInitializeRcvAckMsg.java45 private final int numAck; field in class:InitializeRcvAckMsg
53 * @param numAck The number of acknowledged messages.
56 public InitializeRcvAckMsg(int sender, int destination, int numAck) argument
59 this.numAck = numAck;
96 numAck = Integer.parseInt(numAckStr);
112 byte[] byteNumAck = String.valueOf(numAck).getBytes("UTF-8");
149 " msgID=" + this.numAck + "]";
159 return numAck;
H A DWindowMsg.java45 private final int numAck; field in class:WindowMsg
51 * @param numAck The number of acknowledged messages.
54 public WindowMsg(int numAck) argument
56 this.numAck = numAck;
70 * <numAck>
86 numAck = Integer.parseInt(numAckStr);
101 * <numAck>
104 byte[] byteNumAck = String.valueOf(numAck).getBytes("UTF-8");
132 return numAck;
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DInitializeRcvAckMsg.java45 private final int numAck; field in class:InitializeRcvAckMsg
53 * @param numAck The number of acknowledged messages.
56 public InitializeRcvAckMsg(int sender, int destination, int numAck) argument
59 this.numAck = numAck;
96 numAck = Integer.parseInt(numAckStr);
112 byte[] byteNumAck = String.valueOf(numAck).getBytes("UTF-8");
149 " msgID=" + this.numAck + "]";
159 return numAck;
H A DWindowMsg.java45 private final int numAck; field in class:WindowMsg
51 * @param numAck The number of acknowledged messages.
54 public WindowMsg(int numAck) argument
56 this.numAck = numAck;
70 * <numAck>
86 numAck = Integer.parseInt(numAckStr);
101 * <numAck>
104 byte[] byteNumAck = String.valueOf(numAck).getBytes("UTF-8");
132 return numAck;
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DInitializeRcvAckMsg.java42 private final int numAck; field in class:InitializeRcvAckMsg
49 * @param numAck The number of acknowledged messages.
52 public InitializeRcvAckMsg(int sender, int destination, int numAck) argument
55 this.numAck = numAck;
76 numAck = scanner.nextIntUTF8();
87 builder.appendIntUTF8(numAck);
98 " msgID=" + this.numAck + "]";
108 return numAck;
H A DWindowMsg.java42 private final int numAck; field in class:WindowMsg
47 * @param numAck The number of acknowledged messages.
50 public WindowMsg(int numAck) argument
52 this.numAck = numAck;
72 numAck = scanner.nextIntUTF8();
81 builder.appendIntUTF8(numAck);
92 return numAck;
99 return "WindowMsg : " + "numAck: " + numAck;
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DInitializeRcvAckMsg.java42 private final int numAck; field in class:InitializeRcvAckMsg
49 * @param numAck The number of acknowledged messages.
52 public InitializeRcvAckMsg(int sender, int destination, int numAck) argument
55 this.numAck = numAck;
76 numAck = scanner.nextIntUTF8();
87 builder.appendIntUTF8(numAck);
98 " msgID=" + this.numAck + "]";
108 return numAck;
H A DWindowMsg.java42 private final int numAck; field in class:WindowMsg
47 * @param numAck The number of acknowledged messages.
50 public WindowMsg(int numAck) argument
52 this.numAck = numAck;
72 numAck = scanner.nextIntUTF8();
81 builder.appendIntUTF8(numAck);
92 return numAck;
99 return "WindowMsg : " + "numAck: " + numAck;
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java1246 * @param numAck id of the message received.
1248 public void setAckVal(int serverId, int numAck) argument
1251 TRACER.debugInfo("[IE] setAckVal[" + serverId + "]=" + numAck);
1253 this.ackVals.put(serverId, numAck);
/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java1346 * @param numAck id of the message received.
1348 private void setAckVal(int serverId, int numAck) argument
1351 TRACER.debugInfo("[IE] setAckVal[" + serverId + "]=" + numAck);
1353 this.ackVals.put(serverId, numAck);
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java1247 * @param numAck id of the message received.
1249 public void setAckVal(int serverId, int numAck) argument
1252 TRACER.debugInfo("[IE] setAckVal[" + serverId + "]=" + numAck);
1254 this.ackVals.put(serverId, numAck);
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java1246 * @param numAck id of the message received.
1248 public void setAckVal(int serverId, int numAck) argument
1251 TRACER.debugInfo("[IE] setAckVal[" + serverId + "]=" + numAck);
1253 this.ackVals.put(serverId, numAck);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java1346 * @param numAck id of the message received.
1348 private void setAckVal(int serverId, int numAck) argument
1351 TRACER.debugInfo("[IE] setAckVal[" + serverId + "]=" + numAck);
1353 this.ackVals.put(serverId, numAck);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationDomain.java1313 * @param numAck id of the message received.
1315 private void setAckVal(int serverId, int numAck) argument
1319 logger.trace("[IE] setAckVal[" + serverId + "]=" + numAck);
1322 this.ackVals.put(serverId, numAck);

Completed in 80 milliseconds