Searched defs:updateDoneCount (Results 1 - 6 of 6) sorted by relevance

/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java172 private volatile int updateDoneCount = 0; field in class:ReplicationBroker
2688 updateDoneCount++;
2689 if ((updateDoneCount >= halfRcvWindow) && (session != null))
2691 session.publish(new WindowMsg(updateDoneCount));
2692 rcvWindow += updateDoneCount;
2693 updateDoneCount = 0;
/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java223 private volatile int updateDoneCount = 0; field in class:ReplicationBroker
2685 updateDoneCount++;
2687 if (updateDoneCount >= halfRcvWindow && session != null)
2689 session.publish(new WindowMsg(updateDoneCount));
2690 rcvWindow += updateDoneCount;
2691 updateDoneCount = 0;
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java169 private volatile int updateDoneCount = 0; field in class:ReplicationBroker
2951 updateDoneCount++;
2952 if ((updateDoneCount >= halfRcvWindow) && (session != null))
2954 session.publish(new WindowMsg(updateDoneCount));
2955 rcvWindow += updateDoneCount;
2956 updateDoneCount = 0;
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java172 private volatile int updateDoneCount = 0; field in class:ReplicationBroker
2688 updateDoneCount++;
2689 if ((updateDoneCount >= halfRcvWindow) && (session != null))
2691 session.publish(new WindowMsg(updateDoneCount));
2692 rcvWindow += updateDoneCount;
2693 updateDoneCount = 0;
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java223 private volatile int updateDoneCount = 0; field in class:ReplicationBroker
2685 updateDoneCount++;
2687 if (updateDoneCount >= halfRcvWindow && session != null)
2689 session.publish(new WindowMsg(updateDoneCount));
2690 rcvWindow += updateDoneCount;
2691 updateDoneCount = 0;
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationBroker.java209 private volatile int updateDoneCount; field in class:ReplicationBroker
2650 updateDoneCount++;
2652 if (updateDoneCount >= halfRcvWindow && session != null)
2654 session.publish(new WindowMsg(updateDoneCount));
2655 rcvWindow += updateDoneCount;
2656 updateDoneCount = 0;

Completed in 71 milliseconds