Home
last modified time | relevance | path

Searched refs:tpool (Results 1 – 8 of 8) sorted by relevance

/netbsd-src/external/cddl/osnet/lib/libzfs/
H A Dthread_pool.c38 delete_pool(tpool_t *tpool) in delete_pool() argument
45 for (job = tpool->tp_head; job != NULL; job = tpool->tp_head) { in delete_pool()
46 tpool->tp_head = job->tpj_next; in delete_pool()
49 (void) pthread_attr_destroy(&tpool->tp_attr); in delete_pool()
50 free(tpool); in delete_pool()
59 tpool_t *tpool = arg; in worker_cleanup() local
61 if (--tpool->tp_current == 0 && in worker_cleanup()
62 (tpool->tp_flags & (TP_DESTROY | TP_ABANDON))) { in worker_cleanup()
63 if (tpool->tp_flags & TP_ABANDON) { in worker_cleanup()
64 pthread_mutex_unlock(&tpool->tp_mutex); in worker_cleanup()
[all …]
H A Dthread_pool_impl.h69 struct tpool { struct
/netbsd-src/external/cddl/osnet/include/
H A Dthread_pool.h44 typedef struct tpool tpool_t; /* opaque thread pool descriptor */
50 extern int tpool_dispatch(tpool_t *tpool,
52 extern void tpool_destroy(tpool_t *tpool);
53 extern void tpool_abandon(tpool_t *tpool);
54 extern void tpool_wait(tpool_t *tpool);
55 extern void tpool_suspend(tpool_t *tpool);
56 extern int tpool_suspended(tpool_t *tpool);
57 extern void tpool_resume(tpool_t *tpool);
58 extern int tpool_member(tpool_t *tpool);
/netbsd-src/external/bsd/openldap/dist/libraries/libldap/
H A Dtpool.c228 ldap_pvt_thread_pool_t *tpool, in ldap_pvt_thread_pool_init_q() argument
245 *tpool = NULL; in ldap_pvt_thread_pool_init_q()
336 *tpool = pool; in ldap_pvt_thread_pool_init_q()
342 ldap_pvt_thread_pool_t *tpool, in ldap_pvt_thread_pool_init() argument
346 return ldap_pvt_thread_pool_init_q( tpool, max_threads, max_pending, 1 ); in ldap_pvt_thread_pool_init()
352 ldap_pvt_thread_pool_t *tpool, in ldap_pvt_thread_pool_submit() argument
355 return ldap_pvt_thread_pool_submit2( tpool, start_routine, arg, NULL ); in ldap_pvt_thread_pool_submit()
361 ldap_pvt_thread_pool_t *tpool, in ldap_pvt_thread_pool_submit2() argument
371 if (tpool == NULL) in ldap_pvt_thread_pool_submit2()
374 pool = *tpool; in ldap_pvt_thread_pool_submit2()
[all …]
H A Dthr_debug.c1180 ldap_pvt_thread_pool_t *tpool, in ldap_pvt_thread_pool_init() argument
1188 rc = ldap_int_thread_pool_init( tpool, max_threads, max_pending ); in ldap_pvt_thread_pool_init()
1199 ldap_pvt_thread_pool_t *tpool, in ldap_pvt_thread_pool_submit() argument
1204 has_pool = (tpool && *tpool); in ldap_pvt_thread_pool_submit()
1205 rc = ldap_int_thread_pool_submit( tpool, start_routine, arg ); in ldap_pvt_thread_pool_submit()
1213 ldap_pvt_thread_pool_t *tpool, in ldap_pvt_thread_pool_maxthreads() argument
1217 return ldap_int_thread_pool_maxthreads( tpool, max_threads ); in ldap_pvt_thread_pool_maxthreads()
1221 ldap_pvt_thread_pool_backload( ldap_pvt_thread_pool_t *tpool ) in ldap_pvt_thread_pool_backload() argument
1224 return ldap_int_thread_pool_backload( tpool ); in ldap_pvt_thread_pool_backload()
1228 ldap_pvt_thread_pool_destroy( ldap_pvt_thread_pool_t *tpool, int run_pending ) in ldap_pvt_thread_pool_destroy() argument
[all …]
H A DMakefile.in32 msctrl.c psearchctrl.c threads.c rdwr.c tpool.c rq.c \
48 msctrl.lo psearchctrl.lo threads.lo rdwr.lo tpool.lo rq.lo \
/netbsd-src/external/bsd/openldap/lib/libldap_r/
H A DMakefile14 thr_pth.c thr_debug.c tpool.c
/netbsd-src/external/bsd/openldap/dist/
H A DCHANGES12 Fixed compile warning in libldap/tpool.c (ITS#9601)