mirror of https://github.com/OpenIdentityPlatform/OpenDJ.git

pgamba
22.49.2009 3f3a12a708ce53bc12cca8817ff6812ea86eb585
Still try to improve this test
1 files modified
9 ■■■■ changed files
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ReplicationServerTest.java 9 ●●●● patch | view | raw | blame | history
opends/tests/unit-tests-testng/src/server/org/opends/server/replication/server/ReplicationServerTest.java
@@ -703,7 +703,7 @@
        reader[i].start();
      }
      debugInfo("multipleWriterMultipleReader produces and readers started");
      Thread.sleep(2000);
      //Thread.sleep(2000);
    }
    finally
    {
@@ -1168,7 +1168,11 @@
            numMsgRcv++;
            broker.updateWindowAfterReplay();
          }
          if ((msg == null) || (numMsgRcv >= numMsgExpected))
          // if ((msg == null) || (numMsgRcv >= numMsgExpected))
          // Terminating this thread when the nb of msg received is reached
          // may prevent to process a WindowMsg that would unblock the dual
          // writer thread.
          if (msg == null)
            break;
        }
      } catch (SocketTimeoutException e)
@@ -1188,6 +1192,7 @@
            "a BrokerReader received an Exception" + e.getMessage()
            + stackTraceToSingleLineString(e);
      }
      assert(numMsgRcv >= numMsgExpected);
    }
  }