Searched refs:evbuffer_get_length (Results 1 – 13 of 13) sorted by relevance
132 evbuffer_get_length(u->output) >= u->wm_write.high; in be_underlying_writebuf_full()144 evbuffer_get_length(bufev->input) >= bufev->wm_read.high; in be_readbuf_full()296 evbuffer_get_length(bev->input); in be_filter_process_input()305 evbuffer_get_length(bevf->underlying->input) && in be_filter_process_input()333 !evbuffer_get_length(bufev->output)) in be_filter_process_output()350 evbuffer_get_length(bevf->underlying->output); in be_filter_process_output()366 evbuffer_get_length(bufev->output) && in be_filter_process_output()371 evbuffer_get_length(bufev->output) <= bufev->wm_write.low) { in be_filter_process_output()377 evbuffer_get_length(bufev->output) && in be_filter_process_output()437 evbuffer_get_length(bufev->input) >= bufev->wm_read.low) in be_filter_readcb()
161 dst_size = evbuffer_get_length(dst->input); in be_pair_transfer()168 n = evbuffer_get_length(src->output); in be_pair_transfer()172 n = evbuffer_get_length(src->output); in be_pair_transfer()179 if (evbuffer_get_length(dst->output)) in be_pair_transfer()185 src_size = evbuffer_get_length(src->output); in be_pair_transfer()186 dst_size = evbuffer_get_length(dst->input); in be_pair_transfer()206 evbuffer_get_length(downcast(src)->output); in be_pair_wants_to_talk()240 if ((events & EV_WRITE) && evbuffer_get_length(bufev->output)) in be_pair_enable()
198 size_t len = evbuffer_get_length(evbuf); in decode_tag_internal()262 evtag_encode_int(evbuf, (ev_uint32_t)evbuffer_get_length(data)); in evtag_marshal_buffer()309 ev_ssize_t len = evbuffer_get_length(evbuf) - offset; \438 if (evbuffer_get_length(evbuf) < len) in evtag_unmarshal_header()490 if (evbuffer_get_length(evbuf) < len) in evtag_unmarshal_int()516 if (evbuffer_get_length(evbuf) < len) in evtag_unmarshal_int64()
144 if (evbuffer_get_length(input) == 0) { in bio_bufferevent_read()169 outlen = evbuffer_get_length(output); in bio_bufferevent_write()202 ret = evbuffer_get_length(bufferevent_get_input(bufev)) != 0; in bio_bufferevent_ctrl()205 ret = evbuffer_get_length(bufferevent_get_output(bufev)) != 0; in bio_bufferevent_ctrl()707 if (evbuffer_get_length(output) <= bev->wm_write.low) in do_write()742 if (evbuffer_get_length(input) >= wm->high) { in bytes_to_read()746 result = wm->high - evbuffer_get_length(input); in bytes_to_read()824 if (evbuffer_get_length(input) >= bev->wm_read.low) { in consider_reading()852 if (evbuffer_get_length(input) >= bev->wm_read.low) { in consider_writing()867 evbuffer_get_length(output) && in consider_writing()[all …]
150 howmuch = bufev->wm_read.high - evbuffer_get_length(input); in bufferevent_readcb()185 if (evbuffer_get_length(input) >= bufev->wm_read.low) in bufferevent_readcb()265 if (evbuffer_get_length(bufev->output)) { in bufferevent_writecb()287 if (evbuffer_get_length(bufev->output) == 0) { in bufferevent_writecb()296 evbuffer_get_length(bufev->output) <= bufev->wm_write.low) { in bufferevent_writecb()303 if (evbuffer_get_length(bufev->output) == 0) { in bufferevent_writecb()
194 !evbuffer_get_length(bev->output)) { in bev_async_consider_writing()199 at_most = evbuffer_get_length(bev->output); in bev_async_consider_writing()245 cur_size = evbuffer_get_length(bev->input); in bev_async_consider_reading()464 if (evbuffer_get_length(bev->input) >= bev->wm_read.low) in read_complete()508 if (evbuffer_get_length(bev->output) <= in write_complete()
463 EV_SIZE_ARG(evbuffer_get_length(req->output_buffer))); in evhttp_make_header_request()567 evbuffer_get_length(req->output_buffer)); in evhttp_make_header_response()614 if (evbuffer_get_length(req->output_buffer) > 0) { in evhttp_make_header()851 if ((buflen = evbuffer_get_length(buf)) == 0) { in evhttp_handle_chunked_read()921 evbuffer_get_length(req->input_buffer)); in evhttp_handle_chunked_read()982 if ((size_t)(req->body_size + evbuffer_get_length(buf)) < req->body_size) { in evhttp_read_body()987 req->body_size += evbuffer_get_length(buf); in evhttp_read_body()989 } else if (req->chunk_cb != NULL || evbuffer_get_length(buf) >= (size_t)req->ntoread) { in evhttp_read_body()993 size_t n = evbuffer_get_length(buf); in evhttp_read_body()1013 if (evbuffer_get_length(req->input_buffer) > 0 && req->chunk_cb != NULL) { in evhttp_read_body()[all …]
124 size = evbuffer_get_length(buf); in bufferevent_inbuf_wm_cb()548 if (evbuffer_get_length(bufev->input) >= highmark) in bufferevent_setwatermark()550 else if (evbuffer_get_length(bufev->input) < highmark) in bufferevent_setwatermark()845 evbuffer_get_length(bev->output)) in _bufferevent_generic_adj_timeouts()
594 evbuffer_get_length(const struct evbuffer *buffer) in evbuffer_get_length() function3056 cb->size_before_suspend = evbuffer_get_length(buffer);3071 cb->cb(buffer, sz, evbuffer_get_length(buffer), cb->cbarg);
291 evbuffer_get_length(req->input_buffer) <= 0) in evrpc_request_cb()
105 #define EVBUFFER_LENGTH(x) evbuffer_get_length(x)
218 size_t evbuffer_get_length(const struct evbuffer *buf);
35 data_.resize(evbuffer_get_length(input_buffer)); in RequestImpl()