Lines Matching defs:bev
287 struct bufferevent_private bev;
336 evutil_offsetof(struct bufferevent_openssl, bev.bev),
348 upcast(struct bufferevent *bev)
351 if (bev->be_ops != &bufferevent_ops_openssl)
353 bev_o = (void*)( ((char*)bev) -
354 evutil_offsetof(struct bufferevent_openssl, bev.bev));
355 EVUTIL_ASSERT(bev_o->bev.bev.be_ops == &bufferevent_ops_openssl);
383 struct bufferevent *bev = &bev_ssl->bev.bev;
385 r = _bufferevent_add_event(&bev->ev_read, &bev->timeout_read);
387 r = _bufferevent_add_event(&bev->ev_write,
388 &bev->timeout_write);
403 struct bufferevent *bev = &bev_ssl->bev.bev;
404 r = _bufferevent_add_event(&bev->ev_write, &bev->timeout_write);
406 r = _bufferevent_add_event(&bev->ev_read,
407 &bev->timeout_read);
421 struct bufferevent *bev = &bev_ssl->bev.bev;
422 event_del(&bev->ev_read);
434 struct bufferevent *bev = &bev_ssl->bev.bev;
435 event_del(&bev->ev_write);
460 struct bufferevent *bev = &bev_ssl->bev.bev;
463 if (!(bev->enabled & EV_WRITE))
465 if (bev->enabled & EV_READ)
474 struct bufferevent *bev = &bev_ssl->bev.bev;
477 if (!(bev->enabled & EV_READ))
479 if (bev->enabled & EV_WRITE)
531 _bufferevent_run_eventcb(&bev_ssl->bev.bev, event);
552 _bufferevent_decrement_write_buckets(&bev_ssl->bev, w);
554 _bufferevent_decrement_read_buckets(&bev_ssl->bev, r);
568 struct bufferevent *bev = &bev_ssl->bev.bev;
569 struct evbuffer *input = bev->input;
574 atmost = _bufferevent_get_read_max(&bev_ssl->bev);
583 if (bev_ssl->bev.read_suspended)
623 BEV_RESET_GENERIC_READ_TIMEOUT(bev);
635 struct bufferevent *bev = &bev_ssl->bev.bev;
636 struct evbuffer *output = bev->output;
643 atmost = _bufferevent_get_write_max(&bev_ssl->bev);
652 if (bev_ssl->bev.write_suspended)
702 BEV_RESET_GENERIC_WRITE_TIMEOUT(bev);
704 if (evbuffer_get_length(output) <= bev->wm_write.low)
705 _bufferevent_run_writecb(bev);
717 bytes_to_read(struct bufferevent_openssl *bev)
719 struct evbuffer *input = bev->bev.bev.input;
720 struct event_watermark *wm = &bev->bev.bev.wm_read;
726 if (bev->write_blocked_on_read) {
730 if (! (bev->bev.bev.enabled & EV_READ)) {
734 if (bev->bev.read_suspended) {
749 limit = _bufferevent_get_read_max(&bev->bev);
815 struct bufferevent *bev = &bev_ssl->bev.bev;
816 struct evbuffer *input = bev->input;
818 if (evbuffer_get_length(input) >= bev->wm_read.low) {
819 _bufferevent_run_readcb(bev);
825 if (bev_ssl->bev.read_suspended ||
826 !(bev_ssl->bev.bev.enabled & EV_READ)) {
827 event_del(&bev_ssl->bev.bev.ev_read);
836 struct evbuffer *output = bev_ssl->bev.bev.output;
843 struct bufferevent *bev = &bev_ssl->bev.bev;
844 struct evbuffer *input = bev->input;
846 if (evbuffer_get_length(input) >= bev->wm_read.low) {
847 _bufferevent_run_readcb(bev);
859 while ((bev_ssl->bev.bev.enabled & EV_WRITE) &&
860 (! bev_ssl->bev.write_suspended) &&
875 event_del(&bev_ssl->bev.bev.ev_write);
876 } else if (bev_ssl->bev.write_suspended ||
877 !(bev_ssl->bev.bev.enabled & EV_WRITE)) {
879 event_del(&bev_ssl->bev.bev.ev_write);
920 _bufferevent_run_eventcb(&bev_ssl->bev.bev, event);
927 _bufferevent_incref_and_lock(&bev_ssl->bev.bev);
929 _bufferevent_run_eventcb(&bev_ssl->bev.bev,
933 _bufferevent_decref_and_unlock(&bev_ssl->bev.bev);
940 _bufferevent_incref_and_lock(&bev_ssl->bev.bev);
942 _bufferevent_run_eventcb(&bev_ssl->bev.bev,
946 _bufferevent_decref_and_unlock(&bev_ssl->bev.bev);
958 struct bufferevent *bev = &bev_ssl->bev.bev;
961 fd = event_get_fd(&bev->ev_read);
963 rpending = event_pending(&bev->ev_read, EV_READ, NULL);
964 wpending = event_pending(&bev->ev_write, EV_WRITE, NULL);
965 event_del(&bev->ev_read);
966 event_del(&bev->ev_write);
968 event_assign(&bev->ev_read, bev->ev_base, fd,
970 event_assign(&bev->ev_write, bev->ev_base, fd,
973 r1 = _bufferevent_add_event(&bev->ev_read, &bev->timeout_read);
975 r2 = _bufferevent_add_event(&bev->ev_write, &bev->timeout_write);
1005 bufferevent_enable(&bev_ssl->bev.bev, bev_ssl->bev.bev.enabled);
1006 _bufferevent_run_eventcb(&bev_ssl->bev.bev,
1044 _bufferevent_incref_and_lock(&bev_ssl->bev.bev);
1046 _bufferevent_run_eventcb(&bev_ssl->bev.bev, BEV_EVENT_TIMEOUT);
1049 _bufferevent_decref_and_unlock(&bev_ssl->bev.bev);
1062 struct bufferevent *bev = &bev_ssl->bev.bev;
1065 fd = event_get_fd(&bev->ev_read);
1067 event_del(&bev->ev_read);
1068 event_del(&bev->ev_write);
1070 event_assign(&bev->ev_read, bev->ev_base, fd,
1072 event_assign(&bev->ev_write, bev->ev_base, fd,
1075 r1 = _bufferevent_add_event(&bev->ev_read, &bev->timeout_read);
1076 r2 = _bufferevent_add_event(&bev->ev_write, &bev->timeout_write);
1084 bufferevent_ssl_renegotiate(struct bufferevent *bev)
1086 struct bufferevent_openssl *bev_ssl = upcast(bev);
1109 r = _bufferevent_add_event(&bev_ssl->bev.bev.ev_write,
1110 &bev_ssl->bev.bev.timeout_write);
1119 be_openssl_enable(struct bufferevent *bev, short events)
1121 struct bufferevent_openssl *bev_ssl = upcast(bev);
1134 BEV_RESET_GENERIC_READ_TIMEOUT(bev);
1136 BEV_RESET_GENERIC_WRITE_TIMEOUT(bev);
1147 be_openssl_disable(struct bufferevent *bev, short events)
1149 struct bufferevent_openssl *bev_ssl = upcast(bev);
1160 BEV_DEL_GENERIC_READ_TIMEOUT(bev);
1162 BEV_DEL_GENERIC_WRITE_TIMEOUT(bev);
1168 be_openssl_destruct(struct bufferevent *bev)
1170 struct bufferevent_openssl *bev_ssl = upcast(bev);
1173 _bufferevent_del_generic_timeout_cbs(bev);
1175 event_del(&bev->ev_read);
1176 event_del(&bev->ev_write);
1179 if (bev_ssl->bev.options & BEV_OPT_CLOSE_ON_FREE) {
1209 be_openssl_adj_timeouts(struct bufferevent *bev)
1211 struct bufferevent_openssl *bev_ssl = upcast(bev);
1214 return _bufferevent_generic_adj_timeouts(bev);
1217 if (event_pending(&bev->ev_read, EV_READ, NULL))
1218 r1 = _bufferevent_add_event(&bev->ev_read, &bev->timeout_read);
1219 if (event_pending(&bev->ev_write, EV_WRITE, NULL))
1220 r2 = _bufferevent_add_event(&bev->ev_write, &bev->timeout_write);
1234 be_openssl_ctrl(struct bufferevent *bev,
1237 struct bufferevent_openssl *bev_ssl = upcast(bev);
1258 data->fd = event_get_fd(&bev->ev_read);
1298 bev_p = &bev_ssl->bev;
1311 bev_ssl->outbuf_cb = evbuffer_add_cb(bev_p->bev.output,
1315 bufferevent_enable_locking(&bev_ssl->bev.bev, NULL);
1318 _bufferevent_init_generic_timeout_cbs(&bev_ssl->bev.bev);
1353 bev_ssl->bev.bev.enabled = EV_READ|EV_WRITE;
1356 if (event_add(&bev_ssl->bev.bev.ev_read, NULL) < 0)
1358 if (event_add(&bev_ssl->bev.bev.ev_write, NULL) < 0)
1363 return &bev_ssl->bev.bev;
1366 bufferevent_free(&bev_ssl->bev.bev);
1435 bufferevent_get_openssl_error(struct bufferevent *bev)
1439 BEV_LOCK(bev);
1440 bev_ssl = upcast(bev);
1444 BEV_UNLOCK(bev);