/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | InitializeRcvAckMsg.java | 45 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 D | WindowMsg.java | 45 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 D | InitializeRcvAckMsg.java | 42 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 D | WindowMsg.java | 42 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 D | InitializeRcvAckMsg.java | 45 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 D | WindowMsg.java | 45 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 D | InitializeRcvAckMsg.java | 45 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 D | WindowMsg.java | 45 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 D | InitializeRcvAckMsg.java | 42 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 D | WindowMsg.java | 42 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 D | InitializeRcvAckMsg.java | 42 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 D | WindowMsg.java | 42 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 D | ReplicationDomain.java | 1246 * @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 D | ReplicationDomain.java | 1346 * @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 D | ReplicationDomain.java | 1247 * @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 D | ReplicationDomain.java | 1246 * @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 D | ReplicationDomain.java | 1346 * @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 D | ReplicationDomain.java | 1313 * @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);
|