| | |
| | | } |
| | | |
| | | // Deprecated |
| | | // attributes.add(new Attribute("max-waiting-changes", |
| | | // String.valueOf(maxQueueSize))); |
| | | attributes.add(new Attribute("max-waiting-changes", |
| | | String.valueOf(maxQueueSize))); |
| | | attributes.add(new Attribute("update-sent", |
| | | String.valueOf(getOutCount()))); |
| | | attributes.add(new Attribute("update-received", |
| | |
| | | * - receive all messages from the ReplicationBroker, check that |
| | | * the client receives the correct number of operations. |
| | | */ |
| | | @Test(enabled=false, groups="slow") |
| | | @Test(enabled=true, groups="slow") |
| | | public void saturateQueueAndRestart() throws Exception |
| | | { |
| | | logError(Message.raw( |
| | |
| | | op = connection.processSearch( |
| | | new ASN1OctetString("cn=monitor"), |
| | | SearchScope.WHOLE_SUBTREE, |
| | | LDAPFilter.decode("(waiting-changes=" + |
| | | LDAPFilter.decode("(missing-changes=" + |
| | | (REPLICATION_QUEUE_SIZE + WINDOW_SIZE) + ")")); |
| | | assertEquals(op.getResultCode(), ResultCode.SUCCESS); |
| | | |
| | |
| | | /** |
| | | * Tests done using directly the ReplicationBroker interface. |
| | | */ |
| | | @Test(enabled=false, dataProvider="assured") |
| | | @Test(enabled=true, dataProvider="assured") |
| | | public void updateOperations(boolean assured) throws Exception |
| | | { |
| | | logError(Message.raw( |
| | |
| | | * This method is used to make sure that this order is always respected. |
| | | * (Using testng dependency does not work) |
| | | */ |
| | | @Test(enabled=false) |
| | | @Test(enabled=true) |
| | | public void replicationServerTest() throws Exception |
| | | { |
| | | replicationServer.clearDb(); |