/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/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.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/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/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | InitOnLineTest.java | 148 int initWindow = 100; field in class:InitOnLineTest 505 updatedEntries.length, initWindow);
|
/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);
|
H A D | FractionalReplicationTest.java | 98 int initWindow = 100; field in class:FractionalReplicationTest
|
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | StateMachineTest.java | 89 private int initWindow = 100; field in class:StateMachineTest 783 EXAMPLE_DN_, serverId, destId, serverId, nEntries, initWindow);
|
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | InitOnLineTest.java | 148 int initWindow = 100; field in class:InitOnLineTest 505 updatedEntries.length, initWindow);
|
/forgerock/opendj2.6.2/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);
|
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | StateMachineTest.java | 89 private int initWindow = 100; field in class:StateMachineTest 783 EXAMPLE_DN_, serverId, destId, serverId, nEntries, initWindow);
|
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | InitOnLineTest.java | 148 int initWindow = 100; field in class:InitOnLineTest 505 updatedEntries.length, initWindow);
|
/forgerock/opendj2-jel-hg/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);
|
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/ |
H A D | StateMachineTest.java | 98 private final int initWindow = 100; field in class:StateMachineTest 737 EXAMPLE_DN_, serverId, destId, serverId, nEntries, initWindow);
|
/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/ |
H A D | InitOnLineTest.java | 116 private int initWindow = 100; field in class:InitOnLineTest 397 requestorID, updatedEntries.length, initWindow);
|
/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...] |