Lines Matching refs:pr
8 static mcp_funcgen_t *mcp_funcgen_route(lua_State *L, mcp_funcgen_t *fgen, mcp_parser_t *pr);
430 mcp_rcontext_t *mcp_funcgen_start(lua_State *L, mcp_funcgen_t *fgen, mcp_parser_t *pr) { in mcp_funcgen_start() argument
432 fgen = mcp_funcgen_route(L, fgen, pr); in mcp_funcgen_start()
793 if (!rq->pr.keytoken) { in mcplib_rcontext_enqueue()
1136 … mcp_backend_t *be = mcplib_pool_proxy_call_helper(rqu->obj, MCP_PARSER_KEY(rq->pr), rq->pr.klen); in mcp_run_rcontext_handle()
1261 if (!rq->pr.keytoken) { in mcplib_rcontext_enqueue_and_wait()
1454 mcp_parser_t pr = {0}; in mcplib_rcontext_request_new() local
1456 mcp_new_request(L, &pr, " ", 1); in mcplib_rcontext_request_new()
1566 static mcp_funcgen_t *mcp_funcgen_route(lua_State *L, mcp_funcgen_t *fgen, mcp_parser_t *pr) { in mcp_funcgen_route() argument
1568 if (pr->klen == 0) { in mcp_funcgen_route()
1571 const char *key = &pr->request[pr->tokens[pr->keytoken]]; in mcp_funcgen_route()
1579 return _mcp_funcgen_route_fallback(fr, pr->command); in mcp_funcgen_route()
1582 lookup = _mcp_router_shortsep(key, pr->klen, fr->conf.sep, &lookuplen); in mcp_funcgen_route()
1585 lookup = _mcp_router_longsep(key, pr->klen, fr->conf.lsep, &lookuplen); in mcp_funcgen_route()
1588 lookup = _mcp_router_anchorsm(key, pr->klen, fr->conf.anchorsm, &lookuplen); in mcp_funcgen_route()
1591 lookup = _mcp_router_anchorbig(key, pr->klen, &fr->conf.big, &lookuplen); in mcp_funcgen_route()
1596 return _mcp_funcgen_route_fallback(fr, pr->command); in mcp_funcgen_route()
1607 return _mcp_funcgen_route_fallback(fr, pr->command); in mcp_funcgen_route()
1615 lua_rawgeti(L, -1, pr->command); in mcp_funcgen_route()
1623 return _mcp_funcgen_route_fallback(fr, pr->command); in mcp_funcgen_route()
1634 return _mcp_funcgen_route_fallback(fr, pr->command); in mcp_funcgen_route()