Searched refs:latch (Results 1 - 25 of 30) sorted by relevance

12

/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/
H A DCountDownHandler.java31 private final CountDownLatch latch; field in class:CountDownHandler
36 * @param latch The {@link CountDownLatch} to update as results and errors are received.
38 public CountDownHandler(CountDownLatch latch) { argument
39 this.latch = latch;
49 latch.countDown();
54 latch.countDown();
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/cts/reaper/
H A DTokenDeletion.java54 CountDownLatch latch = new CountDownLatch(tokens.size());
55 ResultHandler<String, CoreTokenException> handler = new CountdownHandler(latch);
59 return latch;
63 * Internal implementation to ensure that delete operations count down the latch.
66 private final CountDownLatch latch; field in class:TokenDeletion.CountdownHandler
67 public CountdownHandler(CountDownLatch latch) { argument
68 this.latch = latch;
78 latch.countDown();
83 latch
[all...]
H A DCTSReaper.java122 for (CountDownLatch latch : latches) {
124 latch.await();
/forgerock/openam/openam-core/src/main/java/com/iplanet/dpro/session/service/
H A DSessionTimeoutHandlerExecutor.java102 final CountDownLatch latch = new CountDownLatch(handlers.size());
128 latch.countDown();
137 latch.await(1000, TimeUnit.MILLISECONDS);
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/cts/worker/process/
H A DCTSWorkerDeleteProcess.java112 CountDownLatch latch = new CountDownLatch(tokens.size());
113 ResultHandler<PartialToken, CoreTokenException> handler = new CountDownHandler<>(latch);
118 return latch;
H A DCTSWorkerBaseProcess.java61 CountDownLatch latch = handleBatch(filteredTokens);
62 latch.await();
H A DSessionExpiryBatchHandler.java87 CountDownLatch latch = new CountDownLatch(tokenIds.size());
89 latch);
102 return latch;
214 * @param latch The {@link CountDownLatch} to decrement as each result or error is processed by the handler.
217 StateChangeResultHandler create(SessionEventType eventType, CountDownLatch latch); argument
/forgerock/opendj-b2.6/src/server/org/opends/server/replication/protocol/
H A DSession.java123 private final CountDownLatch latch = new CountDownLatch(1); field in class:Session
570 latch.countDown();
615 latch.await();
/forgerock/opendj2/src/server/org/opends/server/replication/protocol/
H A DSession.java114 private final CountDownLatch latch = new CountDownLatch(1); field in class:Session
562 latch.countDown();
607 latch.await();
/forgerock/opendj2.6.2/src/server/org/opends/server/replication/protocol/
H A DSession.java123 private final CountDownLatch latch = new CountDownLatch(1); field in class:Session
570 latch.countDown();
615 latch.await();
/forgerock/opendj2-jel-hg/src/server/org/opends/server/replication/protocol/
H A DSession.java123 private final CountDownLatch latch = new CountDownLatch(1); field in class:Session
570 latch.countDown();
615 latch.await();
/forgerock/opendj2-hg/src/server/org/opends/server/replication/protocol/
H A DSession.java114 private final CountDownLatch latch = new CountDownLatch(1); field in class:Session
562 latch.countDown();
607 latch.await();
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/replication/protocol/
H A DSession.java110 private final CountDownLatch latch = new CountDownLatch(1); field in class:Session
541 latch.countDown();
586 latch.await();
/forgerock/opendj2/src/quicksetup/org/opends/quicksetup/
H A DUserData.java671 final CountDownLatch latch = new CountDownLatch(1);
754 latch.countDown();
762 latch.await(1, TimeUnit.SECONDS);
/forgerock/opendj2-hg/src/quicksetup/org/opends/quicksetup/
H A DUserData.java671 final CountDownLatch latch = new CountDownLatch(1);
754 latch.countDown();
762 latch.await(1, TimeUnit.SECONDS);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/quicksetup/
H A DUserData.java677 final CountDownLatch latch = new CountDownLatch(1);
763 latch.countDown();
771 latch.await(1, TimeUnit.SECONDS);
/forgerock/opendj-b2.6/src/quicksetup/org/opends/quicksetup/
H A DUserData.java690 final CountDownLatch latch = new CountDownLatch(1);
773 latch.countDown();
781 latch.await(1, TimeUnit.SECONDS);
/forgerock/opendj2.6.2/src/quicksetup/org/opends/quicksetup/
H A DUserData.java690 final CountDownLatch latch = new CountDownLatch(1);
773 latch.countDown();
781 latch.await(1, TimeUnit.SECONDS);
/forgerock/opendj2-jel-hg/src/quicksetup/org/opends/quicksetup/
H A DUserData.java690 final CountDownLatch latch = new CountDownLatch(1);
773 latch.countDown();
781 latch.await(1, TimeUnit.SECONDS);
/forgerock/openam/openam-core/src/test/java/org/forgerock/openam/cts/worker/process/
H A DSessionExpiryBatchHandlerTest.java209 private StateChangeResultHandler newStateChangeResultHandler(SessionEventType eventType, CountDownLatch latch) { argument
211 mockDebug, mockSessionAdapter, mockLocalOperations, eventType, latch, mockSessionService,
/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/dpro/session/service/
H A DSessionService.java1237 final CountDownLatch latch = new CountDownLatch(handlers.size());
1264 latch.countDown();
1273 latch.await(1000, TimeUnit.MILLISECONDS);
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/
H A DOnDiskMergeImporter.java851 CountDownLatch latch = importedContainers.get(container);
852 if (latch == null)
866 latch = importedContainers.get(container);
868 latch.await();
/forgerock/opendj-b2.6/tests/unit-tests-testng/src/server/org/opends/server/extensions/
H A DLDAPPassThroughAuthenticationPolicyTestCase.java1167 private final CountDownLatch latch = new CountDownLatch(1); field in class:LDAPPassThroughAuthenticationPolicyTestCase.MockServer.BlockAction
1173 latch.countDown();
1180 latch.await();
/forgerock/opendj2/tests/unit-tests-testng/src/server/org/opends/server/extensions/
H A DLDAPPassThroughAuthenticationPolicyTestCase.java1159 private final CountDownLatch latch = new CountDownLatch(1); field in class:LDAPPassThroughAuthenticationPolicyTestCase.MockServer.BlockAction
1165 latch.countDown();
1173 latch.await();
/forgerock/opendj2.6.2/tests/unit-tests-testng/src/server/org/opends/server/extensions/
H A DLDAPPassThroughAuthenticationPolicyTestCase.java1173 private final CountDownLatch latch = new CountDownLatch(1); field in class:LDAPPassThroughAuthenticationPolicyTestCase.MockServer.BlockAction
1179 latch.countDown();
1186 latch.await();

Completed in 196 milliseconds

12