Home
last modified time | relevance | path

Searched refs:io_queue_t (Results 1 – 8 of 8) sorted by relevance

/memcached-1.6.32/
Dproto_proxy.h23 void proxy_submit_cb(io_queue_t *q);
24 void proxy_complete_cb(io_queue_t *q);
Dstorage.h21 void storage_submit_cb(io_queue_t *q);
Dmemcached.h685 typedef struct io_queue_s io_queue_t; typedef
686 typedef void (*io_queue_stack_cb)(io_queue_t *q);
870 io_queue_t io_queues[IO_QUEUE_COUNT]; /* set of deferred IO queues. */
958 io_queue_t *conn_io_queue_get(conn *c, int type);
Dstorage.c256 io_queue_t *q = conn_io_queue_get(c, IO_QUEUE_EXTSTORE); in storage_get_item()
384 void storage_submit_cb(io_queue_t *q) { in storage_submit_cb()
410 io_queue_t *q = conn_io_queue_get(c, p->io_queue_type); in recache_or_free()
468 io_queue_t *q = conn_io_queue_get(pending->c, pending->io_queue_type); in storage_return_cb()
Dproto_proxy.c483 void proxy_submit_cb(io_queue_t *q) { in proxy_submit_cb()
600 io_queue_t *q = conn_io_queue_get(p->c, p->io_queue_type); in proxy_return_rctx_cb()
1308 io_queue_t *q = conn_io_queue_get(c, IO_QUEUE_PROXY); in mcp_queue_rctx_io()
Dmemcached.c581 io_queue_t *q = c->io_queues; in conn_io_queue_setup()
594 for (io_queue_t *q = c->io_queues; q->type != IO_QUEUE_NONE; q++) { in conn_io_queue_reset()
611 io_queue_t *conn_io_queue_get(conn *c, int type) { in conn_io_queue_get()
612 io_queue_t *q = c->io_queues; in conn_io_queue_get()
2158 static char *conn_queue_to_str(const conn *c, io_queue_t *q) { in conn_queue_to_str()
2204 for (io_queue_t *q = sc->io_queues; q->type != IO_QUEUE_NONE; q++) { in process_stats_conns()
3316 for (io_queue_t *q = c->io_queues; q->type != IO_QUEUE_NONE; q++) {
Dproxy_luafgen.c21 for (io_queue_t *q = c->io_queues; q->type != IO_QUEUE_NONE; q++) { in _mcp_queue_hack()
948 io_queue_t *q = conn_io_queue_get(rctx->c, IO_QUEUE_PROXY); in mcp_resume_rctx_from_cb()
Dproxy_internal.c1766 io_queue_t *q = conn_io_queue_get(rctx->c, IO_QUEUE_EXTSTORE); in mcplib_internal_run()