Fix a problem in the synchronization stress test where the main thread was ...

gbellato

22.14.2007 f00748e6a2044b4b4d81b7ed161f22ff92bd5f3c

Fix a problem in the synchronization stress test where the main thread
was not waiting for the reader thread to complete it's job before
returning the number of message read thus causing the test to fail

 opends/tests/unit-tests-testng/src/server/org/opends/server/synchronization/StressTest.java

@@ -118,19 +118,6 @@

    try {
      /*
       * loop receiving update until there is nothing left
       * to make sure that message from previous tests have been consumed.
       */
      try
      {
        while (true)
        {
          broker.receive();
        }
      }
      catch (Exception e)
      { }
      /*
       * Test that operations done on this server are sent to the
       * changelog server and forwarded to our changelog broker session.
       */
@@ -376,7 +363,10 @@
            break;
          count ++;
        }
      } catch (Exception e) {
      } catch (Exception e)
      {}
      finally 
      {
        synchronized (this)
        {
          finished = true;
@@ -393,16 +383,18 @@
    {
      synchronized (this)
      {
        if (finished == true)
          return count;
        try
          int i = 20;
        while ((finished != true) && (i-- >0))
        {
          this.wait(60);
          return count;
        } catch (InterruptedException e)
        {
          return -1;
          try
          {
            this.wait(60000);
          } catch (InterruptedException e)
          {
            return -1;
          }
        }
        return count;
      }
    }