Searched refs:initWindow (Results 1 - 25 of 51) sorted by relevance

123

/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-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/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.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/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationDomain.java248 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 DReplicationDomain.java249 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 DReplicationDomain.java248 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 DReplicationDomain.java565 * @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 DReplicationDomain.java565 * @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 DReplicationDomain.java535 * @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 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/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...]
/forgerock/opendj2.6.2/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-hg/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...]
/forgerock/opendj2-jel-hg/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/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/protocol/
H A DProtocolCompatibilityTest.java1156 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 DStateMachineTest.java102 private int initWindow = 100; field in class:StateMachineTest
940 serverId, nEntries, initWindow);

Completed in 259 milliseconds

123