Lines Matching refs:partner
50 struct bufferevent_pair *partner; member
77 if (bevp->partner) in incref_and_lock()
78 bufferevent_incref_and_lock_(downcast(bevp->partner)); in incref_and_lock()
85 if (bevp->partner) in decref_and_unlock()
86 bufferevent_decref_and_unlock_(downcast(bevp->partner)); in decref_and_unlock()
141 bufev1->partner = bufev2; in bufferevent_pair_new()
142 bufev2->partner = bufev1; in bufferevent_pair_new()
212 struct bufferevent_pair *partner = bev_pair->partner; in be_pair_outbuf_cb() local
216 if (info->n_added > info->n_deleted && partner) { in be_pair_outbuf_cb()
219 if (be_pair_wants_to_talk(bev_pair, partner)) { in be_pair_outbuf_cb()
220 be_pair_transfer(downcast(bev_pair), downcast(partner), 0); in be_pair_outbuf_cb()
231 struct bufferevent_pair *partner = bev_p->partner; in be_pair_enable() local
242 if ((events & EV_READ) && partner && in be_pair_enable()
243 be_pair_wants_to_talk(partner, bev_p)) { in be_pair_enable()
244 be_pair_transfer(downcast(partner), bufev, 0); in be_pair_enable()
247 if ((events & EV_WRITE) && partner && in be_pair_enable()
248 be_pair_wants_to_talk(bev_p, partner)) { in be_pair_enable()
249 be_pair_transfer(bufev, downcast(partner), 0); in be_pair_enable()
272 if (bev_p->partner) { in be_pair_unlink()
273 bev_p->unlinked_partner = bev_p->partner; in be_pair_unlink()
274 bev_p->partner->partner = NULL; in be_pair_unlink()
275 bev_p->partner = NULL; in be_pair_unlink()
312 struct bufferevent *partner; in be_pair_flush() local
314 if (!bev_p->partner) in be_pair_flush()
322 partner = downcast(bev_p->partner); in be_pair_flush()
325 be_pair_transfer(partner, bev, 1); in be_pair_flush()
328 be_pair_transfer(bev, partner, 1); in be_pair_flush()
336 bufferevent_run_eventcb_(partner, what, 0); in be_pair_flush()
346 struct bufferevent *partner = NULL; in bufferevent_pair_get_partner() local
352 if (bev_p->partner) in bufferevent_pair_get_partner()
353 partner = downcast(bev_p->partner); in bufferevent_pair_get_partner()
355 return partner; in bufferevent_pair_get_partner()