/forgerock/opendj2/src/server/org/opends/server/replication/server/ |
H A D | ServerHandler.java | 136 private Semaphore sendWindow; field in class:ServerHandler 301 // sendWindow MUST be created before starting the writer 302 sendWindow = new Semaphore(sendWindowSize); 544 attributes.add(Attributes.create("current-send-window", String.valueOf(sendWindow.availablePermits()))); 979 acquired = sendWindow.tryAcquire(500, TimeUnit.MILLISECONDS); 1022 sendWindow.release(windowMsg.getNumAck());
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/ |
H A D | ServerHandler.java | 136 private Semaphore sendWindow; field in class:ServerHandler 301 // sendWindow MUST be created before starting the writer 302 sendWindow = new Semaphore(sendWindowSize); 544 attributes.add(Attributes.create("current-send-window", String.valueOf(sendWindow.availablePermits()))); 979 acquired = sendWindow.tryAcquire(500, TimeUnit.MILLISECONDS); 1022 sendWindow.release(windowMsg.getNumAck());
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/ |
H A D | ServerHandler.java | 138 private Semaphore sendWindow; field in class:ServerHandler 285 // sendWindow MUST be created before starting the writer 286 sendWindow = new Semaphore(sendWindowSize); 528 attributes.add(Attributes.create("current-send-window", String.valueOf(sendWindow.availablePermits()))); 960 acquired = sendWindow.tryAcquire(500, TimeUnit.MILLISECONDS); 999 sendWindow.release(windowMsg.getNumAck());
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/ |
H A D | ServerHandler.java | 186 protected Semaphore sendWindow; field in class:ServerHandler 362 // sendWindow MUST be created before starting the writer 363 sendWindow = new Semaphore(sendWindowSize); 631 .valueOf(sendWindow.availablePermits()))); 1087 acquired = sendWindow.tryAcquire((long) 500, TimeUnit.MILLISECONDS); 1143 sendWindow.release(windowMsg.getNumAck());
|
H A D | ECLServerHandler.java | 1100 // sendWindow MUST be created before starting the writer 1101 sendWindow = new Semaphore(sendWindowSize); 1206 acquired = sendWindow.tryAcquire((long) 500, TimeUnit.MILLISECONDS);
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/ |
H A D | ServerHandler.java | 188 protected Semaphore sendWindow; field in class:ServerHandler 364 // sendWindow MUST be created before starting the writer 365 sendWindow = new Semaphore(sendWindowSize); 633 .valueOf(sendWindow.availablePermits()))); 1104 acquired = sendWindow.tryAcquire((long) 500, TimeUnit.MILLISECONDS); 1160 sendWindow.release(windowMsg.getNumAck());
|
H A D | ECLServerHandler.java | 1100 // sendWindow MUST be created before starting the writer 1101 sendWindow = new Semaphore(sendWindowSize); 1206 acquired = sendWindow.tryAcquire((long) 500, TimeUnit.MILLISECONDS);
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/ |
H A D | ServerHandler.java | 186 protected Semaphore sendWindow; field in class:ServerHandler 362 // sendWindow MUST be created before starting the writer 363 sendWindow = new Semaphore(sendWindowSize); 631 .valueOf(sendWindow.availablePermits()))); 1087 acquired = sendWindow.tryAcquire((long) 500, TimeUnit.MILLISECONDS); 1143 sendWindow.release(windowMsg.getNumAck());
|
H A D | ECLServerHandler.java | 1100 // sendWindow MUST be created before starting the writer 1101 sendWindow = new Semaphore(sendWindowSize); 1206 acquired = sendWindow.tryAcquire((long) 500, TimeUnit.MILLISECONDS);
|
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 102 private Semaphore sendWindow; field in class:ReplicationBroker 1062 if (sendWindow != null) 1071 if (sendWindow.availablePermits() < MAX_PERMITS) 1079 sendWindow.release(MAX_PERMITS); 1082 sendWindow = new Semaphore(maxSendWindow); 2325 currentWindowSemaphore = sendWindow; 2489 sendWindow.release(windowMsg.getNumAck()); 2798 return sendWindow.availablePermits();
|
/forgerock/opendj2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 164 private Semaphore sendWindow; field in class:ReplicationBroker 941 if (sendWindow != null) 950 if (sendWindow.availablePermits() < MAX_PERMITS) 958 sendWindow.release(MAX_PERMITS); 961 sendWindow = new Semaphore(maxSendWindow); 2308 currentWindowSemaphore = sendWindow; 2488 sendWindow.release(windowMsg.getNumAck()); 2792 return sendWindow.availablePermits();
|
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 96 private Semaphore sendWindow; field in class:ReplicationBroker 1061 if (sendWindow != null) 1070 if (sendWindow.availablePermits() < MAX_PERMITS) 1078 sendWindow.release(MAX_PERMITS); 1081 sendWindow = new Semaphore(maxSendWindow); 2583 currentWindowSemaphore = sendWindow; 2747 sendWindow.release(windowMsg.getNumAck()); 3060 return sendWindow.availablePermits();
|
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 102 private Semaphore sendWindow; field in class:ReplicationBroker 1062 if (sendWindow != null) 1071 if (sendWindow.availablePermits() < MAX_PERMITS) 1079 sendWindow.release(MAX_PERMITS); 1082 sendWindow = new Semaphore(maxSendWindow); 2325 currentWindowSemaphore = sendWindow; 2489 sendWindow.release(windowMsg.getNumAck()); 2798 return sendWindow.availablePermits();
|
/forgerock/opendj2-hg/src/server/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 164 private Semaphore sendWindow; field in class:ReplicationBroker 941 if (sendWindow != null) 950 if (sendWindow.availablePermits() < MAX_PERMITS) 958 sendWindow.release(MAX_PERMITS); 961 sendWindow = new Semaphore(maxSendWindow); 2308 currentWindowSemaphore = sendWindow; 2488 sendWindow.release(windowMsg.getNumAck()); 2792 return sendWindow.availablePermits();
|
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/service/ |
H A D | ReplicationBroker.java | 157 private Semaphore sendWindow; field in class:ReplicationBroker 929 if (sendWindow != null) 938 if (sendWindow.availablePermits() < MAX_PERMITS) 946 sendWindow.release(MAX_PERMITS); 949 sendWindow = new Semaphore(maxSendWindow); 2282 currentWindowSemaphore = sendWindow; 2462 sendWindow.release(windowMsg.getNumAck()); 2760 return sendWindow.availablePermits();
|