/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);
|