Searched defs:pool (Results 1 - 25 of 53) sorted by relevance

123

/forgerock/openam/openam-audit/openam-audit-context/src/main/java/org/forgerock/openam/audit/context/
H A DAMExecutorServiceFactory.java45 * @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 DAuditRequestContextPropagatingExecutorServiceFactory.java53 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 DThreadPool.java42 * 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 DPooledTaskExecutor.java37 * 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 DAuditRequestContextPropagatingExecutorServiceFactory.java51 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 DThreadPool.java42 * 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 DPooledTaskExecutor.java39 * 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 DThreadPool.java39 * 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 DJSSThreadPool.java48 * 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 DThreadPool.java39 * 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 DTimerPool.java109 * 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 DDBHelper.java73 * 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 DOrientDBRepoService.java142 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 DTimerPool.java109 * 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 Dutility.h89 void *pool; member in struct:__anon110
H A Dshared.c53 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 Dthread.c69 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 DOnDiskMergeImporter.java2749 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 Djaxb1-impl.jarMETA-INF/ META-INF/MANIFEST.MF COPYING.txt META-INF/services/ META-INF/ ...
/forgerock/opendj2-jel-hg/resource/dsml/lib/
H A Djaxb1-impl.jarMETA-INF/ META-INF/MANIFEST.MF COPYING.txt META-INF/services/ META-INF/ ...
/forgerock/opendj2/ext/ant/lib/
H A Dant-contrib-1.0b3.jarMETA-INF/ META-INF/MANIFEST.MF net/ net/sf/ net/sf/antcontrib/ net/sf/antcontrib/antclipse/ ...
/forgerock/opendj-b2.6/ext/ant/lib/
H A Dant-contrib-1.0b3.jarMETA-INF/ META-INF/MANIFEST.MF net/ net/sf/ net/sf/antcontrib/ net/sf/antcontrib/antclipse/ ...
/forgerock/opendj2.6.2/ext/ant/lib/
H A Dant-contrib-1.0b3.jarMETA-INF/ META-INF/MANIFEST.MF net/ net/sf/ net/sf/antcontrib/ net/sf/antcontrib/antclipse/ ...
/forgerock/opendj2-hg/ext/ant/lib/
H A Dant-contrib-1.0b3.jarMETA-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 Dant-contrib-1.0b3.jarMETA-INF/ META-INF/MANIFEST.MF net/ net/sf/ net/sf/antcontrib/ net/sf/antcontrib/antclipse/ ...

Completed in 102 milliseconds

123