Home
last modified time | relevance | path

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

/libevent-2.1.12/
H A Dbufferevent.c72 bufev->be_ops->disable(bufev, EV_READ); in bufferevent_suspend_read_()
84 bufev->be_ops->enable(bufev, EV_READ); in bufferevent_unsuspend_read_()
163 bufev->errorcb(bufev, BEV_EVENT_CONNECTED, bufev->cbarg); in bufferevent_run_deferred_callbacks_locked()
167 bufev->readcb(bufev, bufev->cbarg); in bufferevent_run_deferred_callbacks_locked()
172 bufev->writecb(bufev, bufev->cbarg); in bufferevent_run_deferred_callbacks_locked()
180 bufev->errorcb(bufev, what, bufev->cbarg); in bufferevent_run_deferred_callbacks_locked()
251 bufev->readcb(bufev, bufev->cbarg); in bufferevent_run_readcb_()
267 bufev->writecb(bufev, bufev->cbarg); in bufferevent_run_writecb_()
296 bufev->errorcb(bufev, what, bufev->cbarg); in bufferevent_run_eventcb_()
721 bufev->be_ops->unlink(bufev); in bufferevent_decref_and_unlock_()
[all …]
H A Dbufferevent_sock.c366 event_assign(&bufev->ev_read, bufev->ev_base, fd, in bufferevent_socket_new()
368 event_assign(&bufev->ev_write, bufev->ev_base, fd, in bufferevent_socket_new()
376 return bufev; in bufferevent_socket_new()
563 return bufev; in bufferevent_new()
623 BEV_LOCK(bufev); in be_socket_setfd()
632 event_assign(&bufev->ev_read, bufev->ev_base, fd, in be_socket_setfd()
634 event_assign(&bufev->ev_write, bufev->ev_base, fd, in be_socket_setfd()
638 bufferevent_enable(bufev, bufev->enabled); in be_socket_setfd()
652 BEV_LOCK(bufev); in bufferevent_priority_set()
653 if (BEV_IS_ASYNC(bufev) || BEV_IS_FILTER(bufev) || BEV_IS_PAIR(bufev)) in bufferevent_priority_set()
[all …]
H A Dbufferevent-internal.h361 int bufferevent_disable_hard_(struct bufferevent *bufev, short event);
369 #define bufferevent_incref_(bufev) bufferevent_incref(bufev) argument
373 void bufferevent_incref_and_lock_(struct bufferevent *bufev);
377 #define bufferevent_decref_(bufev) bufferevent_decref(bufev) argument
382 int bufferevent_decref_and_unlock_(struct bufferevent *bufev);
387 void bufferevent_run_readcb_(struct bufferevent *bufev, int options);
391 void bufferevent_run_writecb_(struct bufferevent *bufev, int options);
410 evbuffer_get_length(bufev->input) >= bufev->wm_read.low)) in bufferevent_trigger_nolock_()
411 bufferevent_run_readcb_(bufev, options); in bufferevent_trigger_nolock_()
413 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.c382 bufferevent_setcb(evcon->bufev, in evhttp_write_buffer()
407 bufferevent_setcb(evcon->bufev, in evhttp_send_continue()
1192 (bev->readcb)(evcon->bufev, evcon); in evhttp_deferred_read_cb()
1254 if (evcon->bufev != NULL) { in evhttp_connection_free()
1260 bufferevent_free(evcon->bufev); in evhttp_connection_free()
1590 evhttp_error_cb(bufev, what, arg); in evhttp_connection_cb()
1628 bufferevent_setcb(evcon->bufev, in evhttp_connection_cb()
2413 evcon->bufev = bev; in evhttp_connection_base_bufferevent_new()
2445 return evcon->bufev; in evhttp_connection_get_bufferevent()
2596 bufferevent_setcb(evcon->bufev, in evhttp_connection_connect_()
[all …]
H A Dbufferevent_openssl.c161 struct bufferevent *bufev = BIO_get_data(b); in bio_bufferevent_write() local
170 output = bufferevent_get_output(bufev); in bio_bufferevent_write()
175 if (bufev->wm_write.high && bufev->wm_write.high <= (outlen+inlen)) { in bio_bufferevent_write()
176 if (bufev->wm_write.high <= outlen) { in bio_bufferevent_write()
181 inlen = bufev->wm_write.high - outlen; in bio_bufferevent_write()
193 struct bufferevent *bufev = BIO_get_data(b); in bio_bufferevent_ctrl() local
204 ret = evbuffer_get_length(bufferevent_get_input(bufev)) != 0; in bio_bufferevent_ctrl()
336 static int be_openssl_flush(struct bufferevent *bufev,
1259 be_openssl_flush(struct bufferevent *bufev, in be_openssl_flush() argument
1334 bufferevent_openssl_get_ssl(struct bufferevent *bufev) in bufferevent_openssl_get_ssl() argument
[all …]
H A Dhttp-internal.h57 struct bufferevent *bufev; member
/libevent-2.1.12/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,
559 void bufferevent_lock(struct bufferevent *bufev);
566 void bufferevent_unlock(struct bufferevent *bufev);
578 void bufferevent_incref(struct bufferevent *bufev);
592 int bufferevent_decref(struct bufferevent *bufev);
[all …]
H A Dbufferevent_compat.h90 void bufferevent_settimeout(struct bufferevent *bufev,
H A Dbufferevent_ssl.h118 bufferevent_openssl_get_ssl(struct bufferevent *bufev);
/libevent-2.1.12/test/
H A Dregress_http.c1457 struct bufferevent *bufev = NULL; in http_cancel_test() local
1514 bufev = evhttp_connection_get_bufferevent(evcon); in http_cancel_test()
1518 evbuffer_add_cb(bufferevent_get_output(bufev), http_no_write, NULL); in http_cancel_test()
1590 if (bufev) in http_cancel_test()
1591 evbuffer_remove_cb(bufferevent_get_output(bufev), http_no_write, NULL); in http_cancel_test()