Searched refs:maxSendQueue (Results 1 - 12 of 12) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DServerStartMsg.java46 private final int maxSendQueue; field in class:ServerStartMsg
94 this.maxSendQueue = 0;
121 maxSendQueue = scanner.nextIntUTF8();
184 * Get the maxSendQueue.
185 * @return Returns the maxSendQueue.
189 return maxSendQueue;
214 builder.appendIntUTF8(maxSendQueue);
269 "\nmaxSendQueue: " + maxSendQueue +
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DServerStartMsg.java46 private final int maxSendQueue; field in class:ServerStartMsg
94 this.maxSendQueue = 0;
121 maxSendQueue = scanner.nextIntUTF8();
184 * Get the maxSendQueue.
185 * @return Returns the maxSendQueue.
189 return maxSendQueue;
214 builder.appendIntUTF8(maxSendQueue);
269 "\nmaxSendQueue: " + maxSendQueue +
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DServerStartMsg.java46 private final int maxSendQueue; field in class:ServerStartMsg
94 this.maxSendQueue = 0;
121 maxSendQueue = scanner.nextIntUTF8();
184 * Get the maxSendQueue.
185 * @return Returns the maxSendQueue.
189 return maxSendQueue;
214 builder.appendIntUTF8(maxSendQueue);
269 "\nmaxSendQueue: " + maxSendQueue +
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DServerStartECLMsg.java44 private int maxSendQueue; field in class:ServerStartECLMsg
72 * @param maxSendQueue The max send Queue from this server.
83 int maxSendQueue, int windowSize,
96 this.maxSendQueue = maxSendQueue;
152 * read the maxSendQueue
155 maxSendQueue = Integer.valueOf(new String(in, pos, length, "UTF-8"));
231 * Get the maxSendQueue.
232 * @return Returns the maxSendQueue.
236 return maxSendQueue;
81 ServerStartECLMsg(String serverURL, int maxReceiveDelay, int maxReceiveQueue, int maxSendDelay, int maxSendQueue, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
[all...]
H A DServerStartMsg.java46 private int maxSendQueue; field in class:ServerStartMsg
94 this.maxSendQueue = 0;
166 * read the maxSendQueue
169 maxSendQueue = Integer.valueOf(new String(in, pos, length, "UTF-8"));
263 * Get the maxSendQueue.
264 * @return Returns the maxSendQueue.
268 return maxSendQueue;
297 String.valueOf(maxSendQueue).getBytes("UTF-8");
401 "\nmaxSendQueue: " + maxSendQueue +
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DServerStartECLMsg.java44 private int maxSendQueue; field in class:ServerStartECLMsg
72 * @param maxSendQueue The max send Queue from this server.
83 int maxSendQueue, int windowSize,
96 this.maxSendQueue = maxSendQueue;
152 * read the maxSendQueue
155 maxSendQueue = Integer.valueOf(new String(in, pos, length, "UTF-8"));
231 * Get the maxSendQueue.
232 * @return Returns the maxSendQueue.
236 return maxSendQueue;
81 ServerStartECLMsg(String serverURL, int maxReceiveDelay, int maxReceiveQueue, int maxSendDelay, int maxSendQueue, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
[all...]
H A DServerStartMsg.java46 private int maxSendQueue; field in class:ServerStartMsg
94 this.maxSendQueue = 0;
166 * read the maxSendQueue
169 maxSendQueue = Integer.valueOf(new String(in, pos, length, "UTF-8"));
263 * Get the maxSendQueue.
264 * @return Returns the maxSendQueue.
268 return maxSendQueue;
297 String.valueOf(maxSendQueue).getBytes("UTF-8");
401 "\nmaxSendQueue: " + maxSendQueue +
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DServerStartECLMsg.java44 private int maxSendQueue; field in class:ServerStartECLMsg
72 * @param maxSendQueue The max send Queue from this server.
83 int maxSendQueue, int windowSize,
96 this.maxSendQueue = maxSendQueue;
152 * read the maxSendQueue
155 maxSendQueue = Integer.valueOf(new String(in, pos, length, "UTF-8"));
231 * Get the maxSendQueue.
232 * @return Returns the maxSendQueue.
236 return maxSendQueue;
81 ServerStartECLMsg(String serverURL, int maxReceiveDelay, int maxReceiveQueue, int maxSendDelay, int maxSendQueue, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
[all...]
H A DServerStartMsg.java46 private int maxSendQueue; field in class:ServerStartMsg
94 this.maxSendQueue = 0;
166 * read the maxSendQueue
169 maxSendQueue = Integer.valueOf(new String(in, pos, length, "UTF-8"));
263 * Get the maxSendQueue.
264 * @return Returns the maxSendQueue.
268 return maxSendQueue;
297 String.valueOf(maxSendQueue).getBytes("UTF-8");
401 "\nmaxSendQueue: " + maxSendQueue +
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DReplicationTestCase.java340 int port, int timeout, int maxSendQueue, int maxRcvQueue,
338 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, int maxSendQueue, int maxRcvQueue, boolean emptyOldChanges) argument
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DReplicationTestCase.java340 int port, int timeout, int maxSendQueue, int maxRcvQueue,
338 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, int maxSendQueue, int maxRcvQueue, boolean emptyOldChanges) argument
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/
H A DReplicationTestCase.java340 int port, int timeout, int maxSendQueue, int maxRcvQueue,
338 openReplicationSession( final DN baseDn, int serverId, int window_size, int port, int timeout, int maxSendQueue, int maxRcvQueue, boolean emptyOldChanges) argument

Completed in 66 milliseconds