/forgerock/openam/openam-audit/openam-audit-context/src/main/java/org/forgerock/openam/audit/context/ |
H A D | AMExecutorServiceFactory.java | 45 * @param poolSize The size of the ScheduledExecutorService thread pool. 55 * @param pool The size of the pool to create. 59 ExecutorService createFixedThreadPool(int pool, ThreadFactory factory); argument 67 * @param pool Size of the fixed pool. 71 ExecutorService createFixedThreadPool(int pool, String threadNamePrefix); argument 99 * @param coreSize the number of threads to keep in the pool, even if they are idle 100 * @param maxSize Max number of threads in the pool
|
H A D | AuditRequestContextPropagatingExecutorServiceFactory.java | 53 public ExecutorService createFixedThreadPool(int pool, ThreadFactory factory) { argument 54 return decorate(delegate.createFixedThreadPool(pool, factory)); 58 public ExecutorService createFixedThreadPool(int pool, String threadName) { argument 59 return decorate(delegate.createFixedThreadPool(pool, threadName));
|
/forgerock/openam-v13/openam-core/src/main/java/com/sun/identity/entitlement/ |
H A D | ThreadPool.java | 42 * This thread pool maintains a number of threads that run the tasks from a task 45 * by the thread pool. 47 * This thread pool has a fixed size of threads. It maintains all the tasks to 52 * This guarantees the thread pool will not use up the system resources under 66 * Constructs a thread pool with given parameters. 69 * name of the thread pool. 71 * the thread pool size, indicates how many threads are created 72 * in the pool. 83 * Create threads for the pool. 132 private ThreadPool pool; field in class:ThreadPool.WorkerThread 135 WorkerThread(String name, ThreadPool pool) argument [all...] |
/forgerock/openam-v13/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | PooledTaskExecutor.java | 37 * This is a thread-safe, synchronous {@link TaskExecutor} that is implemented as a pool of 40 * On calling {@link #execute}, a thread will be blocked until an executor from the pool becomes 52 private final Queue<SimpleTaskExecutor> pool = new ConcurrentLinkedQueue<SimpleTaskExecutor>(); field in class:PooledTaskExecutor 57 * Creates a new Executor pool. 58 * @param simpleTaskExecutorProvider Creates new {@link SimpleTaskExecutor} instances for the pool. 62 * @param semaphore Controls access to the pool. 78 throw new IllegalArgumentException("Configuration error - mismatch in pool sizes"); 85 debug("Polling pool for an executor"); 91 SimpleTaskExecutor executor = pool.poll(); 99 debug("Returning executor to the pool"); [all...] |
/forgerock/openam-v13/openam-audit/openam-audit-context/src/main/java/org/forgerock/openam/audit/context/ |
H A D | AuditRequestContextPropagatingExecutorServiceFactory.java | 51 public ExecutorService createFixedThreadPool(int pool, ThreadFactory factory) { argument 52 return decorate(super.createFixedThreadPool(pool, factory)); 56 public ExecutorService createFixedThreadPool(int pool, String threadName) { argument 57 return decorate(super.createFixedThreadPool(pool, threadName)); 61 public ExecutorService createFixedThreadPool(int pool) { argument 62 return decorate(super.createFixedThreadPool(pool));
|
/forgerock/openam/openam-core/src/main/java/com/sun/identity/entitlement/ |
H A D | ThreadPool.java | 42 * This thread pool maintains a number of threads that run the tasks from a task 45 * by the thread pool. 47 * This thread pool has a fixed size of threads. It maintains all the tasks to 52 * This guarantees the thread pool will not use up the system resources under 66 * Constructs a thread pool with given parameters. 69 * name of the thread pool. 71 * the thread pool size, indicates how many threads are created 72 * in the pool. 83 * Create threads for the pool. 132 private ThreadPool pool; field in class:ThreadPool.WorkerThread 135 WorkerThread(String name, ThreadPool pool) argument [all...] |
/forgerock/openam/openam-core/src/main/java/org/forgerock/openam/sm/datalayer/impl/ |
H A D | PooledTaskExecutor.java | 39 * This is a thread-safe, synchronous {@link TaskExecutor} that is implemented as a pool of 42 * On calling {@link #execute}, a thread will be blocked until an executor from the pool becomes 54 private final Queue<SimpleTaskExecutor> pool = new ConcurrentLinkedQueue<SimpleTaskExecutor>(); field in class:PooledTaskExecutor 59 * Creates a new Executor pool. 60 * @param simpleTaskExecutorProvider Creates new {@link SimpleTaskExecutor} instances for the pool. 64 * @param semaphore Controls access to the pool. 80 throw new IllegalArgumentException("Configuration error - mismatch in pool sizes"); 87 debug("Polling pool for an executor"); 93 SimpleTaskExecutor executor = pool.poll(); 101 debug("Returning executor to the pool"); [all...] |
/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/am/util/ |
H A D | ThreadPool.java | 39 * This thread pool maintains a number of threads that run the tasks from a task 42 * by the thread pool. 44 * This thread pool has a fixed size of threads. It maintains all the tasks to 49 * This guarantees the thread pool will not use up the system resources under 67 * Constructs a thread pool with given parameters. 70 * name of the thread pool. 72 * the thread pool size, indicates how many threads are created 73 * in the pool. 75 * the maximum size of the task queue in the thread pool. 100 debug.message("Initiating login thread pool siz 279 private ThreadPool pool; field in class:ThreadPool.WorkerThread 283 WorkerThread(String name, ThreadPool pool) argument [all...] |
/forgerock/openam-v13/openam-core/src/main/java/com/iplanet/services/comm/https/ |
H A D | JSSThreadPool.java | 48 * Constructs a thread pool with given parameters. 51 * name of the thread pool. 53 * the thread pool size, indicates how many threads are created 54 * in the pool. 81 * Create thread for the pool. 83 * @param threadsToCreate number of threads of the pool after creation 142 // return the thread to the thread pool 146 // notify the thread pool when all threads are backed 147 // need to discuss whether the thread pool need to wait until all 155 // because the thread pool ha 214 private JSSThreadPool pool; field in class:JSSThreadPool.WorkerThread 218 WorkerThread(String name, JSSThreadPool pool) argument [all...] |
/forgerock/openam/openam-core/src/main/java/com/iplanet/am/util/ |
H A D | ThreadPool.java | 39 * This thread pool maintains a number of threads that run the tasks from a task 42 * by the thread pool. 44 * This thread pool has a fixed size of threads. It maintains all the tasks to 49 * This guarantees the thread pool will not use up the system resources under 67 * Constructs a thread pool with given parameters. 70 * name of the thread pool. 72 * the thread pool size, indicates how many threads are created 73 * in the pool. 75 * the maximum size of the task queue in the thread pool. 100 debug.message("Initiating login thread pool siz 279 private ThreadPool pool; field in class:ThreadPool.WorkerThread 283 WorkerThread(String name, ThreadPool pool) argument [all...] |
/forgerock/openam-v13/openam-shared/src/main/java/com/sun/identity/common/ |
H A D | TimerPool.java | 109 * Returns thread which is free in the pool. 352 private TimerPool pool; field in class:TimerPool.WorkerThread 361 * @param pool The TimerPool the thread belongs to 364 public WorkerThread(String name, TimerPool pool) { argument 366 this.pool = pool; 391 // terminate the thread pool when daemon is set to false 392 // it is better to have a way to terminate the thread pool 436 pool.schedule(runTask, new Date( 466 pool 572 private TimerPool pool; field in class:TimerPool.Scheduler 580 Scheduler(TimerPool pool) argument [all...] |
/forgerock/openidm-v4/openidm-repo-orientdb/src/main/java/org/forgerock/openidm/repo/orientdb/impl/ |
H A D | DBHelper.java | 73 * Get the DB pool for the given URL. May return an existing pool instance. 77 * Do not close the returned pool directly as it may be used by others. 84 * @param minSize the orientdb pool minimum size 85 * @param maxSize the orientdb pool maximum size 89 * @return the pool 96 ODatabaseDocumentPool pool = null; 99 logger.debug("Check DB exists in expected state for pool {}", dbURL); 102 logger.debug("Getting pool {}", dbURL); 103 pool 169 closePool(String dbUrl, ODatabaseDocumentPool pool) argument 237 test(ODatabaseDocumentPool pool, String dbURL, String user, String password, boolean finalTry) argument 268 warmUpPool(ODatabaseDocumentPool pool, String dbURL, String user, String password, int minSize) argument [all...] |
H A D | OrientDBRepoService.java | 142 private ODatabaseDocumentPool pool; field in class:OrientDBRepoService 684 * @return A connection from the pool. Call close on the connection when done to return to the pool. 696 db = pool.acquire(dbURL, user, password); 698 logger.info("Succeeded in acquiring connection from pool in retry attempt {}", retryCount); 704 logger.warn("Failure reported acquiring connection from pool, retried {} times before giving up.", retryCount, ex); 706 "Failure reported acquiring connection from pool, retried " + retryCount + " times before giving up: " 858 pool = DBHelper.getPool(dbURL, user, password, poolMinSize, poolMaxSize, config, true); 859 logger.debug("Obtained pool {}", pool); [all...] |
/forgerock/openam/openam-shared/src/main/java/com/sun/identity/common/ |
H A D | TimerPool.java | 109 * Returns thread which is free in the pool. 352 private TimerPool pool; field in class:TimerPool.WorkerThread 361 * @param pool The TimerPool the thread belongs to 364 public WorkerThread(String name, TimerPool pool) { argument 366 this.pool = pool; 391 // terminate the thread pool when daemon is set to false 392 // it is better to have a way to terminate the thread pool 436 pool.schedule(runTask, new Date( 466 pool 572 private TimerPool pool; field in class:TimerPool.Scheduler 580 Scheduler(TimerPool pool) argument [all...] |
/forgerock/web-agents-v4/source/ |
H A D | utility.h | 89 void *pool; member in struct:__anon110
|
H A D | shared.c | 53 static void initialise_freelist(struct mem_pool *pool) { argument 56 pool->freelist_hdrs[i] = FREELIST_END; 73 static size_t verify_freelists(struct mem_pool *pool, char *action) { argument 79 for (i = pool->freelist_hdrs[hdr_offset]; i != FREELIST_END; i = FREELIST_FROM_CHUNK(AM_GET_POINTER(pool, i))->next) { 80 struct mem_chunk * chunk = AM_GET_POINTER(pool, i); 97 struct mem_pool *pool = (struct mem_pool *) am->pool; local 105 for (i = pool->freelist_hdrs[hdr_offset]; i != FREELIST_END; i = FREELIST_FROM_CHUNK(AM_GET_POINTER(pool, 120 add_to_freelist(struct mem_pool *pool, struct mem_chunk *chunk) argument 141 remove_from_freelist(struct mem_pool *pool, struct mem_chunk *chunk) argument 164 get_free_chunk_for_size(struct mem_pool *pool, size_t size) argument 363 struct mem_pool *pool = (struct mem_pool *) am->pool; local 372 struct mem_pool *pool = NULL; local 682 struct mem_pool *pool; local 793 struct mem_pool *pool; local 890 struct mem_pool *pool; local 982 struct mem_pool *pool; local [all...] |
H A D | thread.c | 69 int min_threads; /* minimum number of threads kept in the pool */ 70 int max_threads; /* maximum number of threads that can be in the pool */ 109 static int create_worker(struct am_threadpool *pool) { argument 114 error = pthread_create(&thread, &pool->attr, do_work, pool); 120 struct am_threadpool *pool = (struct am_threadpool *) arg; local 121 --pool->num_threads; 122 if (pool->flag & AM_THREADPOOL_DESTROY) { 123 if (pool->num_threads == 0) { 124 pthread_cond_broadcast(&pool 133 worker_notify(struct am_threadpool *pool) argument 141 struct am_threadpool *pool = (struct am_threadpool *) arg; local 176 struct am_threadpool *pool = (struct am_threadpool *) arg; local [all...] |
/forgerock/opendj-v3/opendj-server-legacy/src/main/java/org/opends/server/backends/pluggable/ |
H A D | OnDiskMergeImporter.java | 2749 private final BlockingQueue<Buffer> pool; field in class:OnDiskMergeImporter.BufferPool 2776 this.pool = new ArrayBlockingQueue<>(nbBuffer); 2780 pool.offer(supportOffHeap() ? new OffHeapBuffer(bufferSize) : new HeapBuffer(bufferSize)); 2793 return pool.take(); 2805 pool.put(buffer); 2815 while (pool.size() > size) 2825 while ((buffer = pool.poll()) != null)
|
/forgerock/opendj-b2.6/resource/dsml/lib/ |
H A D | jaxb1-impl.jar | META-INF/ META-INF/MANIFEST.MF COPYING.txt META-INF/services/ META-INF/ ... |
/forgerock/opendj2-jel-hg/resource/dsml/lib/ |
H A D | jaxb1-impl.jar | META-INF/ META-INF/MANIFEST.MF COPYING.txt META-INF/services/ META-INF/ ... |
/forgerock/opendj2/ext/ant/lib/ |
H A D | ant-contrib-1.0b3.jar | META-INF/ META-INF/MANIFEST.MF net/ net/sf/ net/sf/antcontrib/ net/sf/antcontrib/antclipse/ ... |
/forgerock/opendj-b2.6/ext/ant/lib/ |
H A D | ant-contrib-1.0b3.jar | META-INF/ META-INF/MANIFEST.MF net/ net/sf/ net/sf/antcontrib/ net/sf/antcontrib/antclipse/ ... |
/forgerock/opendj2.6.2/ext/ant/lib/ |
H A D | ant-contrib-1.0b3.jar | META-INF/ META-INF/MANIFEST.MF net/ net/sf/ net/sf/antcontrib/ net/sf/antcontrib/antclipse/ ... |
/forgerock/opendj2-hg/ext/ant/lib/ |
H A D | ant-contrib-1.0b3.jar | META-INF/ META-INF/MANIFEST.MF net/ net/sf/ net/sf/antcontrib/ net/sf/antcontrib/antclipse/ ... |
/forgerock/opendj-v3/opendj-server-legacy/ext/ant/lib/ |
H A D | ant-contrib-1.0b3.jar | META-INF/ META-INF/MANIFEST.MF net/ net/sf/ net/sf/antcontrib/ net/sf/antcontrib/antclipse/ ... |