Home
last modified time | relevance | path

Searched refs:pending (Results 1 – 7 of 7) sorted by relevance

/memcached-1.6.32/
Dproxy_network.c179 if (pending != 0) { in _cleanup_backend()
183 if (pending != 0) { in _cleanup_backend()
186 pending = event_pending(&bec->timeout_event, EV_TIMEOUT, NULL); in _cleanup_backend()
187 if (pending != 0) { in _cleanup_backend()
406 if (pending != 0) { in _set_main_event()
425 int pending = event_pending(&be->write_event, EV_WRITE|EV_TIMEOUT, NULL); in _start_write_event() local
426 if (pending != 0) { in _start_write_event()
440 int pending = event_pending(&be->timeout_event, EV_TIMEOUT, NULL); in _start_timeout_event() local
441 if (pending != 0) { in _start_timeout_event()
448 int pending = event_pending(&be->timeout_event, EV_TIMEOUT, NULL); in _stop_timeout_event() local
[all …]
Dstorage.c26 static void storage_finalize_cb(io_pending_t *pending);
27 static void storage_return_cb(io_pending_t *pending);
393 static void recache_or_free(io_pending_t *pending) { in recache_or_free() argument
395 io_pending_storage_t *p = (io_pending_storage_t *)pending; in recache_or_free()
467 static void storage_return_cb(io_pending_t *pending) { in storage_return_cb() argument
468 io_queue_t *q = conn_io_queue_get(pending->c, pending->io_queue_type); in storage_return_cb()
471 conn_worker_readd(pending->c); in storage_return_cb()
476 static void storage_finalize_cb(io_pending_t *pending) { in storage_finalize_cb() argument
477 recache_or_free(pending); in storage_finalize_cb()
478 io_pending_storage_t *p = (io_pending_storage_t *)pending; in storage_finalize_cb()
Dproxy_luafgen.c13 static void proxy_return_rqu_cb(io_pending_t *pending);
962 static void proxy_return_rqu_dummy_cb(io_pending_t *pending) { in proxy_return_rqu_dummy_cb() argument
963 io_pending_proxy_t *p = (io_pending_proxy_t *)pending; in proxy_return_rqu_dummy_cb()
1109 static void proxy_return_rqu_cb(io_pending_t *pending) { in proxy_return_rqu_cb() argument
1110 io_pending_proxy_t *p = (io_pending_proxy_t *)pending; in proxy_return_rqu_cb()
1169 int pending = event_pending(&rctx->timeout_event, EV_TIMEOUT, NULL); in _mcplib_set_rctx_alarm() local
1170 if ((pending & (EV_TIMEOUT)) == 0) { in _mcplib_set_rctx_alarm()
Dproxy.h636 void proxy_return_rctx_cb(io_pending_t *pending);
637 void proxy_finalize_rctx_cb(io_pending_t *pending);
Dproto_proxy.c582 void proxy_return_rctx_cb(io_pending_t *pending) { in proxy_return_rctx_cb() argument
583 io_pending_proxy_t *p = (io_pending_proxy_t *)pending; in proxy_return_rctx_cb()
622 void proxy_finalize_rctx_cb(io_pending_t *pending) { in proxy_finalize_rctx_cb() argument
623 io_pending_proxy_t *p = (io_pending_proxy_t *)pending; in proxy_finalize_rctx_cb()
Dmemcached.h687 typedef void (*io_queue_cb)(io_pending_t *pending);
/memcached-1.6.32/doc/
Dprotocol.txt1905 several pending from the same server; any datagrams with an unknown request