Fix for 4265 : Unit test AssuredReplicationServerTest#testSafeDataLevelOne ...

gbellato

02.47.2009 d54f458902ba8de3503f8cd24e1f30821e151a56

 opendj-sdk/opends/src/server/org/opends/server/replication/server/MessageHandler.java

@@ -403,9 +403,11 @@
            iterator.releaseCursor();
          }
          /*
           * Check if the first change in the lateQueue is also on the regular
           * queue
           * If the late queue is empty then we could not find any
           * messages in the replication log so the remote serevr is not
           * late anymore.
           */

          if (lateQueue.isEmpty())
          {
            synchronized (msgQueue)
@@ -418,6 +420,11 @@
            }
          } else
          {
            /*
             * if the first change in the lateQueue is also on the regular
             * queue, we can resume the processing from the regular queue
             * -> set following to true and empty the lateQueue.
             */
            msg = lateQueue.first();
            synchronized (msgQueue)
            {
@@ -432,7 +439,7 @@
                  msg1 = msgQueue.removeFirst();
                } while (!msg.getChangeNumber().equals(msg1.getChangeNumber()));
                this.updateServerState(msg);
                return msg;
                return msg1;
              }
            }
          }