/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/ |
H A D | ServerStartECLMsg.java | 44 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 D | ServerStartMsg.java | 46 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/src/server/org/opends/server/replication/protocol/ |
H A D | ServerStartMsg.java | 46 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.6.2/src/server/org/opends/server/replication/protocol/ |
H A D | ServerStartECLMsg.java | 44 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 D | ServerStartMsg.java | 46 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 D | ServerStartECLMsg.java | 44 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 D | ServerStartMsg.java | 46 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-hg/src/server/org/opends/server/replication/protocol/ |
H A D | ServerStartMsg.java | 46 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 D | ServerStartMsg.java | 46 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/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | ReplicationTestCase.java | 340 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 D | ReplicationTestCase.java | 340 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 D | ReplicationTestCase.java | 340 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
|