Home
last modified time | relevance | path

Searched refs:bufev (Results 1 – 15 of 15) sorted by relevance

/netbsd-src/external/bsd/libevent/dist/
H A Dbufferevent.c71 bufferevent_suspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what) in bufferevent_suspend_read_() argument
73 struct bufferevent_private *bufev_private = BEV_UPCAST(bufev); in bufferevent_suspend_read_()
74 BEV_LOCK(bufev); in bufferevent_suspend_read_()
76 bufev->be_ops->disable(bufev, EV_READ); in bufferevent_suspend_read_()
78 BEV_UNLOCK(bufev); in bufferevent_suspend_read_()
82 bufferevent_unsuspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what) in bufferevent_unsuspend_read_() argument
84 struct bufferevent_private *bufev_private = BEV_UPCAST(bufev); in bufferevent_unsuspend_read_()
85 BEV_LOCK(bufev); in bufferevent_unsuspend_read_()
87 if (!bufev_private->read_suspended && (bufev->enabled & EV_READ)) in bufferevent_unsuspend_read_()
88 bufev->be_ops->enable(bufev, EV_READ); in bufferevent_unsuspend_read_()
[all …]
H A Dbufferevent_sock.c136 struct bufferevent *bufev = arg; in bufferevent_socket_outbuf_cb() local
137 struct bufferevent_private *bufev_p = BEV_UPCAST(bufev); in bufferevent_socket_outbuf_cb()
140 (bufev->enabled & EV_WRITE) && in bufferevent_socket_outbuf_cb()
141 !event_pending(&bufev->ev_write, EV_WRITE, NULL) && in bufferevent_socket_outbuf_cb()
145 if (bufferevent_add_event_(&bufev->ev_write, &bufev->timeout_write) == -1) { in bufferevent_socket_outbuf_cb()
154 struct bufferevent *bufev = arg; in bufferevent_readcb() local
155 struct bufferevent_private *bufev_p = BEV_UPCAST(bufev); in bufferevent_readcb()
161 bufferevent_incref_and_lock_(bufev); in bufferevent_readcb()
171 input = bufev->input; in bufferevent_readcb()
177 if (bufev->wm_read.high != 0) { in bufferevent_readcb()
[all …]
H A Dbufferevent-internal.h332 void bufferevent_suspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what);
336 void bufferevent_unsuspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what);
340 void bufferevent_suspend_write_(struct bufferevent *bufev, bufferevent_suspend_flags what);
343 void bufferevent_unsuspend_write_(struct bufferevent *bufev, bufferevent_suspend_flags what);
363 int bufferevent_disable_hard_(struct bufferevent *bufev, short event);
368 int bufferevent_enable_locking_(struct bufferevent *bufev, void *lock);
371 #define bufferevent_incref_(bufev) bufferevent_incref(bufev) argument
375 void bufferevent_incref_and_lock_(struct bufferevent *bufev);
379 #define bufferevent_decref_(bufev) bufferevent_decref(bufev) argument
384 int bufferevent_decref_and_unlock_(struct bufferevent *bufev);
[all …]
H A Dbufferevent_pair.c99 struct bufferevent_pair *bufev; in bufferevent_pair_elt_new() local
100 if (! (bufev = mm_calloc(1, sizeof(struct bufferevent_pair)))) in bufferevent_pair_elt_new()
102 if (bufferevent_init_common_(&bufev->bev, base, &bufferevent_ops_pair, in bufferevent_pair_elt_new()
104 mm_free(bufev); in bufferevent_pair_elt_new()
107 if (!evbuffer_add_cb(bufev->bev.bev.output, be_pair_outbuf_cb, bufev)) { in bufferevent_pair_elt_new()
108 bufferevent_free(downcast(bufev)); in bufferevent_pair_elt_new()
112 bufferevent_init_generic_timeout_cbs_(&bufev->bev.bev); in bufferevent_pair_elt_new()
114 return bufev; in bufferevent_pair_elt_new()
228 be_pair_enable(struct bufferevent *bufev, short events) in be_pair_enable() argument
230 struct bufferevent_pair *bev_p = upcast(bufev); in be_pair_enable()
[all …]
H A Dbufferevent_filter.c73 static int be_filter_flush(struct bufferevent *bufev,
153 struct bufferevent *bufev = downcast(bevf); in be_readbuf_full() local
155 bufev->wm_read.high && in be_readbuf_full()
156 evbuffer_get_length(bufev->input) >= bufev->wm_read.high; in be_readbuf_full()
350 struct bufferevent *bufev = downcast(bevf); in be_filter_process_output() local
359 if (!(bufev->enabled & EV_WRITE) || in be_filter_process_output()
361 !evbuffer_get_length(bufev->output)) in be_filter_process_output()
367 evbuffer_cb_clear_flags(bufev->output, bevf->outbuf_cb, in be_filter_process_output()
392 (bufev->enabled & EV_WRITE) && in be_filter_process_output()
395 evbuffer_get_length(bufev->output) && in be_filter_process_output()
[all …]
H A Dhttp.c210 static void evhttp_error_cb(struct bufferevent *bufev, short what, void *arg);
386 bufferevent_setcb(evcon->bufev, in evhttp_write_buffer()
392 bufferevent_enable(evcon->bufev, EV_READ|EV_WRITE); in evhttp_write_buffer()
398 bufferevent_disable(evcon->bufev, EV_WRITE); in evhttp_send_continue_done()
405 bufferevent_enable(evcon->bufev, EV_WRITE); in evhttp_send_continue()
406 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), in evhttp_send_continue()
411 bufferevent_setcb(evcon->bufev, in evhttp_send_continue()
454 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), in evhttp_make_header_request()
539 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), in evhttp_make_header_response()
613 struct evbuffer *output = bufferevent_get_output(evcon->bufev); in evhttp_make_header()
[all …]
H A Dbufferevent_openssl.c164 struct bufferevent *bufev = BIO_get_data(b); in bio_bufferevent_write() local
173 output = bufferevent_get_output(bufev); in bio_bufferevent_write()
178 if (bufev->wm_write.high && bufev->wm_write.high <= (outlen+inlen)) { in bio_bufferevent_write()
179 if (bufev->wm_write.high <= outlen) { in bio_bufferevent_write()
184 inlen = bufev->wm_write.high - outlen; in bio_bufferevent_write()
196 struct bufferevent *bufev = BIO_get_data(b); in bio_bufferevent_ctrl() local
207 ret = evbuffer_get_length(bufferevent_get_input(bufev)) != 0; in bio_bufferevent_ctrl()
210 ret = evbuffer_get_length(bufferevent_get_output(bufev)) != 0; in bio_bufferevent_ctrl()
339 static int be_openssl_flush(struct bufferevent *bufev,
1262 be_openssl_flush(struct bufferevent *bufev, in be_openssl_flush() argument
[all …]
H A Dhttp-internal.h58 struct bufferevent *bufev; member
/netbsd-src/external/bsd/libevent/dist/include/event2/
H A Dbufferevent.h269 int bufferevent_base_set(struct event_base *base, struct bufferevent *bufev);
287 int bufferevent_priority_set(struct bufferevent *bufev, int pri);
295 int bufferevent_get_priority(const struct bufferevent *bufev);
306 void bufferevent_free(struct bufferevent *bufev);
324 void bufferevent_setcb(struct bufferevent *bufev,
343 void bufferevent_getcb(struct bufferevent *bufev,
357 int bufferevent_setfd(struct bufferevent *bufev, evutil_socket_t fd);
364 evutil_socket_t bufferevent_getfd(struct bufferevent *bufev);
371 struct bufferevent *bufferevent_get_underlying(struct bufferevent *bufev);
387 int bufferevent_write(struct bufferevent *bufev,
[all …]
H A Dbufferevent_compat.h91 void bufferevent_settimeout(struct bufferevent *bufev,
H A Dbufferevent_ssl.h119 bufferevent_openssl_get_ssl(struct bufferevent *bufev);
/netbsd-src/external/bsd/tmux/dist/
H A Dcmd-pipe-pane.c189 cmd_pipe_pane_read_callback(__unused struct bufferevent *bufev, void *data) in cmd_pipe_pane_read_callback() argument
206 cmd_pipe_pane_write_callback(__unused struct bufferevent *bufev, void *data) in cmd_pipe_pane_write_callback() argument
217 cmd_pipe_pane_error_callback(__unused struct bufferevent *bufev, in cmd_pipe_pane_error_callback() argument
H A Dcontrol.c537 control_error_callback(__unused struct bufferevent *bufev, in control_error_callback() argument
547 control_read_callback(__unused struct bufferevent *bufev, void *data) in control_read_callback() argument
722 control_write_callback(__unused struct bufferevent *bufev, void *data) in control_write_callback() argument
/netbsd-src/external/bsd/ntp/dist/sntp/libevent/include/event2/
H A Dbufferevent_ssl.h120 bufferevent_openssl_get_ssl(struct bufferevent *bufev);
/netbsd-src/external/bsd/libevent/dist/test/
H A Dregress_http.c1462 struct bufferevent *bufev = NULL; in http_cancel_test() local
1519 bufev = evhttp_connection_get_bufferevent(evcon); in http_cancel_test()
1523 evbuffer_add_cb(bufferevent_get_output(bufev), http_no_write, NULL); in http_cancel_test()
1595 if (bufev) in http_cancel_test()
1596 evbuffer_remove_cb(bufferevent_get_output(bufev), http_no_write, NULL); in http_cancel_test()