Searched defs:sendWindow (Results 1 - 12 of 12) sorted by relevance

/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DServerHandler.java136 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 DServerHandler.java136 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 DServerHandler.java138 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 DServerHandler.java186 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());
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DServerHandler.java188 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());
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DServerHandler.java186 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());
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/service/
H A DReplicationBroker.java102 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 DReplicationBroker.java164 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 DReplicationBroker.java96 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 DReplicationBroker.java102 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 DReplicationBroker.java164 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 DReplicationBroker.java157 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();

Completed in 114 milliseconds