Lines Matching refs:be
503 mcp_backend_t *be; in proxy_submit_cb() local
522 be = p->backend; in proxy_submit_cb()
524 if (be->use_io_thread) { in proxy_submit_cb()
528 STAILQ_INSERT_HEAD(&be->io_head, p, io_next); in proxy_submit_cb()
529 assert(be->depth > -1); in proxy_submit_cb()
530 be->depth++; in proxy_submit_cb()
531 if (!be->stacked) { in proxy_submit_cb()
532 be->stacked = true; in proxy_submit_cb()
533 STAILQ_INSERT_TAIL(&w_head, be, be_next); in proxy_submit_cb()
1248 void mcp_set_resobj(mcp_resp_t *r, mcp_request_t *rq, mcp_backend_t *be, LIBEVENT_THREAD *t) { in mcp_set_resobj() argument
1279 strncpy(r->be_name, be->name, MAX_NAMELEN+1); in mcp_set_resobj()
1280 strncpy(r->be_port, be->port, MAX_PORTLEN+1); in mcp_set_resobj()
1284 mcp_resp_t *mcp_prep_resobj(lua_State *L, mcp_request_t *rq, mcp_backend_t *be, LIBEVENT_THREAD *t)… in mcp_prep_resobj() argument
1286 mcp_set_resobj(r, rq, be, t); in mcp_prep_resobj()
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() argument
1336 p->backend = be; in mcp_queue_rctx_io()
1633 mcp_backend_t *be = p->pool[x].be; in dump_pool_info() local
1635 if (be != NULL) { in dump_pool_info()
1637 x, be->label, be->name, be->conncount, be->depth); in dump_pool_info()
1638 for (int i = 0; i < be->conncount; i++) { in dump_pool_info()
1639 struct mcp_backendconn_s *bec = &be->be[i]; in dump_pool_info()