Searched refs:rcvWindow (Results 1 - 18 of 18) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DServerHandler.java126 private int rcvWindow; field in class:ServerHandler
202 this.rcvWindow = rcvWindowSize;
262 if (rcvWindow < rcvWindowSizeHalf)
266 rcvWindow += rcvWindowSizeHalf;
278 rcvWindow--;
546 attributes.add(Attributes.create("current-rcv-window", String.valueOf(rcvWindow)));
861 if (rcvWindow > 0)
868 session.publish(new WindowMsg(rcvWindow));
H A DReplicationServer.java258 final int rcvWindow = this.config.getWindowSize();
262 session, queueSize, this, rcvWindow);
268 session, queueSize, this, rcvWindow);
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DServerHandler.java126 private int rcvWindow; field in class:ServerHandler
202 this.rcvWindow = rcvWindowSize;
262 if (rcvWindow < rcvWindowSizeHalf)
266 rcvWindow += rcvWindowSizeHalf;
278 rcvWindow--;
546 attributes.add(Attributes.create("current-rcv-window", String.valueOf(rcvWindow)));
861 if (rcvWindow > 0)
868 session.publish(new WindowMsg(rcvWindow));
H A DReplicationServer.java258 final int rcvWindow = this.config.getWindowSize();
262 session, queueSize, this, rcvWindow);
268 session, queueSize, this, rcvWindow);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DServerHandler.java132 private int rcvWindow; field in class:ServerHandler
186 this.rcvWindow = rcvWindowSize;
246 if (rcvWindow < rcvWindowSizeHalf)
250 rcvWindow += rcvWindowSizeHalf;
262 rcvWindow--;
530 attributes.add(Attributes.create("current-rcv-window", String.valueOf(rcvWindow)));
824 if (rcvWindow > 0)
831 session.publish(new WindowMsg(rcvWindow));
H A DReplicationServer.java255 final int rcvWindow = this.config.getWindowSize();
259 session, queueSize, this, rcvWindow);
265 session, queueSize, this, rcvWindow);
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DServerHandler.java176 private int rcvWindow; field in class:ServerHandler
262 this.rcvWindow = rcvWindowSize;
303 if (rcvWindow < rcvWindowSizeHalf)
307 rcvWindow += rcvWindowSizeHalf;
319 rcvWindow--;
635 .valueOf(rcvWindow)));
949 if (rcvWindow > 0)
957 WindowMsg msg = new WindowMsg(rcvWindow);
H A DReplicationServer.java107 private int rcvWindow; field in class:ReplicationServer
220 rcvWindow = configuration.getWindowSize();
334 queueSize,serverURL,serverId,this,rcvWindow);
340 session,queueSize,serverURL,serverId,this,rcvWindow);
346 session,queueSize,serverURL,serverId,this,rcvWindow);
500 rcvWindow);
1018 rcvWindow = configuration.getWindowSize();
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DServerHandler.java178 private int rcvWindow; field in class:ServerHandler
264 this.rcvWindow = rcvWindowSize;
305 if (rcvWindow < rcvWindowSizeHalf)
309 rcvWindow += rcvWindowSizeHalf;
321 rcvWindow--;
637 .valueOf(rcvWindow)));
975 if (rcvWindow > 0)
983 WindowMsg msg = new WindowMsg(rcvWindow);
H A DReplicationServer.java106 private int rcvWindow; field in class:ReplicationServer
220 rcvWindow = configuration.getWindowSize();
335 queueSize,serverURL,serverId,this,rcvWindow);
341 session,queueSize,serverURL,serverId,this,rcvWindow);
347 session,queueSize,serverURL,serverId,this,rcvWindow);
506 rcvWindow);
1025 rcvWindow = configuration.getWindowSize();
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DServerHandler.java176 private int rcvWindow; field in class:ServerHandler
262 this.rcvWindow = rcvWindowSize;
303 if (rcvWindow < rcvWindowSizeHalf)
307 rcvWindow += rcvWindowSizeHalf;
319 rcvWindow--;
635 .valueOf(rcvWindow)));
949 if (rcvWindow > 0)
957 WindowMsg msg = new WindowMsg(rcvWindow);
H A DReplicationServer.java107 private int rcvWindow; field in class:ReplicationServer
220 rcvWindow = configuration.getWindowSize();
334 queueSize,serverURL,serverId,this,rcvWindow);
340 session,queueSize,serverURL,serverId,this,rcvWindow);
346 session,queueSize,serverURL,serverId,this,rcvWindow);
500 rcvWindow);
1018 rcvWindow = configuration.getWindowSize();
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java104 private int rcvWindow = 100; field in class:ReplicationBroker
105 private int halfRcvWindow = rcvWindow / 2;
106 private int maxRcvWindow = rcvWindow;
243 this.rcvWindow = window;
265 this.rcvWindow = this.maxRcvWindow;
289 this.rcvWindow = this.maxRcvWindow;
1083 rcvWindow = maxRcvWindow;
2483 rcvWindow--;
2692 rcvWindow += updateDoneCount;
2776 return rcvWindow;
[all...]
/forgerock/opendj2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java166 private int rcvWindow = 100; field in class:ReplicationBroker
167 private int halfRcvWindow = rcvWindow / 2;
267 this.rcvWindow = getMaxRcvWindow();
268 this.halfRcvWindow = rcvWindow / 2;
287 this.rcvWindow = getMaxRcvWindow();
962 rcvWindow = getMaxRcvWindow();
2482 rcvWindow--;
2690 rcvWindow += updateDoneCount;
2770 return rcvWindow;
2827 this.rcvWindow
[all...]
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java98 private int rcvWindow = 100; field in class:ReplicationBroker
99 private int halfRcvWindow = rcvWindow / 2;
100 private int maxRcvWindow = rcvWindow;
242 this.rcvWindow = window;
265 this.rcvWindow = this.maxRcvWindow;
289 this.rcvWindow = this.maxRcvWindow;
1082 rcvWindow = maxRcvWindow;
2741 rcvWindow--;
2955 rcvWindow += updateDoneCount;
3038 return rcvWindow;
[all...]
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java104 private int rcvWindow = 100; field in class:ReplicationBroker
105 private int halfRcvWindow = rcvWindow / 2;
106 private int maxRcvWindow = rcvWindow;
243 this.rcvWindow = window;
265 this.rcvWindow = this.maxRcvWindow;
289 this.rcvWindow = this.maxRcvWindow;
1083 rcvWindow = maxRcvWindow;
2483 rcvWindow--;
2692 rcvWindow += updateDoneCount;
2776 return rcvWindow;
[all...]
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java166 private int rcvWindow = 100; field in class:ReplicationBroker
167 private int halfRcvWindow = rcvWindow / 2;
267 this.rcvWindow = getMaxRcvWindow();
268 this.halfRcvWindow = rcvWindow / 2;
287 this.rcvWindow = getMaxRcvWindow();
962 rcvWindow = getMaxRcvWindow();
2482 rcvWindow--;
2690 rcvWindow += updateDoneCount;
2770 return rcvWindow;
2827 this.rcvWindow
[all...]
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/
H A DReplicationBroker.java159 private int rcvWindow = 100; field in class:ReplicationBroker
160 private int halfRcvWindow = rcvWindow / 2;
253 this.rcvWindow = getMaxRcvWindow();
254 this.halfRcvWindow = rcvWindow / 2;
278 this.rcvWindow = getMaxRcvWindow();
950 rcvWindow = getMaxRcvWindow();
2456 rcvWindow--;
2655 rcvWindow += updateDoneCount;
2738 return rcvWindow;
2795 this.rcvWindow
[all...]

Completed in 110 milliseconds