| opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationBroker.java | ●●●●● patch | view | raw | blame | history |
opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationBroker.java
@@ -2466,12 +2466,17 @@ } if ((!credit) && (currentWindowSemaphore.availablePermits() == 0)) { 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) { if (!retryOnFailure)