/freebsd/contrib/ntp/sntp/libevent/ |
H A D | bufferevent_async.c | 131 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 D | bufferevent_ratelim.c | 238 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 D | bufferevent_openssl.c | 390 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 D | bufferevent_filter.c | 105 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 D | bufferevent_pair.c | 59 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 D | bufferevent.c | 127 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 D | bufferevent_sock.c | 363 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 D | bufferevent-internal.h | 156 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 …]
|
/freebsd/contrib/libevent/ |
H A D | bufferevent_async.c | 131 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 D | bufferevent_ratelim.c | 238 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 D | bufferevent_openssl.c | 390 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 D | bufferevent_filter.c | 105 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 D | bufferevent_pair.c | 59 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 D | bufferevent.c | 127 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 D | bufferevent_sock.c | 363 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 D | bufferevent-internal.h | 156 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 …]
|
/freebsd/contrib/ntp/sntp/libevent/test/ |
H A D | regress_ssl.c | 315 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 D | test-fdleak.c | 82 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 D | regress_bufferevent.c | 394 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 …]
|
/freebsd/contrib/libevent/test/ |
H A D | regress_ssl.c | 315 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 D | test-fdleak.c | 82 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 D | regress_bufferevent.c | 394 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 …]
|
/freebsd/contrib/ntp/sntp/libevent/sample/ |
H A D | hello-world.c | 92 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 …]
|
/freebsd/contrib/libevent/sample/ |
H A D | hello-world.c | 92 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 …]
|
/freebsd/contrib/ntp/sntp/libevent/include/event2/ |
H A D | bufferevent.h | 135 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 …]
|