Lines Matching refs:req
112 struct evhttp_request* req = EVRPC_REQUEST_HTTP(rpc); in MessageCb() local
114 req->input_headers, "X-Hook"); in MessageCb()
167 rpc_postrequest_failure(struct evhttp_request *req, void *arg) in rpc_postrequest_failure() argument
169 if (req->response_code != HTTP_SERVUNAVAIL) { in rpc_postrequest_failure()
190 struct evhttp_request *req = NULL; in rpc_basic_test() local
202 req = evhttp_request_new(rpc_postrequest_failure, NULL); in rpc_basic_test()
203 tt_assert(req); in rpc_basic_test()
206 evhttp_add_header(req->output_headers, "Host", "somehost"); in rpc_basic_test()
207 evbuffer_add_printf(req->output_buffer, "Some Nonsense"); in rpc_basic_test()
209 if (evhttp_make_request(evcon, req, in rpc_basic_test()
230 rpc_postrequest_done(struct evhttp_request *req, void *arg) in rpc_postrequest_done() argument
234 if (req->response_code != HTTP_OK) { in rpc_postrequest_done()
241 if ((kill_unmarshal(kill_reply, req->input_buffer)) == -1) { in rpc_postrequest_done()
259 struct evhttp_request *req = NULL; in rpc_basic_message() local
272 req = evhttp_request_new(rpc_postrequest_done, NULL); in rpc_basic_message()
273 if (req == NULL) { in rpc_basic_message()
279 evhttp_add_header(req->output_headers, "Host", "somehost"); in rpc_basic_message()
285 msg_marshal(req->output_buffer, msg); in rpc_basic_message()
288 if (evhttp_make_request(evcon, req, in rpc_basic_message()
332 struct evhttp_request *req = status->http_req; in GotKillCb() local
334 req->input_headers, "X-Pool-Hook"); in GotKillCb()
396 rpc_hook_add_header(void *ctx, struct evhttp_request *req, in rpc_hook_add_header() argument
401 evhttp_add_header(req->input_headers, "X-Hook", hook_type); in rpc_hook_add_header()
403 evhttp_add_header(req->output_headers, "X-Hook", hook_type); in rpc_hook_add_header()
411 rpc_hook_add_meta(void *ctx, struct evhttp_request *req, in rpc_hook_add_meta() argument
422 rpc_hook_remove_header(void *ctx, struct evhttp_request *req, in rpc_hook_remove_header() argument
425 const char *header = evhttp_find_header(req->input_headers, "X-Hook"); in rpc_hook_remove_header()
432 evhttp_remove_header(req->input_headers, "X-Hook"); in rpc_hook_remove_header()
433 evhttp_add_header(req->input_headers, "X-Pool-Hook", "ran"); in rpc_hook_remove_header()
615 rpc_hook_pause(void *ctx, struct evhttp_request *req, struct evbuffer *evbuf, in rpc_hook_pause() argument
889 struct evhttp_request *req = NULL; in rpc_invalid_type() local
901 req = evhttp_request_new(rpc_postrequest_failure, NULL); in rpc_invalid_type()
902 tt_assert(req); in rpc_invalid_type()
905 evhttp_add_header(req->output_headers, "Host", "somehost"); in rpc_invalid_type()
906 evbuffer_add_printf(req->output_buffer, "Some Nonsense"); in rpc_invalid_type()
908 if (evhttp_make_request(evcon, req, in rpc_invalid_type()