Lines Matching refs:dst
153 be_pair_transfer(struct bufferevent *src, struct bufferevent *dst, in be_pair_transfer() argument
160 evbuffer_unfreeze(dst->input, 0); in be_pair_transfer()
162 if (dst->wm_read.high) { in be_pair_transfer()
163 dst_size = evbuffer_get_length(dst->input); in be_pair_transfer()
164 if (dst_size < dst->wm_read.high) { in be_pair_transfer()
165 n = dst->wm_read.high - dst_size; in be_pair_transfer()
166 evbuffer_remove_buffer(src->output, dst->input, n); in be_pair_transfer()
171 evbuffer_add_buffer(dst->input, src->output); in be_pair_transfer()
175 evbuffer_add_buffer(dst->input, src->output); in be_pair_transfer()
179 BEV_RESET_GENERIC_READ_TIMEOUT(dst); in be_pair_transfer()
181 if (evbuffer_get_length(dst->output)) in be_pair_transfer()
182 BEV_RESET_GENERIC_WRITE_TIMEOUT(dst); in be_pair_transfer()
184 BEV_DEL_GENERIC_WRITE_TIMEOUT(dst); in be_pair_transfer()
187 bufferevent_trigger_nolock_(dst, EV_READ, 0); in be_pair_transfer()
191 evbuffer_freeze(dst->input, 0); in be_pair_transfer()
196 struct bufferevent_pair *dst) in be_pair_wants_to_talk() argument
199 (downcast(dst)->enabled & EV_READ) && in be_pair_wants_to_talk()
200 !dst->bev.read_suspended && in be_pair_wants_to_talk()