/forgerock/opendj2/src/server/org/opends/server/replication/protocol/ |
H A D | InitializeRequestMsg.java | 42 private int initWindow = 0; field in class:InitializeRequestMsg 50 * @param initWindow initialization window for flow control 53 int initWindow) 57 this.initWindow = initWindow; // V4 82 initWindow = scanner.nextIntUTF8(); 111 builder.appendIntUTF8(initWindow); 124 + senderID + " destination=" + destination + " initWindow=" + initWindow; 128 * Return the initWindow valu 52 InitializeRequestMsg(DN baseDN, int serverID, int destination, int initWindow) argument 140 setInitWindow(int initWindow) argument [all...] |
H A D | InitializeTargetMsg.java | 52 private int initWindow; field in class:InitializeTargetMsg 62 * @param initWindow the initialization window. 65 int destination, int requestorID, long entryCount, int initWindow) 71 this.initWindow = initWindow; // V4 98 initWindow = scanner.nextIntUTF8(); 140 return this.initWindow; 160 builder.appendIntUTF8(initWindow); 166 * Set the initWindow value. 167 * @param initWindow Th 64 InitializeTargetMsg(DN baseDN, int serverID, int destination, int requestorID, long entryCount, int initWindow) argument 169 setInitWindow(int initWindow) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/ |
H A D | InitializeRequestMsg.java | 42 private int initWindow = 0; field in class:InitializeRequestMsg 50 * @param initWindow initialization window for flow control 53 int initWindow) 57 this.initWindow = initWindow; // V4 82 initWindow = scanner.nextIntUTF8(); 111 builder.appendIntUTF8(initWindow); 124 + senderID + " destination=" + destination + " initWindow=" + initWindow; 128 * Return the initWindow valu 52 InitializeRequestMsg(DN baseDN, int serverID, int destination, int initWindow) argument 140 setInitWindow(int initWindow) argument [all...] |
H A D | InitializeTargetMsg.java | 52 private int initWindow; field in class:InitializeTargetMsg 62 * @param initWindow the initialization window. 65 int destination, int requestorID, long entryCount, int initWindow) 71 this.initWindow = initWindow; // V4 98 initWindow = scanner.nextIntUTF8(); 140 return this.initWindow; 160 builder.appendIntUTF8(initWindow); 166 * Set the initWindow value. 167 * @param initWindow Th 64 InitializeTargetMsg(DN baseDN, int serverID, int destination, int requestorID, long entryCount, int initWindow) argument 169 setInitWindow(int initWindow) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/ |
H A D | InitializeRequestMsg.java | 42 private int initWindow; field in class:InitializeRequestMsg 50 * @param initWindow initialization window for flow control 53 int initWindow) 57 this.initWindow = initWindow; // V4 82 initWindow = scanner.nextIntUTF8(); 111 builder.appendIntUTF8(initWindow); 124 + senderID + " destination=" + destination + " initWindow=" + initWindow; 128 * Return the initWindow valu 52 InitializeRequestMsg(DN baseDN, int serverID, int destination, int initWindow) argument 140 setInitWindow(int initWindow) argument [all...] |
H A D | InitializeTargetMsg.java | 52 private int initWindow; field in class:InitializeTargetMsg 62 * @param initWindow the initialization window. 65 int destination, int requestorID, long entryCount, int initWindow) 71 this.initWindow = initWindow; // V4 98 initWindow = scanner.nextIntUTF8(); 140 return this.initWindow; 160 builder.appendIntUTF8(initWindow); 166 * Set the initWindow value. 167 * @param initWindow Th 64 InitializeTargetMsg(DN baseDN, int serverID, int destination, int requestorID, long entryCount, int initWindow) argument 169 setInitWindow(int initWindow) argument [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | InitializeRequestMsg.java | 45 private int initWindow = 0; field in class:InitializeRequestMsg 53 * @param initWindow initialization window for flow control 56 int initWindow) 60 this.initWindow = initWindow; // V4 104 initWindow = Integer.valueOf(initWindowString); 152 initWindowBytes = String.valueOf(initWindow).getBytes("UTF-8"); 192 " destination=" + destination + " initWindow=" + initWindow; 196 * Return the initWindow valu 55 InitializeRequestMsg(String baseDn, int serverID, int destination, int initWindow) argument 208 setInitWindow(int initWindow) argument [all...] |
H A D | InitializeTargetMsg.java | 51 private int initWindow; field in class:InitializeTargetMsg 61 * @param initWindow the initialization window. 64 int target, int target2, long entryCount, int initWindow) 70 this.initWindow = initWindow; // V4 126 initWindow = Integer.valueOf(initWindowString); 174 return this.initWindow; 204 byteInitWindow = String.valueOf(initWindow).getBytes("UTF-8"); 231 /* put the initWindow */ 244 * Set the initWindow valu 63 InitializeTargetMsg(String baseDN, int serverID, int target, int target2, long entryCount, int initWindow) argument 247 setInitWindow(int initWindow) argument [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | InitializeRequestMsg.java | 45 private int initWindow = 0; field in class:InitializeRequestMsg 53 * @param initWindow initialization window for flow control 56 int initWindow) 60 this.initWindow = initWindow; // V4 104 initWindow = Integer.valueOf(initWindowString); 152 initWindowBytes = String.valueOf(initWindow).getBytes("UTF-8"); 192 " destination=" + destination + " initWindow=" + initWindow; 196 * Return the initWindow valu 55 InitializeRequestMsg(String baseDn, int serverID, int destination, int initWindow) argument 208 setInitWindow(int initWindow) argument [all...] |
H A D | InitializeTargetMsg.java | 51 private int initWindow; field in class:InitializeTargetMsg 61 * @param initWindow the initialization window. 64 int target, int target2, long entryCount, int initWindow) 70 this.initWindow = initWindow; // V4 126 initWindow = Integer.valueOf(initWindowString); 174 return this.initWindow; 204 byteInitWindow = String.valueOf(initWindow).getBytes("UTF-8"); 231 /* put the initWindow */ 244 * Set the initWindow valu 63 InitializeTargetMsg(String baseDN, int serverID, int target, int target2, long entryCount, int initWindow) argument 247 setInitWindow(int initWindow) argument [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/ |
H A D | InitializeRequestMsg.java | 45 private int initWindow = 0; field in class:InitializeRequestMsg 53 * @param initWindow initialization window for flow control 56 int initWindow) 60 this.initWindow = initWindow; // V4 104 initWindow = Integer.valueOf(initWindowString); 152 initWindowBytes = String.valueOf(initWindow).getBytes("UTF-8"); 192 " destination=" + destination + " initWindow=" + initWindow; 196 * Return the initWindow valu 55 InitializeRequestMsg(String baseDn, int serverID, int destination, int initWindow) argument 208 setInitWindow(int initWindow) argument [all...] |
H A D | InitializeTargetMsg.java | 51 private int initWindow; field in class:InitializeTargetMsg 61 * @param initWindow the initialization window. 64 int target, int target2, long entryCount, int initWindow) 70 this.initWindow = initWindow; // V4 126 initWindow = Integer.valueOf(initWindowString); 174 return this.initWindow; 204 byteInitWindow = String.valueOf(initWindow).getBytes("UTF-8"); 231 /* put the initWindow */ 244 * Set the initWindow valu 63 InitializeTargetMsg(String baseDN, int serverID, int target, int target2, long entryCount, int initWindow) argument 247 setInitWindow(int initWindow) argument [all...] |
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 248 protected int initWindow = 100; field in class:ReplicationDomain 308 * @param initWindow Window used during initialization. 310 public ReplicationDomain(String serviceID, int serverID,int initWindow) argument 314 this.initWindow = initWindow; 1017 private final int initWindow; field in class:ReplicationDomain.ExportThread 1026 * @param initWindow 1030 public ExportThread(int serverToInitialize, int initWindow) argument 1035 this.initWindow = initWindow; 1123 int initWindow; field in class:ReplicationDomain.IEContext 1352 initializeRemote(int serverToInitialize, int serverRunningTheTask, Task initTask, int initWindow) argument [all...] |
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 249 protected int initWindow = 100; field in class:ReplicationDomain 309 * @param initWindow Window used during initialization. 311 public ReplicationDomain(String serviceID, int serverID,int initWindow) argument 315 this.initWindow = initWindow; 1018 private final int initWindow; field in class:ReplicationDomain.ExportThread 1027 * @param initWindow 1031 public ExportThread(int serverToInitialize, int initWindow) argument 1036 this.initWindow = initWindow; 1124 int initWindow; field in class:ReplicationDomain.IEContext 1353 initializeRemote(int serverToInitialize, int serverRunningTheTask, Task initTask, int initWindow) argument [all...] |
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 248 protected int initWindow = 100; field in class:ReplicationDomain 308 * @param initWindow Window used during initialization. 310 public ReplicationDomain(String serviceID, int serverID,int initWindow) argument 314 this.initWindow = initWindow; 1017 private final int initWindow; field in class:ReplicationDomain.ExportThread 1026 * @param initWindow 1030 public ExportThread(int serverToInitialize, int initWindow) argument 1035 this.initWindow = initWindow; 1123 int initWindow; field in class:ReplicationDomain.IEContext 1352 initializeRemote(int serverToInitialize, int serverRunningTheTask, Task initTask, int initWindow) argument [all...] |
/forgerock/opendj2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 565 * @return the initWindow 1059 private final int initWindow; field in class:ReplicationDomain.ExportThread 1068 * @param initWindow 1072 public ExportThread(int serverIdToInitialize, int initWindow) argument 1077 this.initWindow = initWindow; 1093 initWindow); 1179 private int initWindow; field in class:ReplicationDomain.ImportExportContext 1453 * @param initWindow The value of the initialization window for flow control 1460 int serverRunningTheTask, Task initTask, int initWindow) 1459 initializeRemote(int serverToInitialize, int serverRunningTheTask, Task initTask, int initWindow) argument [all...] |
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 565 * @return the initWindow 1059 private final int initWindow; field in class:ReplicationDomain.ExportThread 1068 * @param initWindow 1072 public ExportThread(int serverIdToInitialize, int initWindow) argument 1077 this.initWindow = initWindow; 1093 initWindow); 1179 private int initWindow; field in class:ReplicationDomain.ImportExportContext 1453 * @param initWindow The value of the initialization window for flow control 1460 int serverRunningTheTask, Task initTask, int initWindow) 1459 initializeRemote(int serverToInitialize, int serverRunningTheTask, Task initTask, int initWindow) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/ |
H A D | ReplicationDomain.java | 535 * @return the initWindow 1029 private final int initWindow; field in class:ReplicationDomain.ExportThread 1038 * @param initWindow 1042 public ExportThread(int serverIdToInitialize, int initWindow) argument 1047 this.initWindow = initWindow; 1065 initWindow); 1146 private int initWindow; field in class:ReplicationDomain.ImportExportContext 1424 * @param initWindow The value of the initialization window for flow control 1431 int serverRunningTheTask, Task initTask, int initWindow) 1430 initializeRemote(int serverToInitialize, int serverRunningTheTask, Task initTask, int initWindow) argument [all...] |
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 1250 int initWindow = 22; 1251 Object[] set1 = new Object[] {sender, dest, baseDn, initWindow }; 1261 String baseDn, int initWindow) 1265 InitializeRequestMsg msg = new InitializeRequestMsg(baseDn, sender, dest, initWindow); 1282 newMsg.setInitWindow(initWindow); 1303 int initWindow = 22; 1305 entryCount, initWindow }; 1315 int initiator, String baseDn, int entryCount, int initWindow) 1320 initiator, entryCount, initWindow); 1339 newMsg.setInitWindow(initWindow); 1260 initializationRequestMsgTestVLASTV3(int sender, int dest, String baseDn, int initWindow) argument 1314 initializeTargetMsgTestVLASTV3(int sender, int dest, int initiator, String baseDn, int entryCount, int initWindow) argument [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 1152 int initWindow = 22; 1155 { sender, dest, baseDN, initWindow }, 1165 DN baseDN, int initWindow) throws Exception 1168 InitializeRequestMsg msg = new InitializeRequestMsg(baseDN, sender, dest, initWindow); 1185 newMsg.setInitWindow(initWindow); 1206 int initWindow = 22; 1209 { sender, dest, initiator, baseDN, entryCount, initWindow }, 1219 int initiator, DN baseDN, int entryCount, int initWindow) 1224 initiator, entryCount, initWindow); 1243 newMsg.setInitWindow(initWindow); 1164 initializationRequestMsgTestVLASTV3(int sender, int dest, DN baseDN, int initWindow) argument 1218 initializeTargetMsgTestVLASTV3(int sender, int dest, int initiator, DN baseDN, int entryCount, int initWindow) argument [all...] |
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 1250 int initWindow = 22; 1251 Object[] set1 = new Object[] {sender, dest, baseDn, initWindow }; 1261 String baseDn, int initWindow) 1265 InitializeRequestMsg msg = new InitializeRequestMsg(baseDn, sender, dest, initWindow); 1282 newMsg.setInitWindow(initWindow); 1303 int initWindow = 22; 1305 entryCount, initWindow }; 1315 int initiator, String baseDn, int entryCount, int initWindow) 1320 initiator, entryCount, initWindow); 1339 newMsg.setInitWindow(initWindow); 1260 initializationRequestMsgTestVLASTV3(int sender, int dest, String baseDn, int initWindow) argument 1314 initializeTargetMsgTestVLASTV3(int sender, int dest, int initiator, String baseDn, int entryCount, int initWindow) argument [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 1152 int initWindow = 22; 1155 { sender, dest, baseDN, initWindow }, 1165 DN baseDN, int initWindow) throws Exception 1168 InitializeRequestMsg msg = new InitializeRequestMsg(baseDN, sender, dest, initWindow); 1185 newMsg.setInitWindow(initWindow); 1206 int initWindow = 22; 1209 { sender, dest, initiator, baseDN, entryCount, initWindow }, 1219 int initiator, DN baseDN, int entryCount, int initWindow) 1224 initiator, entryCount, initWindow); 1243 newMsg.setInitWindow(initWindow); 1164 initializationRequestMsgTestVLASTV3(int sender, int dest, DN baseDN, int initWindow) argument 1218 initializeTargetMsgTestVLASTV3(int sender, int dest, int initiator, DN baseDN, int entryCount, int initWindow) argument [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 1250 int initWindow = 22; 1251 Object[] set1 = new Object[] {sender, dest, baseDn, initWindow }; 1261 String baseDn, int initWindow) 1265 InitializeRequestMsg msg = new InitializeRequestMsg(baseDn, sender, dest, initWindow); 1282 newMsg.setInitWindow(initWindow); 1303 int initWindow = 22; 1305 entryCount, initWindow }; 1315 int initiator, String baseDn, int entryCount, int initWindow) 1320 initiator, entryCount, initWindow); 1339 newMsg.setInitWindow(initWindow); 1260 initializationRequestMsgTestVLASTV3(int sender, int dest, String baseDn, int initWindow) argument 1314 initializeTargetMsgTestVLASTV3(int sender, int dest, int initiator, String baseDn, int entryCount, int initWindow) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/protocol/ |
H A D | ProtocolCompatibilityTest.java | 1156 int initWindow = 22; 1159 { sender, dest, baseDN, initWindow }, 1169 DN baseDN, int initWindow) throws Exception 1172 InitializeRequestMsg msg = new InitializeRequestMsg(baseDN, sender, dest, initWindow); 1189 newMsg.setInitWindow(initWindow); 1210 int initWindow = 22; 1213 { sender, dest, initiator, baseDN, entryCount, initWindow }, 1223 int initiator, DN baseDN, int entryCount, int initWindow) 1228 initiator, entryCount, initWindow); 1247 newMsg.setInitWindow(initWindow); 1168 initializationRequestMsgTestVLASTV3(int sender, int dest, DN baseDN, int initWindow) argument 1222 initializeTargetMsgTestVLASTV3(int sender, int dest, int initiator, DN baseDN, int entryCount, int initWindow) argument [all...] |
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | StateMachineTest.java | 102 private int initWindow = 100; field in class:StateMachineTest 940 serverId, nEntries, initWindow);
|