Home
last modified time | relevance | path

Searched refs:req (Results 1 – 22 of 22) sorted by relevance

/libevent-2.1.12/
H A Dhttp.c404 req->major, req->minor); in evhttp_send_continue()
452 method, req->uri, req->major, req->minor); in evhttp_make_header_request()
537 req->major, req->minor, req->response_code, in evhttp_make_header_response()
707 (*req->cb)(req, req->cb_arg); in evhttp_connection_incoming_fail()
873 (*req->cb)(req, req->cb_arg); in evhttp_connection_done()
983 (*req->chunk_cb)(req, req->cb_arg); in evhttp_handle_chunked_read()
1106 (*req->chunk_cb)(req, req->cb_arg); in evhttp_read_body()
2316 if ((*req->header_cb)(req, req->cb_arg) < 0) { in evhttp_read_header()
2664 if (!req->major && !req->minor) { in evhttp_make_request()
2774 req->on_complete_cb(req, req->on_complete_cb_arg); in evhttp_send_done()
[all …]
H A Devdns.c133 EVUTIL_ASSERT((req)->handle && (req)->handle->current_req == (req))
482 req = req->next; in request_find_from_trans_id()
615 req = req->next; in nameserver_failed()
2030 req->prev_pending = req->next_pending = req; in evdns_server_request_respond()
2103 if (req->next_pending && req->next_pending != req) in server_request_free()
2117 if (req->next_pending && req->next_pending != req) { in server_request_free()
2377 req = req->next; in evdns_transmit()
2742 if (req->next == req) { in evdns_request_remove()
2746 req->next->prev = req->prev; in evdns_request_remove()
2760 req->next = req->prev = req; in evdns_request_insert()
[all …]
H A Devrpc.c311 rpc_state, req, req->input_buffer); in evrpc_request_cb()
470 return req->reply; in evrpc_get_reply()
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
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()
916 struct evhttp_request *req = ctx->req; in evrpc_reply_done_closure() local
946 if (req != NULL && evhttp_request_is_owned(req)) in evrpc_reply_done_closure()
[all …]
H A Dhttp-internal.h113 void (*cb)(struct evhttp_request *req, void *);
166 void (*gencb)(struct evhttp_request *req, void *);
H A Devrpc-internal.h180 struct evhttp_request *req; member
H A Dutil-internal.h410 struct evdns_getaddrinfo_request *req);
H A Dconfigure.ac15 dnl AM_SILENT_RULES req. automake 1.11. [no] defaults V=1
H A DChangeLog328 o http: fix formatter for pritnf for req->ntoread (osx) (1cbf26f6 Azat Khuzhin)
890 o Clarifications in response to merge req. comments (bd41947 Ondřej
H A DChangeLog-2.0441 o Correctly count req->body_size on http usage without Content-Length (8e342e5)
/libevent-2.1.12/test/
H A Dregress_http.c448 state->req = req; in http_chunked_cb()
1351 tt_assert(req); in http_timed_out_request_done()
1556 if (!req) in http_cancel_test()
1576 if (!req) in http_cancel_test()
1617 if (!req) { in http_request_done()
1826 if (!req) { in http_request_empty_done()
1886 if (!req) { in http_dispatcher_test_done()
1939 tt_assert(req); in http_dispatcher_test()
3271 if (req) in http_chunked_errorcb()
4284 state->req = req; in terminate_chunked_cb()
[all …]
H A Dregress_rpc.c114 req->input_headers, "X-Hook"); in MessageCb()
190 struct evhttp_request *req = NULL; in rpc_basic_test() local
203 tt_assert(req); in rpc_basic_test()
209 if (evhttp_make_request(evcon, req, in rpc_basic_test()
234 if (req->response_code != HTTP_OK) { in rpc_postrequest_done()
259 struct evhttp_request *req = NULL; in rpc_basic_message() local
273 if (req == NULL) { in rpc_basic_message()
288 if (evhttp_make_request(evcon, req, in rpc_basic_message()
889 struct evhttp_request *req = NULL; in rpc_invalid_type() local
902 tt_assert(req); in rpc_invalid_type()
[all …]
H A Dregress_testutils.c150 regress_dns_server_cb(struct evdns_server_request *req, void *data) in regress_dns_server_cb() argument
155 if (req->nquestions != 1) in regress_dns_server_cb()
157 req->nquestions)); in regress_dns_server_cb()
159 question = req->questions[0]->name; in regress_dns_server_cb()
174 tt_assert(! evdns_server_request_respond(req, err)); in regress_dns_server_cb()
188 req, EVDNS_AUTHORITY_SECTION, in regress_dns_server_cb()
191 tt_assert(! evdns_server_request_respond(req, err)); in regress_dns_server_cb()
198 evdns_server_request_add_a_reply(req, question, 1, &in.s_addr, in regress_dns_server_cb()
205 evdns_server_request_add_aaaa_reply(req, in regress_dns_server_cb()
210 tt_assert(! evdns_server_request_respond(req, 0)) in regress_dns_server_cb()
[all …]
H A Dregress_dns.c217 tt_assert(req); in dns_resolve_reverse()
386 struct evdns_request *req=NULL; in dns_server() local
633 if (req->nquestions != 1) in search_cancel_server_cb()
635 req->nquestions)); in search_cancel_server_cb()
706 if (req->nquestions != 1) in fail_server_cb()
708 req->nquestions)); in fail_server_cb()
1831 tt_assert(req->nquestions); in gaic_server_cb()
1832 evdns_server_request_add_a_reply(req, req->questions[0]->name, 1, in gaic_server_cb()
1918 struct evdns_request *req; member
1983 env->req = 0; in test_dbg_leak_cancel()
[all …]
H A Dbench_http.c51 static void http_basic_cb(struct evhttp_request *req, void *arg);
57 http_basic_cb(struct evhttp_request *req, void *arg) in http_basic_cb() argument
64 evhttp_send_reply(req, HTTP_OK, "Everything is fine", evb); in http_basic_cb()
71 http_ref_cb(struct evhttp_request *req, void *arg) in http_ref_cb() argument
78 evhttp_send_reply(req, HTTP_OK, "Everything is fine", evb); in http_ref_cb()
H A Dregress_testutils.h52 struct evdns_server_request *req, void *data);
/libevent-2.1.12/sample/
H A Dhttp-connect.c58 static void get_cb(struct evhttp_request *req, void *arg) in get_cb() argument
63 VERIFY(req); in get_cb()
65 evbuf = evhttp_request_get_input_buffer(req); in get_cb()
76 struct evhttp_request *req; in connect_cb() local
82 req = evhttp_request_new(get_cb, NULL); in connect_cb()
83 evhttp_add_header(req->output_headers, "Connection", "close"); in connect_cb()
85 VERIFY(!evhttp_make_request(evcon, req, EVHTTP_REQ_GET, in connect_cb()
98 struct evhttp_request *req; in main() local
115 VERIFY(req = evhttp_request_new(connect_cb, &connect_base)); in main()
120 evhttp_add_header(req->output_headers, "Host", hostport); in main()
[all …]
H A Ddns-example.c116 for (i = 0; i < req->nquestions; ++i) { in evdns_server_callback()
118 if (req->questions[i]->type == EVDNS_TYPE_A && in evdns_server_callback()
119 req->questions[i]->dns_question_class == EVDNS_CLASS_INET) { in evdns_server_callback()
120 printf(" -- replying for %s (A)\n", req->questions[i]->name); in evdns_server_callback()
121 r = evdns_server_request_add_a_reply(req, req->questions[i]->name, in evdns_server_callback()
125 } else if (req->questions[i]->type == EVDNS_TYPE_PTR && in evdns_server_callback()
126 req->questions[i]->dns_question_class == EVDNS_CLASS_INET) { in evdns_server_callback()
128 r = evdns_server_request_add_ptr_reply(req, NULL, req->questions[i]->name, in evdns_server_callback()
133 printf(" -- skipping %s [%d %d]\n", req->questions[i]->name, in evdns_server_callback()
134 req->questions[i]->type, req->questions[i]->dns_question_class); in evdns_server_callback()
[all …]
H A Dhttp-server.c134 dump_request_cb(struct evhttp_request *req, void *arg) in dump_request_cb() argument
141 switch (evhttp_request_get_command(req)) { in dump_request_cb()
155 cmdtype, evhttp_request_get_uri(req)); in dump_request_cb()
157 headers = evhttp_request_get_input_headers(req); in dump_request_cb()
163 buf = evhttp_request_get_input_buffer(req); in dump_request_cb()
174 evhttp_send_reply(req, 200, "OK", NULL); in dump_request_cb()
182 send_document_cb(struct evhttp_request *req, void *arg) in send_document_cb() argument
186 const char *uri = evhttp_request_get_uri(req); in send_document_cb()
196 dump_request_cb(req, arg); in send_document_cb()
206 evhttp_send_error(req, HTTP_BADREQUEST, 0); in send_document_cb()
[all …]
H A Dhttps-client.c51 http_request_done(struct evhttp_request *req, void *ctx) in http_request_done() argument
56 if (!req || !evhttp_request_get_response_code(req)) { in http_request_done()
82 evhttp_request_get_response_code(req), in http_request_done()
83 evhttp_request_get_response_code_line(req)); in http_request_done()
85 while ((nread = evbuffer_remove(evhttp_request_get_input_buffer(req), in http_request_done()
232 struct evhttp_request *req; in main() local
465 req = evhttp_request_new(http_request_done, bev); in main()
466 if (req == NULL) { in main()
471 output_headers = evhttp_request_get_output_headers(req); in main()
489 output_buffer = evhttp_request_get_output_buffer(req); in main()
[all …]
/libevent-2.1.12/include/event2/
H A Dhttp.h401 void evhttp_send_error(struct evhttp_request *req, int error,
418 void evhttp_send_reply(struct evhttp_request *req, int code,
438 void evhttp_send_reply_start(struct evhttp_request *req, int code,
453 void evhttp_send_reply_chunk(struct evhttp_request *req,
479 void evhttp_send_reply_end(struct evhttp_request *req);
629 void evhttp_request_free(struct evhttp_request *req);
683 void evhttp_request_own(struct evhttp_request *req);
687 int evhttp_request_is_owned(struct evhttp_request *req);
793 struct evhttp_request *req,
810 void evhttp_cancel_request(struct evhttp_request *req);
[all …]
H A Ddns.h450 void evdns_cancel_request(struct evdns_base *base, struct evdns_request *req);
664 void evdns_server_request_set_flags(struct evdns_server_request *req, int flags);
669 int evdns_server_request_add_reply(struct evdns_server_request *req, int section, const char *name,…
671 int evdns_server_request_add_a_reply(struct evdns_server_request *req, const char *name, int n, con…
673 int evdns_server_request_add_aaaa_reply(struct evdns_server_request *req, const char *name, int n, …
675 int evdns_server_request_add_ptr_reply(struct evdns_server_request *req, struct in_addr *in, const …
677 int evdns_server_request_add_cname_reply(struct evdns_server_request *req, const char *name, const …
683 int evdns_server_request_respond(struct evdns_server_request *req, int err);
688 int evdns_server_request_drop(struct evdns_server_request *req);
694 int evdns_server_request_get_requesting_addr(struct evdns_server_request *req, struct sockaddr *sa,…
[all …]
H A Drpc.h267 void evrpc_request_done(struct evrpc_req_generic *req);
271 void *evrpc_get_request(struct evrpc_req_generic *req);
273 void *evrpc_get_reply(struct evrpc_req_generic *req);