/forgerock/opendj2/src/server/org/opends/server/replication/server/ |
H A D | ServerHandler.java | 126 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));
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
H A D | ServerHandler.java | 126 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));
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
H A D | ServerHandler.java | 132 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));
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServer.java | 107 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();
|
H A D | ServerHandler.java | 176 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);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServer.java | 106 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();
|
H A D | ServerHandler.java | 178 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);
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | ReplicationServer.java | 107 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();
|
H A D | ServerHandler.java | 176 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);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 104 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 D | ReplicationBroker.java | 166 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 D | ReplicationBroker.java | 98 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 D | ReplicationBroker.java | 104 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 D | ReplicationBroker.java | 166 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 D | ReplicationBroker.java | 159 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...] |