Lines Matching refs:bufev
2475 struct bufferevent *bufev = arg;
2476 struct ctl_relay_event *cre = bufev->cbarg;
2487 if (bufev->wm_read.high != 0)
2488 howmuch = MINIMUM(sizeof(rbuf), bufev->wm_read.high);
2504 if (evbuffer_add(bufev->input, rbuf, ret) == -1) {
2509 relay_bufferevent_add(&bufev->ev_read, bufev->timeout_read);
2511 len = EVBUFFER_LENGTH(bufev->input);
2512 if (bufev->wm_read.low != 0 && len < bufev->wm_read.low)
2514 if (bufev->wm_read.high != 0 && len > bufev->wm_read.high) {
2515 struct evbuffer *buf = bufev->input;
2516 event_del(&bufev->ev_read);
2517 evbuffer_setcb(buf, bufferevent_read_pressure_cb, bufev);
2521 if (bufev->readcb != NULL)
2522 (*bufev->readcb)(bufev, bufev->cbarg);
2526 relay_bufferevent_add(&bufev->ev_read, bufev->timeout_read);
2530 (*bufev->errorcb)(bufev, what, bufev->cbarg);
2536 struct bufferevent *bufev = arg;
2537 struct ctl_relay_event *cre = bufev->cbarg;
2547 if (EVBUFFER_LENGTH(bufev->output)) {
2548 ret = tls_write(cre->tls, EVBUFFER_DATA(bufev->output),
2549 EVBUFFER_LENGTH(bufev->output));
2557 evbuffer_drain(bufev->output, len);
2560 if (EVBUFFER_LENGTH(bufev->output) != 0)
2561 relay_bufferevent_add(&bufev->ev_write, bufev->timeout_write);
2563 if (bufev->writecb != NULL &&
2564 EVBUFFER_LENGTH(bufev->output) <= bufev->wm_write.low)
2565 (*bufev->writecb)(bufev, bufev->cbarg);
2569 relay_bufferevent_add(&bufev->ev_write, bufev->timeout_write);
2573 (*bufev->errorcb)(bufev, what, bufev->cbarg);