| /libevent-2.1.12/ |
| H A D | evrpc.c | 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()
771 pause->ctx = ctx; in evrpc_pause_request()
786 if (pause->ctx == ctx) in evrpc_resume_request()
845 ctx->cb = cb; in evrpc_make_request_ctx()
853 return (ctx); in evrpc_make_request_ctx()
878 evrpc_hook_associate_meta_(&ctx->hook_meta, ctx->evcon); in evrpc_reply_done()
937 ctx->reply_clear(ctx->reply); in evrpc_reply_done_closure()
940 (*ctx->cb)(&status, ctx->request, ctx->reply, ctx->cb_arg); in evrpc_reply_done_closure()
[all …]
|
| H A D | evmap.c | 237 ctx->nentries = 0; in evmap_signal_initmap_()
253 ctx->nentries = 0; in evmap_signal_clear_()
296 nread = ctx->nread; in evmap_io_add_()
432 if (NULL == ctx) in evmap_io_active_()
511 if (!ctx) in evmap_signal_active_()
522 if (ctx) in evmap_io_get_fdinfo_()
561 if (!ctx)
595 if (!ctx)
618 if (ctx->nread)
620 if (ctx->nwrite)
[all …]
|
| H A D | evmap-internal.h | 42 void evmap_io_initmap_(struct event_io_map* ctx);
43 void evmap_signal_initmap_(struct event_signal_map* ctx);
49 void evmap_io_clear_(struct event_io_map* ctx);
50 void evmap_signal_clear_(struct event_signal_map* ctx);
91 void *evmap_io_get_fdinfo_(struct event_io_map *ctx, evutil_socket_t fd);
|
| H A D | evrpc-internal.h | 101 void *ctx; member
128 static void evrpc_hook_context_free_(struct evrpc_hook_meta *ctx);
|
| H A D | bufferevent_openssl.c | 904 be_openssl_readcb(struct bufferevent *bev_base, void *ctx) in be_openssl_readcb() argument
906 struct bufferevent_openssl *bev_ssl = ctx; in be_openssl_readcb()
911 be_openssl_writecb(struct bufferevent *bev_base, void *ctx) in be_openssl_writecb() argument
913 struct bufferevent_openssl *bev_ssl = ctx; in be_openssl_writecb()
918 be_openssl_eventcb(struct bufferevent *bev_base, short what, void *ctx) in be_openssl_eventcb() argument
920 struct bufferevent_openssl *bev_ssl = ctx; in be_openssl_eventcb()
1064 be_openssl_handshakecb(struct bufferevent *bev_base, void *ctx) in be_openssl_handshakecb() argument
1066 struct bufferevent_openssl *bev_ssl = ctx; in be_openssl_handshakecb()
|
| H A D | bufferevent_filter.c | 160 enum bufferevent_flush_mode state, void *ctx) in be_null_filter() argument
175 void *ctx) in bufferevent_filter_new() argument
206 bufev_f->context = ctx; in bufferevent_filter_new()
|
| H A D | bufferevent.c | 942 bufferevent_generic_read_timeout_cb(evutil_socket_t fd, short event, void *ctx) in bufferevent_generic_read_timeout_cb() argument
944 struct bufferevent *bev = ctx; in bufferevent_generic_read_timeout_cb()
951 bufferevent_generic_write_timeout_cb(evutil_socket_t fd, short event, void *ctx) in bufferevent_generic_write_timeout_cb() argument
953 struct bufferevent *bev = ctx; in bufferevent_generic_write_timeout_cb()
|
| /libevent-2.1.12/sample/ |
| H A D | le-proxy.c | 49 static void drained_writecb(struct bufferevent *bev, void *ctx);
50 static void eventcb(struct bufferevent *bev, short what, void *ctx);
53 readcb(struct bufferevent *bev, void *ctx) in readcb() argument
55 struct bufferevent *partner = ctx; in readcb()
80 drained_writecb(struct bufferevent *bev, void *ctx) in drained_writecb() argument
82 struct bufferevent *partner = ctx; in drained_writecb()
93 close_on_finished_writecb(struct bufferevent *bev, void *ctx) in close_on_finished_writecb() argument
103 eventcb(struct bufferevent *bev, short what, void *ctx) in eventcb() argument
105 struct bufferevent *partner = ctx; in eventcb()
126 readcb(bev, ctx); in eventcb()
|
| H A D | https-client.c | 51 http_request_done(struct evhttp_request *req, void *ctx) in http_request_done() argument
60 struct bufferevent *bev = (struct bufferevent *) ctx; in http_request_done()
189 PCCERT_CONTEXT ctx = NULL; in add_cert_for_store() local
197 while ((ctx = CertEnumCertificatesInStore(sys_store, ctx))) { in add_cert_for_store()
198 X509 *x509 = d2i_X509(NULL, (unsigned char const **)&ctx->pbCertEncoded, in add_cert_for_store()
199 ctx->cbCertEncoded); in add_cert_for_store()
|
| /libevent-2.1.12/test/ |
| H A D | regress_ssl.c | 326 type = (enum regress_openssl_type)ctx; in respond_to_number()
814 struct wm_context *ctx = arg; in wm_transfer() local
818 size_t drain = len < ctx->to_read ? len : ctx->to_read; in wm_transfer()
820 if (ctx->get >= ctx->limit) { in wm_transfer()
825 if (ctx->neighbour->get >= ctx->neighbour->limit) { in wm_transfer()
829 ctx->get += drain; in wm_transfer()
840 ctx->get)); in wm_transfer()
847 struct wm_context *ctx = arg; in wm_eventcb() local
852 ctx->get = 0; in wm_eventcb()
859 struct wm_context *ctx = arg; in wm_acceptcb() local
[all …]
|
| H A D | regress_rpc.c | 405 assert(evrpc_hook_get_connection(ctx) != NULL); in rpc_hook_add_header()
411 rpc_hook_add_meta(void *ctx, struct evhttp_request *req, in rpc_hook_add_meta() argument
414 evrpc_hook_add_meta(ctx, "meta", "test", 5); in rpc_hook_add_meta()
416 assert(evrpc_hook_get_connection(ctx) != NULL); in rpc_hook_add_meta()
439 assert(evrpc_hook_get_connection(ctx) != NULL); in rpc_hook_remove_header()
499 struct evrpc_request_wrapper *ctx = in rpc_basic_client() local
502 evrpc_make_request(ctx); in rpc_basic_client()
600 void *ctx; member
608 struct rpc_hook_ctx_ *ctx = arg; in rpc_hook_pause_cb() local
610 evrpc_resume_request(ctx->vbase, ctx->ctx, EVRPC_CONTINUE); in rpc_hook_pause_cb()
[all …]
|
| H A D | regress_zlib.c | 94 zlib_deflate_free(void *ctx) in zlib_deflate_free() argument
96 z_streamp p = ctx; in zlib_deflate_free()
103 zlib_inflate_free(void *ctx) in zlib_inflate_free() argument
105 z_streamp p = ctx; in zlib_inflate_free()
132 ev_ssize_t lim, enum bufferevent_flush_mode state, void *ctx) in zlib_input_filter() argument
139 z_streamp p = ctx; in zlib_input_filter()
186 ev_ssize_t lim, enum bufferevent_flush_mode state, void *ctx) in zlib_output_filter() argument
193 z_streamp p = ctx; in zlib_output_filter()
|
| H A D | regress_bufferevent.c | 522 struct bufferevent **bevp = ctx; in bufferevent_output_filter()
617 sender_writecb(struct bufferevent *bev, void *ctx) in sender_writecb() argument
684 struct event_base *base = ctx; in reader_eventcb()
719 reader_readcb(struct bufferevent *bev, void *ctx) in reader_readcb() argument
870 struct event_base *base = ctx; in want_fail_eventcb()
1085 struct event_base *base = ctx; in trigger_eventcb()
1091 reader_eventcb(bev, what, ctx); in trigger_eventcb()
1103 trigger_readcb(struct bufferevent *bev, void *ctx) in trigger_readcb() argument
1106 struct event_base *base = ctx; in trigger_readcb()
1223 int *callback_what = ctx; in pair_flush_eventcb()
[all …]
|
| H A D | test-ratelim.c | 128 loud_writecb(struct bufferevent *bev, void *ctx) in loud_writecb() argument
130 struct client_state *cs = ctx; in loud_writecb()
142 discard_readcb(struct bufferevent *bev, void *ctx) in discard_readcb() argument
144 struct client_state *cs = ctx; in discard_readcb()
152 write_on_connectedcb(struct bufferevent *bev, short what, void *ctx) in write_on_connectedcb() argument
155 loud_writecb(bev, ctx); in write_on_connectedcb()
162 echo_readcb(struct bufferevent *bev, void *ctx) in echo_readcb() argument
173 echo_writecb(struct bufferevent *bev, void *ctx) in echo_writecb() argument
181 echo_eventcb(struct bufferevent *bev, short what, void *ctx) in echo_eventcb() argument
191 struct sockaddr *sourceaddr, int socklen, void *ctx) in echo_listenercb() argument
[all …]
|
| H A D | test-fdleak.c | 82 server_read_cb(struct bufferevent *bev, void *ctx) in server_read_cb() argument
93 server_event_cb(struct bufferevent *bev, short events, void *ctx) in server_event_cb() argument
173 client_read_cb(struct bufferevent *bev, void *ctx) in client_read_cb() argument
193 client_event_cb(struct bufferevent *bev, short events, void *ctx) in client_event_cb() argument
|
| H A D | regress_dns.c | 1217 be_connect_hostname_event_cb(struct bufferevent *bev, short what, void *ctx) in be_connect_hostname_event_cb() argument
1219 struct be_conn_hostname_result *got = ctx; in be_connect_hostname_event_cb()
|
| /libevent-2.1.12/include/event2/ |
| H A D | rpc.h | 402 int evrpc_make_request(struct evrpc_request_wrapper *ctx);
537 int evrpc_resume_request(void *vbase, void *ctx, enum EVRPC_HOOK_RESULT res);
551 void evrpc_hook_add_meta(void *ctx, const char *key,
565 int evrpc_hook_find_meta(void *ctx, const char *key,
576 struct evhttp_connection *evrpc_hook_get_connection(void *ctx);
613 struct evrpc_pool* evrpc_request_get_pool(struct evrpc_request_wrapper *ctx);
615 void evrpc_request_set_pool(struct evrpc_request_wrapper *ctx,
618 void evrpc_request_set_cb(struct evrpc_request_wrapper *ctx,
|
| H A D | bufferevent.h | 135 typedef void (*bufferevent_data_cb)(struct bufferevent *bev, void *ctx);
154 typedef void (*bufferevent_event_cb)(struct bufferevent *bev, short what, void *ctx);
705 enum bufferevent_flush_mode mode, void *ctx);
727 void *ctx);
|