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()  argument
337     cq_push(t->ev_queue, item);  in notify_worker()
340     if (write(t->n.notify_event_fd, &u, sizeof(uint64_t)) != sizeof(uint64_t)) {  in notify_worker()
346     if (write(t->n.notify_send_fd, buf, 1) != 1) {  in notify_worker()
354 static void notify_worker_fd(LIBEVENT_THREAD *t, int sfd, enum conn_queue_item_modes mode) {  in notify_worker_fd()  argument
356     while ( (item = cqi_new(t->ev_queue)) == NULL ) {  in notify_worker_fd()
369     notify_worker(t, item);  in notify_worker_fd()
817 void proxy_reload_notify(LIBEVENT_THREAD *t) {  in proxy_reload_notify()  argument
818     notify_worker_fd(t, 0, queue_proxy_reload);  in proxy_reload_notify()
824     LIBEVENT_THREAD *t = io->thread;  in return_io_pending()  local
825     pthread_mutex_lock(&t->ion_lock);  in return_io_pending()
826     if (STAILQ_EMPTY(&t->ion_head)) {  in return_io_pending()
829     STAILQ_INSERT_TAIL(&t->ion_head, io, iop_next);  in return_io_pending()
830     pthread_mutex_unlock(&t->ion_lock);  in return_io_pending()
837         if (write(t->ion.notify_event_fd, &u, sizeof(uint64_t)) != sizeof(uint64_t)) {  in return_io_pending()
843         if (write(t->ion.notify_send_fd, buf, 1) != 1) {  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()  argument
883     it = do_item_get(key, nkey, hv, t, 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()  argument
895     it = do_item_get(key, nkey, *hv, t, 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()  argument
904     it = do_item_touch(key, nkey, exptime, hv, t);  in item_touch()
945 enum delta_result_type add_delta(LIBEVENT_THREAD *t, const char *key,  in add_delta()  argument
954     ret = do_add_delta(t, key, nkey, incr, delta, buf, cas, hv, NULL);  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()  argument
968     ret = do_store_item(item, comm, t, hv, nbytes, cas, cas_in, cas_stale);  in store_item()