/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | ReplicationServerLoadBalancingTest.java | 113 private SortedSet<String> createRSListForTestCase(String testCase) argument 117 final int nbRSs = getNbRSs(testCase); 125 private int getNbRSs(String testCase) argument 127 if ("testFailoversAndWeightChanges".equals(testCase) 128 || "testSpreadLoad".equals(testCase)) 132 else if ("testNoYoyo1".equals(testCase)) 136 else if ("testNoYoyo2".equals(testCase) || "testNoYoyo3".equals(testCase)) 140 fail("Unknown test case: " + testCase); 148 int weight, String testCase) throw 147 createReplicationServer(int rsIndex, int weight, String testCase) argument 170 createReplicationServerConfigWithNewWeight(int rsIndex, int weight, String testCase) argument 200 createReplicationDomain(int serverId, String testCase) argument 1091 createReplicationDomains(String testCase, int start, int end) argument [all...] |
H A D | GroupIdHandshakeTest.java | 211 private SortedSet<String> createRSListForTestCase(String testCase) argument 215 if (testCase.equals("testRSWithSameGroupIds")) 220 } else if (testCase.equals("testRSWithManyGroupIds")) 227 fail("Unknown test case: " + testCase); 236 String testCase) throws Exception 243 if (testCase.equals("testRSWithSameGroupIds")) 248 else if (testCase.equals("testRSWithManyGroupIds")) 255 fail("Unknown test case: " + testCase); 260 if (testCase.equals("testRSWithSameGroupIds")) 265 else if (testCase 235 createReplicationServer(int serverId, int groupId, String testCase) argument 300 createReplicationDomain(int serverId, int groupId, String testCase) argument [all...] |
H A D | ReplicationServerFailoverTest.java | 123 String testCase = "testFailOverSingle"; 125 debugInfo("Starting " + testCase); 132 rs1 = createReplicationServer(RS1_ID, testCase); 134 rs2 = createReplicationServer(RS2_ID, testCase); 171 debugInfo(testCase + " successfully ended."); 192 String testCase = "testFailOverMulti"; 194 debugInfo("Starting " + testCase); 201 rs1 = createReplicationServer(RS1_ID, testCase); 203 rs2 = createReplicationServer(RS2_ID, testCase); 224 rs1 = createReplicationServer(RS1_ID, testCase); [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | ReplicationServerLoadBalancingTest.java | 113 private SortedSet<String> createRSListForTestCase(String testCase) argument 117 final int nbRSs = getNbRSs(testCase); 125 private int getNbRSs(String testCase) argument 127 if ("testFailoversAndWeightChanges".equals(testCase) 128 || "testSpreadLoad".equals(testCase)) 132 else if ("testNoYoyo1".equals(testCase)) 136 else if ("testNoYoyo2".equals(testCase) || "testNoYoyo3".equals(testCase)) 140 fail("Unknown test case: " + testCase); 148 int weight, String testCase) throw 147 createReplicationServer(int rsIndex, int weight, String testCase) argument 170 createReplicationServerConfigWithNewWeight(int rsIndex, int weight, String testCase) argument 200 createReplicationDomain(int serverId, String testCase) argument 1091 createReplicationDomains(String testCase, int start, int end) argument [all...] |
H A D | GroupIdHandshakeTest.java | 211 private SortedSet<String> createRSListForTestCase(String testCase) argument 215 if (testCase.equals("testRSWithSameGroupIds")) 220 } else if (testCase.equals("testRSWithManyGroupIds")) 227 fail("Unknown test case: " + testCase); 236 String testCase) throws Exception 243 if (testCase.equals("testRSWithSameGroupIds")) 248 else if (testCase.equals("testRSWithManyGroupIds")) 255 fail("Unknown test case: " + testCase); 260 if (testCase.equals("testRSWithSameGroupIds")) 265 else if (testCase 235 createReplicationServer(int serverId, int groupId, String testCase) argument 300 createReplicationDomain(int serverId, int groupId, String testCase) argument [all...] |
H A D | ReplicationServerFailoverTest.java | 123 String testCase = "testFailOverSingle"; 125 debugInfo("Starting " + testCase); 132 rs1 = createReplicationServer(RS1_ID, testCase); 134 rs2 = createReplicationServer(RS2_ID, testCase); 171 debugInfo(testCase + " successfully ended."); 192 String testCase = "testFailOverMulti"; 194 debugInfo("Starting " + testCase); 201 rs1 = createReplicationServer(RS1_ID, testCase); 203 rs2 = createReplicationServer(RS2_ID, testCase); 224 rs1 = createReplicationServer(RS1_ID, testCase); [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/ |
H A D | ReplicationServerLoadBalancingTest.java | 113 private SortedSet<String> createRSListForTestCase(String testCase) argument 117 final int nbRSs = getNbRSs(testCase); 125 private int getNbRSs(String testCase) argument 127 if ("testFailoversAndWeightChanges".equals(testCase) 128 || "testSpreadLoad".equals(testCase)) 132 else if ("testNoYoyo1".equals(testCase)) 136 else if ("testNoYoyo2".equals(testCase) || "testNoYoyo3".equals(testCase)) 140 fail("Unknown test case: " + testCase); 148 int weight, String testCase) throw 147 createReplicationServer(int rsIndex, int weight, String testCase) argument 169 createReplicationServerConfigWithNewWeight(int rsIndex, int weight, String testCase) argument 199 createReplicationDomain(int serverId, String testCase) argument 1090 createReplicationDomains(String testCase, int start, int end) argument [all...] |
H A D | GroupIdHandshakeTest.java | 208 private SortedSet<String> createRSListForTestCase(String testCase) argument 212 if (testCase.equals("testRSWithSameGroupIds")) 217 } else if (testCase.equals("testRSWithManyGroupIds")) 226 fail("Unknown test case: " + testCase); 236 String testCase) throws Exception 243 if (testCase.equals("testRSWithSameGroupIds")) 248 else if (testCase.equals("testRSWithManyGroupIds")) 256 fail("Unknown test case: " + testCase); 262 if (testCase.equals("testRSWithSameGroupIds")) 267 else if (testCase 235 createReplicationServer(int serverId, int groupId, String testCase) argument 304 createReplicationDomain(int serverId, int groupId, String testCase) argument [all...] |
H A D | ReplicationServerFailoverTest.java | 119 String testCase = "testFailOverSingle"; 121 debugInfo("Starting " + testCase); 128 rs1 = createReplicationServer(RS1_ID, testCase); 130 rs2 = createReplicationServer(RS2_ID, testCase); 167 debugInfo(testCase + " successfully ended."); 188 String testCase = "testFailOverMulti"; 190 debugInfo("Starting " + testCase); 197 rs1 = createReplicationServer(RS1_ID, testCase); 199 rs2 = createReplicationServer(RS2_ID, testCase); 220 rs1 = createReplicationServer(RS1_ID, testCase); [all...] |
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | InitOnLineTest.java | 493 String testCase) throws Exception 507 "initOnlineTest" + port + testCase + "Db", 564 String testCase = "initializeImport "; 565 log("Starting "+testCase); 568 replServer1 = createReplicationServer(replServer1ID, testCase); 596 log("Successfully ending " + testCase); 599 afterTest(testCase); 613 String testCase = "initializeExport"; 614 log("Starting "+testCase); 617 replServer1 = createReplicationServer(replServer1ID, testCase); 492 createReplicationServer(int replServerId, String testCase) argument 1035 waitForInitializeTargetMsg(String testCase, ReplicationBroker server) argument 1303 afterTest(String testCase) argument [all...] |
H A D | GenerationIdTest.java | 321 boolean all, String testCase) throws Exception 334 String rsDir = "generationIdTest" + replServerId + testCase + "Db"; 591 String testCase = "testSingleRS"; 592 debugInfo("Starting " + testCase + " debugEnabled:" + debugEnabled()); 594 debugInfo(testCase + " Clearing DS1 backend"); 604 replServer1 = createReplicationServer(replServerId1, false, testCase); 610 debugInfo(testCase + " ** TEST ** Empty backend"); 614 debugInfo(testCase 619 debugInfo(testCase 630 debugInfo(testCase 320 createReplicationServer(int replServerId, boolean all, String testCase) argument [all...] |
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | InitOnLineTest.java | 493 String testCase) throws Exception 507 "initOnlineTest" + port + testCase + "Db", 564 String testCase = "initializeImport "; 565 log("Starting "+testCase); 568 replServer1 = createReplicationServer(replServer1ID, testCase); 596 log("Successfully ending " + testCase); 599 afterTest(testCase); 613 String testCase = "initializeExport"; 614 log("Starting "+testCase); 617 replServer1 = createReplicationServer(replServer1ID, testCase); 492 createReplicationServer(int replServerId, String testCase) argument 1035 waitForInitializeTargetMsg(String testCase, ReplicationBroker server) argument 1303 afterTest(String testCase) argument [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/ |
H A D | InitOnLineTest.java | 477 String testCase) throws Exception 495 port, "initOnlineTest" + port + testCase + "Db", 0, replServerId, 0, 100, servers); 549 String testCase = "initializeImport "; 550 log("Starting "+testCase); 553 replServer1 = createReplicationServer(replServer1ID, testCase); 583 log("Successfully ending " + testCase); 586 afterTest(testCase); 600 String testCase = "initializeExport"; 601 log("Starting "+testCase); 604 replServer1 = createReplicationServer(replServer1ID, testCase); 476 createReplicationServer(int replServerId, String testCase) argument 1033 waitForInitializeTargetMsg(String testCase, ReplicationBroker server) argument 1299 afterTest(String testCase) argument [all...] |
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | InitOnLineTest.java | 625 private ReplicationServer createChangelogServer(int changelogId, String testCase) argument 640 "initOnlineTest" + getChangelogPort(changelogId) + testCase + "Db", 745 String testCase = "initializeImport "; 747 log("Starting "+testCase); 751 changelog1 = createChangelogServer(changelog1ID, testCase); 770 fail(testCase + " Message received by S2 is of unexpected class" + msg); 785 log("Successfully ending " + testCase); 789 fail(testCase + " Exception:"+ e.getMessage() + " " + stackTraceToSingleLineString(e)); 792 afterTest(testCase); 806 String testCase 1594 afterTest(String testCase) argument [all...] |
H A D | GenerationIdTest.java | 348 boolean all, String testCase) 363 String chDir = "generationIdTest"+changelogId+testCase+"Db"; 692 String testCase = "testSingleRS"; 693 debugInfo("Starting "+ testCase + " debugEnabled:" + debugEnabled()); 695 debugInfo(testCase + " Clearing DS1 backend"); 705 replServer1 = createReplicationServer(changelog1ID, false, testCase); 714 debugInfo(testCase + " ** TEST ** Empty backend"); 716 debugInfo(testCase + " Configuring DS1 to replicate to RS1(" + changelog1ID + ") on an empty backend"); 719 debugInfo(testCase + " Expect genId to be not retrievable from suffix root entry"); 723 debugInfo(testCase 347 createReplicationServer(int changelogId, boolean all, String testCase) argument [all...] |
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | InitOnLineTest.java | 625 private ReplicationServer createChangelogServer(int changelogId, String testCase) argument 640 "initOnlineTest" + getChangelogPort(changelogId) + testCase + "Db", 745 String testCase = "initializeImport "; 747 log("Starting "+testCase); 751 changelog1 = createChangelogServer(changelog1ID, testCase); 770 fail(testCase + " Message received by S2 is of unexpected class" + msg); 785 log("Successfully ending " + testCase); 789 fail(testCase + " Exception:"+ e.getMessage() + " " + stackTraceToSingleLineString(e)); 792 afterTest(testCase); 806 String testCase 1594 afterTest(String testCase) argument [all...] |
H A D | GenerationIdTest.java | 348 boolean all, String testCase) 363 String chDir = "generationIdTest"+changelogId+testCase+"Db"; 692 String testCase = "testSingleRS"; 693 debugInfo("Starting "+ testCase + " debugEnabled:" + debugEnabled()); 695 debugInfo(testCase + " Clearing DS1 backend"); 705 replServer1 = createReplicationServer(changelog1ID, false, testCase); 714 debugInfo(testCase + " ** TEST ** Empty backend"); 716 debugInfo(testCase + " Configuring DS1 to replicate to RS1(" + changelog1ID + ") on an empty backend"); 719 debugInfo(testCase + " Expect genId to be not retrievable from suffix root entry"); 723 debugInfo(testCase 347 createReplicationServer(int changelogId, boolean all, String testCase) argument [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/ |
H A D | InitOnLineTest.java | 625 private ReplicationServer createChangelogServer(int changelogId, String testCase) argument 640 "initOnlineTest" + getChangelogPort(changelogId) + testCase + "Db", 745 String testCase = "initializeImport "; 747 log("Starting "+testCase); 751 changelog1 = createChangelogServer(changelog1ID, testCase); 770 fail(testCase + " Message received by S2 is of unexpected class" + msg); 785 log("Successfully ending " + testCase); 789 fail(testCase + " Exception:"+ e.getMessage() + " " + stackTraceToSingleLineString(e)); 792 afterTest(testCase); 806 String testCase 1594 afterTest(String testCase) argument [all...] |
H A D | GenerationIdTest.java | 348 boolean all, String testCase) 363 String chDir = "generationIdTest"+changelogId+testCase+"Db"; 692 String testCase = "testSingleRS"; 693 debugInfo("Starting "+ testCase + " debugEnabled:" + debugEnabled()); 695 debugInfo(testCase + " Clearing DS1 backend"); 705 replServer1 = createReplicationServer(changelog1ID, false, testCase); 714 debugInfo(testCase + " ** TEST ** Empty backend"); 716 debugInfo(testCase + " Configuring DS1 to replicate to RS1(" + changelog1ID + ") on an empty backend"); 719 debugInfo(testCase + " Expect genId to be not retrievable from suffix root entry"); 723 debugInfo(testCase 347 createReplicationServer(int changelogId, boolean all, String testCase) argument [all...] |
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | ReplicationServerLoadBalancingTest.java | 172 private SortedSet<String> createRSListForTestCase(String testCase) argument 176 if (testCase.equals("testFailoversAndWeightChanges")) 183 } else if (testCase.equals("testSpreadLoad")) 190 } else if (testCase.equals("testNoYoyo1")) 197 } else if (testCase.equals("testNoYoyo2")) 204 } else if (testCase.equals("testNoYoyo3")) 213 fail("Unknown test case: " + testCase); 222 int weight, String testCase) 227 if (testCase.equals("testFailoversAndWeightChanges")) 235 } else if (testCase 221 createReplicationServer(int rsIndex, int weight, String testCase) argument 287 createReplicationServerConfigWithNewWeight(int rsIndex, int weight, String testCase) argument 328 createReplicationDomain(int serverId, String testCase) argument [all...] |
H A D | GroupIdHandshakeTest.java | 281 private SortedSet<String> createRSListForTestCase(String testCase) argument 285 if (testCase.equals("testRSWithSameGroupIds")) 290 } else if (testCase.equals("testRSWithManyGroupIds")) 297 fail("Unknown test case: " + testCase); 306 int groupId, String testCase) 315 if (testCase.equals("testRSWithSameGroupIds")) 319 } else if (testCase.equals("testRSWithManyGroupIds")) 325 fail("Unknown test case: " + testCase); 329 if (testCase.equals("testRSWithSameGroupIds")) 333 } else if (testCase 305 createReplicationServer(int serverId, int groupId, String testCase) argument 372 createReplicationDomain(int serverId, int groupId, String testCase) argument [all...] |
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | ReplicationServerLoadBalancingTest.java | 172 private SortedSet<String> createRSListForTestCase(String testCase) argument 176 if (testCase.equals("testFailoversAndWeightChanges")) 183 } else if (testCase.equals("testSpreadLoad")) 190 } else if (testCase.equals("testNoYoyo1")) 197 } else if (testCase.equals("testNoYoyo2")) 204 } else if (testCase.equals("testNoYoyo3")) 213 fail("Unknown test case: " + testCase); 222 int weight, String testCase) 227 if (testCase.equals("testFailoversAndWeightChanges")) 235 } else if (testCase 221 createReplicationServer(int rsIndex, int weight, String testCase) argument 287 createReplicationServerConfigWithNewWeight(int rsIndex, int weight, String testCase) argument 328 createReplicationDomain(int serverId, String testCase) argument [all...] |
H A D | GroupIdHandshakeTest.java | 281 private SortedSet<String> createRSListForTestCase(String testCase) argument 285 if (testCase.equals("testRSWithSameGroupIds")) 290 } else if (testCase.equals("testRSWithManyGroupIds")) 297 fail("Unknown test case: " + testCase); 306 int groupId, String testCase) 315 if (testCase.equals("testRSWithSameGroupIds")) 319 } else if (testCase.equals("testRSWithManyGroupIds")) 325 fail("Unknown test case: " + testCase); 329 if (testCase.equals("testRSWithSameGroupIds")) 333 } else if (testCase 305 createReplicationServer(int serverId, int groupId, String testCase) argument 372 createReplicationDomain(int serverId, int groupId, String testCase) argument [all...] |
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/ |
H A D | ReplicationServerLoadBalancingTest.java | 172 private SortedSet<String> createRSListForTestCase(String testCase) argument 176 if (testCase.equals("testFailoversAndWeightChanges")) 183 } else if (testCase.equals("testSpreadLoad")) 190 } else if (testCase.equals("testNoYoyo1")) 197 } else if (testCase.equals("testNoYoyo2")) 204 } else if (testCase.equals("testNoYoyo3")) 213 fail("Unknown test case: " + testCase); 222 int weight, String testCase) 227 if (testCase.equals("testFailoversAndWeightChanges")) 235 } else if (testCase 221 createReplicationServer(int rsIndex, int weight, String testCase) argument 287 createReplicationServerConfigWithNewWeight(int rsIndex, int weight, String testCase) argument 328 createReplicationDomain(int serverId, String testCase) argument [all...] |
H A D | GroupIdHandshakeTest.java | 281 private SortedSet<String> createRSListForTestCase(String testCase) argument 285 if (testCase.equals("testRSWithSameGroupIds")) 290 } else if (testCase.equals("testRSWithManyGroupIds")) 297 fail("Unknown test case: " + testCase); 306 int groupId, String testCase) 315 if (testCase.equals("testRSWithSameGroupIds")) 319 } else if (testCase.equals("testRSWithManyGroupIds")) 325 fail("Unknown test case: " + testCase); 329 if (testCase.equals("testRSWithSameGroupIds")) 333 } else if (testCase 305 createReplicationServer(int serverId, int groupId, String testCase) argument 372 createReplicationDomain(int serverId, int groupId, String testCase) argument [all...] |