apr-util/misc/apr_thread_pool.c

210     struct apr_thread_list_elt *elt;
213         elt = apr_pcalloc(me->pool, sizeof(*elt));
214         if (NULL == elt) {
219         elt = APR_RING_FIRST(me->recycled_thds);
220         APR_RING_REMOVE(elt, link);
223     APR_RING_ELEM_INIT(elt, link);
224     elt->thd = t;
225     elt->current_owner = NULL;
226     elt->state = TH_RUN;
227     return elt;
243     struct apr_thread_list_elt *elt;
246     elt = elt_new(me, t);
247     if (!elt) {
252     while (!me->terminated && elt->state != TH_STOP) {
254         if (APR_RING_NEXT(elt, link) != elt) {
256             APR_RING_REMOVE(elt, link);
259         APR_RING_INSERT_TAIL(me->busy_thds, elt, apr_thread_list_elt, link);
263             elt->current_owner = task->owner;
270             elt->current_owner = NULL;
271             if (TH_STOP == elt->state) {
276         assert(NULL == elt->current_owner);
277         if (TH_STOP != elt->state)
278             APR_RING_REMOVE(elt, link);
284             || me->terminated || elt->state != TH_RUN) {
286             if ((TH_PROBATION == elt->state) && me->idle_wait)
288             APR_RING_INSERT_TAIL(me->recycled_thds, elt,
298         APR_RING_INSERT_TAIL(me->idle_thds, elt, apr_thread_list_elt, link);
309             elt->state = TH_PROBATION;
664     struct apr_thread_list_elt *elt;
666     elt = APR_RING_FIRST(me->busy_thds);
667     while (elt != APR_RING_SENTINEL(me->busy_thds, apr_thread_list_elt, link)) {
668         if (elt->current_owner != owner) {
669             elt = APR_RING_NEXT(elt, link);
674         apr_os_thread_get(&os_thread, elt->thd);
682         while (elt->current_owner == owner) {
687         elt = APR_RING_FIRST(me->busy_thds);
783     struct apr_thread_list_elt *head, *tail, *elt;
812     for (elt = head; elt != tail; elt = APR_RING_NEXT(elt, link)) {
813         elt->state = TH_STOP;
816     elt->state = TH_STOP;
831     struct apr_thread_list_elt *elt, *head, *tail;
834     elt = trim_threads(me, &cnt, 1);
841     if (NULL != (head = elt)) {
842         while (elt) {
843             tail = elt;
844             apr_thread_join(&rv, elt->thd);
845             elt = APR_RING_NEXT(elt, link);