Lines Matching defs:bufev
108 struct bufferevent *bufev = arg;
110 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
113 (bufev->enabled & EV_WRITE) &&
114 !event_pending(&bufev->ev_write, EV_WRITE, NULL) &&
118 if (be_socket_add(&bufev->ev_write, &bufev->timeout_write) == -1) {
127 struct bufferevent *bufev = arg;
129 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
135 bufferevent_incref_and_lock_(bufev);
145 input = bufev->input;
151 if (bufev->wm_read.high != 0) {
152 howmuch = bufev->wm_read.high - evbuffer_get_length(input);
155 bufferevent_wm_suspend_read(bufev);
187 bufferevent_trigger_nolock_(bufev, EV_READ, 0);
195 bufferevent_disable(bufev, EV_READ);
196 bufferevent_run_eventcb_(bufev, what, 0);
199 bufferevent_decref_and_unlock_(bufev);
205 struct bufferevent *bufev = arg;
207 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
213 bufferevent_incref_and_lock_(bufev);
236 event_del(&bufev->ev_write);
237 event_del(&bufev->ev_read);
238 bufferevent_run_eventcb_(bufev, BEV_EVENT_ERROR, 0);
243 if (BEV_IS_ASYNC(bufev)) {
244 event_del(&bufev->ev_write);
245 bufferevent_async_set_connected_(bufev);
246 bufferevent_run_eventcb_(bufev,
251 bufferevent_run_eventcb_(bufev,
253 if (!(bufev->enabled & EV_WRITE) ||
255 event_del(&bufev->ev_write);
266 if (evbuffer_get_length(bufev->output)) {
267 evbuffer_unfreeze(bufev->output, 1);
268 res = evbuffer_write_atmost(bufev->output, fd, atmost);
269 evbuffer_freeze(bufev->output, 1);
288 if (evbuffer_get_length(bufev->output) == 0) {
289 event_del(&bufev->ev_write);
297 bufferevent_trigger_nolock_(bufev, EV_WRITE, 0);
303 if (evbuffer_get_length(bufev->output) == 0) {
304 event_del(&bufev->ev_write);
309 bufferevent_disable(bufev, EV_WRITE);
310 bufferevent_run_eventcb_(bufev, what, 0);
313 bufferevent_decref_and_unlock_(bufev);
321 struct bufferevent *bufev;
336 bufev = &bufev_p->bev;
337 evbuffer_set_flags(bufev->output, EVBUFFER_FLAG_DRAINS_TO_FD);
339 event_assign(&bufev->ev_read, bufev->ev_base, fd,
340 EV_READ|EV_PERSIST|EV_FINALIZE, bufferevent_readcb, bufev);
341 event_assign(&bufev->ev_write, bufev->ev_base, fd,
342 EV_WRITE|EV_PERSIST|EV_FINALIZE, bufferevent_writecb, bufev);
344 evbuffer_add_cb(bufev->output, bufferevent_socket_outbuf_cb, bufev);
346 evbuffer_freeze(bufev->input, 0);
347 evbuffer_freeze(bufev->output, 1);
349 return bufev;
539 struct bufferevent *bufev;
541 if (!(bufev = bufferevent_socket_new(NULL, fd, 0)))
544 bufferevent_setcb(bufev, readcb, writecb, eventcb, cbarg);
546 return bufev;
551 be_socket_enable(struct bufferevent *bufev, short event)
554 if (be_socket_add(&bufev->ev_read,&bufev->timeout_read) == -1)
558 if (be_socket_add(&bufev->ev_write,&bufev->timeout_write) == -1)
565 be_socket_disable(struct bufferevent *bufev, short event)
568 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
570 if (event_del(&bufev->ev_read) == -1)
575 if (event_del(&bufev->ev_write) == -1)
582 be_socket_destruct(struct bufferevent *bufev)
585 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
587 EVUTIL_ASSERT(bufev->be_ops == &bufferevent_ops_socket);
589 fd = event_get_fd(&bufev->ev_read);
596 be_socket_adj_timeouts(struct bufferevent *bufev)
599 if (event_pending(&bufev->ev_read, EV_READ, NULL)) {
600 if (evutil_timerisset(&bufev->timeout_read)) {
601 if (be_socket_add(&bufev->ev_read, &bufev->timeout_read) < 0)
604 event_remove_timer(&bufev->ev_read);
607 if (event_pending(&bufev->ev_write, EV_WRITE, NULL)) {
608 if (evutil_timerisset(&bufev->timeout_write)) {
609 if (be_socket_add(&bufev->ev_write, &bufev->timeout_write) < 0)
612 event_remove_timer(&bufev->ev_write);
627 be_socket_setfd(struct bufferevent *bufev, evutil_socket_t fd)
629 BEV_LOCK(bufev);
630 EVUTIL_ASSERT(bufev->be_ops == &bufferevent_ops_socket);
632 event_del(&bufev->ev_read);
633 event_del(&bufev->ev_write);
635 event_assign(&bufev->ev_read, bufev->ev_base, fd,
636 EV_READ|EV_PERSIST|EV_FINALIZE, bufferevent_readcb, bufev);
637 event_assign(&bufev->ev_write, bufev->ev_base, fd,
638 EV_WRITE|EV_PERSIST|EV_FINALIZE, bufferevent_writecb, bufev);
641 bufferevent_enable(bufev, bufev->enabled);
643 BEV_UNLOCK(bufev);
648 bufferevent_priority_set(struct bufferevent *bufev, int priority)
652 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev);
654 BEV_LOCK(bufev);
655 if (bufev->be_ops != &bufferevent_ops_socket)
658 if (event_priority_set(&bufev->ev_read, priority) == -1)
660 if (event_priority_set(&bufev->ev_write, priority) == -1)
667 BEV_UNLOCK(bufev);
673 bufferevent_base_set(struct event_base *base, struct bufferevent *bufev)
677 BEV_LOCK(bufev);
678 if (bufev->be_ops != &bufferevent_ops_socket)
681 bufev->ev_base = base;
683 res = event_base_set(base, &bufev->ev_read);
687 res = event_base_set(base, &bufev->ev_write);
689 BEV_UNLOCK(bufev);