Searched refs:pool (Results 1 - 25 of 76) sorted by relevance

1234

/forgerock/openam-v13/openam-federation/openam-federation-library/src/main/java/com/sun/identity/saml2/profile/
H A DCacheCleanUpScheduler.java40 TimerPool pool = SystemTimerPool.getTimerPool();
43 pool.schedule(SPCache.requestHash, nextRun);
44 pool.schedule(SPCache.responseHash, nextRun);
45 pool.schedule(SPCache.mniRequestHash, nextRun);
46 pool.schedule(SPCache.relayStateHash, nextRun);
47 pool.schedule(SPCache.logoutRequestIDHash, nextRun);
48 pool.schedule(SPCache.reqParamHash, nextRun);
49 pool.schedule(SPCache.authnRequestHash, nextRun);
50 pool.schedule(SPCache.fedAccountHash, nextRun);
51 pool
[all...]
/forgerock/openam/openam-federation/openam-federation-library/src/main/java/com/sun/identity/saml2/profile/
H A DCacheCleanUpScheduler.java43 TimerPool pool = SystemTimerPool.getTimerPool();
46 pool.schedule(SPCache.requestHash, nextRun);
47 pool.schedule(SPCache.responseHash, nextRun);
48 pool.schedule(SPCache.mniRequestHash, nextRun);
49 pool.schedule(SPCache.relayStateHash, nextRun);
50 pool.schedule(SPCache.logoutRequestIDHash, nextRun);
51 pool.schedule(SPCache.reqParamHash, nextRun);
52 pool.schedule(SPCache.authnRequestHash, nextRun);
53 pool.schedule(SPCache.fedAccountHash, nextRun);
54 pool
[all...]
/forgerock/web-agents-v4/source/
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...]
H A Dcache.c132 am_shm_set_user_offset(cache, AM_GET_OFFSET(cache->pool, cache_data));
181 head = (struct am_cache_entry *) AM_GET_POINTER(cache->pool, cache_data->table[entry_index].prev);
183 AM_OFFSET_LIST_FOR_EACH(cache->pool, head, element, tmp, struct am_cache_entry) {
184 char *element_key = AM_GET_POINTER(cache->pool, element->key_offset);
213 head = (struct am_cache_entry_data *) AM_GET_POINTER(cache->pool, element->data.prev);
215 AM_OFFSET_LIST_FOR_EACH(cache->pool, head, i, tmp, struct am_cache_entry_data) {
223 ((struct am_cache_entry *) AM_GET_POINTER(cache->pool, element->lh.prev))->lh.next = element->lh.next;
229 ((struct am_cache_entry *) AM_GET_POINTER(cache->pool, element->lh.next))->lh.prev = element->lh.prev;
246 head = (struct am_cache_entry_data *) AM_GET_POINTER(cache->pool, entry->data.prev);
248 AM_OFFSET_LIST_FOR_EACH(cache->pool, hea
[all...]
/forgerock/openidm-v4/openidm-repo-orientdb/src/test/java/org/forgerock/openidm/repo/orientdb/impl/
H A DDBHelperTest.java46 ODatabaseDocumentPool pool = DBHelper.getPool(dbURL, user, password, minSize, maxSize, new JsonValue(new HashMap()), true);
47 assertNotNull(pool);
48 ODatabaseDocumentTx db = pool.acquire(dbURL, user, password);
63 ODatabaseDocumentPool pool = DBHelper.getPool(dbURL, user, password, minSize, maxSize, completeConfig, true);
64 assertNotNull(pool);
66 pool = DBHelper.getPool(dbURL, newUser, newPassword, minSize, maxSize, completeConfig, true);
67 assertNotNull(pool);
68 ODatabaseDocumentTx db = pool.acquire(dbURL, newUser, newPassword);
/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-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/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-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/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/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/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/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...]
/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/web-agents-v4/expat/
H A Dxmlparse.c267 STRING_POOL pool; member in struct:__anon41
416 poolAppend(STRING_POOL *pool, const ENCODING *enc,
419 poolStoreString(STRING_POOL *pool, const ENCODING *enc,
421 static XML_Bool FASTCALL poolGrow(STRING_POOL *pool);
423 poolCopyString(STRING_POOL *pool, const XML_Char *s);
425 poolCopyStringN(STRING_POOL *pool, const XML_Char *s, int n);
427 poolAppendString(STRING_POOL *pool, const XML_Char *s);
447 #define poolStart(pool) ((pool)->start)
448 #define poolEnd(pool) ((poo
4922 storeAttributeValue(XML_Parser parser, const ENCODING *enc, XML_Bool isCdata, const char *ptr, const char *end, STRING_POOL *pool) argument
4938 appendAttributeValue(XML_Parser parser, const ENCODING *enc, XML_Bool isCdata, const char *ptr, const char *end, STRING_POOL *pool) argument
5094 STRING_POOL *pool = &(dtd->entityValuePool); local
6097 poolInit(STRING_POOL *pool, const XML_Memory_Handling_Suite *ms) argument
6108 poolClear(STRING_POOL *pool) argument
6128 poolDestroy(STRING_POOL *pool) argument
6145 poolAppend(STRING_POOL *pool, const ENCODING *enc, const char *ptr, const char *end) argument
6161 poolCopyString(STRING_POOL *pool, const XML_Char *s) argument
6173 poolCopyStringN(STRING_POOL *pool, const XML_Char *s, int n) argument
6187 poolAppendString(STRING_POOL *pool, const XML_Char *s) argument
6198 poolStoreString(STRING_POOL *pool, const ENCODING *enc, const char *ptr, const char *end) argument
6210 poolGrow(STRING_POOL *pool) argument
[all...]
/forgerock/jee-agents-v3.5/jee-agents-sdk/src/main/java/com/sun/identity/agents/common/
H A DPDPCache.java70 TimerPool pool = SystemTimerPool.getTimerPool();
73 pool.schedule(_cache, nextRun);
/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/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/web-agents-v4/source/apache/
H A Dagent.c51 ap_log_rerror(APLOG_MARK,l|APLOG_NOERRNO,0,r, "%s", apr_psprintf((r)->pool, __VA_ARGS__))
53 ap_log_error(APLOG_MARK,l|APLOG_NOERRNO,0,s, "%s", apr_psprintf((s)->process->pool, __VA_ARGS__))
78 conf->config = apr_psprintf(c->pool, "%s", arg);
83 conf->debug_file = ac->debug_file != NULL ? apr_pstrdup(c->pool, ac->debug_file) : NULL;
84 conf->audit_file = ac->audit_file != NULL ? apr_pstrdup(c->pool, ac->audit_file) : NULL;
148 apr_pool_userdata_get(&data, AMAGENT_INIT_ONCE, s->process->pool);
152 apr_pool_cleanup_null, s->process->pool);
164 rv = apr_dso_load(&mod_handle, "mod_openam.so", s->process->pool);
262 req->orig_url = ap_construct_url(rec->pool, rec->unparsed_uri, rec);
275 r->user = apr_pstrdup(r->pool, use
[all...]
/forgerock/openam-v13/openam-schema/openam-diagnostics-schema/src/main/java/com/sun/identity/diagnostic/base/core/jaxbgen/impl/runtime/
H A DGrammarInfoFacade.java248 final com.sun.msv.grammar.ExpressionPool pool = g1.getPool();
249 final com.sun.msv.grammar.Expression top = pool.createChoice(g1.getTopLevel(),g2.getTopLevel());
253 return pool;
/forgerock/openam-v13/openam-schema/openam-liberty-schema/src/main/java/com/sun/identity/federation/jaxb/entityconfig/impl/runtime/
H A DGrammarInfoFacade.java248 final com.sun.msv.grammar.ExpressionPool pool = g1.getPool();
249 final com.sun.msv.grammar.Expression top = pool.createChoice(g1.getTopLevel(),g2.getTopLevel());
253 return pool;
/forgerock/openam-v13/openam-schema/openam-saml2-schema/src/main/java/com/sun/identity/saml2/jaxb/assertion/impl/runtime/
H A DGrammarInfoFacade.java248 final com.sun.msv.grammar.ExpressionPool pool = g1.getPool();
249 final com.sun.msv.grammar.Expression top = pool.createChoice(g1.getTopLevel(),g2.getTopLevel());
253 return pool;

Completed in 128 milliseconds

1234