Searched refs:io_pending_proxy_t (Results 1 – 6 of 6) sorted by relevance
| /memcached-1.6.32/ |
| D | proxy_network.c | 154 io_pending_proxy_t *io = STAILQ_FIRST(&head); in _proxy_event_handler_dequeue()
298 io_pending_proxy_t *io = NULL; in _proxy_flush_backend_queue()
455 static void _drive_machine_next(struct mcp_backendconn_s *be, io_pending_proxy_t *p) { in _drive_machine_next()
477 io_pending_proxy_t *p = NULL; in proxy_backend_drive_machine()
877 io_pending_proxy_t *io = NULL; in _reset_bad_backend()
922 io_pending_proxy_t *io = NULL; in _prep_pending_write()
949 io_pending_proxy_t *io = be->io_next; in _post_pending_write()
995 io_pending_proxy_t *nio = STAILQ_NEXT(io, io_next); in _post_pending_write()
|
| D | proto_proxy.c | 485 io_pending_proxy_t *p = q->stack_ctx; in proxy_submit_cb()
583 io_pending_proxy_t *p = (io_pending_proxy_t *)pending; in proxy_return_rctx_cb()
623 io_pending_proxy_t *p = (io_pending_proxy_t *)pending; in proxy_finalize_rctx_cb()
1306 io_pending_proxy_t *mcp_queue_rctx_io(mcp_rcontext_t *rctx, mcp_request_t *rq, mcp_backend_t *be, m… in mcp_queue_rctx_io()
1309 io_pending_proxy_t *p = do_cache_alloc(c->thread->io_cache); in mcp_queue_rctx_io()
1319 assert(sizeof(io_pending_t) >= sizeof(io_pending_proxy_t)); in mcp_queue_rctx_io()
1320 memset(p, 0, sizeof(io_pending_proxy_t)); in mcp_queue_rctx_io()
|
| D | proxy_luafgen.c | 853 io_pending_proxy_t *p = mcp_queue_rctx_io(rctx->parent, NULL, NULL, r); in _mcp_start_rctx_process_error()
870 io_pending_proxy_t *p = mcp_queue_rctx_io(rctx->parent, NULL, NULL, r); in mcp_start_subrctx()
884 io_pending_proxy_t *p = mcp_queue_rctx_io(rctx->parent, NULL, NULL, NULL); in mcp_start_subrctx()
963 io_pending_proxy_t *p = (io_pending_proxy_t *)pending; in proxy_return_rqu_dummy_cb()
1110 io_pending_proxy_t *p = (io_pending_proxy_t *)pending; in proxy_return_rqu_cb()
1142 io_pending_proxy_t *p = mcp_queue_rctx_io(rctx, rq, be, rqu->res_obj); in mcp_run_rcontext_handle()
1236 io_pending_proxy_t *p = mcp_queue_rctx_io(rctx, NULL, NULL, NULL); in mcplib_rcontext_wait_cond()
|
| D | proxy.h | 168 typedef struct _io_pending_proxy_t io_pending_proxy_t; typedef
410 io_pending_proxy_t *io_next; // next request to write.
611 io_pending_proxy_t *mcp_queue_rctx_io(mcp_rcontext_t *rctx, mcp_request_t *rq, mcp_backend_t *be, m…
844 void mcp_request_attach(mcp_request_t *rq, io_pending_proxy_t *p);
|
| D | proxy_internal.c | 87 io_pending_proxy_t *io = (io_pending_proxy_t *)eio->data; in _storage_get_item_cb()
150 io_pending_proxy_t *io = do_cache_alloc(t->io_cache); in proxy_storage_get()
152 assert(sizeof(io_pending_t) >= sizeof(io_pending_proxy_t)); in proxy_storage_get()
153 memset(io, 0, sizeof(io_pending_proxy_t)); in proxy_storage_get()
1767 io_pending_proxy_t *io = (io_pending_proxy_t *)rctx->resp->io_pending; in mcplib_internal_run()
|
| D | proxy_request.c | 593 void mcp_request_attach(mcp_request_t *rq, io_pending_proxy_t *p) { in mcp_request_attach()
|