| | |
| | | * |
| | | * Copyright 2006-2010 Sun Microsystems, Inc. |
| | | * Portions Copyright 2011-2016 ForgeRock AS. |
| | | * Portions Copyright 2026 3A Systems, LLC |
| | | */ |
| | | package org.opends.server.replication; |
| | | |
| | |
| | | * and test that, on S1 side, the task ends with an error. |
| | | * State of the backend on S1 partially initialized: ? |
| | | */ |
| | | @Test(enabled=true, groups="slow") |
| | | @Test(enabled=true) |
| | | public void initializeImport() throws Exception |
| | | { |
| | | String testCase = "initializeImport "; |
| | |
| | | * - test that S1 has successfully exported the entries (by receiving them |
| | | * on S2 side). |
| | | */ |
| | | @Test(enabled=true, groups="slow") |
| | | @Test(enabled=true) |
| | | public void initializeExport() throws Exception |
| | | { |
| | | String testCase = "initializeExport"; |
| | |
| | | * - wait task completed |
| | | * - test that S2 has successfully received the entries |
| | | */ |
| | | @Test(enabled=true, groups="slow") |
| | | @Test(enabled=true) |
| | | public void initializeTargetExport() throws Exception |
| | | { |
| | | String testCase = "initializeTargetExport"; |
| | |
| | | * |
| | | * TODO: Error case: make S2 crash in the middle of the import and test what?? |
| | | */ |
| | | @Test(enabled=true, groups="slow") |
| | | @Test(enabled=true) |
| | | public void initializeTargetExportAll() throws Exception |
| | | { |
| | | String testCase = "initializeTargetExportAll"; |
| | |
| | | /** |
| | | * Tests the import side of the InitializeTarget task. |
| | | */ |
| | | @Test(enabled=true, groups="slow") |
| | | @Test(enabled=true) |
| | | public void initializeTargetImport() throws Exception |
| | | { |
| | | String testCase = "initializeTargetImport"; |
| | |
| | | * connected to each replication server of the topology, thanks to the |
| | | * ReplServerInfoMessage(s) exchanged by the replication servers. |
| | | */ |
| | | @Test(enabled=true, groups="slow") |
| | | @Test(enabled=true) |
| | | public void testReplServerInfos() throws Exception |
| | | { |
| | | String testCase = "testReplServerInfos"; |
| | |
| | | return domain.getConnectedDSs().keySet(); |
| | | } |
| | | |
| | | @Test(enabled=true, groups="slow") |
| | | @Test(enabled=true) |
| | | public void initializeTargetExportMultiSS() throws Exception |
| | | { |
| | | String testCase = "initializeTargetExportMultiSS"; |
| | |
| | | Assertions.assertThat(msgrcv).isInstanceOf(InitializeTargetMsg.class); |
| | | } |
| | | |
| | | @Test(enabled=true, groups="slow") |
| | | @Test(enabled=true) |
| | | public void initializeExportMultiSS() throws Exception |
| | | { |
| | | String testCase = "initializeExportMultiSS"; |