Searched refs:nextNonEligibleMsg (Results 1 - 3 of 3) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DECLServerHandler.java155 private UpdateMsg nextNonEligibleMsg; field in class:ECLServerHandler.DomainContext
181 .append(")" + "] [nextNonEligibleMsg=").append(nextNonEligibleMsg)
205 if (nextNonEligibleMsg != null)
208 (nextNonEligibleMsg.getChangeNumber().getTime()
214 + " stored nonEligibleMsg " + nextNonEligibleMsg
222 nextMsg = nextNonEligibleMsg;
223 nextNonEligibleMsg = null;
270 nextNonEligibleMsg = newMsg;
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DECLServerHandler.java155 private UpdateMsg nextNonEligibleMsg; field in class:ECLServerHandler.DomainContext
181 .append(")" + "] [nextNonEligibleMsg=").append(nextNonEligibleMsg)
205 if (nextNonEligibleMsg != null)
208 (nextNonEligibleMsg.getChangeNumber().getTime()
214 + " stored nonEligibleMsg " + nextNonEligibleMsg
222 nextMsg = nextNonEligibleMsg;
223 nextNonEligibleMsg = null;
270 nextNonEligibleMsg = newMsg;
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DECLServerHandler.java155 private UpdateMsg nextNonEligibleMsg; field in class:ECLServerHandler.DomainContext
181 .append(")" + "] [nextNonEligibleMsg=").append(nextNonEligibleMsg)
205 if (nextNonEligibleMsg != null)
208 (nextNonEligibleMsg.getChangeNumber().getTime()
214 + " stored nonEligibleMsg " + nextNonEligibleMsg
222 nextMsg = nextNonEligibleMsg;
223 nextNonEligibleMsg = null;
270 nextNonEligibleMsg = newMsg;

Completed in 1590 milliseconds