| /forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | ReplicationServerLoadBalancingTest.java | 74 private final int[] rsPort = new int[NRS]; field in class:ReplicationServerLoadBalancingTest
102 rsPort[i] = -1;
119 rsPort[i] = ss[i].getLocalPort();
163 rsPort[i] = -1;
181 replServers.add("localhost:" + rsPort[i]);
188 replServers.add("localhost:" + rsPort[i]);
195 replServers.add("localhost:" + rsPort[i]);
202 replServers.add("localhost:" + rsPort[i]);
209 replServers.add("localhost:" + rsPort[i]);
233 replServers.add("localhost:" + rsPort[
[all...] |
| /forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | ReplicationServerLoadBalancingTest.java | 63 private int[] rsPort; field in class:ReplicationServerLoadBalancingTest
86 rsPort = TestCaseUtils.findFreePorts(NRS);
105 Arrays.fill(rsPort, -1);
120 replServers.add("localhost:" + rsPort[i]);
156 replServers.add("localhost:" + rsPort[i]);
162 new ReplServerFakeConfiguration(rsPort[rsIndex], dir, replicationDbImplementation, 0, rsIndex+501, 0,
183 replServers.add("localhost:" + rsPort[i]);
193 return new ReplServerFakeConfiguration(rsPort[rsIndex], dir, replicationDbImplementation,
|
| /forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | ReplicationServerLoadBalancingTest.java | 74 private final int[] rsPort = new int[NRS]; field in class:ReplicationServerLoadBalancingTest
102 rsPort[i] = -1;
119 rsPort[i] = ss[i].getLocalPort();
163 rsPort[i] = -1;
181 replServers.add("localhost:" + rsPort[i]);
188 replServers.add("localhost:" + rsPort[i]);
195 replServers.add("localhost:" + rsPort[i]);
202 replServers.add("localhost:" + rsPort[i]);
209 replServers.add("localhost:" + rsPort[i]);
233 replServers.add("localhost:" + rsPort[
[all...] |
| /forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | ReplicationServerLoadBalancingTest.java | 63 private int[] rsPort; field in class:ReplicationServerLoadBalancingTest
86 rsPort = TestCaseUtils.findFreePorts(NRS);
105 Arrays.fill(rsPort, -1);
120 replServers.add("localhost:" + rsPort[i]);
156 replServers.add("localhost:" + rsPort[i]);
162 new ReplServerFakeConfiguration(rsPort[rsIndex], dir, replicationDbImplementation, 0, rsIndex+501, 0,
183 replServers.add("localhost:" + rsPort[i]);
193 return new ReplServerFakeConfiguration(rsPort[rsIndex], dir, replicationDbImplementation,
|
| /forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
| H A D | ReplicationServerLoadBalancingTest.java | 74 private final int[] rsPort = new int[NRS]; field in class:ReplicationServerLoadBalancingTest
102 rsPort[i] = -1;
119 rsPort[i] = ss[i].getLocalPort();
163 rsPort[i] = -1;
181 replServers.add("localhost:" + rsPort[i]);
188 replServers.add("localhost:" + rsPort[i]);
195 replServers.add("localhost:" + rsPort[i]);
202 replServers.add("localhost:" + rsPort[i]);
209 replServers.add("localhost:" + rsPort[i]);
233 replServers.add("localhost:" + rsPort[
[all...] |
| /forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/ |
| H A D | ReplicationServerLoadBalancingTest.java | 63 private int[] rsPort; field in class:ReplicationServerLoadBalancingTest
86 rsPort = TestCaseUtils.findFreePorts(NRS);
105 Arrays.fill(rsPort, -1);
120 replServers.add("localhost:" + rsPort[i]);
156 replServers.add("localhost:" + rsPort[i]);
162 rsPort[rsIndex], dir, 0, rsIndex + 501, 0, 100, replServers, 1, 1000, 5000, weight);
182 replServers.add("localhost:" + rsPort[i]);
193 rsPort[rsIndex], dir, 0, rsIndex + 501, 0, 100, replServers, 1, 1000, 5000, weight);
|
| /forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
| H A D | ReplicationTestCase.java | 258 protected void checkConnection(int secTimeout, ReplicationBroker rb, int rsPort) argument
292 + "the RS port " + rsPort + " after " + secTimeout + " seconds.");
|
| /forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
| H A D | ReplicationTestCase.java | 258 protected void checkConnection(int secTimeout, ReplicationBroker rb, int rsPort) argument
292 + "the RS port " + rsPort + " after " + secTimeout + " seconds.");
|
| /forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
| H A D | ReplicationTestCase.java | 258 protected void checkConnection(int secTimeout, ReplicationBroker rb, int rsPort) argument
292 + "the RS port " + rsPort + " after " + secTimeout + " seconds.");
|
| /forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
| H A D | ReplicationTestCase.java | 255 protected void checkConnection(int secTimeout, ReplicationBroker rb, int rsPort) throws Exception argument
276 + "the RS port " + rsPort + " after " + secTimeout + " seconds.");
|
| /forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
| H A D | ReplicationTestCase.java | 255 protected void checkConnection(int secTimeout, ReplicationBroker rb, int rsPort) throws Exception argument
276 + "the RS port " + rsPort + " after " + secTimeout + " seconds.");
|
| /forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/ |
| H A D | ReplicationTestCase.java | 255 protected void checkConnection(int secTimeout, final ReplicationBroker rb, int rsPort) throws Exception argument
|
| /forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
| H A D | AssuredReplicationServerTest.java | 422 int rsPort = -1;
426 rsPort = rs1Port;
429 rsPort = rs2Port;
432 rsPort = rs3Port;
435 rsPort = rs4Port;
440 return rsPort;
484 int rsPort = getRsPort(rsId);
492 replicationServers.add("localhost:" + rsPort);
506 assertEquals(rdPort, rsPort);
520 int rsPort
586 addIfNotSame(Set<String> replServers, int rsPort, int excludedRsPort) argument
[all...] |
| /forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
| H A D | AssuredReplicationServerTest.java | 324 final int rsPort = getRsPort(rsId);
326 DN.decode(TEST_ROOT_DN_STRING), serverId, newSortedSet("localhost:" + rsPort),
369 int rsPort = getRsPort(rsId);
372 rsPort, serverId, assured, assuredMode, safeDataLevel, groupId,
435 private void addIfNotSame(Set<String> replServers, int rsPort, argument
438 if (rsPort != excludedRsPort)
440 replServers.add("localhost:" + rsPort);
|
| /forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
| H A D | AssuredReplicationServerTest.java | 422 int rsPort = -1;
426 rsPort = rs1Port;
429 rsPort = rs2Port;
432 rsPort = rs3Port;
435 rsPort = rs4Port;
440 return rsPort;
484 int rsPort = getRsPort(rsId);
492 replicationServers.add("localhost:" + rsPort);
506 assertEquals(rdPort, rsPort);
520 int rsPort
586 addIfNotSame(Set<String> replServers, int rsPort, int excludedRsPort) argument
[all...] |
| /forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
| H A D | AssuredReplicationServerTest.java | 324 final int rsPort = getRsPort(rsId);
326 DN.decode(TEST_ROOT_DN_STRING), serverId, newSortedSet("localhost:" + rsPort),
369 int rsPort = getRsPort(rsId);
372 rsPort, serverId, assured, assuredMode, safeDataLevel, groupId,
435 private void addIfNotSame(Set<String> replServers, int rsPort, argument
438 if (rsPort != excludedRsPort)
440 replServers.add("localhost:" + rsPort);
|
| /forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ |
| H A D | AssuredReplicationServerTest.java | 422 int rsPort = -1;
426 rsPort = rs1Port;
429 rsPort = rs2Port;
432 rsPort = rs3Port;
435 rsPort = rs4Port;
440 return rsPort;
484 int rsPort = getRsPort(rsId);
492 replicationServers.add("localhost:" + rsPort);
506 assertEquals(rdPort, rsPort);
520 int rsPort
586 addIfNotSame(Set<String> replServers, int rsPort, int excludedRsPort) argument
[all...] |
| /forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/server/ |
| H A D | AssuredReplicationServerTest.java | 322 final int rsPort = getRsPort(rsId);
324 DN.valueOf(TEST_ROOT_DN_STRING), serverId, newTreeSet("localhost:" + rsPort),
367 int rsPort = getRsPort(rsId);
370 rsPort, serverId, assured, assuredMode, safeDataLevel, groupId,
433 private void addIfNotSame(Set<String> replServers, int rsPort, argument
436 if (rsPort != excludedRsPort)
438 replServers.add("localhost:" + rsPort);
|