| /forgerock/openam-v13/openam-shared/src/main/java/org/forgerock/openam/shared/concurrency/ |
| H A D | ResizableSemaphore.java | 30 * permits and the given fairness setting.
32 * @param permits the initial number of permits available.
36 * first-in first-out granting of permits under contention,
39 public ResizableSemaphore(int permits, boolean fair) { argument
40 super(permits, fair);
45 * permits and nonfair fairness setting.
47 * @param permits the initial number of permits available.
51 public ResizableSemaphore(int permits) { argument
[all...] |
| /forgerock/openam/openam-shared/src/main/java/org/forgerock/openam/shared/concurrency/ |
| H A D | ResizableSemaphore.java | 30 * permits and the given fairness setting.
32 * @param permits the initial number of permits available.
36 * first-in first-out granting of permits under contention,
39 public ResizableSemaphore(int permits, boolean fair) { argument
40 super(permits, fair);
45 * permits and nonfair fairness setting.
47 * @param permits the initial number of permits available.
51 public ResizableSemaphore(int permits) { argument
[all...] |
| /forgerock/opendj2/src/server/org/opends/server/backends/jeb/importLDIF/ |
| H A D | Importer.java | 1240 Semaphore permits = new Semaphore(buffers);
1245 futures.add(dbService.submit(new IndexDBWriteTask(dnMgr, permits,
1250 futures.add(dbService.submit(new IndexDBWriteTask(mgr, permits, buffers,
1910 private final Semaphore permits; field in class:Importer.IndexDBWriteTask
1929 * @param permits
1937 public IndexDBWriteTask(IndexManager indexMgr, Semaphore permits, argument
1941 this.permits = permits;
1979 * buffer permits are available.
1988 // First release any previously acquired permits
[all...] |
| /forgerock/opendj-b2.6/src/server/org/opends/server/backends/jeb/importLDIF/ |
| H A D | Importer.java | 1208 Semaphore permits = new Semaphore(buffers);
1213 futures.add(dbService.submit(new IndexDBWriteTask(dnMgr, permits,
1218 futures.add(dbService.submit(new IndexDBWriteTask(mgr, permits, buffers,
1876 private final Semaphore permits; field in class:Importer.IndexDBWriteTask
1895 * @param permits
1903 public IndexDBWriteTask(IndexManager indexMgr, Semaphore permits, argument
1907 this.permits = permits;
1945 * buffer permits are available.
1954 // First release any previously acquired permits
[all...] |
| /forgerock/opendj2.6.2/src/server/org/opends/server/backends/jeb/importLDIF/ |
| H A D | Importer.java | 1208 Semaphore permits = new Semaphore(buffers);
1213 futures.add(dbService.submit(new IndexDBWriteTask(dnMgr, permits,
1218 futures.add(dbService.submit(new IndexDBWriteTask(mgr, permits, buffers,
1876 private final Semaphore permits; field in class:Importer.IndexDBWriteTask
1895 * @param permits
1903 public IndexDBWriteTask(IndexManager indexMgr, Semaphore permits, argument
1907 this.permits = permits;
1945 * buffer permits are available.
1954 // First release any previously acquired permits
[all...] |
| /forgerock/opendj2-hg/src/server/org/opends/server/backends/jeb/importLDIF/ |
| H A D | Importer.java | 1240 Semaphore permits = new Semaphore(buffers);
1245 futures.add(dbService.submit(new IndexDBWriteTask(dnMgr, permits,
1250 futures.add(dbService.submit(new IndexDBWriteTask(mgr, permits, buffers,
1910 private final Semaphore permits; field in class:Importer.IndexDBWriteTask
1929 * @param permits
1937 public IndexDBWriteTask(IndexManager indexMgr, Semaphore permits, argument
1941 this.permits = permits;
1979 * buffer permits are available.
1988 // First release any previously acquired permits
[all...] |
| /forgerock/opendj2-jel-hg/src/server/org/opends/server/backends/jeb/importLDIF/ |
| H A D | Importer.java | 1208 Semaphore permits = new Semaphore(buffers);
1213 futures.add(dbService.submit(new IndexDBWriteTask(dnMgr, permits,
1218 futures.add(dbService.submit(new IndexDBWriteTask(mgr, permits, buffers,
1876 private final Semaphore permits; field in class:Importer.IndexDBWriteTask
1895 * @param permits
1903 public IndexDBWriteTask(IndexManager indexMgr, Semaphore permits, argument
1907 this.permits = permits;
1945 * buffer permits are available.
1954 // First release any previously acquired permits
[all...] |