| | |
| | | * Note : Other tests in this file depends on this test and may need to |
| | | * change if this test is modified. |
| | | */ |
| | | @Test(enabled=false) |
| | | @Test(enabled=true) |
| | | public void changelogBasic() throws Exception |
| | | { |
| | | debugInfo("Starting changelogBasic"); |
| | |
| | | * Test that a new client see the change that was sent in the |
| | | * previous test. |
| | | */ |
| | | @Test(enabled=false, dependsOnMethods = { "changelogBasic" }) |
| | | @Test(enabled=true, dependsOnMethods = { "changelogBasic" }) |
| | | public void newClient() throws Exception |
| | | { |
| | | debugInfo("Starting newClient"); |
| | |
| | | * Test that a client that has already seen the first change now see the |
| | | * second change |
| | | */ |
| | | @Test(enabled=false, dependsOnMethods = { "changelogBasic" }) |
| | | @Test(enabled=true, dependsOnMethods = { "changelogBasic" }) |
| | | public void newClientWithFirstChanges() throws Exception |
| | | { |
| | | debugInfo("Starting newClientWithFirstChanges"); |
| | |
| | | * Test with a client that has already seen a Change that the |
| | | * ReplicationServer has not seen. |
| | | */ |
| | | @Test(enabled=false, dependsOnMethods = { "changelogBasic" }) |
| | | @Test(enabled=true, dependsOnMethods = { "changelogBasic" }) |
| | | public void newClientWithUnknownChanges() throws Exception |
| | | { |
| | | /* |
| | |
| | | * Test that a client that has already seen the first change from server 1 |
| | | * now see the first change from server 2 |
| | | */ |
| | | @Test(enabled=false, dependsOnMethods = { "changelogBasic" }) |
| | | @Test(enabled=true, dependsOnMethods = { "changelogBasic" }) |
| | | public void newClientWithChangefromServer1() throws Exception |
| | | { |
| | | /* |
| | |
| | | * Test that a client that has already seen the first chaneg from server 2 |
| | | * now see the first change from server 1 |
| | | */ |
| | | @Test(enabled=false, dependsOnMethods = { "changelogBasic" }) |
| | | @Test(enabled=true, dependsOnMethods = { "changelogBasic" }) |
| | | public void newClientWithChangefromServer2() throws Exception |
| | | { |
| | | /* |
| | |
| | | * Test that a client that has not seen the second change from server 1 |
| | | * now receive it. |
| | | */ |
| | | @Test(enabled=false, dependsOnMethods = { "changelogBasic" }) |
| | | @Test(enabled=true, dependsOnMethods = { "changelogBasic" }) |
| | | public void newClientLateServer1() throws Exception |
| | | { |
| | | /* |
| | |
| | | * Test that newClient() and newClientWithFirstChange() still works |
| | | * after stopping and restarting the replicationServer. |
| | | */ |
| | | @Test(enabled=false, dependsOnMethods = { "changelogBasic" }) |
| | | @Test(enabled=true, dependsOnMethods = { "changelogBasic" }) |
| | | public void stopChangelog() throws Exception |
| | | { |
| | | replicationServer.remove(); |
| | |
| | | * This test i sconfigured by a relatively low stress |
| | | * but can be changed using TOTAL_MSG and CLIENT_THREADS consts. |
| | | */ |
| | | @Test(enabled=false, groups="slow") |
| | | @Test(enabled=true, groups="slow") |
| | | public void oneWriterMultipleReader() throws Exception |
| | | { |
| | | ReplicationBroker server = null; |
| | |
| | | * This test is sconfigured for a relatively low stress |
| | | * but can be changed using TOTAL_MSG and THREADS consts. |
| | | */ |
| | | @Test(enabled=false, groups="slow") |
| | | @Test(enabled=true, groups="slow") |
| | | public void multipleWriterMultipleReader() throws Exception |
| | | { |
| | | ReplicationBroker server = null; |
| | |
| | | * - Check that client 2 receives the changes published by client 1 |
| | | * |
| | | */ |
| | | @Test(enabled=false) |
| | | @Test(enabled=true) |
| | | public void changelogChaining() throws Exception |
| | | { |
| | | for (int itest = 0; itest <2; itest++) |
| | |
| | | * Test that the Replication sends back correctly WindowsUpdate |
| | | * when we send a WindowProbe. |
| | | */ |
| | | @Test(enabled=false) |
| | | @Test(enabled=true) |
| | | public void windowProbeTest() throws Exception |
| | | { |
| | | final int WINDOW = 10; |
| | |
| | | /* |
| | | * Test backup and restore of the Replication server backend |
| | | */ |
| | | @Test(enabled=false) |
| | | @Test(enabled=true) |
| | | public void backupRestore() throws Exception |
| | | { |
| | | debugInfo("Starting backupRestore"); |
| | |
| | | * - Launch a full export |
| | | * - Launch a partial export on one of the 2 domains |
| | | */ |
| | | @Test(enabled=false) |
| | | @Test(enabled=true) |
| | | public void exportBackend() throws Exception |
| | | { |
| | | debugInfo("Starting exportBackend"); |
| | |
| | | * Testing searches on the backend of the replication server. |
| | | * @throws Exception |
| | | */ |
| | | @Test(enabled=true) |
| | | @Test(enabled=false) |
| | | public void searchBackend() throws Exception |
| | | { |
| | | debugInfo("Starting searchBackend"); |