Home
last modified time | relevance | path

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

12

/netbsd-src/external/bsd/libevent/dist/
H A Dbufferevent_async.c84 struct bufferevent_private bev; member
97 evutil_offsetof(struct bufferevent_async, bev.bev),
108 be_async_run_eventcb(struct bufferevent *bev, short what, int options) in be_async_run_eventcb() argument
109 { bufferevent_run_eventcb_(bev, what, options|BEV_TRIG_DEFER_CALLBACKS); } in be_async_run_eventcb()
112 be_async_trigger_nolock(struct bufferevent *bev, short what, int options) in be_async_trigger_nolock() argument
113 { bufferevent_trigger_nolock_(bev, what, options|BEV_TRIG_DEFER_CALLBACKS); } in be_async_trigger_nolock()
129 upcast(struct bufferevent *bev) in upcast() argument
132 if (!BEV_IS_ASYNC(bev)) in upcast()
134 bev_a = EVUTIL_UPCAST(bev, struct bufferevent_async, bev.bev); in upcast()
143 EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev)); in upcast_connect()
[all …]
H A Dbufferevent_ratelim.c116 bufferevent_update_buckets(struct bufferevent_private *bev) in bufferevent_update_buckets() argument
121 event_base_gettimeofday_cached(bev->bev.ev_base, &now); in bufferevent_update_buckets()
122 tick = ev_token_bucket_get_tick_(&now, bev->rate_limiting->cfg); in bufferevent_update_buckets()
123 if (tick != bev->rate_limiting->limit.last_updated) in bufferevent_update_buckets()
124 ev_token_bucket_update_(&bev->rate_limiting->limit, in bufferevent_update_buckets()
125 bev->rate_limiting->cfg, tick); in bufferevent_update_buckets()
200 bufferevent_get_rlim_max_(struct bufferevent_private *bev, int is_write) in bufferevent_get_rlim_max_() argument
203 ev_ssize_t max_so_far = is_write?bev->max_single_write:bev->max_single_read; in bufferevent_get_rlim_max_()
218 if (!bev->rate_limiting) in bufferevent_get_rlim_max_()
226 if (bev->rate_limiting->cfg) { in bufferevent_get_rlim_max_()
[all …]
H A Dbufferevent_openssl.c295 struct bufferevent_private bev; member
345 evutil_offsetof(struct bufferevent_openssl, bev.bev),
358 upcast(struct bufferevent *bev) in upcast() argument
361 if (!BEV_IS_OPENSSL(bev)) in upcast()
363 bev_o = (void*)( ((char*)bev) - in upcast()
364 evutil_offsetof(struct bufferevent_openssl, bev.bev)); in upcast()
365 EVUTIL_ASSERT(BEV_IS_OPENSSL(&bev_o->bev.bev)); in upcast()
393 struct bufferevent *bev = &bev_ssl->bev.bev; in start_reading() local
395 r = bufferevent_add_event_(&bev->ev_read, &bev->timeout_read); in start_reading()
397 r = bufferevent_add_event_(&bev->ev_write, in start_reading()
[all …]
H A Dbufferevent_filter.c84 struct bufferevent_private bev; member
108 evutil_offsetof(struct bufferevent_filtered, bev.bev),
121 upcast(struct bufferevent *bev) in upcast() argument
124 if (!BEV_IS_FILTER(bev)) in upcast()
126 bev_f = (void*)( ((char*)bev) - in upcast()
127 evutil_offsetof(struct bufferevent_filtered, bev.bev)); in upcast()
128 EVUTIL_ASSERT(BEV_IS_FILTER(&bev_f->bev.bev)); in upcast()
132 #define downcast(bev_f) (&(bev_f)->bev.bev)
195 if (bufferevent_init_common_(&bufev_f->bev, underlying->ev_base, in bufferevent_filter_new()
232 be_filter_unlink(struct bufferevent *bev) in be_filter_unlink() argument
[all …]
H A Dbufferevent_pair.c49 struct bufferevent_private bev; member
59 upcast(struct bufferevent *bev) in upcast() argument
62 if (!BEV_IS_PAIR(bev)) in upcast()
64 bev_p = EVUTIL_UPCAST(bev, struct bufferevent_pair, bev.bev); in upcast()
65 EVUTIL_ASSERT(BEV_IS_PAIR(&bev_p->bev.bev)); in upcast()
69 #define downcast(bev_pair) (&(bev_pair)->bev.bev)
102 if (bufferevent_init_common_(&bufev->bev, base, &bufferevent_ops_pair, in bufferevent_pair_elt_new()
107 if (!evbuffer_add_cb(bufev->bev.bev.output, be_pair_outbuf_cb, bufev)) { in bufferevent_pair_elt_new()
112 bufferevent_init_generic_timeout_cbs_(&bufev->bev.bev); in bufferevent_pair_elt_new()
138 bufferevent_enable_locking_(downcast(bufev2), bufev1->bev.lock); in bufferevent_pair_new()
[all …]
H A Dbufferevent.c67 static void bufferevent_cancel_all_(struct bufferevent *bev);
125 static void bufferevent_inbuf_wm_check(struct bufferevent *bev) in bufferevent_inbuf_wm_check() argument
127 if (!bev->wm_read.high) in bufferevent_inbuf_wm_check()
129 if (!(bev->enabled & EV_READ)) in bufferevent_inbuf_wm_check()
131 if (evbuffer_get_length(bev->input) < bev->wm_read.high) in bufferevent_inbuf_wm_check()
134 bufferevent_trigger(bev, EV_READ, BEV_OPT_DEFER_CALLBACKS); in bufferevent_inbuf_wm_check()
159 struct bufferevent *bufev = &bufev_private->bev; in bufferevent_run_deferred_callbacks_locked()
193 struct bufferevent *bufev = &bufev_private->bev; in bufferevent_run_deferred_callbacks_unlocked()
238 (bevp)->bev.ev_base, \
240 bufferevent_incref_(&(bevp)->bev); \
[all …]
H A Dbufferevent_sock.c92 evutil_offsetof(struct bufferevent_private, bev),
103 bufferevent_socket_get_conn_address_(struct bufferevent *bev) in bufferevent_socket_get_conn_address_() argument
105 struct bufferevent_private *bev_p = BEV_UPCAST(bev); in bufferevent_socket_get_conn_address_()
110 bufferevent_socket_set_conn_address_fd_(struct bufferevent *bev, in bufferevent_socket_set_conn_address_fd_() argument
113 struct bufferevent_private *bev_p = BEV_UPCAST(bev); in bufferevent_socket_set_conn_address_fd_()
123 bufferevent_socket_set_conn_address_(struct bufferevent *bev, in bufferevent_socket_set_conn_address_() argument
126 struct bufferevent_private *bev_p = BEV_UPCAST(bev); in bufferevent_socket_set_conn_address_()
366 bufev = &bufev_p->bev; in bufferevent_socket_new()
383 bufferevent_socket_connect(struct bufferevent *bev, in bufferevent_socket_connect() argument
386 struct bufferevent_private *bufev_p = BEV_UPCAST(bev); in bufferevent_socket_connect()
[all …]
H A Dbufferevent-internal.h158 struct bufferevent bev; member
432 void bufferevent_init_generic_timeout_cbs_(struct bufferevent *bev);
438 int bufferevent_generic_adj_timeouts_(struct bufferevent *bev);
440 int bufferevent_generic_adj_existing_timeouts_(struct bufferevent *bev);
443 enum bufferevent_options bufferevent_get_options_(struct bufferevent *bev);
447 bufferevent_socket_get_conn_address_(struct bufferevent *bev);
451 bufferevent_socket_set_conn_address_fd_(struct bufferevent *bev, evutil_socket_t fd);
455 bufferevent_socket_set_conn_address_(struct bufferevent *bev, struct sockaddr *addr, size_t addrlen…
460 #define BEV_RESET_GENERIC_READ_TIMEOUT(bev) \ argument
462 if (evutil_timerisset(&(bev)->timeout_read)) \
[all …]
H A Diocp-internal.h207 void bufferevent_async_set_connected_(struct bufferevent *bev);
208 int bufferevent_async_can_connect_(struct bufferevent *bev);
209 int bufferevent_async_connect_(struct bufferevent *bev, evutil_socket_t fd,
H A Dratelim-internal.h88 int bufferevent_remove_from_rate_limit_group_internal_(struct bufferevent *bev,
/netbsd-src/external/bsd/libevent/dist/test/
H A Dregress_ssl.c291 bufferevent_openssl_check_fd(struct bufferevent *bev, int filter) in bufferevent_openssl_check_fd() argument
293 tt_fd_op(bufferevent_getfd(bev), !=, EVUTIL_INVALID_SOCKET); in bufferevent_openssl_check_fd()
294 tt_fd_op(bufferevent_setfd(bev, EVUTIL_INVALID_SOCKET), ==, 0); in bufferevent_openssl_check_fd()
296 tt_fd_op(bufferevent_getfd(bev), !=, EVUTIL_INVALID_SOCKET); in bufferevent_openssl_check_fd()
298 tt_fd_op(bufferevent_getfd(bev), ==, EVUTIL_INVALID_SOCKET); in bufferevent_openssl_check_fd()
305 bufferevent_openssl_check_freed(struct bufferevent *bev) in bufferevent_openssl_check_freed() argument
307 tt_int_op(event_pending(&bev->ev_read, EVLIST_ALL, NULL), ==, 0); in bufferevent_openssl_check_freed()
308 tt_int_op(event_pending(&bev->ev_write, EVLIST_ALL, NULL), ==, 0); in bufferevent_openssl_check_freed()
315 free_on_cb(struct bufferevent *bev, void *ctx) in free_on_cb() argument
317 TT_BLATHER(("free_on_cb: %p", bev)); in free_on_cb()
[all …]
H A Dtest-fdleak.c85 server_read_cb(struct bufferevent *bev, void *ctx) in server_read_cb() argument
87 while (evbuffer_get_length(bufferevent_get_input(bev))) { in server_read_cb()
89 bufferevent_read(bev, &tmp, 1); in server_read_cb()
90 bufferevent_write(bev, &tmp, 1); in server_read_cb()
96 server_event_cb(struct bufferevent *bev, short events, void *ctx) in server_event_cb() argument
102 bufferevent_free(bev); in server_event_cb()
104 event_base_loopbreak(bufferevent_get_base(bev)); in server_event_cb()
115 struct bufferevent *bev = bufferevent_socket_new(base, sock, in listener_accept_cb() local
117 bufferevent_setcb(bev, server_read_cb, NULL, server_event_cb, NULL); in listener_accept_cb()
118 bufferevent_enable(bev, EV_READ|EV_WRITE); in listener_accept_cb()
[all …]
H A Dregress_bufferevent.c109 readcb(struct bufferevent *bev, void *arg) in readcb() argument
111 if (evbuffer_get_length(bev->input) == 8333) { in readcb()
116 bufferevent_read_buffer(bev, evbuf); in readcb()
118 bufferevent_disable(bev, EV_READ); in readcb()
129 writecb(struct bufferevent *bev, void *arg) in writecb() argument
131 if (evbuffer_get_length(bev->output) == 0) { in writecb()
137 errorcb(struct bufferevent *bev, short what, void *arg) in errorcb() argument
371 wm_readcb(struct bufferevent *bev, void *arg) in wm_readcb() argument
374 int len = (int)evbuffer_get_length(bev->input); in wm_readcb()
382 bufferevent_read_buffer(bev, evbuf); in wm_readcb()
[all …]
H A Dtest-ratelim.c129 loud_writecb(struct bufferevent *bev, void *ctx) in loud_writecb() argument
132 struct evbuffer *output = bufferevent_get_output(bev); in loud_writecb()
143 discard_readcb(struct bufferevent *bev, void *ctx) in discard_readcb() argument
146 struct evbuffer *input = bufferevent_get_input(bev); in discard_readcb()
153 write_on_connectedcb(struct bufferevent *bev, short what, void *ctx) in write_on_connectedcb() argument
156 loud_writecb(bev, ctx); in write_on_connectedcb()
158 bufferevent_enable(bev, EV_READ|EV_WRITE); in write_on_connectedcb()
163 echo_readcb(struct bufferevent *bev, void *ctx) in echo_readcb() argument
165 struct evbuffer *input = bufferevent_get_input(bev); in echo_readcb()
166 struct evbuffer *output = bufferevent_get_output(bev); in echo_readcb()
[all …]
H A Dregress_http.c261 http_readcb(struct bufferevent *bev, void *arg) in http_readcb() argument
266 if (evbuffer_contains(bufferevent_get_input(bev), what)) { in http_readcb()
271 done = evhttp_parse_firstline_(req, bufferevent_get_input(bev)); in http_readcb()
275 done = evhttp_parse_headers_(req, bufferevent_get_input(bev)); in http_readcb()
286 bufferevent_disable(bev, EV_READ); in http_readcb()
299 http_writecb(struct bufferevent *bev, void *arg) in http_writecb() argument
301 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { in http_writecb()
303 bufferevent_enable(bev, EV_READ); in http_writecb()
309 http_errorcb(struct bufferevent *bev, short what, void *arg) in http_errorcb() argument
472 struct bufferevent *bev = NULL; in create_bev() local
[all …]
H A Dregress_zlib.c246 readcb(struct bufferevent *bev, void *arg) in readcb() argument
248 if (evbuffer_get_length(bufferevent_get_input(bev)) == 8333) { in readcb()
253 bufferevent_read_buffer(bev, evbuf); in readcb()
255 bufferevent_disable(bev, EV_READ); in readcb()
266 writecb(struct bufferevent *bev, void *arg) in writecb() argument
268 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { in writecb()
274 errorcb(struct bufferevent *bev, short what, void *arg) in errorcb() argument
/netbsd-src/external/bsd/libevent/dist/include/event2/
H A Dbufferevent.h136 typedef void (*bufferevent_data_cb)(struct bufferevent *bev, void *ctx);
155 typedef void (*bufferevent_event_cb)(struct bufferevent *bev, short what, void *ctx);
255 int bufferevent_socket_get_dns_error(struct bufferevent *bev);
275 struct event_base *bufferevent_get_base(struct bufferevent *bev);
750 struct bufferevent *bufferevent_pair_get_partner(struct bufferevent *bev);
809 int bufferevent_set_rate_limit(struct bufferevent *bev,
881 int bufferevent_add_to_rate_limit_group(struct bufferevent *bev,
886 int bufferevent_remove_from_rate_limit_group(struct bufferevent *bev);
896 int bufferevent_set_max_single_read(struct bufferevent *bev, size_t size);
906 int bufferevent_set_max_single_write(struct bufferevent *bev, size_t size);
[all …]
H A Dbufferevent_ssl.h111 int bufferevent_openssl_get_allow_dirty_shutdown(struct bufferevent *bev);
113 void bufferevent_openssl_set_allow_dirty_shutdown(struct bufferevent *bev,
123 int bufferevent_ssl_renegotiate(struct bufferevent *bev);
127 unsigned long bufferevent_get_openssl_error(struct bufferevent *bev);
/netbsd-src/external/bsd/libevent/dist/sample/
H A Dhello-world.c93 struct bufferevent *bev; in listener_cb() local
95 bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE); in listener_cb()
96 if (!bev) { in listener_cb()
101 bufferevent_setcb(bev, NULL, conn_writecb, conn_eventcb, NULL); in listener_cb()
102 bufferevent_enable(bev, EV_WRITE); in listener_cb()
103 bufferevent_disable(bev, EV_READ); in listener_cb()
105 bufferevent_write(bev, MESSAGE, strlen(MESSAGE)); in listener_cb()
109 conn_writecb(struct bufferevent *bev, void *user_data) in conn_writecb() argument
111 struct evbuffer *output = bufferevent_get_output(bev); in conn_writecb()
114 bufferevent_free(bev); in conn_writecb()
[all …]
H A Dle-proxy.c50 static void drained_writecb(struct bufferevent *bev, void *ctx);
51 static void eventcb(struct bufferevent *bev, short what, void *ctx);
54 readcb(struct bufferevent *bev, void *ctx) in readcb() argument
59 src = bufferevent_get_input(bev); in readcb()
73 eventcb, bev); in readcb()
76 bufferevent_disable(bev, EV_READ); in readcb()
81 drained_writecb(struct bufferevent *bev, void *ctx) in drained_writecb() argument
87 bufferevent_setcb(bev, readcb, NULL, eventcb, partner); in drained_writecb()
88 bufferevent_setwatermark(bev, EV_WRITE, 0, 0); in drained_writecb()
94 close_on_finished_writecb(struct bufferevent *bev, void *ctx) in close_on_finished_writecb() argument
[all …]
H A Dhttps-client.c61 struct bufferevent *bev = (struct bufferevent *) ctx; in http_request_done() local
68 while ((oslerr = bufferevent_get_openssl_error(bev))) { in http_request_done()
231 struct bufferevent *bev; in main() local
434 bev = bufferevent_socket_new(base, -1, BEV_OPT_CLOSE_ON_FREE); in main()
437 bev = bufferevent_openssl_socket_new(base, -1, ssl, in main()
442 if (bev == NULL) { in main()
447 bufferevent_openssl_set_allow_dirty_shutdown(bev, 1); in main()
451 evcon = evhttp_connection_base_bufferevent_new(base, NULL, bev, in main()
466 req = evhttp_request_new(http_request_done, bev); in main()
/netbsd-src/sys/arch/landisk/dev/
H A Dbutton.c121 btn_queue_event(button_event_t *bev) in btn_queue_event() argument
127 btn_event_queue[btn_event_queue_head] = *bev; in btn_queue_event()
135 btn_get_event(button_event_t *bev) in btn_get_event() argument
141 *bev = btn_event_queue[btn_event_queue_tail]; in btn_get_event()
230 button_event_t bev; in btnread() local
243 if (btn_get_event(&bev)) { in btnread()
245 return (uiomove(&bev, BUTTON_EVENT_MSG_SIZE, uio)); in btnread()
365 btn_event_register(struct btn_event *bev) in btn_event_register() argument
369 LIST_INSERT_HEAD(&btn_event_list, bev, bev_list); in btn_event_register()
376 btn_event_unregister(struct btn_event *bev) in btn_event_unregister() argument
[all …]
H A Dbuttonvar.h52 int btn_event_register(struct btn_event *bev);
53 void btn_event_unregister(struct btn_event *bev);
H A Dbtn_obio.c223 struct btn_event *bev = (void *)arg; in btn_pressed_event() local
225 btn_event_send(bev, BUTTON_EVENT_PRESSED); in btn_pressed_event()
/netbsd-src/external/bsd/ntp/dist/sntp/libevent/include/event2/
H A Dbufferevent_ssl.h112 int bufferevent_openssl_get_allow_dirty_shutdown(struct bufferevent *bev);
114 void bufferevent_openssl_set_allow_dirty_shutdown(struct bufferevent *bev,
124 int bufferevent_ssl_renegotiate(struct bufferevent *bev);
128 unsigned long bufferevent_get_openssl_error(struct bufferevent *bev);

12