opends/src/server/org/opends/server/replication/server/ServerHandler.java
@@ -1504,8 +1504,8 @@ } // 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", opends/tests/unit-tests-testng/src/server/org/opends/server/replication/ProtocolWindowTest.java
@@ -90,7 +90,7 @@ * - 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( @@ -221,7 +221,7 @@ 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); opends/tests/unit-tests-testng/src/server/org/opends/server/replication/UpdateOperationTest.java
@@ -1253,7 +1253,7 @@ /** * 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( opends/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ReplicationServerTest.java
@@ -145,7 +145,7 @@ * 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();