Searched defs:initWindow (Results 1 - 25 of 45) sorted by relevance

12

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DInitializeRequestMsg.java45 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 DInitializeTargetMsg.java51 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 DInitializeRequestMsg.java42 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 DInitializeTargetMsg.java52 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 DInitializeRequestMsg.java45 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 DInitializeTargetMsg.java51 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 DInitializeRequestMsg.java45 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 DInitializeTargetMsg.java51 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 DInitializeRequestMsg.java42 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 DInitializeTargetMsg.java52 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 DInitializeRequestMsg.java42 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 DInitializeTargetMsg.java52 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 DInitOnLineTest.java148 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 DStateMachineTest.java102 private int initWindow = 100; field in class:StateMachineTest
940 serverId, nEntries, initWindow);
H A DFractionalReplicationTest.java98 int initWindow = 100; field in class:FractionalReplicationTest
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DStateMachineTest.java89 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 DInitOnLineTest.java148 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 DStateMachineTest.java102 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 DStateMachineTest.java89 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 DInitOnLineTest.java148 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 DStateMachineTest.java102 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 DStateMachineTest.java98 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 DProtocolCompatibilityTest.java1250 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 DInitOnLineTest.java116 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 DProtocolCompatibilityTest.java1152 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...]

Completed in 76 milliseconds

12