Lines Matching refs:bufev

783 	struct bufferevent	*bufev = arg;  in server_tls_readcb()  local
784 struct client *clt = bufev->cbarg; in server_tls_readcb()
796 if (bufev->wm_read.high != 0) in server_tls_readcb()
797 howmuch = MINIMUM(sizeof(rbuf), bufev->wm_read.high); in server_tls_readcb()
813 if (evbuffer_add(bufev->input, rbuf, len) == -1) { in server_tls_readcb()
818 server_bufferevent_add(&bufev->ev_read, bufev->timeout_read); in server_tls_readcb()
820 len = EVBUFFER_LENGTH(bufev->input); in server_tls_readcb()
821 if (bufev->wm_read.low != 0 && len < bufev->wm_read.low) in server_tls_readcb()
823 if (bufev->wm_read.high != 0 && len > bufev->wm_read.high) { in server_tls_readcb()
824 struct evbuffer *buf = bufev->input; in server_tls_readcb()
825 event_del(&bufev->ev_read); in server_tls_readcb()
826 evbuffer_setcb(buf, bufferevent_read_pressure_cb, bufev); in server_tls_readcb()
830 if (bufev->readcb != NULL) in server_tls_readcb()
831 (*bufev->readcb)(bufev, bufev->cbarg); in server_tls_readcb()
835 server_bufferevent_add(&bufev->ev_read, bufev->timeout_read); in server_tls_readcb()
839 (*bufev->errorcb)(bufev, what, bufev->cbarg); in server_tls_readcb()
845 struct bufferevent *bufev = arg; in server_tls_writecb() local
846 struct client *clt = bufev->cbarg; in server_tls_writecb()
856 if (EVBUFFER_LENGTH(bufev->output)) { in server_tls_writecb()
858 EVBUFFER_DATA(bufev->output), in server_tls_writecb()
859 EVBUFFER_LENGTH(bufev->output)); in server_tls_writecb()
867 evbuffer_drain(bufev->output, len); in server_tls_writecb()
870 if (EVBUFFER_LENGTH(bufev->output) != 0) in server_tls_writecb()
871 server_bufferevent_add(&bufev->ev_write, bufev->timeout_write); in server_tls_writecb()
873 if (bufev->writecb != NULL && in server_tls_writecb()
874 EVBUFFER_LENGTH(bufev->output) <= bufev->wm_write.low) in server_tls_writecb()
875 (*bufev->writecb)(bufev, bufev->cbarg); in server_tls_writecb()
879 server_bufferevent_add(&bufev->ev_write, bufev->timeout_write); in server_tls_writecb()
883 (*bufev->errorcb)(bufev, what, bufev->cbarg); in server_tls_writecb()