Lines Matching refs:bev
292 struct bufferevent_private bev; member
342 evutil_offsetof(struct bufferevent_openssl, bev.bev),
355 upcast(struct bufferevent *bev) in upcast() argument
358 if (!BEV_IS_OPENSSL(bev)) in upcast()
360 bev_o = (void*)( ((char*)bev) - in upcast()
361 evutil_offsetof(struct bufferevent_openssl, bev.bev)); in upcast()
362 EVUTIL_ASSERT(BEV_IS_OPENSSL(&bev_o->bev.bev)); in upcast()
390 struct bufferevent *bev = &bev_ssl->bev.bev; in start_reading() local
392 r = bufferevent_add_event_(&bev->ev_read, &bev->timeout_read); in start_reading()
394 r = bufferevent_add_event_(&bev->ev_write, in start_reading()
395 &bev->timeout_write); in start_reading()
413 struct bufferevent *bev = &bev_ssl->bev.bev; in start_writing() local
414 r = bufferevent_add_event_(&bev->ev_write, &bev->timeout_write); in start_writing()
416 r = bufferevent_add_event_(&bev->ev_read, in start_writing()
417 &bev->timeout_read); in start_writing()
431 struct bufferevent *bev = &bev_ssl->bev.bev; in stop_reading() local
432 event_del(&bev->ev_read); in stop_reading()
445 struct bufferevent *bev = &bev_ssl->bev.bev; in stop_writing() local
446 event_del(&bev->ev_write); in stop_writing()
471 struct bufferevent *bev = &bev_ssl->bev.bev; in clear_rbow() local
474 if (!(bev->enabled & EV_WRITE)) in clear_rbow()
476 if (bev->enabled & EV_READ) in clear_rbow()
485 struct bufferevent *bev = &bev_ssl->bev.bev; in clear_wbor() local
488 if (!(bev->enabled & EV_READ)) in clear_wbor()
490 if (bev->enabled & EV_WRITE) in clear_wbor()
547 bufferevent_run_eventcb_(&bev_ssl->bev.bev, event, 0); in conn_closed()
570 bufferevent_decrement_write_buckets_(&bev_ssl->bev, w); in decrement_buckets()
572 bufferevent_decrement_read_buckets_(&bev_ssl->bev, r); in decrement_buckets()
586 struct bufferevent *bev = &bev_ssl->bev.bev; in do_read() local
587 struct evbuffer *input = bev->input; in do_read()
592 if (bev_ssl->bev.read_suspended) in do_read()
595 atmost = bufferevent_get_read_max_(&bev_ssl->bev); in do_read()
604 if (bev_ssl->bev.read_suspended) in do_read()
645 BEV_RESET_GENERIC_READ_TIMEOUT(bev); in do_read()
657 struct bufferevent *bev = &bev_ssl->bev.bev; in do_write() local
658 struct evbuffer *output = bev->output; in do_write()
665 atmost = bufferevent_get_write_max_(&bev_ssl->bev); in do_write()
674 if (bev_ssl->bev.write_suspended) in do_write()
725 BEV_RESET_GENERIC_WRITE_TIMEOUT(bev); in do_write()
727 bufferevent_trigger_nolock_(bev, EV_WRITE, BEV_OPT_DEFER_CALLBACKS); in do_write()
739 bytes_to_read(struct bufferevent_openssl *bev) in bytes_to_read() argument
741 struct evbuffer *input = bev->bev.bev.input; in bytes_to_read()
742 struct event_watermark *wm = &bev->bev.bev.wm_read; in bytes_to_read()
748 if (bev->write_blocked_on_read) { in bytes_to_read()
752 if (! (bev->bev.bev.enabled & EV_READ)) { in bytes_to_read()
756 if (bev->bev.read_suspended) { in bytes_to_read()
771 limit = bufferevent_get_read_max_(&bev->bev); in bytes_to_read()
808 if (bev_ssl->bev.read_suspended) in consider_reading()
840 struct bufferevent *bev = &bev_ssl->bev.bev; in consider_reading() local
842 bufferevent_trigger_nolock_(bev, EV_READ, 0); in consider_reading()
847 if (bev_ssl->bev.read_suspended || in consider_reading()
848 !(bev_ssl->bev.bev.enabled & EV_READ)) { in consider_reading()
849 event_del(&bev_ssl->bev.bev.ev_read); in consider_reading()
858 struct evbuffer *output = bev_ssl->bev.bev.output; in consider_writing()
865 struct bufferevent *bev = &bev_ssl->bev.bev; in consider_writing() local
867 bufferevent_trigger_nolock_(bev, EV_READ, 0); in consider_writing()
878 while ((bev_ssl->bev.bev.enabled & EV_WRITE) && in consider_writing()
879 (! bev_ssl->bev.write_suspended) && in consider_writing()
894 event_del(&bev_ssl->bev.bev.ev_write); in consider_writing()
895 } else if (bev_ssl->bev.write_suspended || in consider_writing()
896 !(bev_ssl->bev.bev.enabled & EV_WRITE)) { in consider_writing()
898 event_del(&bev_ssl->bev.bev.ev_write); in consider_writing()
939 bufferevent_run_eventcb_(&bev_ssl->bev.bev, event, 0); in be_openssl_eventcb()
946 bufferevent_incref_and_lock_(&bev_ssl->bev.bev); in be_openssl_readeventcb()
948 bufferevent_run_eventcb_(&bev_ssl->bev.bev, in be_openssl_readeventcb()
953 bufferevent_decref_and_unlock_(&bev_ssl->bev.bev); in be_openssl_readeventcb()
960 bufferevent_incref_and_lock_(&bev_ssl->bev.bev); in be_openssl_writeeventcb()
962 bufferevent_run_eventcb_(&bev_ssl->bev.bev, in be_openssl_writeeventcb()
967 bufferevent_decref_and_unlock_(&bev_ssl->bev.bev); in be_openssl_writeeventcb()
974 struct bufferevent *bev = &bev_ssl->bev.bev; in be_openssl_auto_fd() local
975 if (event_initialized(&bev->ev_read) && fd < 0) { in be_openssl_auto_fd()
976 fd = event_get_fd(&bev->ev_read); in be_openssl_auto_fd()
991 struct bufferevent *bev = &bev_ssl->bev.bev; in set_open_callbacks() local
994 if (event_initialized(&bev->ev_read)) { in set_open_callbacks()
995 rpending = event_pending(&bev->ev_read, EV_READ, NULL); in set_open_callbacks()
996 wpending = event_pending(&bev->ev_write, EV_WRITE, NULL); in set_open_callbacks()
998 event_del(&bev->ev_read); in set_open_callbacks()
999 event_del(&bev->ev_write); in set_open_callbacks()
1002 event_assign(&bev->ev_read, bev->ev_base, fd, in set_open_callbacks()
1005 event_assign(&bev->ev_write, bev->ev_base, fd, in set_open_callbacks()
1010 r1 = bufferevent_add_event_(&bev->ev_read, &bev->timeout_read); in set_open_callbacks()
1012 r2 = bufferevent_add_event_(&bev->ev_write, &bev->timeout_write); in set_open_callbacks()
1037 evutil_socket_t fd = event_get_fd(&bev_ssl->bev.bev.ev_read); in do_handshake()
1042 bufferevent_enable(&bev_ssl->bev.bev, bev_ssl->bev.bev.enabled); in do_handshake()
1043 bufferevent_run_eventcb_(&bev_ssl->bev.bev, in do_handshake()
1075 bufferevent_incref_and_lock_(&bev_ssl->bev.bev); in be_openssl_handshakeeventcb()
1077 bufferevent_run_eventcb_(&bev_ssl->bev.bev, BEV_EVENT_TIMEOUT, 0); in be_openssl_handshakeeventcb()
1080 bufferevent_decref_and_unlock_(&bev_ssl->bev.bev); in be_openssl_handshakeeventcb()
1100 struct bufferevent *bev = &bev_ssl->bev.bev; in set_handshake_callbacks() local
1102 if (event_initialized(&bev->ev_read)) { in set_handshake_callbacks()
1103 event_del(&bev->ev_read); in set_handshake_callbacks()
1104 event_del(&bev->ev_write); in set_handshake_callbacks()
1107 event_assign(&bev->ev_read, bev->ev_base, fd, in set_handshake_callbacks()
1110 event_assign(&bev->ev_write, bev->ev_base, fd, in set_handshake_callbacks()
1114 bufferevent_enable(bev, bev->enabled); in set_handshake_callbacks()
1120 bufferevent_ssl_renegotiate(struct bufferevent *bev) in bufferevent_ssl_renegotiate() argument
1122 struct bufferevent_openssl *bev_ssl = upcast(bev); in bufferevent_ssl_renegotiate()
1145 r = bufferevent_add_event_(&bev_ssl->bev.bev.ev_write, in be_openssl_outbuf_cb()
1146 &bev_ssl->bev.bev.timeout_write); in be_openssl_outbuf_cb()
1157 be_openssl_enable(struct bufferevent *bev, short events) in be_openssl_enable() argument
1159 struct bufferevent_openssl *bev_ssl = upcast(bev); in be_openssl_enable()
1169 BEV_RESET_GENERIC_READ_TIMEOUT(bev); in be_openssl_enable()
1171 BEV_RESET_GENERIC_WRITE_TIMEOUT(bev); in be_openssl_enable()
1182 be_openssl_disable(struct bufferevent *bev, short events) in be_openssl_disable() argument
1184 struct bufferevent_openssl *bev_ssl = upcast(bev); in be_openssl_disable()
1193 BEV_DEL_GENERIC_READ_TIMEOUT(bev); in be_openssl_disable()
1195 BEV_DEL_GENERIC_WRITE_TIMEOUT(bev); in be_openssl_disable()
1201 be_openssl_unlink(struct bufferevent *bev) in be_openssl_unlink() argument
1203 struct bufferevent_openssl *bev_ssl = upcast(bev); in be_openssl_unlink()
1205 if (bev_ssl->bev.options & BEV_OPT_CLOSE_ON_FREE) { in be_openssl_unlink()
1229 be_openssl_destruct(struct bufferevent *bev) in be_openssl_destruct() argument
1231 struct bufferevent_openssl *bev_ssl = upcast(bev); in be_openssl_destruct()
1233 if (bev_ssl->bev.options & BEV_OPT_CLOSE_ON_FREE) { in be_openssl_destruct()
1247 be_openssl_adj_timeouts(struct bufferevent *bev) in be_openssl_adj_timeouts() argument
1249 struct bufferevent_openssl *bev_ssl = upcast(bev); in be_openssl_adj_timeouts()
1252 return bufferevent_generic_adj_timeouts_(bev); in be_openssl_adj_timeouts()
1254 return bufferevent_generic_adj_existing_timeouts_(bev); in be_openssl_adj_timeouts()
1299 be_openssl_ctrl(struct bufferevent *bev, in be_openssl_ctrl() argument
1302 struct bufferevent_openssl *bev_ssl = upcast(bev); in be_openssl_ctrl()
1321 data->fd = event_get_fd(&bev->ev_read); in be_openssl_ctrl()
1361 bev_p = &bev_ssl->bev; in bufferevent_openssl_new_impl()
1374 bev_ssl->outbuf_cb = evbuffer_add_cb(bev_p->bev.output, in bufferevent_openssl_new_impl()
1378 bufferevent_enable_locking_(&bev_ssl->bev.bev, NULL); in bufferevent_openssl_new_impl()
1381 bufferevent_init_generic_timeout_cbs_(&bev_ssl->bev.bev); in bufferevent_openssl_new_impl()
1402 return &bev_ssl->bev.bev; in bufferevent_openssl_new_impl()
1408 bufferevent_free(&bev_ssl->bev.bev); in bufferevent_openssl_new_impl()
1421 struct bufferevent *bev; in bufferevent_openssl_filter_new() local
1430 bev = bufferevent_openssl_new_impl( in bufferevent_openssl_filter_new()
1432 return bev; in bufferevent_openssl_filter_new()
1488 bufferevent_openssl_get_allow_dirty_shutdown(struct bufferevent *bev) in bufferevent_openssl_get_allow_dirty_shutdown() argument
1492 BEV_LOCK(bev); in bufferevent_openssl_get_allow_dirty_shutdown()
1493 bev_ssl = upcast(bev); in bufferevent_openssl_get_allow_dirty_shutdown()
1496 BEV_UNLOCK(bev); in bufferevent_openssl_get_allow_dirty_shutdown()
1501 bufferevent_openssl_set_allow_dirty_shutdown(struct bufferevent *bev, in bufferevent_openssl_set_allow_dirty_shutdown() argument
1505 BEV_LOCK(bev); in bufferevent_openssl_set_allow_dirty_shutdown()
1506 bev_ssl = upcast(bev); in bufferevent_openssl_set_allow_dirty_shutdown()
1509 BEV_UNLOCK(bev); in bufferevent_openssl_set_allow_dirty_shutdown()
1513 bufferevent_get_openssl_error(struct bufferevent *bev) in bufferevent_get_openssl_error() argument
1517 BEV_LOCK(bev); in bufferevent_get_openssl_error()
1518 bev_ssl = upcast(bev); in bufferevent_get_openssl_error()
1522 BEV_UNLOCK(bev); in bufferevent_get_openssl_error()