opends/tests/unit-tests-testng/src/server/org/opends/server/core/CompareOperationTestCase.java
@@ -598,6 +598,13 @@ @Test(groups = "slow") public void testCompareWriteLock() throws Exception { // Since we are going to be watching the post-response count, we need to // wait for the server to become idle before kicking off the next request to // ensure that any remaining post-response processing from the previous // operation has completed. assertTrue(DirectoryServer.getWorkQueue().waitUntilIdle(10000)); // We need the operation to be run in a separate thread because we are going // to write lock the entry in the test case thread and check that the // compare operation does not proceed. opends/tests/unit-tests-testng/src/server/org/opends/server/core/SearchOperationTestCase.java
@@ -236,6 +236,13 @@ ArrayList<LDAPControl> controls) throws IOException, LDAPException, ASN1Exception, InterruptedException { // Since we are going to be watching the post-response count, we need to // wait for the server to become idle before kicking off the next request to // ensure that any remaining post-response processing from the previous // operation has completed. assertTrue(DirectoryServer.getWorkQueue().waitUntilIdle(10000)); // Establish a connection to the server. Socket s = new Socket("127.0.0.1", (int) TestCaseUtils.getServerLdapPort()); try @@ -287,6 +294,13 @@ private void bindAsManager(ASN1Writer w, ASN1Reader r) throws IOException, LDAPException, ASN1Exception, InterruptedException { // Since we are going to be watching the post-response count, we need to // wait for the server to become idle before kicking off the next request to // ensure that any remaining post-response processing from the previous // operation has completed. assertTrue(DirectoryServer.getWorkQueue().waitUntilIdle(10000)); InvocationCounterPlugin.resetAllCounters(); BindRequestProtocolOp bindRequest = new BindRequestProtocolOp( opends/tests/unit-tests-testng/src/server/org/opends/server/core/TestModifyDNOperation.java
@@ -1095,6 +1095,13 @@ @Test public void testShortCircuitModify() throws Exception { // Since we are going to be watching the post-response count, we need to // wait for the server to become idle before kicking off the next request to // ensure that any remaining post-response processing from the previous // operation has completed. assertTrue(DirectoryServer.getWorkQueue().waitUntilIdle(10000)); // Establish a connection to the server. Socket s = new Socket("127.0.0.1", (int) TestCaseUtils.getServerLdapPort()); @@ -1128,6 +1135,13 @@ @Test(groups = "slow") public void testWriteLockModify() throws Exception { // Since we are going to be watching the post-response count, we need to // wait for the server to become idle before kicking off the next request to // ensure that any remaining post-response processing from the previous // operation has completed. assertTrue(DirectoryServer.getWorkQueue().waitUntilIdle(10000)); // We need the operation to be run in a separate thread because we are going // to write lock the entry in the test case thread and check that the // modify DN operation does not proceed.