Lines Matching refs:LIBEVENT_THREAD

762 } LIBEVENT_THREAD;  typedef
804     LIBEVENT_THREAD *thread;
814     LIBEVENT_THREAD *thread;
903     LIBEVENT_THREAD *thread; /* Pointer to the thread object serving this connection */
950 enum delta_result_type do_add_delta(LIBEVENT_THREAD *t, const char *key,
955 enum store_item_type do_store_item(item *item, int comm, LIBEVENT_THREAD *t, const uint32_t hv, int…
956 void thread_io_queue_add(LIBEVENT_THREAD *t, int type, void *ctx, io_queue_stack_cb cb);
959 io_queue_cb_t *thread_io_queue_get(LIBEVENT_THREAD *t, int type);
989 void proxy_reload_notify(LIBEVENT_THREAD *t);
997 enum delta_result_type add_delta(LIBEVENT_THREAD *t, const char *key,
1007 item *item_get(const char *key, const size_t nkey, LIBEVENT_THREAD *t, const bool do_update);
1008 item *item_get_locked(const char *key, const size_t nkey, LIBEVENT_THREAD *t, const bool do_update,…
1009 item *item_touch(const char *key, const size_t nkey, uint32_t exptime, LIBEVENT_THREAD *t);
1032 LIBEVENT_THREAD *get_worker_thread(int id);
1038 enum store_item_type store_item(item *item, int comm, LIBEVENT_THREAD *t, int *nbytes, uint64_t *ca…
1049 item* limited_get(const char *key, size_t nkey, LIBEVENT_THREAD *t, uint32_t exptime, bool should_t…
1050 item* limited_get_locked(const char *key, size_t nkey, LIBEVENT_THREAD *t, bool do_update, uint32_t…
1058 void resp_free(LIBEVENT_THREAD *th, mc_resp *resp);