Lines Matching defs:thread

56                                       LIBEVENT_THREAD *thread,
63 void zstored_error_count(LIBEVENT_THREAD *thread,
67 bool zstored_downstream_waiting_add(downstream *d, LIBEVENT_THREAD *thread,
88 zstored_downstream_conns *zstored_get_downstream_conns(LIBEVENT_THREAD *thread,
159 cb_assert(nthreads > 1); /* Main thread + at least one worker. */
216 /* We start at 1, because thread[0] is the main listen/accept */
217 /* thread, and not a true worker thread. Too lazy to save */
218 /* the wasted thread[0] slot memory. */
283 /* Must be called on the main listener thread.
440 /* Finds the proxy_td associated with a worker thread.
446 /* 0 is the main listen thread, not a worker thread. */
467 /* lifecycle, on the worker thread, so it's a good place */
698 /* Or, when a downstream conn is in the thread-based free pool, it */
703 /* thread-based free pool. This shouldn't happen, but we */
713 if (c->thread != NULL &&
715 zstored_error_count(c->thread, c->host_ident, true);
865 cb_assert(uc_retry->thread);
866 cb_assert(uc_retry->thread->work_queue);
868 work_send(uc_retry->thread->work_queue,
1438 int cproxy_connect_downstream(downstream *d, LIBEVENT_THREAD *thread,
1450 cb_assert(thread != NULL);
1451 cb_assert(thread->base != NULL);
1498 zstored_acquire_downstream_conn(d, thread,
1529 if (zstored_downstream_waiting_add(d, thread,
1556 LIBEVENT_THREAD *thread,
1566 cb_assert(thread);
1567 cb_assert(thread->base);
1595 thread->base,
1601 c->thread = thread;
1646 cb_assert(c->thread != NULL);
1667 zstored_error_count(c->thread, host_ident, false);
1684 zstored_error_count(c->thread, host_ident, true);
2226 conns = zstored_get_downstream_conns(c->thread, c->host_ident);
2310 cb_assert(uc->thread);
2311 cb_assert(uc->thread->base);
2322 event_base_set(uc->thread->base, &ptd->timeout_event);
2484 char *suffix = cache_alloc(c->thread->suffix_cache);
2848 cb_assert(uc->thread != NULL);
2849 cb_assert(uc->thread->base != NULL);
2859 event_base_set(uc->thread->base, &d->timeout_event);
3296 zstored_downstream_conns *zstored_get_downstream_conns(LIBEVENT_THREAD *thread,
3302 cb_assert(thread);
3303 cb_assert(thread->base);
3305 conn_hash = thread->conn_hash;
3325 void zstored_error_count(LIBEVENT_THREAD *thread,
3330 cb_assert(thread != NULL);
3333 conns = zstored_get_downstream_conns(thread, host_ident);
3356 /* rather than be released back to the thread->conn_hash, */
3391 LIBEVENT_THREAD *thread,
3403 cb_assert(thread);
3420 conns = zstored_get_downstream_conns(thread, host_ident);
3424 cb_assert(dc->thread == thread);
3468 dc = cproxy_connect_downstream_conn(d, thread, msst, behavior);
3515 cb_assert(dc->thread != NULL);
3520 conns = zstored_get_downstream_conns(dc->thread, dc->host_ident);
3567 LIBEVENT_THREAD *thread = thread_by_index(thread_index(cb_thread_self()));
3568 cb_assert(thread != NULL);
3584 conns = zstored_get_downstream_conns(thread, host_ident);
3626 bool zstored_downstream_waiting_add(downstream *d, LIBEVENT_THREAD *thread,
3633 cb_assert(thread != NULL);
3643 conns = zstored_get_downstream_conns(thread, host_ident);
3782 fprintf(out, " thread:%d\n", ti);