Home
last modified time | relevance | path

Searched refs:bev (Results 1 – 25 of 49) sorted by relevance

12

/libevent-2.1.12/
H A Dbufferevent_async.c131 bev_a = EVUTIL_UPCAST(bev, struct bufferevent_async, bev.bev); in upcast()
165 struct bufferevent *bev = &beva->bev.bev; in bev_async_del_write() local
176 struct bufferevent *bev = &beva->bev.bev; in bev_async_del_read() local
187 struct bufferevent *bev = &beva->bev.bev; in bev_async_add_write() local
198 struct bufferevent *bev = &beva->bev.bev; in bev_async_add_read() local
211 struct bufferevent *bev = &beva->bev.bev; in bev_async_consider_writing() local
257 struct bufferevent *bev = &beva->bev.bev; in bev_async_consider_reading() local
437 struct bufferevent *bev = &bev_a->bev.bev; in connect_complete() local
465 struct bufferevent *bev = &bev_a->bev.bev; in read_complete() local
504 struct bufferevent *bev = &bev_a->bev.bev; in write_complete() local
[all …]
H A Dbufferevent_ratelim.c238 bufferevent_suspend_write_(&bev->bev, in bufferevent_get_rlim_max_()
241 bufferevent_suspend_read_(&bev->bev, in bufferevent_get_rlim_max_()
365 bufferevent_suspend_read_(&bev->bev, in bev_group_suspend_reading_()
383 bufferevent_suspend_write_(&bev->bev, in bev_group_suspend_writing_()
400 BEV_LOCK(&bev->bev); in bev_refill_callback_()
402 BEV_UNLOCK(&bev->bev); in bev_refill_callback_()
438 BEV_UNLOCK(&bev->bev); in bev_refill_callback_()
477 for (bev = first; bev != LIST_END(&g->members); \
481 for (bev = LIST_FIRST(&g->members); bev && bev != first; \
496 bufferevent_unsuspend_read_(&bev->bev, in bev_group_unsuspend_reading_()
[all …]
H A Dbufferevent_openssl.c390 struct bufferevent *bev = &bev_ssl->bev.bev; in start_reading() local
413 struct bufferevent *bev = &bev_ssl->bev.bev; in start_writing() local
431 struct bufferevent *bev = &bev_ssl->bev.bev; in stop_reading() local
445 struct bufferevent *bev = &bev_ssl->bev.bev; in stop_writing() local
471 struct bufferevent *bev = &bev_ssl->bev.bev; in clear_rbow() local
485 struct bufferevent *bev = &bev_ssl->bev.bev; in clear_wbor() local
586 struct bufferevent *bev = &bev_ssl->bev.bev; in do_read() local
657 struct bufferevent *bev = &bev_ssl->bev.bev; in do_write() local
741 struct evbuffer *input = bev->bev.bev.input; in bytes_to_read()
752 if (! (bev->bev.bev.enabled & EV_READ)) { in bytes_to_read()
[all …]
H A Dbufferevent_filter.c105 evutil_offsetof(struct bufferevent_filtered, bev.bev),
124 evutil_offsetof(struct bufferevent_filtered, bev.bev)); in upcast()
125 EVUTIL_ASSERT(BEV_IS_FILTER(&bev_f->bev.bev)); in upcast()
129 #define downcast(bev_f) (&(bev_f)->bev.bev)
490 BEV_LOCK(bev); in bufferevent_filtered_inbuf_cb()
509 BEV_UNLOCK(bev); in bufferevent_filtered_inbuf_cb()
519 BEV_LOCK(bev); in be_filter_readcb()
523 BEV_UNLOCK(bev); in be_filter_readcb()
536 BEV_LOCK(bev); in be_filter_writecb()
546 BEV_UNLOCK(bev); in be_filter_writecb()
[all …]
H A Dbufferevent_pair.c59 if (!BEV_IS_PAIR(bev)) in upcast()
61 bev_p = EVUTIL_UPCAST(bev, struct bufferevent_pair, bev.bev); in upcast()
62 EVUTIL_ASSERT(BEV_IS_PAIR(&bev_p->bev.bev)); in upcast()
66 #define downcast(bev_pair) (&(bev_pair)->bev.bev)
104 if (!evbuffer_add_cb(bufev->bev.bev.output, be_pair_outbuf_cb, bufev)) { in bufferevent_pair_elt_new()
109 bufferevent_init_generic_timeout_cbs_(&bufev->bev.bev); in bufferevent_pair_elt_new()
317 incref_and_lock(bev); in be_pair_flush()
335 decref_and_unlock(bev); in be_pair_flush()
344 bev_p = upcast(bev); in bufferevent_pair_get_partner()
348 incref_and_lock(bev); in bufferevent_pair_get_partner()
[all …]
H A Dbufferevent.c127 if (evbuffer_get_length(bev->input) < bev->wm_read.high) in bufferevent_inbuf_wm_check()
870 BEV_LOCK(bev); in bufferevent_setfd()
872 res = bev->be_ops->ctrl(bev, BEV_CTRL_SET_FD, &d); in bufferevent_setfd()
885 BEV_LOCK(bev); in bufferevent_getfd()
887 res = bev->be_ops->ctrl(bev, BEV_CTRL_GET_FD, &d); in bufferevent_getfd()
900 BEV_LOCK(bev); in bufferevent_get_options_()
912 BEV_LOCK(bev); in bufferevent_cancel_all_()
914 bev->be_ops->ctrl(bev, BEV_CTRL_CANCEL_ALL, &d); in bufferevent_cancel_all_()
963 event_assign(&bev->ev_read, bev->ev_base, -1, EV_FINALIZE, in bufferevent_init_generic_timeout_cbs_()
977 r1 = event_add(&bev->ev_read, &bev->timeout_read); in bufferevent_generic_adj_timeouts_()
[all …]
H A Dbufferevent_sock.c363 bufev = &bufev_p->bev; in bufferevent_socket_new()
392 fd = bufferevent_getfd(bev); in bufferevent_socket_connect()
422 if (BEV_IS_ASYNC(bev)) { in bufferevent_socket_connect()
423 event_assign(&bev->ev_write, bev->ev_base, fd, in bufferevent_socket_connect()
427 bufferevent_setfd(bev, fd); in bufferevent_socket_connect()
463 BEV_LOCK(bev); in bufferevent_connect_getaddrinfo_cb()
513 BEV_LOCK(bev); in bufferevent_socket_connect_hostname()
519 bufferevent_incref_(bev); in bufferevent_socket_connect_hostname()
522 BEV_UNLOCK(bev); in bufferevent_socket_connect_hostname()
533 BEV_LOCK(bev); in bufferevent_socket_get_dns_error()
[all …]
H A Dbufferevent-internal.h156 struct bufferevent bev; member
458 #define BEV_RESET_GENERIC_READ_TIMEOUT(bev) \ argument
460 if (evutil_timerisset(&(bev)->timeout_read)) \
461 event_add(&(bev)->ev_read, &(bev)->timeout_read); \
465 #define BEV_RESET_GENERIC_WRITE_TIMEOUT(bev) \ argument
467 if (evutil_timerisset(&(bev)->timeout_write)) \
468 event_add(&(bev)->ev_write, &(bev)->timeout_write); \
470 #define BEV_DEL_GENERIC_READ_TIMEOUT(bev) \ argument
471 event_del(&(bev)->ev_read)
472 #define BEV_DEL_GENERIC_WRITE_TIMEOUT(bev) \ argument
[all …]
/libevent-2.1.12/test/
H A Dregress_ssl.c315 bufferevent_free(bev); in free_on_cb()
399 bufferevent_free(bev); in eventcb()
409 bufferevent_free(bev); in eventcb()
419 bufferevent_free(bev); in eventcb()
582 struct bufferevent *bev; in acceptcb() local
594 tt_assert(bev); in acceptcb()
765 tt_assert(bev); in regress_bufferevent_openssl_connect()
876 ctx->bev = bev; in wm_acceptcb()
948 tt_assert(bev); in regress_bufferevent_openssl_wm()
957 tt_assert(bev); in regress_bufferevent_openssl_wm()
[all …]
H A Dtest-fdleak.c82 server_read_cb(struct bufferevent *bev, void *ctx) in server_read_cb() argument
86 bufferevent_read(bev, &tmp, 1); in server_read_cb()
87 bufferevent_write(bev, &tmp, 1); in server_read_cb()
99 bufferevent_free(bev); in server_event_cb()
101 event_base_loopbreak(bufferevent_get_base(bev)); in server_event_cb()
115 bufferevent_enable(bev, EV_READ|EV_WRITE); in listener_accept_cb()
178 bufferevent_read(bev, &tmp, 1); in client_read_cb()
183 bufferevent_free(bev); in client_read_cb()
197 bufferevent_write(bev, &tmp, 1); in client_event_cb()
203 bufferevent_enable(bev, EV_READ); in client_event_cb()
[all …]
H A Dregress_bufferevent.c394 evbuffer_drain(bev->output, evbuffer_get_length(bev->output)); in wm_writecb()
622 bufferevent_free(bev); in sender_writecb()
649 tt_assert(bev); in listen_cb()
832 tt_assert(bev); in test_bufferevent_connect_fail_eventcb()
861 if (bev) in test_bufferevent_connect_fail_eventcb()
905 tt_assert(bev); in test_bufferevent_connect_fail()
928 if (bev) in test_bufferevent_connect_fail()
1184 tt_assert(bev); in test_bufferevent_trigger()
1198 if (bev) in test_bufferevent_trigger()
1209 tt_assert(bev); in test_bufferevent_socket_filter_inactive()
[all …]
H A Dtest-ratelim.c128 loud_writecb(struct bufferevent *bev, void *ctx) in loud_writecb() argument
155 loud_writecb(bev, ctx); in write_on_connectedcb()
157 bufferevent_enable(bev, EV_READ|EV_WRITE); in write_on_connectedcb()
162 echo_readcb(struct bufferevent *bev, void *ctx) in echo_readcb() argument
169 bufferevent_disable(bev, EV_READ); in echo_readcb()
173 echo_writecb(struct bufferevent *bev, void *ctx) in echo_writecb() argument
177 bufferevent_enable(bev, EV_READ); in echo_writecb()
185 bufferevent_free(bev); in echo_eventcb()
195 struct bufferevent *bev; in echo_listenercb() local
210 bufferevent_enable(bev, EV_READ|EV_WRITE); in echo_listenercb()
[all …]
H A Dregress_http.c487 return bev; in create_bev()
544 bufferevent_free(bev); in http_basic_test_impl()
565 bufferevent_free(bev); in http_basic_test_impl()
588 if (bev) in http_basic_test_impl()
761 if (bev) in http_bad_request_test()
3356 bev = NULL; in http_chunk_out_test_impl()
3954 if (bev) in http_multi_line_header_test()
4338 terminate_state.bev = bev; in http_terminate_chunked_test_impl()
4535 if (bev) in http_write_during_read_test_impl()
4602 if (bev) in http_run_bev_request()
[all …]
H A Dregress_zlib.c243 readcb(struct bufferevent *bev, void *arg) in readcb() argument
245 if (evbuffer_get_length(bufferevent_get_input(bev)) == 8333) { in readcb()
250 bufferevent_read_buffer(bev, evbuf); in readcb()
252 bufferevent_disable(bev, EV_READ); in readcb()
263 writecb(struct bufferevent *bev, void *arg) in writecb() argument
265 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { in writecb()
271 errorcb(struct bufferevent *bev, short what, void *arg) in errorcb() argument
/libevent-2.1.12/sample/
H A Dhello-world.c92 struct bufferevent *bev; in listener_cb() local
94 bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE); in listener_cb()
95 if (!bev) { in listener_cb()
100 bufferevent_setcb(bev, NULL, conn_writecb, conn_eventcb, NULL); in listener_cb()
101 bufferevent_enable(bev, EV_WRITE); in listener_cb()
102 bufferevent_disable(bev, EV_READ); in listener_cb()
104 bufferevent_write(bev, MESSAGE, strlen(MESSAGE)); in listener_cb()
108 conn_writecb(struct bufferevent *bev, void *user_data) in conn_writecb() argument
110 struct evbuffer *output = bufferevent_get_output(bev); in conn_writecb()
113 bufferevent_free(bev); in conn_writecb()
[all …]
H A Dle-proxy.c53 readcb(struct bufferevent *bev, void *ctx) in readcb() argument
58 src = bufferevent_get_input(bev); in readcb()
72 eventcb, bev); in readcb()
75 bufferevent_disable(bev, EV_READ); in readcb()
80 drained_writecb(struct bufferevent *bev, void *ctx) in drained_writecb() argument
87 bufferevent_setwatermark(bev, EV_WRITE, 0, 0); in drained_writecb()
95 struct evbuffer *b = bufferevent_get_output(bev); in close_on_finished_writecb()
98 bufferevent_free(bev); in close_on_finished_writecb()
103 eventcb(struct bufferevent *bev, short what, void *ctx) in eventcb() argument
126 readcb(bev, ctx); in eventcb()
[all …]
H A Dhttps-client.c60 struct bufferevent *bev = (struct bufferevent *) ctx; in http_request_done() local
67 while ((oslerr = bufferevent_get_openssl_error(bev))) { in http_request_done()
230 struct bufferevent *bev; in main() local
433 bev = bufferevent_socket_new(base, -1, BEV_OPT_CLOSE_ON_FREE); in main()
436 bev = bufferevent_openssl_socket_new(base, -1, ssl, in main()
441 if (bev == NULL) { in main()
446 bufferevent_openssl_set_allow_dirty_shutdown(bev, 1); in main()
450 evcon = evhttp_connection_base_bufferevent_new(base, NULL, bev, in main()
465 req = evhttp_request_new(http_request_done, bev); in main()
/libevent-2.1.12/include/event2/
H A Dbufferevent.h135 typedef void (*bufferevent_data_cb)(struct bufferevent *bev, void *ctx);
254 int bufferevent_socket_get_dns_error(struct bufferevent *bev);
274 struct event_base *bufferevent_get_base(struct bufferevent *bev);
808 int bufferevent_set_rate_limit(struct bufferevent *bev,
880 int bufferevent_add_to_rate_limit_group(struct bufferevent *bev,
909 ev_ssize_t bufferevent_get_max_single_read(struct bufferevent *bev);
913 ev_ssize_t bufferevent_get_max_single_write(struct bufferevent *bev);
927 ev_ssize_t bufferevent_get_read_limit(struct bufferevent *bev);
929 ev_ssize_t bufferevent_get_write_limit(struct bufferevent *bev);
933 ev_ssize_t bufferevent_get_max_to_read(struct bufferevent *bev);
[all …]
H A Dbufferevent_ssl.h110 int bufferevent_openssl_get_allow_dirty_shutdown(struct bufferevent *bev);
112 void bufferevent_openssl_set_allow_dirty_shutdown(struct bufferevent *bev,
122 int bufferevent_ssl_renegotiate(struct bufferevent *bev);
126 unsigned long bufferevent_get_openssl_error(struct bufferevent *bev);
/libevent-2.1.12/test-export/
H A Dtest-export.c56 struct bufferevent *bev; in test() local
77 bev = bufferevent_openssl_socket_new(base, -1, ssl, in test()
80 if (bev == NULL) { in test()
H A Dtest-export.c56 struct bufferevent *bev; in test() local
77 bev = bufferevent_openssl_socket_new(base, -1, ssl, in test()
80 if (bev == NULL) { in test()
H A Dtest-export.c56 struct bufferevent *bev; in test() local
77 bev = bufferevent_openssl_socket_new(base, -1, ssl, in test()
80 if (bev == NULL) { in test()
H A Dtest-export.c56 struct bufferevent *bev; in test() local
77 bev = bufferevent_openssl_socket_new(base, -1, ssl, in test()
80 if (bev == NULL) { in test()
H A Dtest-export.c56 struct bufferevent *bev; in test() local
77 bev = bufferevent_openssl_socket_new(base, -1, ssl, in test()
80 if (bev == NULL) { in test()
H A Dtest-export.c56 struct bufferevent *bev; in test() local
77 bev = bufferevent_openssl_socket_new(base, -1, ssl, in test()
80 if (bev == NULL) { in test()

12