Lines Matching refs:request

353 	rpc_state->request = rpc->request_new(rpc->request_new_arg);  in evrpc_request_cb_closure()
354 if (rpc_state->request == NULL) in evrpc_request_cb_closure()
358 rpc_state->request, req->input_buffer) == -1) { in evrpc_request_cb_closure()
391 if (rpc_state->request != NULL) in evrpc_reqstate_free_()
392 rpc->request_free(rpc_state->request); in evrpc_reqstate_free_()
464 return req->request; in evrpc_get_request()
529 evrpc_request_wrapper_free(struct evrpc_request_wrapper *request) in evrpc_request_wrapper_free() argument
531 if (request->hook_meta != NULL) in evrpc_request_wrapper_free()
532 evrpc_hook_context_free_(request->hook_meta); in evrpc_request_wrapper_free()
533 mm_free(request->name); in evrpc_request_wrapper_free()
534 mm_free(request); in evrpc_request_wrapper_free()
541 struct evrpc_request_wrapper *request; in evrpc_pool_free() local
546 while ((request = TAILQ_FIRST(&pool->requests)) != NULL) { in evrpc_pool_free()
547 TAILQ_REMOVE(&pool->requests, request, next); in evrpc_pool_free()
548 evrpc_request_wrapper_free(request); in evrpc_pool_free()
605 struct evrpc_request_wrapper *request = in evrpc_pool_add_connection() local
607 TAILQ_REMOVE(&pool->requests, request, next); in evrpc_pool_add_connection()
608 evrpc_schedule_request(connection, request); in evrpc_pool_add_connection()
670 ctx->request_marshal(req->output_buffer, ctx->request); in evrpc_schedule_request()
712 (*ctx->cb)(&status, ctx->request, ctx->reply, ctx->cb_arg); in evrpc_schedule_request()
757 (*ctx->cb)(&status, ctx->request, ctx->reply, ctx->cb_arg); in evrpc_schedule_request_closure()
824 struct evrpc_pool *pool, void *request, void *reply, in evrpc_make_request_ctx() argument
847 ctx->request = request; in evrpc_make_request_ctx()
940 (*ctx->cb)(&status, ctx->request, ctx->reply, ctx->cb_arg); in evrpc_reply_done_closure()
1080 void *request, void *reply, in evrpc_send_request_generic() argument
1090 ctx = evrpc_make_request_ctx(pool, request, reply, in evrpc_send_request_generic()
1098 (*(cb))(&status, request, reply, cb_arg); in evrpc_send_request_generic()
1166 void (*cb)(struct evrpc_status*, void *request, void *reply, void *arg), in evrpc_request_set_cb() argument