Home
last modified time | relevance | path

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

12

/freebsd-12.1/contrib/libevent/
H A Dbufferevent.c73 bufev->be_ops->disable(bufev, EV_READ); in bufferevent_suspend_read_()
86 bufev->be_ops->enable(bufev, EV_READ); in bufferevent_unsuspend_read_()
145 bufev->errorcb(bufev, BEV_EVENT_CONNECTED, bufev->cbarg); in bufferevent_run_deferred_callbacks_locked()
149 bufev->readcb(bufev, bufev->cbarg); in bufferevent_run_deferred_callbacks_locked()
153 bufev->writecb(bufev, bufev->cbarg); in bufferevent_run_deferred_callbacks_locked()
161 bufev->errorcb(bufev, what, bufev->cbarg); in bufferevent_run_deferred_callbacks_locked()
232 bufev->readcb(bufev, bufev->cbarg); in bufferevent_run_readcb_()
248 bufev->writecb(bufev, bufev->cbarg); in bufferevent_run_writecb_()
278 bufev->errorcb(bufev, what, bufev->cbarg); in bufferevent_run_eventcb_()
700 bufev->be_ops->unlink(bufev); in bufferevent_decref_and_unlock_()
[all …]
H A Dbufferevent_sock.c365 event_assign(&bufev->ev_read, bufev->ev_base, fd, in bufferevent_socket_new()
367 event_assign(&bufev->ev_write, bufev->ev_base, fd, in bufferevent_socket_new()
370 evbuffer_add_cb(bufev->output, bufferevent_socket_outbuf_cb, bufev); in bufferevent_socket_new()
375 return bufev; in bufferevent_socket_new()
571 return bufev; in bufferevent_new()
634 BEV_LOCK(bufev); in be_socket_setfd()
643 event_assign(&bufev->ev_read, bufev->ev_base, fd, in be_socket_setfd()
645 event_assign(&bufev->ev_write, bufev->ev_base, fd, in be_socket_setfd()
649 bufferevent_enable(bufev, bufev->enabled); in be_socket_setfd()
664 BEV_LOCK(bufev); in bufferevent_priority_set()
[all …]
H A Dbufferevent-internal.h350 int bufferevent_disable_hard_(struct bufferevent *bufev, short event);
357 #define bufferevent_incref_(bufev) bufferevent_incref(bufev) argument
360 void bufferevent_incref_and_lock_(struct bufferevent *bufev);
364 #define bufferevent_decref_(bufev) bufferevent_decref(bufev) argument
368 int bufferevent_decref_and_unlock_(struct bufferevent *bufev);
372 void bufferevent_run_readcb_(struct bufferevent *bufev, int options);
375 void bufferevent_run_writecb_(struct bufferevent *bufev, int options);
393 evbuffer_get_length(bufev->input) >= bufev->wm_read.low)) in bufferevent_trigger_nolock_()
394 bufferevent_run_readcb_(bufev, options); in bufferevent_trigger_nolock_()
396 evbuffer_get_length(bufev->output) <= bufev->wm_write.low)) in bufferevent_trigger_nolock_()
[all …]
H A Dbufferevent_pair.c96 struct bufferevent_pair *bufev; in bufferevent_pair_elt_new() local
101 mm_free(bufev); in bufferevent_pair_elt_new()
104 if (!evbuffer_add_cb(bufev->bev.bev.output, be_pair_outbuf_cb, bufev)) { in bufferevent_pair_elt_new()
105 bufferevent_free(downcast(bufev)); in bufferevent_pair_elt_new()
111 return bufev; in bufferevent_pair_elt_new()
227 struct bufferevent_pair *bev_p = upcast(bufev); in be_pair_enable()
230 incref_and_lock(bufev); in be_pair_enable()
233 BEV_RESET_GENERIC_READ_TIMEOUT(bufev); in be_pair_enable()
236 BEV_RESET_GENERIC_WRITE_TIMEOUT(bufev); in be_pair_enable()
241 be_pair_transfer(downcast(partner), bufev, 0); in be_pair_enable()
[all …]
H A Dbufferevent_filter.c150 struct bufferevent *bufev = downcast(bevf); in be_readbuf_full() local
152 bufev->wm_read.high && in be_readbuf_full()
153 evbuffer_get_length(bufev->input) >= bufev->wm_read.high; in be_readbuf_full()
356 if (!(bufev->enabled & EV_WRITE) || in be_filter_process_output()
358 !evbuffer_get_length(bufev->output)) in be_filter_process_output()
389 (bufev->enabled & EV_WRITE) && in be_filter_process_output()
392 evbuffer_get_length(bufev->output) && in be_filter_process_output()
401 (bufev->enabled & EV_WRITE) && in be_filter_process_output()
414 BEV_RESET_GENERIC_WRITE_TIMEOUT(bufev); in be_filter_process_output()
580 bufferevent_incref_and_lock_(bufev); in be_filter_flush()
[all …]
H A Dhttp.c373 bufferevent_setcb(evcon->bufev, in evhttp_write_buffer()
398 bufferevent_setcb(evcon->bufev, in evhttp_send_continue()
1173 evhttp_read_cb(evcon->bufev, evcon); in evhttp_deferred_read_cb()
1231 if (evcon->bufev != NULL) in evhttp_connection_free()
1232 bufferevent_free(evcon->bufev); in evhttp_connection_free()
1558 evhttp_error_cb(bufev, what, arg); in evhttp_connection_cb()
1596 bufferevent_setcb(evcon->bufev, in evhttp_connection_cb()
2372 evcon->bufev = bev; in evhttp_connection_base_bufferevent_new()
2404 return evcon->bufev; in evhttp_connection_get_bufferevent()
2553 bufferevent_setcb(evcon->bufev, in evhttp_connection_connect_()
[all …]
H A Dbufferevent_openssl.c162 struct bufferevent *bufev = BIO_get_data(b); in bio_bufferevent_write() local
171 output = bufferevent_get_output(bufev); in bio_bufferevent_write()
176 if (bufev->wm_write.high && bufev->wm_write.high <= (outlen+inlen)) { in bio_bufferevent_write()
177 if (bufev->wm_write.high <= outlen) { in bio_bufferevent_write()
182 inlen = bufev->wm_write.high - outlen; in bio_bufferevent_write()
194 struct bufferevent *bufev = BIO_get_data(b); in bio_bufferevent_ctrl() local
205 ret = evbuffer_get_length(bufferevent_get_input(bufev)) != 0; in bio_bufferevent_ctrl()
335 static int be_openssl_flush(struct bufferevent *bufev,
1255 be_openssl_flush(struct bufferevent *bufev, in be_openssl_flush() argument
1326 bufferevent_openssl_get_ssl(struct bufferevent *bufev) in bufferevent_openssl_get_ssl() argument
[all …]
H A Dhttp-internal.h60 struct bufferevent *bufev; member
/freebsd-12.1/contrib/ntp/sntp/libevent/
H A Dbufferevent.c74 bufev->be_ops->disable(bufev, EV_READ); in bufferevent_suspend_read_()
87 bufev->be_ops->enable(bufev, EV_READ); in bufferevent_unsuspend_read_()
146 bufev->errorcb(bufev, BEV_EVENT_CONNECTED, bufev->cbarg); in bufferevent_run_deferred_callbacks_locked()
150 bufev->readcb(bufev, bufev->cbarg); in bufferevent_run_deferred_callbacks_locked()
154 bufev->writecb(bufev, bufev->cbarg); in bufferevent_run_deferred_callbacks_locked()
162 bufev->errorcb(bufev, what, bufev->cbarg); in bufferevent_run_deferred_callbacks_locked()
233 bufev->readcb(bufev, bufev->cbarg); in bufferevent_run_readcb_()
249 bufev->writecb(bufev, bufev->cbarg); in bufferevent_run_writecb_()
279 bufev->errorcb(bufev, what, bufev->cbarg); in bufferevent_run_eventcb_()
701 bufev->be_ops->unlink(bufev); in bufferevent_decref_and_unlock_()
[all …]
H A Dbufferevent_sock.c339 event_assign(&bufev->ev_read, bufev->ev_base, fd, in bufferevent_socket_new()
341 event_assign(&bufev->ev_write, bufev->ev_base, fd, in bufferevent_socket_new()
349 return bufev; in bufferevent_socket_new()
546 return bufev; in bufferevent_new()
554 if (be_socket_add(&bufev->ev_read,&bufev->timeout_read) == -1) in be_socket_enable()
629 BEV_LOCK(bufev); in be_socket_setfd()
635 event_assign(&bufev->ev_read, bufev->ev_base, fd, in be_socket_setfd()
637 event_assign(&bufev->ev_write, bufev->ev_base, fd, in be_socket_setfd()
641 bufferevent_enable(bufev, bufev->enabled); in be_socket_setfd()
654 BEV_LOCK(bufev); in bufferevent_priority_set()
[all …]
H A Dbufferevent-internal.h325 int bufferevent_disable_hard_(struct bufferevent *bufev, short event);
331 void bufferevent_incref_(struct bufferevent *bufev);
334 void bufferevent_incref_and_lock_(struct bufferevent *bufev);
337 int bufferevent_decref_(struct bufferevent *bufev);
340 int bufferevent_decref_and_unlock_(struct bufferevent *bufev);
344 void bufferevent_run_readcb_(struct bufferevent *bufev, int options);
347 void bufferevent_run_writecb_(struct bufferevent *bufev, int options);
365 evbuffer_get_length(bufev->input) >= bufev->wm_read.low)) in bufferevent_trigger_nolock_()
366 bufferevent_run_readcb_(bufev, options); in bufferevent_trigger_nolock_()
368 evbuffer_get_length(bufev->output) <= bufev->wm_write.low)) in bufferevent_trigger_nolock_()
[all …]
H A Dbufferevent_filter.c147 bufev->wm_read.high && in be_readbuf_full()
148 evbuffer_get_length(bufev->input) >= bufev->wm_read.high; in be_readbuf_full()
340 if (!(bufev->enabled & EV_WRITE) || in be_filter_process_output()
372 (bufev->enabled & EV_WRITE) && in be_filter_process_output()
375 evbuffer_get_length(bufev->output) && in be_filter_process_output()
384 (bufev->enabled & EV_WRITE) && in be_filter_process_output()
397 BEV_RESET_GENERIC_WRITE_TIMEOUT(bufev); in be_filter_process_output()
431 BEV_LOCK(bufev); in be_filter_readcb()
455 BEV_UNLOCK(bufev); in be_filter_readcb()
512 bufferevent_incref_and_lock_(bufev); in be_filter_flush()
[all …]
H A Dbufferevent_pair.c96 struct bufferevent_pair *bufev; in bufferevent_pair_elt_new() local
101 mm_free(bufev); in bufferevent_pair_elt_new()
104 if (!evbuffer_add_cb(bufev->bev.bev.output, be_pair_outbuf_cb, bufev)) { in bufferevent_pair_elt_new()
105 bufferevent_free(downcast(bufev)); in bufferevent_pair_elt_new()
111 return bufev; in bufferevent_pair_elt_new()
227 struct bufferevent_pair *bev_p = upcast(bufev); in be_pair_enable()
230 incref_and_lock(bufev); in be_pair_enable()
233 BEV_RESET_GENERIC_READ_TIMEOUT(bufev); in be_pair_enable()
236 BEV_RESET_GENERIC_WRITE_TIMEOUT(bufev); in be_pair_enable()
241 be_pair_transfer(downcast(partner), bufev, 0); in be_pair_enable()
[all …]
H A Dhttp.c370 bufferevent_setcb(evcon->bufev, in evhttp_write_buffer()
395 bufferevent_setcb(evcon->bufev, in evhttp_send_continue()
1116 evhttp_read_cb(evcon->bufev, evcon); in evhttp_deferred_read_cb()
1169 if (evcon->bufev != NULL) in evhttp_connection_free()
1170 bufferevent_free(evcon->bufev); in evhttp_connection_free()
1458 evhttp_error_cb(bufev, what, arg); in evhttp_connection_cb()
1504 bufferevent_setcb(evcon->bufev, in evhttp_connection_cb()
2284 evcon->bufev = bev; in evhttp_connection_base_bufferevent_new()
2316 return evcon->bufev; in evhttp_connection_get_bufferevent()
2446 bufferevent_setcb(evcon->bufev, in evhttp_connection_connect_()
[all …]
H A Dbufferevent_openssl.c165 struct bufferevent *bufev = b->ptr; in bio_bufferevent_write() local
174 output = bufferevent_get_output(bufev); in bio_bufferevent_write()
179 if (bufev->wm_write.high && bufev->wm_write.high <= (outlen+inlen)) { in bio_bufferevent_write()
180 if (bufev->wm_write.high <= outlen) { in bio_bufferevent_write()
185 inlen = bufev->wm_write.high - outlen; in bio_bufferevent_write()
197 struct bufferevent *bufev = b->ptr; in bio_bufferevent_ctrl() local
208 ret = evbuffer_get_length(bufferevent_get_input(bufev)) != 0; in bio_bufferevent_ctrl()
337 static int be_openssl_flush(struct bufferevent *bufev,
1257 be_openssl_flush(struct bufferevent *bufev, in be_openssl_flush() argument
1305 bufferevent_openssl_get_ssl(struct bufferevent *bufev) in bufferevent_openssl_get_ssl() argument
[all …]
H A Dhttp-internal.h60 struct bufferevent *bufev; member
/freebsd-12.1/contrib/pf/libevent/
H A Devbuffer.c84 bufferevent_add(&bufev->ev_read, bufev->timeout_read); in bufferevent_read_pressure_cb()
123 bufferevent_add(&bufev->ev_read, bufev->timeout_read); in bufferevent_readcb()
127 if (bufev->wm_read.low != 0 && len < bufev->wm_read.low) in bufferevent_readcb()
140 (*bufev->readcb)(bufev, bufev->cbarg); in bufferevent_readcb()
144 bufferevent_add(&bufev->ev_read, bufev->timeout_read); in bufferevent_readcb()
148 (*bufev->errorcb)(bufev, what, bufev->cbarg); in bufferevent_readcb()
189 bufferevent_add(&bufev->ev_write, bufev->timeout_write); in bufferevent_writecb()
197 (*bufev->writecb)(bufev, bufev->cbarg); in bufferevent_writecb()
207 (*bufev->errorcb)(bufev, what, bufev->cbarg); in bufferevent_writecb()
282 free(bufev); in bufferevent_free()
[all …]
H A Devent.h263 int bufferevent_base_set(struct event_base *base, struct bufferevent *bufev);
264 int bufferevent_priority_set(struct bufferevent *bufev, int pri);
265 void bufferevent_free(struct bufferevent *bufev);
266 int bufferevent_write(struct bufferevent *bufev, void *data, size_t size);
267 int bufferevent_write_buffer(struct bufferevent *bufev, struct evbuffer *buf);
268 size_t bufferevent_read(struct bufferevent *bufev, void *data, size_t size);
269 int bufferevent_enable(struct bufferevent *bufev, short event);
270 int bufferevent_disable(struct bufferevent *bufev, short event);
271 void bufferevent_settimeout(struct bufferevent *bufev,
/freebsd-12.1/contrib/libevent/include/event2/
H A Dbufferevent.h305 void bufferevent_free(struct bufferevent *bufev);
323 void bufferevent_setcb(struct bufferevent *bufev,
342 void bufferevent_getcb(struct bufferevent *bufev,
386 int bufferevent_write(struct bufferevent *bufev,
483 short bufferevent_get_enabled(struct bufferevent *bufev);
512 int bufferevent_set_timeouts(struct bufferevent *bufev,
556 void bufferevent_lock(struct bufferevent *bufev);
563 void bufferevent_unlock(struct bufferevent *bufev);
575 void bufferevent_incref(struct bufferevent *bufev);
589 int bufferevent_decref(struct bufferevent *bufev);
[all …]
H A Dbufferevent_compat.h86 void bufferevent_settimeout(struct bufferevent *bufev,
H A Dbufferevent_ssl.h118 bufferevent_openssl_get_ssl(struct bufferevent *bufev);
/freebsd-12.1/contrib/ntp/sntp/libevent/include/event2/
H A Dbufferevent.h294 int bufferevent_get_priority(const struct bufferevent *bufev);
305 void bufferevent_free(struct bufferevent *bufev);
323 void bufferevent_setcb(struct bufferevent *bufev,
342 void bufferevent_getcb(struct bufferevent *bufev,
363 evutil_socket_t bufferevent_getfd(struct bufferevent *bufev);
386 int bufferevent_write(struct bufferevent *bufev,
483 short bufferevent_get_enabled(struct bufferevent *bufev);
512 int bufferevent_set_timeouts(struct bufferevent *bufev,
556 void bufferevent_lock(struct bufferevent *bufev);
563 void bufferevent_unlock(struct bufferevent *bufev);
[all …]
H A Dbufferevent_compat.h86 void bufferevent_settimeout(struct bufferevent *bufev,
H A Dbufferevent_ssl.h118 bufferevent_openssl_get_ssl(struct bufferevent *bufev);
/freebsd-12.1/contrib/pf/ftp-proxy/
H A Dftp-proxy.c134 client_error(struct bufferevent *bufev __unused, short what, void *arg) in client_error()
240 client_read(struct bufferevent *bufev, void *arg) in client_read() argument
248 clientread = bufferevent_read(bufev, s->cbuf + s->cbuf_valid, in client_read()
907 server_error(struct bufferevent *bufev __unused, short what, void *arg) in server_error()
1076 server_read(struct bufferevent *bufev, void *arg) in server_read() argument
1082 bufferevent_settimeout(bufev, timeout, 0); in server_read()
1086 srvread = bufferevent_read(bufev, s->sbuf + s->sbuf_valid, in server_read()

12