Home
last modified time | relevance | path

Searched refs:q (Results 1 – 10 of 10) 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.c351 eio->next = q->stack_ctx; in storage_get_item()
352 q->stack_ctx = eio; in storage_get_item()
355 assert(q->count >= 0); in storage_get_item()
356 q->count++; in storage_get_item()
384 void storage_submit_cb(io_queue_t *q) { in storage_submit_cb() argument
386 extstore_submit(q->ctx, q->stack_ctx); in storage_submit_cb()
389 q->stack_ctx = NULL; in storage_submit_cb()
411 q->count--; in recache_or_free()
412 assert(q->count >= 0); in recache_or_free()
469 q->count--; in storage_return_cb()
[all …]
Dmemcached.c571 q++; in thread_io_queue_add()
573 q->type = type; in thread_io_queue_add()
574 q->ctx = ctx; in thread_io_queue_add()
586 q->count = 0; in conn_io_queue_setup()
588 q++; 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() local
604 return q; in thread_io_queue_get()
606 q++; in thread_io_queue_get()
617 q++; in conn_io_queue_get()
2204 for (io_queue_t *q = sc->io_queues; q->type != IO_QUEUE_NONE; q++) { in process_stats_conns() local
[all …]
Dstorage.h21 void storage_submit_cb(io_queue_t *q);
Dproto_proxy.c483 void proxy_submit_cb(io_queue_t *q) { in proxy_submit_cb() argument
484 proxy_event_thread_t *e = ((proxy_ctx_t *)q->ctx)->proxy_io_thread; in proxy_submit_cb()
485 io_pending_proxy_t *p = q->stack_ctx; in proxy_submit_cb()
509 q->count++; in proxy_submit_cb()
541 q->stack_ctx = NULL; in proxy_submit_cb()
600 io_queue_t *q = conn_io_queue_get(p->c, p->io_queue_type); in proxy_return_rctx_cb() local
610 q->count--; in proxy_return_rctx_cb()
611 if (q->count == 0) { in proxy_return_rctx_cb()
1308 io_queue_t *q = conn_io_queue_get(c, IO_QUEUE_PROXY); in mcp_queue_rctx_io() local
1354 p->next = q->stack_ctx; in mcp_queue_rctx_io()
[all …]
Dproxy_luafgen.c21 for (io_queue_t *q = c->io_queues; q->type != IO_QUEUE_NONE; q++) { in _mcp_queue_hack() local
22 if (q->stack_ctx != NULL) { in _mcp_queue_hack()
23 io_queue_cb_t *qcb = thread_io_queue_get(c->thread, q->type); in _mcp_queue_hack()
24 qcb->submit_cb(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() local
949 q->count--; in mcp_resume_rctx_from_cb()
950 if (q->count == 0) { 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() local
1769 io->eio.next = q->stack_ctx; in mcplib_internal_run()
1770 q->stack_ctx = &io->eio; in mcplib_internal_run()
1771 assert(q->count >= 0); in mcplib_internal_run()
1772 q->count++; in mcplib_internal_run()
Dmemcached.spec.in63 %setup -q -n %{name}-%{version}
Dmemcached.h686 typedef void (*io_queue_stack_cb)(io_queue_t *q);
/memcached-1.6.32/doc/
Dprotocol.txt114 Flags are single character codes, ie 'q' or 'k' or 'I', which adjust the
119 Flags are single character codes, ie 'q' or 'k' or 'O', which adjust the
539 Unless the (q) flag was supplied, which suppresses the status code for a miss.
550 - q: use noreply semantics for return codes.
598 - q: use noreply semantics for return codes.
737 - q: use noreply semantics for return codes
768 - q: use noreply semantics for return codes
831 - q: noreply
851 - q: noreply
915 - q: use noreply semantics for return codes (see details under mset)
[all …]