Lines Matching defs:bufev
71 struct bufferevent *bufev = buftls->bt_bufev;
87 if (bufev->wm_read.high != 0) {
88 howmuch = bufev->wm_read.high - EVBUFFER_LENGTH(bufev->input);
91 struct evbuffer *buf = bufev->input;
92 event_del(&bufev->ev_read);
94 bufferevent_read_pressure_cb, bufev);
99 res = evtls_read(bufev->input, fd, howmuch, ctx);
102 bufferevent_add(&bufev->ev_read, bufev->timeout_read);
105 event_del(&bufev->ev_write);
106 event_set(&bufev->ev_write, fd, EV_WRITE, buffertls_readcb,
108 bufferevent_add(&bufev->ev_write, bufev->timeout_write);
121 event_del(&bufev->ev_write);
122 event_set(&bufev->ev_write, fd, EV_WRITE, buffertls_writecb, buftls);
123 if (bufev->enabled & EV_READ)
124 bufferevent_add(&bufev->ev_read, bufev->timeout_read);
125 if (EVBUFFER_LENGTH(bufev->output) != 0 && bufev->enabled & EV_WRITE)
126 bufferevent_add(&bufev->ev_write, bufev->timeout_write);
129 len = EVBUFFER_LENGTH(bufev->input);
130 if (bufev->wm_read.low != 0 && len < bufev->wm_read.low)
132 if (bufev->wm_read.high != 0 && len >= bufev->wm_read.high) {
133 struct evbuffer *buf = bufev->input;
134 event_del(&bufev->ev_read);
137 evbuffer_setcb(buf, bufferevent_read_pressure_cb, bufev);
141 if (bufev->readcb != NULL)
142 (*bufev->readcb)(bufev, bufev->cbarg);
146 (*bufev->errorcb)(bufev, what, bufev->cbarg);
153 struct bufferevent *bufev = buftls->bt_bufev;
163 if (EVBUFFER_LENGTH(bufev->output) != 0) {
164 res = evtls_write(bufev->output, fd, ctx);
167 event_del(&bufev->ev_read);
168 event_set(&bufev->ev_read, fd, EV_READ,
170 bufferevent_add(&bufev->ev_read, bufev->timeout_read);
173 bufferevent_add(&bufev->ev_write, bufev->timeout_write);
186 event_del(&bufev->ev_read);
187 event_set(&bufev->ev_read, fd, EV_READ, buffertls_readcb, buftls);
188 if (bufev->enabled & EV_READ)
189 bufferevent_add(&bufev->ev_read, bufev->timeout_read);
190 if (EVBUFFER_LENGTH(bufev->output) != 0 && bufev->enabled & EV_WRITE)
191 bufferevent_add(&bufev->ev_write, bufev->timeout_write);
197 if (bufev->writecb != NULL &&
198 EVBUFFER_LENGTH(bufev->output) <= bufev->wm_write.low)
199 (*bufev->writecb)(bufev, bufev->cbarg);
204 (*bufev->errorcb)(bufev, what, bufev->cbarg);
211 struct bufferevent *bufev = buftls->bt_bufev;
224 bufferevent_add(&bufev->ev_read, bufev->timeout_read);
227 bufferevent_add(&bufev->ev_write, bufev->timeout_write);
237 event_del(&bufev->ev_read);
238 event_del(&bufev->ev_write);
239 event_set(&bufev->ev_read, fd, EV_READ, buffertls_readcb, buftls);
240 event_set(&bufev->ev_write, fd, EV_WRITE, buffertls_writecb, buftls);
241 if (bufev->enabled & EV_READ)
242 bufferevent_add(&bufev->ev_read, bufev->timeout_read);
243 if (bufev->enabled & EV_WRITE)
244 bufferevent_add(&bufev->ev_write, bufev->timeout_write);
249 (*bufev->errorcb)(bufev, what, bufev->cbarg);
253 buffertls_set(struct buffertls *buftls, struct bufferevent *bufev,
256 bufferevent_setfd(bufev, fd);
257 event_set(&bufev->ev_read, fd, EV_READ, buffertls_readcb, buftls);
258 event_set(&bufev->ev_write, fd, EV_WRITE, buffertls_writecb, buftls);
259 buftls->bt_bufev = bufev;
266 struct bufferevent *bufev = buftls->bt_bufev;
268 event_del(&bufev->ev_read);
269 event_del(&bufev->ev_write);
270 event_set(&bufev->ev_read, fd, EV_READ, buffertls_handshakecb, buftls);
271 event_set(&bufev->ev_write, fd, EV_WRITE, buffertls_handshakecb,
273 bufferevent_add(&bufev->ev_read, bufev->timeout_read);
279 struct bufferevent *bufev = buftls->bt_bufev;
281 event_del(&bufev->ev_read);
282 event_del(&bufev->ev_write);
283 event_set(&bufev->ev_read, fd, EV_READ, buffertls_handshakecb, buftls);
284 event_set(&bufev->ev_write, fd, EV_WRITE, buffertls_handshakecb,
286 bufferevent_add(&bufev->ev_write, bufev->timeout_write);