/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | CountDownHandler.java | 31 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 D | TokenDeletion.java | 54 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 D | CTSReaper.java | 122 for (CountDownLatch latch : latches) { 124 latch.await();
|
/forgerock/openam/openam-core/src/main/java/com/iplanet/dpro/session/service/ |
H A D | SessionTimeoutHandlerExecutor.java | 102 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 D | CTSWorkerDeleteProcess.java | 112 CountDownLatch latch = new CountDownLatch(tokens.size()); 113 ResultHandler<PartialToken, CoreTokenException> handler = new CountDownHandler<>(latch); 118 return latch;
|
H A D | CTSWorkerBaseProcess.java | 61 CountDownLatch latch = handleBatch(filteredTokens); 62 latch.await();
|
H A D | SessionExpiryBatchHandler.java | 87 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 D | Session.java | 123 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 D | Session.java | 114 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 D | Session.java | 123 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 D | Session.java | 123 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 D | Session.java | 114 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 D | Session.java | 110 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 D | UserData.java | 671 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 D | UserData.java | 671 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 D | UserData.java | 677 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 D | UserData.java | 690 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 D | UserData.java | 690 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 D | UserData.java | 690 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 D | SessionExpiryBatchHandlerTest.java | 209 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 D | SessionService.java | 1237 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 D | OnDiskMergeImporter.java | 851 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 D | LDAPPassThroughAuthenticationPolicyTestCase.java | 1167 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 D | LDAPPassThroughAuthenticationPolicyTestCase.java | 1159 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 D | LDAPPassThroughAuthenticationPolicyTestCase.java | 1173 private final CountDownLatch latch = new CountDownLatch(1); field in class:LDAPPassThroughAuthenticationPolicyTestCase.MockServer.BlockAction 1179 latch.countDown(); 1186 latch.await();
|