/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...] |