opendj-sdk/opends/src/server/org/opends/server/replication/server/ECLServerHandler.java
@@ -1400,7 +1400,7 @@ break; } } // while DraftCN } } // if draftCompat // here we have the right oldest change // and in the draft case, we have its draft changenumber @@ -1414,7 +1414,11 @@ { domainCtxts[iDom].active = false; } if (draftCompat && (lastDraftCN>0) && (oldestChange.getDraftChangeNumber()>lastDraftCN)) { domainCtxts[iDom].active = false; } if (domainCtxts[iDom].active) { // populates the table with the next eligible msg from idomain opendj-sdk/opends/src/server/org/opends/server/replication/service/ReplicationDomain.java
@@ -1699,7 +1699,8 @@ done = true; short reconnectMaxDelayInSec = 10; short reconnectWait = 0; for (int serverId : replicasWeAreWaitingFor) Integer[] servers = replicasWeAreWaitingFor.toArray(new Integer[0]); for (int serverId : servers) { if (ieContext.failureList.contains(serverId)) {