Lines Matching defs:bufev
129 struct bufferevent *bufev = arg;
131 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
134 (bufev->enabled & EV_WRITE) &&
135 !event_pending(&bufev->ev_write, EV_WRITE, NULL) &&
139 if (bufferevent_add_event_(&bufev->ev_write, &bufev->timeout_write) == -1) {
148 struct bufferevent *bufev = arg;
150 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
156 bufferevent_incref_and_lock_(bufev);
166 input = bufev->input;
172 if (bufev->wm_read.high != 0) {
173 howmuch = bufev->wm_read.high - evbuffer_get_length(input);
176 bufferevent_wm_suspend_read(bufev);
212 bufferevent_trigger_nolock_(bufev, EV_READ, 0);
220 bufferevent_disable(bufev, EV_READ);
221 bufferevent_run_eventcb_(bufev, what, 0);
224 bufferevent_decref_and_unlock_(bufev);
230 struct bufferevent *bufev = arg;
232 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
238 bufferevent_incref_and_lock_(bufev);
261 event_del(&bufev->ev_write);
262 event_del(&bufev->ev_read);
263 bufferevent_run_eventcb_(bufev, BEV_EVENT_ERROR, 0);
269 if (BEV_IS_ASYNC(bufev)) {
270 event_del(&bufev->ev_write);
271 bufferevent_async_set_connected_(bufev);
272 bufferevent_run_eventcb_(bufev,
277 bufferevent_run_eventcb_(bufev,
279 if (!(bufev->enabled & EV_WRITE) ||
281 event_del(&bufev->ev_write);
292 if (evbuffer_get_length(bufev->output)) {
293 evbuffer_unfreeze(bufev->output, 1);
294 res = evbuffer_write_atmost(bufev->output, fd, atmost);
295 evbuffer_freeze(bufev->output, 1);
314 if (evbuffer_get_length(bufev->output) == 0) {
315 event_del(&bufev->ev_write);
323 bufferevent_trigger_nolock_(bufev, EV_WRITE, 0);
329 if (evbuffer_get_length(bufev->output) == 0) {
330 event_del(&bufev->ev_write);
335 bufferevent_disable(bufev, EV_WRITE);
336 bufferevent_run_eventcb_(bufev, what, 0);
339 bufferevent_decref_and_unlock_(bufev);
347 struct bufferevent *bufev;
362 bufev = &bufev_p->bev;
363 evbuffer_set_flags(bufev->output, EVBUFFER_FLAG_DRAINS_TO_FD);
365 event_assign(&bufev->ev_read, bufev->ev_base, fd,
366 EV_READ|EV_PERSIST|EV_FINALIZE, bufferevent_readcb, bufev);
367 event_assign(&bufev->ev_write, bufev->ev_base, fd,
368 EV_WRITE|EV_PERSIST|EV_FINALIZE, bufferevent_writecb, bufev);
370 evbuffer_add_cb(bufev->output, bufferevent_socket_outbuf_cb, bufev);
372 evbuffer_freeze(bufev->input, 0);
373 evbuffer_freeze(bufev->output, 1);
375 return bufev;
564 struct bufferevent *bufev;
566 if (!(bufev = bufferevent_socket_new(NULL, fd, 0)))
569 bufferevent_setcb(bufev, readcb, writecb, eventcb, cbarg);
571 return bufev;
576 be_socket_enable(struct bufferevent *bufev, short event)
579 bufferevent_add_event_(&bufev->ev_read, &bufev->timeout_read) == -1)
582 bufferevent_add_event_(&bufev->ev_write, &bufev->timeout_write) == -1)
588 be_socket_disable(struct bufferevent *bufev, short event)
591 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
593 if (event_del(&bufev->ev_read) == -1)
598 if (event_del(&bufev->ev_write) == -1)
605 be_socket_destruct(struct bufferevent *bufev)
608 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
610 EVUTIL_ASSERT(bufev->be_ops == &bufferevent_ops_socket);
612 fd = event_get_fd(&bufev->ev_read);
629 be_socket_setfd(struct bufferevent *bufev, evutil_socket_t fd)
632 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
634 BEV_LOCK(bufev);
635 EVUTIL_ASSERT(bufev->be_ops == &bufferevent_ops_socket);
637 event_del(&bufev->ev_read);
638 event_del(&bufev->ev_write);
640 evbuffer_unfreeze(bufev->input, 0);
641 evbuffer_unfreeze(bufev->output, 1);
643 event_assign(&bufev->ev_read, bufev->ev_base, fd,
644 EV_READ|EV_PERSIST|EV_FINALIZE, bufferevent_readcb, bufev);
645 event_assign(&bufev->ev_write, bufev->ev_base, fd,
646 EV_WRITE|EV_PERSIST|EV_FINALIZE, bufferevent_writecb, bufev);
649 bufferevent_enable(bufev, bufev->enabled);
653 BEV_UNLOCK(bufev);
658 bufferevent_priority_set(struct bufferevent *bufev, int priority)
662 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
664 BEV_LOCK(bufev);
665 if (bufev->be_ops != &bufferevent_ops_socket)
668 if (event_priority_set(&bufev->ev_read, priority) == -1)
670 if (event_priority_set(&bufev->ev_write, priority) == -1)
677 BEV_UNLOCK(bufev);
683 bufferevent_base_set(struct event_base *base, struct bufferevent *bufev)
687 BEV_LOCK(bufev);
688 if (bufev->be_ops != &bufferevent_ops_socket)
691 bufev->ev_base = base;
693 res = event_base_set(base, &bufev->ev_read);
697 res = event_base_set(base, &bufev->ev_write);
699 BEV_UNLOCK(bufev);