Searched defs:take (Results 1 - 21 of 21) sorted by relevance

/forgerock/openam-v13/openam-shared/src/main/java/org/forgerock/openam/shared/concurrency/
H A DResizableLinkedBlockingQueue.java198 public E take() throws InterruptedException { method in class:ResizableLinkedBlockingQueue
199 E result = super.take();
/forgerock/openam/openam-shared/src/main/java/org/forgerock/openam/shared/concurrency/
H A DResizableLinkedBlockingQueue.java198 public E take() throws InterruptedException { method in class:ResizableLinkedBlockingQueue
199 E result = super.take();
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DTestSynchronousReplayQueue.java109 public UpdateToReplay take() throws InterruptedException method in class:TestSynchronousReplayQueue
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DTestSynchronousReplayQueue.java108 public UpdateToReplay take() throws InterruptedException method in class:TestSynchronousReplayQueue
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DTestSynchronousReplayQueue.java109 public UpdateToReplay take() throws InterruptedException method in class:TestSynchronousReplayQueue
/forgerock/opendj2-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DTestSynchronousReplayQueue.java108 public UpdateToReplay take() throws InterruptedException method in class:TestSynchronousReplayQueue
/forgerock/opendj2-jel-hg/tests/unit-tests-testng/src/server/org/opends/server/replication/plugin/
H A DTestSynchronousReplayQueue.java109 public UpdateToReplay take() throws InterruptedException method in class:TestSynchronousReplayQueue
/forgerock/opendj-v3/opendj-server-legacy/src/test/java/org/opends/server/replication/plugin/
H A DTestSynchronousReplayQueue.java107 public UpdateToReplay take() throws InterruptedException method in class:TestSynchronousReplayQueue
/forgerock/opendj2/src/server/org/opends/server/replication/server/
H A DServerHandler.java769 * thread to take the lock it was waiting for and process the connection
969 public UpdateMsg take(Set<Integer> connectedReplicaIds) method in class:ServerHandler
H A DReplicationServerDomain.java1293 public UpdateMsg take(ServerHandler sHandler) method in class:ReplicationServerDomain
1296 return sHandler.take(new HashSet<Integer>(getConnectedDSs().keySet()));
1841 // Order to take a gen id we already have, just ignore
2577 // take RSD lock to test. If we attempt to change the status whereas
2579 // the changeStatusFromStatusAnalyzer() method. This allows to take the
/forgerock/opendj2-hg/src/server/org/opends/server/replication/server/
H A DServerHandler.java769 * thread to take the lock it was waiting for and process the connection
969 public UpdateMsg take(Set<Integer> connectedReplicaIds) method in class:ServerHandler
H A DReplicationServerDomain.java1293 public UpdateMsg take(ServerHandler sHandler) method in class:ReplicationServerDomain
1296 return sHandler.take(new HashSet<Integer>(getConnectedDSs().keySet()));
1841 // Order to take a gen id we already have, just ignore
2577 // take RSD lock to test. If we attempt to change the status whereas
2579 // the changeStatusFromStatusAnalyzer() method. This allows to take the
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/server/
H A DServerHandler.java735 * thread to take the lock it was waiting for and process the connection
934 public UpdateMsg take() throws ChangelogException method in class:ServerHandler
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/server/
H A DReplicationServerDomain.java1302 public UpdateMsg take(ServerHandler handler) method in class:ReplicationServerDomain
1314 msg = handler.take();
2117 // Order to take a gen id we already have, just ignore
2650 // So for a given DS connected we can take the state and the max from
3172 * For each DS, take the oldest CN from the changetime heartbeat state
H A DServerHandler.java891 * listen thread to take the lock it was waiting for and process
1077 public UpdateMsg take() method in class:ServerHandler
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/server/
H A DServerHandler.java893 * listen thread to take the lock it was waiting for and process
1094 public UpdateMsg take() method in class:ServerHandler
H A DReplicationServerDomain.java1386 public UpdateMsg take(ServerHandler handler) method in class:ReplicationServerDomain
1398 msg = handler.take();
2121 // Order to take a gen id we already have, just ignore
2679 // So for a given DS connected we can take the state and the max from
3150 * For each DS, take the oldest CN from the changetime heartbeat state
3380 // take RSD lock to test. If we attempt to change the status whereas
3382 // the changeStatusFromStatusAnalyzer() method. This allows to take the
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/server/
H A DReplicationServerDomain.java1302 public UpdateMsg take(ServerHandler handler) method in class:ReplicationServerDomain
1314 msg = handler.take();
2117 // Order to take a gen id we already have, just ignore
2650 // So for a given DS connected we can take the state and the max from
3172 * For each DS, take the oldest CN from the changetime heartbeat state
H A DServerHandler.java891 * listen thread to take the lock it was waiting for and process
1077 public UpdateMsg take() method in class:ServerHandler
/forgerock/opendj-b2.6/resource/dsml/lib/
H A Djaxb-impl.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/sun/ com/sun/xml/ com/sun/xml/bind/ ...
/forgerock/opendj2-jel-hg/resource/dsml/lib/
H A Djaxb-impl.jarMETA-INF/ META-INF/MANIFEST.MF com/ com/sun/ com/sun/xml/ com/sun/xml/bind/ ...

Completed in 164 milliseconds