Fix bug which can cause replicas to diverge under heavy stress

matthew_swift

18.17.2010 b889fd211a81d2208afaa1c077c1b42e6b2b2873

 opends/src/server/org/opends/server/replication/service/ReplicationBroker.java

@@ -2466,11 +2466,16 @@
        }
        if ((!credit) && (currentWindowSemaphore.availablePermits() == 0))
        {
          // the window is still closed.
          // Send a WindowProbeMsg message to wakeup the receiver in case the
          // window update message was lost somehow...
          // then loop to check again if connection was closed.
          session.publish(new WindowProbeMsg());
          synchronized (connectPhaseLock)
          {
            // the window is still closed.
            // Send a WindowProbeMsg message to wakeup the receiver in case the
            // window update message was lost somehow...
            // then loop to check again if connection was closed.
            if (session != null) {
              session.publish(new WindowProbeMsg());
            }
          }
        }
      } catch (IOException e)
      {