Lines Matching defs:bufev
75 struct bufferevent *bufev = arg;
80 if (bufev->wm_read.high == 0 || now < bufev->wm_read.high) {
83 if (bufev->enabled & EV_READ)
84 bufferevent_add(&bufev->ev_read, bufev->timeout_read);
91 struct bufferevent *bufev = arg;
106 if (bufev->wm_read.high != 0)
107 howmuch = bufev->wm_read.high;
109 res = evbuffer_read(bufev->input, fd, howmuch);
123 bufferevent_add(&bufev->ev_read, bufev->timeout_read);
126 len = EVBUFFER_LENGTH(bufev->input);
127 if (bufev->wm_read.low != 0 && len < bufev->wm_read.low)
129 if (bufev->wm_read.high != 0 && len > bufev->wm_read.high) {
130 struct evbuffer *buf = bufev->input;
131 event_del(&bufev->ev_read);
134 evbuffer_setcb(buf, bufferevent_read_pressure_cb, bufev);
139 if (bufev->readcb != NULL)
140 (*bufev->readcb)(bufev, bufev->cbarg);
144 bufferevent_add(&bufev->ev_read, bufev->timeout_read);
148 (*bufev->errorcb)(bufev, what, bufev->cbarg);
154 struct bufferevent *bufev = arg;
163 if (EVBUFFER_LENGTH(bufev->output)) {
164 res = evbuffer_write(bufev->output, fd);
188 if (EVBUFFER_LENGTH(bufev->output) != 0)
189 bufferevent_add(&bufev->ev_write, bufev->timeout_write);
195 if (bufev->writecb != NULL &&
196 EVBUFFER_LENGTH(bufev->output) <= bufev->wm_write.low)
197 (*bufev->writecb)(bufev, bufev->cbarg);
202 if (EVBUFFER_LENGTH(bufev->output) != 0)
203 bufferevent_add(&bufev->ev_write, bufev->timeout_write);
207 (*bufev->errorcb)(bufev, what, bufev->cbarg);
225 struct bufferevent *bufev;
227 if ((bufev = calloc(1, sizeof(struct bufferevent))) == NULL)
230 if ((bufev->input = evbuffer_new()) == NULL) {
231 free(bufev);
235 if ((bufev->output = evbuffer_new()) == NULL) {
236 evbuffer_free(bufev->input);
237 free(bufev);
241 event_set(&bufev->ev_read, fd, EV_READ, bufferevent_readcb, bufev);
242 event_set(&bufev->ev_write, fd, EV_WRITE, bufferevent_writecb, bufev);
244 bufev->readcb = readcb;
245 bufev->writecb = writecb;
246 bufev->errorcb = errorcb;
248 bufev->cbarg = cbarg;
255 bufev->enabled = EV_WRITE;
257 return (bufev);
261 bufferevent_priority_set(struct bufferevent *bufev, int priority)
263 if (event_priority_set(&bufev->ev_read, priority) == -1)
265 if (event_priority_set(&bufev->ev_write, priority) == -1)
274 bufferevent_free(struct bufferevent *bufev)
276 event_del(&bufev->ev_read);
277 event_del(&bufev->ev_write);
279 evbuffer_free(bufev->input);
280 evbuffer_free(bufev->output);
282 free(bufev);
291 bufferevent_write(struct bufferevent *bufev, void *data, size_t size)
295 res = evbuffer_add(bufev->output, data, size);
301 if (size > 0 && (bufev->enabled & EV_WRITE))
302 bufferevent_add(&bufev->ev_write, bufev->timeout_write);
308 bufferevent_write_buffer(struct bufferevent *bufev, struct evbuffer *buf)
312 res = bufferevent_write(bufev, buf->buffer, buf->off);
320 bufferevent_read(struct bufferevent *bufev, void *data, size_t size)
322 struct evbuffer *buf = bufev->input;
337 bufferevent_enable(struct bufferevent *bufev, short event)
340 if (bufferevent_add(&bufev->ev_read, bufev->timeout_read) == -1)
344 if (bufferevent_add(&bufev->ev_write, bufev->timeout_write) == -1)
348 bufev->enabled |= event;
353 bufferevent_disable(struct bufferevent *bufev, short event)
356 if (event_del(&bufev->ev_read) == -1)
360 if (event_del(&bufev->ev_write) == -1)
364 bufev->enabled &= ~event;
373 bufferevent_settimeout(struct bufferevent *bufev,
375 bufev->timeout_read = timeout_read;
376 bufev->timeout_write = timeout_write;
384 bufferevent_setwatermark(struct bufferevent *bufev, short events,
388 bufev->wm_read.low = lowmark;
389 bufev->wm_read.high = highmark;
393 bufev->wm_write.low = lowmark;
394 bufev->wm_write.high = highmark;
398 bufferevent_read_pressure_cb(bufev->input,
399 0, EVBUFFER_LENGTH(bufev->input), bufev);
403 bufferevent_base_set(struct event_base *base, struct bufferevent *bufev)
407 res = event_base_set(base, &bufev->ev_read);
411 res = event_base_set(base, &bufev->ev_write);