Lines Matching defs:bufev
2494 struct bufferevent *bufev = arg;
2495 struct ctl_relay_event *cre = bufev->cbarg;
2506 if (bufev->wm_read.high != 0)
2507 howmuch = MINIMUM(sizeof(rbuf), bufev->wm_read.high);
2523 if (evbuffer_add(bufev->input, rbuf, ret) == -1) {
2528 relay_bufferevent_add(&bufev->ev_read, bufev->timeout_read);
2530 len = EVBUFFER_LENGTH(bufev->input);
2531 if (bufev->wm_read.low != 0 && len < bufev->wm_read.low)
2533 if (bufev->wm_read.high != 0 && len > bufev->wm_read.high) {
2534 struct evbuffer *buf = bufev->input;
2535 event_del(&bufev->ev_read);
2536 evbuffer_setcb(buf, bufferevent_read_pressure_cb, bufev);
2540 if (bufev->readcb != NULL)
2541 (*bufev->readcb)(bufev, bufev->cbarg);
2545 relay_bufferevent_add(&bufev->ev_read, bufev->timeout_read);
2549 (*bufev->errorcb)(bufev, what, bufev->cbarg);
2555 struct bufferevent *bufev = arg;
2556 struct ctl_relay_event *cre = bufev->cbarg;
2566 if (EVBUFFER_LENGTH(bufev->output)) {
2567 ret = tls_write(cre->tls, EVBUFFER_DATA(bufev->output),
2568 EVBUFFER_LENGTH(bufev->output));
2576 evbuffer_drain(bufev->output, len);
2579 if (EVBUFFER_LENGTH(bufev->output) != 0)
2580 relay_bufferevent_add(&bufev->ev_write, bufev->timeout_write);
2582 if (bufev->writecb != NULL &&
2583 EVBUFFER_LENGTH(bufev->output) <= bufev->wm_write.low)
2584 (*bufev->writecb)(bufev, bufev->cbarg);
2588 relay_bufferevent_add(&bufev->ev_write, bufev->timeout_write);
2592 (*bufev->errorcb)(bufev, what, bufev->cbarg);