Lines Matching refs:p

485     io_pending_proxy_t *p = q->stack_ctx;  in proxy_submit_cb()  local
502 while (p) { in proxy_submit_cb()
504 P_DEBUG("%s: queueing req for backend: %p\n", __func__, (void *)p); in proxy_submit_cb()
505 if (p->qcount_incr) { in proxy_submit_cb()
512 if (p->background) { in proxy_submit_cb()
513 P_DEBUG("%s: fast-returning background object: %p\n", __func__, (void *)p); in proxy_submit_cb()
518 return_io_pending((io_pending_t *)p); in proxy_submit_cb()
519 p = p->next; in proxy_submit_cb()
522 be = p->backend; in proxy_submit_cb()
525 STAILQ_INSERT_HEAD(&head, p, io_next); in proxy_submit_cb()
528 STAILQ_INSERT_HEAD(&be->io_head, p, io_next); in proxy_submit_cb()
537 p = p->next; in proxy_submit_cb()
583 io_pending_proxy_t *p = (io_pending_proxy_t *)pending; in proxy_return_rctx_cb() local
584 if (p->client_resp && p->client_resp->blen) { in proxy_return_rctx_cb()
587 unsigned int kb = p->client_resp->blen / 1000; in proxy_return_rctx_cb()
588 p->thread->proxy_vm_extra_kb += kb > 0 ? kb : 1; in proxy_return_rctx_cb()
591 mcp_rcontext_t *rctx = p->rctx; in proxy_return_rctx_cb()
600 io_queue_t *q = conn_io_queue_get(p->c, p->io_queue_type); in proxy_return_rctx_cb()
602 conn *c = p->c; in proxy_return_rctx_cb()
603 if (p->io_type != IO_PENDING_TYPE_EXTSTORE) { in proxy_return_rctx_cb()
607 do_cache_free(p->thread->io_cache, p); in proxy_return_rctx_cb()
623 io_pending_proxy_t *p = (io_pending_proxy_t *)pending; in proxy_finalize_rctx_cb() local
625 if (p->io_type == IO_PENDING_TYPE_EXTSTORE) { in proxy_finalize_rctx_cb()
626 if (p->hdr_it) { in proxy_finalize_rctx_cb()
628 if (p->miss) { in proxy_finalize_rctx_cb()
629 item_unlink(p->hdr_it); in proxy_finalize_rctx_cb()
631 item_remove(p->hdr_it); in proxy_finalize_rctx_cb()
1309 io_pending_proxy_t *p = do_cache_alloc(c->thread->io_cache); in mcp_queue_rctx_io() local
1310 if (p == NULL) { in mcp_queue_rctx_io()
1320 memset(p, 0, sizeof(io_pending_proxy_t)); in mcp_queue_rctx_io()
1322 p->io_queue_type = IO_QUEUE_PROXY; in mcp_queue_rctx_io()
1323 p->thread = c->thread; in mcp_queue_rctx_io()
1324 p->c = c; in mcp_queue_rctx_io()
1325 p->client_resp = r; in mcp_queue_rctx_io()
1326 p->flushed = false; in mcp_queue_rctx_io()
1327 p->return_cb = NULL; in mcp_queue_rctx_io()
1328 p->finalize_cb = proxy_finalize_rctx_cb; in mcp_queue_rctx_io()
1331 p->rctx = rctx; in mcp_queue_rctx_io()
1334 p->ascii_multiget = rq->ascii_multiget; in mcp_queue_rctx_io()
1336 p->backend = be; in mcp_queue_rctx_io()
1338 mcp_request_attach(rq, p); in mcp_queue_rctx_io()
1349 p->qcount_incr = true; in mcp_queue_rctx_io()
1354 p->next = q->stack_ctx; in mcp_queue_rctx_io()
1355 q->stack_ctx = p; in mcp_queue_rctx_io()
1358 return p; in mcp_queue_rctx_io()
1628 static void dump_pool_info(mcp_pool_t *p) { in dump_pool_info() argument
1630 p->beprefix, p->pool_size, p->pool_be_total, p->g.refcount, p->use_iothread); in dump_pool_info()
1632 for (int x = 0; x < p->pool_be_total; x++) { in dump_pool_info()
1633 mcp_backend_t *be = p->pool[x].be; in dump_pool_info()
1661 mcp_pool_t *p = luaL_testudata(L, -1, "mcp.pool"); in dump_pools() local
1662 if (p != NULL) { in dump_pools()
1663 dump_pool_info(p); in dump_pools()