92 static LIBEVENT_THREAD *threads;
101 static void notify_worker(LIBEVENT_THREAD *t, CQ_ITEM *item);
102 static void notify_worker_fd(LIBEVENT_THREAD *t, int sfd, enum conn_queue_item_modes mode);
336 static void notify_worker(LIBEVENT_THREAD *t, CQ_ITEM *item) {  in notify_worker()
354 static void notify_worker_fd(LIBEVENT_THREAD *t, int sfd, enum conn_queue_item_modes mode) {  in notify_worker_fd()
381     if ((ret = pthread_create(&((LIBEVENT_THREAD*)arg)->thread_id, &attr, func, arg)) != 0) {  in create_worker()
387     thread_setname(((LIBEVENT_THREAD*)arg)->thread_id, "mc-worker");  in create_worker()
400 static void setup_thread_notify(LIBEVENT_THREAD *me, struct thread_notify *tn,  in setup_thread_notify()
420 static void setup_thread(LIBEVENT_THREAD *me) {  in setup_thread()
508     LIBEVENT_THREAD *me = arg;  in worker_libevent()
547     LIBEVENT_THREAD *me = arg;  in thread_libevent_ionotify()
588     LIBEVENT_THREAD *me = arg;  in thread_libevent_process()
689 LIBEVENT_THREAD *get_worker_thread(int id) {  in get_worker_thread()
699 static LIBEVENT_THREAD *select_thread_round_robin(void)  in select_thread_round_robin()
710     LIBEVENT_THREAD *thread;  in reset_threads_napi_id()
725 static LIBEVENT_THREAD *select_thread_by_napi_id(int sfd)  in select_thread_by_napi_id()
727     LIBEVENT_THREAD *thread;  in select_thread_by_napi_id()
776     LIBEVENT_THREAD *thread;  in dispatch_conn_new()
817 void proxy_reload_notify(LIBEVENT_THREAD *t) {  in proxy_reload_notify()
824     LIBEVENT_THREAD *t = io->thread;  in return_io_pending()
878 item *item_get(const char *key, const size_t nkey, LIBEVENT_THREAD *t, const bool do_update) {  in item_get()
891 item *item_get_locked(const char *key, const size_t nkey, LIBEVENT_THREAD *t, const bool do_update,…  in item_get_locked()
899 item *item_touch(const char *key, size_t nkey, uint32_t exptime, LIBEVENT_THREAD *t) {  in item_touch()
945 enum delta_result_type add_delta(LIBEVENT_THREAD *t, const char *key,  in add_delta()
962 enum store_item_type store_item(item *item, int comm, LIBEVENT_THREAD *t, int *nbytes, uint64_t *ca…  in store_item()
1129     threads = calloc(nthreads, sizeof(LIBEVENT_THREAD));  in memcached_thread_init()