Lines Matching refs:thread
639 c->thread = me; in thread_libevent_process()
643 assert(c->thread && c->thread->ssl_wbuf); in thread_libevent_process()
644 c->ssl_wbuf = c->thread->ssl_wbuf; in thread_libevent_process()
679 void thread_setname(pthread_t thread, const char *name) { in thread_setname() argument
682 pthread_setname_np(thread, name); in thread_setname()
710 LIBEVENT_THREAD *thread; in reset_threads_napi_id() local
714 thread = threads + i; in reset_threads_napi_id()
715 thread->napi_id = 0; in reset_threads_napi_id()
727 LIBEVENT_THREAD *thread; in select_thread_by_napi_id() local
743 thread = threads + i; in select_thread_by_napi_id()
745 thread->napi_id = napi_id; in select_thread_by_napi_id()
750 if (thread->napi_id == napi_id) { in select_thread_by_napi_id()
776 LIBEVENT_THREAD *thread; in dispatch_conn_new() local
779 thread = select_thread_round_robin(); in dispatch_conn_new()
781 thread = select_thread_by_napi_id(sfd); in dispatch_conn_new()
783 item = cqi_new(thread->ev_queue); in dispatch_conn_new()
801 MEMCACHED_CONN_DISPATCH(sfd, (int64_t)thread->thread_id); in dispatch_conn_new()
802 notify_worker(thread, item); in dispatch_conn_new()
810 notify_worker_fd(c->thread, c->sfd, queue_redispatch); in redispatch_conn()
814 notify_worker_fd(c->thread, c->sfd, queue_timeout); in timeout_conn()
824 LIBEVENT_THREAD *t = io->thread; in return_io_pending()