Searched refs:windowSize (Results 1 - 25 of 92) sorted by relevance

1234

/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplServerFakeConfiguration.java48 int windowSize; field in class:ReplServerFakeConfiguration
74 int queueSize, int windowSize, SortedSet<String> servers)
99 if (windowSize == 0)
101 this.windowSize = 100;
105 this.windowSize = windowSize;
116 int queueSize, int windowSize, SortedSet<String> servers,
119 this(port, dirName, purgeDelay, serverId, queueSize, windowSize, servers);
130 int queueSize, int windowSize, SortedSet<String> servers,
133 this(port, dirName, purgeDelay, serverId, queueSize, windowSize, server
72 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers) argument
114 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold) argument
128 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) argument
[all...]
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplServerFakeConfiguration.java50 int windowSize; field in class:ReplServerFakeConfiguration
76 int queueSize, int windowSize, SortedSet<String> servers)
101 if (windowSize == 0)
103 this.windowSize = 100;
107 this.windowSize = windowSize;
118 int queueSize, int windowSize, SortedSet<String> servers,
121 this(port, dirName, purgeDelay, serverId, queueSize, windowSize, servers);
132 int queueSize, int windowSize, SortedSet<String> servers,
135 this(port, dirName, purgeDelay, serverId, queueSize, windowSize, server
74 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers) argument
116 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold) argument
130 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) argument
[all...]
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplServerFakeConfiguration.java48 int windowSize; field in class:ReplServerFakeConfiguration
74 int queueSize, int windowSize, SortedSet<String> servers)
99 if (windowSize == 0)
101 this.windowSize = 100;
105 this.windowSize = windowSize;
116 int queueSize, int windowSize, SortedSet<String> servers,
119 this(port, dirName, purgeDelay, serverId, queueSize, windowSize, servers);
130 int queueSize, int windowSize, SortedSet<String> servers,
133 this(port, dirName, purgeDelay, serverId, queueSize, windowSize, server
72 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers) argument
114 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold) argument
128 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) argument
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DReplServerStartMsg.java43 private final int windowSize; field in class:ReplServerStartMsg
73 * @param windowSize The window size.
82 int windowSize,
93 this.windowSize = windowSize;
114 * <baseDN><serverId><serverURL><windowSize><sslEncryption>
120 windowSize = scanner.nextIntUTF8();
183 builder.appendIntUTF8(windowSize);
190 * <operation type><baseDN><serverId><serverURL><windowSize><sslEncryption>
197 builder.appendIntUTF8(windowSize);
81 ReplServerStartMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument
[all...]
H A DReplServerStartDSMsg.java43 private final int windowSize; field in class:ReplServerStartDSMsg
75 * @param windowSize The window size.
87 int windowSize,
100 this.windowSize = windowSize;
122 * <baseDN><serverId><serverURL><windowSize><sslEncryption>
129 windowSize = scanner.nextIntUTF8();
179 * <operation type><baseDN><serverId><serverURL><windowSize><sslEncryption>
188 builder.appendIntUTF8(windowSize);
204 return windowSize;
86 ReplServerStartDSMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument
[all...]
H A DServerStartMsg.java49 private final int windowSize; field in class:ServerStartMsg
73 * @param windowSize The window size used by this server.
82 int windowSize, long heartbeatInterval, ServerState serverState,
95 this.windowSize = windowSize;
122 windowSize = scanner.nextIntUTF8();
215 builder.appendIntUTF8(windowSize);
229 return windowSize;
274 "\nwindowSize: " + windowSize;
81 ServerStartMsg(int serverId2, String serverURL, DN baseDN, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DReplServerStartMsg.java43 private final int windowSize; field in class:ReplServerStartMsg
73 * @param windowSize The window size.
82 int windowSize,
93 this.windowSize = windowSize;
114 * <baseDN><serverId><serverURL><windowSize><sslEncryption>
120 windowSize = scanner.nextIntUTF8();
183 builder.appendIntUTF8(windowSize);
190 * <operation type><baseDN><serverId><serverURL><windowSize><sslEncryption>
197 builder.appendIntUTF8(windowSize);
81 ReplServerStartMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument
[all...]
H A DReplServerStartDSMsg.java43 private final int windowSize; field in class:ReplServerStartDSMsg
75 * @param windowSize The window size.
87 int windowSize,
100 this.windowSize = windowSize;
122 * <baseDN><serverId><serverURL><windowSize><sslEncryption>
129 windowSize = scanner.nextIntUTF8();
179 * <operation type><baseDN><serverId><serverURL><windowSize><sslEncryption>
188 builder.appendIntUTF8(windowSize);
204 return windowSize;
86 ReplServerStartDSMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument
[all...]
H A DServerStartMsg.java49 private final int windowSize; field in class:ServerStartMsg
73 * @param windowSize The window size used by this server.
82 int windowSize, long heartbeatInterval, ServerState serverState,
95 this.windowSize = windowSize;
122 windowSize = scanner.nextIntUTF8();
215 builder.appendIntUTF8(windowSize);
229 return windowSize;
274 "\nwindowSize: " + windowSize;
81 ServerStartMsg(int serverId2, String serverURL, DN baseDN, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DReplServerStartMsg.java43 private final int windowSize; field in class:ReplServerStartMsg
73 * @param windowSize The window size.
82 int windowSize,
93 this.windowSize = windowSize;
114 * <baseDN><serverId><serverURL><windowSize><sslEncryption>
120 windowSize = scanner.nextIntUTF8();
183 builder.appendIntUTF8(windowSize);
190 * <operation type><baseDN><serverId><serverURL><windowSize><sslEncryption>
197 builder.appendIntUTF8(windowSize);
81 ReplServerStartMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument
[all...]
H A DReplServerStartDSMsg.java43 private final int windowSize; field in class:ReplServerStartDSMsg
75 * @param windowSize The window size.
87 int windowSize,
100 this.windowSize = windowSize;
122 * <baseDN><serverId><serverURL><windowSize><sslEncryption>
129 windowSize = scanner.nextIntUTF8();
179 * <operation type><baseDN><serverId><serverURL><windowSize><sslEncryption>
188 builder.appendIntUTF8(windowSize);
204 return windowSize;
86 ReplServerStartDSMsg(int serverId, String serverURL, DN baseDN, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument
[all...]
H A DServerStartMsg.java49 private final int windowSize; field in class:ServerStartMsg
73 * @param windowSize The window size used by this server.
82 int windowSize, long heartbeatInterval, ServerState serverState,
95 this.windowSize = windowSize;
122 windowSize = scanner.nextIntUTF8();
215 builder.appendIntUTF8(windowSize);
229 return windowSize;
274 "\nwindowSize: " + windowSize;
81 ServerStartMsg(int serverId2, String serverURL, DN baseDN, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplServerFakeConfiguration.java52 private int windowSize; field in class:ReplServerFakeConfiguration
82 int serverId, int queueSize, int windowSize, SortedSet<String> servers)
108 if (windowSize == 0)
110 this.windowSize = 100;
114 this.windowSize = windowSize;
125 int serverId, int queueSize, int windowSize,
128 this(port, dirName, dbImpl, purgeDelay, serverId, queueSize, windowSize, servers);
139 int serverId, int queueSize, int windowSize,
142 this(port, dirName, dbImpl, purgeDelay, serverId, queueSize, windowSize,
80 ReplServerFakeConfiguration( int port, String dirName, ReplicationDBImplementation dbImpl, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers) argument
123 ReplServerFakeConfiguration( int port, String dirName, ReplicationDBImplementation dbImpl, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold) argument
137 ReplServerFakeConfiguration( int port, String dirName, ReplicationDBImplementation dbImpl, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) argument
[all...]
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/
H A DReplServerFakeConfiguration.java52 private int windowSize; field in class:ReplServerFakeConfiguration
82 int serverId, int queueSize, int windowSize, SortedSet<String> servers)
108 if (windowSize == 0)
110 this.windowSize = 100;
114 this.windowSize = windowSize;
125 int serverId, int queueSize, int windowSize,
128 this(port, dirName, dbImpl, purgeDelay, serverId, queueSize, windowSize, servers);
139 int serverId, int queueSize, int windowSize,
142 this(port, dirName, dbImpl, purgeDelay, serverId, queueSize, windowSize,
80 ReplServerFakeConfiguration( int port, String dirName, ReplicationDBImplementation dbImpl, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers) argument
123 ReplServerFakeConfiguration( int port, String dirName, ReplicationDBImplementation dbImpl, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold) argument
137 ReplServerFakeConfiguration( int port, String dirName, ReplicationDBImplementation dbImpl, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) argument
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/
H A DReplServerFakeConfiguration.java51 private int windowSize; field in class:ReplServerFakeConfiguration
75 int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers)
100 if (windowSize == 0)
102 this.windowSize = 100;
106 this.windowSize = windowSize;
116 int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize,
119 this(port, dirName, purgeDelay, serverId, queueSize, windowSize, servers);
127 int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize,
130 this(port, dirName, purgeDelay, serverId, queueSize, windowSize,
74 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers) argument
115 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold) argument
126 ReplServerFakeConfiguration( int port, String dirName, int purgeDelay, int serverId, int queueSize, int windowSize, SortedSet<String> servers, int groupId, long assuredTimeout, int degradedStatusThreshold, int weight) argument
[all...]
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DReplServerStartMsg.java44 private int windowSize; field in class:ReplServerStartMsg
74 * @param windowSize The window size.
83 int windowSize,
97 this.windowSize = windowSize;
130 * <baseDn><serverId><serverURL><windowSize><sslEncryption>
163 windowSize = Integer.valueOf(new String(in, pos, length, "UTF-8"));
209 * <baseDn><serverId><serverURL><windowSize><sslEncryption>
239 windowSize = Integer.valueOf(new String(in, pos, length, "UTF-8"));
315 * <operation type><baseDn><serverId><serverURL><windowSize><sslEncryptio
82 ReplServerStartMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument
[all...]
H A DReplServerStartDSMsg.java44 private int windowSize; field in class:ReplServerStartDSMsg
76 * @param windowSize The window size.
88 int windowSize,
104 this.windowSize = windowSize;
129 * <baseDn><serverId><serverURL><windowSize><sslEncryption>
163 windowSize = Integer.valueOf(new String(in, pos, length, "UTF-8"));
256 * <operation type><baseDn><serverId><serverURL><windowSize><sslEncryption>
264 byte[] byteWindowSize = String.valueOf(windowSize).getBytes("UTF-8");
323 return windowSize;
87 ReplServerStartDSMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument
[all...]
H A DServerStartECLMsg.java47 private int windowSize; field in class:ServerStartECLMsg
73 * @param windowSize The window size used by this server.
83 int maxSendQueue, int windowSize,
97 this.windowSize = windowSize;
159 * read the windowSize
162 windowSize = Integer.valueOf(new String(in, pos, length, "UTF-8"));
265 String.valueOf(windowSize).getBytes("UTF-8");
320 return windowSize;
365 "\nwindowSize: " + windowSize;
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.java49 private int windowSize; field in class:ServerStartMsg
73 * @param windowSize The window size used by this server.
82 int windowSize, long heartbeatInterval, ServerState serverState,
95 this.windowSize = windowSize;
173 * read the windowSize
176 windowSize = Integer.valueOf(new String(in, pos, length, "UTF-8"));
299 String.valueOf(windowSize).getBytes("UTF-8");
359 return windowSize;
406 "\nwindowSize: " + windowSize;
81 ServerStartMsg(int serverId2, String serverURL, String baseDn, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DReplServerStartMsg.java44 private int windowSize; field in class:ReplServerStartMsg
74 * @param windowSize The window size.
83 int windowSize,
97 this.windowSize = windowSize;
130 * <baseDn><serverId><serverURL><windowSize><sslEncryption>
163 windowSize = Integer.valueOf(new String(in, pos, length, "UTF-8"));
209 * <baseDn><serverId><serverURL><windowSize><sslEncryption>
239 windowSize = Integer.valueOf(new String(in, pos, length, "UTF-8"));
315 * <operation type><baseDn><serverId><serverURL><windowSize><sslEncryptio
82 ReplServerStartMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument
[all...]
H A DReplServerStartDSMsg.java44 private int windowSize; field in class:ReplServerStartDSMsg
76 * @param windowSize The window size.
88 int windowSize,
104 this.windowSize = windowSize;
129 * <baseDn><serverId><serverURL><windowSize><sslEncryption>
163 windowSize = Integer.valueOf(new String(in, pos, length, "UTF-8"));
256 * <operation type><baseDn><serverId><serverURL><windowSize><sslEncryption>
264 byte[] byteWindowSize = String.valueOf(windowSize).getBytes("UTF-8");
323 return windowSize;
87 ReplServerStartDSMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument
[all...]
H A DServerStartECLMsg.java47 private int windowSize; field in class:ServerStartECLMsg
73 * @param windowSize The window size used by this server.
83 int maxSendQueue, int windowSize,
97 this.windowSize = windowSize;
159 * read the windowSize
162 windowSize = Integer.valueOf(new String(in, pos, length, "UTF-8"));
265 String.valueOf(windowSize).getBytes("UTF-8");
320 return windowSize;
365 "\nwindowSize: " + windowSize;
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.java49 private int windowSize; field in class:ServerStartMsg
73 * @param windowSize The window size used by this server.
82 int windowSize, long heartbeatInterval, ServerState serverState,
95 this.windowSize = windowSize;
173 * read the windowSize
176 windowSize = Integer.valueOf(new String(in, pos, length, "UTF-8"));
299 String.valueOf(windowSize).getBytes("UTF-8");
359 return windowSize;
406 "\nwindowSize: " + windowSize;
81 ServerStartMsg(int serverId2, String serverURL, String baseDn, int windowSize, long heartbeatInterval, ServerState serverState, long generationId, boolean sslEncryption, byte groupId) argument
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DReplServerStartMsg.java44 private int windowSize; field in class:ReplServerStartMsg
74 * @param windowSize The window size.
83 int windowSize,
97 this.windowSize = windowSize;
130 * <baseDn><serverId><serverURL><windowSize><sslEncryption>
163 windowSize = Integer.valueOf(new String(in, pos, length, "UTF-8"));
209 * <baseDn><serverId><serverURL><windowSize><sslEncryption>
239 windowSize = Integer.valueOf(new String(in, pos, length, "UTF-8"));
315 * <operation type><baseDn><serverId><serverURL><windowSize><sslEncryptio
82 ReplServerStartMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold) argument
[all...]
H A DReplServerStartDSMsg.java44 private int windowSize; field in class:ReplServerStartDSMsg
76 * @param windowSize The window size.
88 int windowSize,
104 this.windowSize = windowSize;
129 * <baseDn><serverId><serverURL><windowSize><sslEncryption>
163 windowSize = Integer.valueOf(new String(in, pos, length, "UTF-8"));
256 * <operation type><baseDn><serverId><serverURL><windowSize><sslEncryption>
264 byte[] byteWindowSize = String.valueOf(windowSize).getBytes("UTF-8");
323 return windowSize;
87 ReplServerStartDSMsg(int serverId, String serverURL, String baseDn, int windowSize, ServerState serverState, long generationId, boolean sslEncryption, byte groupId, int degradedStatusThreshold, int weight, int connectedDSNumber) argument
[all...]

Completed in 54 milliseconds

1234