Lines Matching refs:req
189 struct evhttp_request *req, struct evbuffer *evbuf) in evrpc_process_hooks() argument
193 int res = hook->process(ctx, req, evbuf, hook->process_arg); in evrpc_process_hooks()
285 evrpc_request_cb(struct evhttp_request *req, void *arg) in evrpc_request_cb() argument
291 if (req->type != EVHTTP_REQ_POST || in evrpc_request_cb()
292 evbuffer_get_length(req->input_buffer) <= 0) in evrpc_request_cb()
299 rpc_state->http_req = req; in evrpc_request_cb()
305 evrpc_hook_associate_meta_(&rpc_state->hook_meta, req->evcon); in evrpc_request_cb()
311 rpc_state, req, req->input_buffer); in evrpc_request_cb()
334 evhttp_send_error(req, HTTP_SERVUNAVAIL, NULL); in evrpc_request_cb()
343 struct evhttp_request *req; in evrpc_request_cb_closure() local
347 req = rpc_state->http_req; in evrpc_request_cb_closure()
358 rpc_state->request, req->input_buffer) == -1) { in evrpc_request_cb_closure()
376 evhttp_send_error(req, HTTP_SERVUNAVAIL, NULL); in evrpc_request_cb_closure()
406 struct evhttp_request *req; in evrpc_request_done() local
411 req = rpc_state->http_req; in evrpc_request_done()
430 evrpc_hook_associate_meta_(&rpc_state->hook_meta, req->evcon); in evrpc_request_done()
434 rpc_state, req, rpc_state->rpc_data); in evrpc_request_done()
457 evhttp_send_error(req, HTTP_SERVUNAVAIL, NULL); in evrpc_request_done()
462 evrpc_get_request(struct evrpc_req_generic *req) in evrpc_get_request() argument
464 return req->request; in evrpc_get_request()
468 evrpc_get_reply(struct evrpc_req_generic *req) in evrpc_get_reply() argument
470 return req->reply; in evrpc_get_reply()
477 struct evhttp_request *req; in evrpc_request_done_closure() local
479 req = rpc_state->http_req; in evrpc_request_done_closure()
485 if (evhttp_find_header(req->output_headers, "Content-Type") == NULL) { in evrpc_request_done_closure()
486 evhttp_add_header(req->output_headers, in evrpc_request_done_closure()
489 evhttp_send_reply(req, HTTP_OK, "OK", rpc_state->rpc_data); in evrpc_request_done_closure()
497 evhttp_send_error(req, HTTP_SERVUNAVAIL, NULL); in evrpc_request_done_closure()
662 struct evhttp_request *req = NULL; in evrpc_schedule_request() local
666 if ((req = evhttp_request_new(evrpc_reply_done, ctx)) == NULL) in evrpc_schedule_request()
670 ctx->request_marshal(req->output_buffer, ctx->request); in evrpc_schedule_request()
676 ctx->req = req; in evrpc_schedule_request()
685 ctx, req, req->output_buffer); in evrpc_schedule_request()
722 struct evhttp_request *req = ctx->req; in evrpc_schedule_request_closure() local
746 res = evhttp_make_request(connection, req, EVHTTP_REQ_POST, uri); in evrpc_schedule_request_closure()
860 evrpc_reply_done(struct evhttp_request *req, void *arg) in evrpc_reply_done() argument
869 ctx->req = req; in evrpc_reply_done()
872 if (req == NULL) { in evrpc_reply_done()
882 ctx, req, req->input_buffer); in evrpc_reply_done()
895 evhttp_request_own(req); in evrpc_reply_done()
916 struct evhttp_request *req = ctx->req; in evrpc_reply_done_closure() local
922 status.http_req = req; in evrpc_reply_done_closure()
925 if (req == NULL) { in evrpc_reply_done_closure()
930 res = ctx->reply_unmarshal(ctx->reply, req->input_buffer); in evrpc_reply_done_closure()
946 if (req != NULL && evhttp_request_is_owned(req)) in evrpc_reply_done_closure()
947 evhttp_request_free(req); in evrpc_reply_done_closure()
1032 struct evrpc_request_wrapper *req = ctx; in evrpc_hook_add_meta() local
1036 if ((store = req->hook_meta) == NULL) in evrpc_hook_add_meta()
1037 store = req->hook_meta = evrpc_hook_meta_new_(); in evrpc_hook_add_meta()
1054 struct evrpc_request_wrapper *req = ctx; in evrpc_hook_find_meta() local
1057 if (req->hook_meta == NULL) in evrpc_hook_find_meta()
1060 TAILQ_FOREACH(meta, &req->hook_meta->meta_data, next) { in evrpc_hook_find_meta()
1074 struct evrpc_request_wrapper *req = ctx; in evrpc_hook_get_connection() local
1075 return (req->hook_meta != NULL ? req->hook_meta->evcon : NULL); in evrpc_hook_get_connection()