Lines Matching refs:bufev
96 struct bufferevent_pair *bufev; in bufferevent_pair_elt_new() local
97 if (! (bufev = mm_calloc(1, sizeof(struct bufferevent_pair)))) in bufferevent_pair_elt_new()
99 if (bufferevent_init_common_(&bufev->bev, base, &bufferevent_ops_pair, in bufferevent_pair_elt_new()
101 mm_free(bufev); in bufferevent_pair_elt_new()
104 if (!evbuffer_add_cb(bufev->bev.bev.output, be_pair_outbuf_cb, bufev)) { in bufferevent_pair_elt_new()
105 bufferevent_free(downcast(bufev)); in bufferevent_pair_elt_new()
109 bufferevent_init_generic_timeout_cbs_(&bufev->bev.bev); in bufferevent_pair_elt_new()
111 return bufev; in bufferevent_pair_elt_new()
225 be_pair_enable(struct bufferevent *bufev, short events) in be_pair_enable() argument
227 struct bufferevent_pair *bev_p = upcast(bufev); in be_pair_enable()
230 incref_and_lock(bufev); in be_pair_enable()
233 BEV_RESET_GENERIC_READ_TIMEOUT(bufev); in be_pair_enable()
235 if ((events & EV_WRITE) && evbuffer_get_length(bufev->output)) in be_pair_enable()
236 BEV_RESET_GENERIC_WRITE_TIMEOUT(bufev); in be_pair_enable()
241 be_pair_transfer(downcast(partner), bufev, 0); in be_pair_enable()
246 be_pair_transfer(bufev, downcast(partner), 0); in be_pair_enable()
248 decref_and_unlock(bufev); in be_pair_enable()