Home
last modified time | relevance | path

Searched refs:evbuffer_get_length (Results 1 – 25 of 27) sorted by relevance

12

/external/libevent/test/
Dregress_buffer.c185 tt_assert(evbuffer_get_length(evb) == 7); in test_evbuffer()
193 tt_assert(evbuffer_get_length(evb) == 1); in test_evbuffer()
201 tt_assert(evbuffer_get_length(evb_two) == 0); in test_evbuffer()
202 tt_assert(evbuffer_get_length(evb) == 7); in test_evbuffer()
208 tt_assert(evbuffer_get_length(evb) == 7 + 512); in test_evbuffer()
238 tt_assert(evbuffer_get_length(evb_two) == 0); in test_evbuffer()
239 tt_assert(evbuffer_get_length(evb) == i * sizeof(buffer)); in test_evbuffer()
244 tt_assert(evbuffer_get_length(evb_two) == sz_tmp); in test_evbuffer()
245 tt_assert(evbuffer_get_length(evb) == sizeof(buffer) / 2); in test_evbuffer()
279 tt_assert(evbuffer_get_length(evb) >= 10000); in test_evbuffer()
[all …]
Dregress_zlib.c177 } while (evbuffer_get_length(src) > 0); in zlib_input_filter()
231 } while (evbuffer_get_length(src) > 0); in zlib_output_filter()
245 if (evbuffer_get_length(bufferevent_get_input(bev)) == 8333) { in readcb()
254 if (evbuffer_get_length(evbuf) == 8333) { in readcb()
265 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { in writecb()
Dregress_bufferevent.c107 if (evbuffer_get_length(bev->input) == 8333) { in readcb()
116 if (evbuffer_get_length(evbuf) == 8333) { in readcb()
127 if (evbuffer_get_length(bev->output) == 0) { in writecb()
370 int len = (int)evbuffer_get_length(bev->input); in wm_readcb()
392 assert(evbuffer_get_length(bev->output) <= 100); in wm_writecb()
393 if (evbuffer_get_length(bev->output) == 0) { in wm_writecb()
394 evbuffer_drain(bev->output, evbuffer_get_length(bev->output)); in wm_writecb()
501 buffer = evbuffer_pullup(src, evbuffer_get_length(src)); in bufferevent_input_filter()
502 for (i = 0; i < evbuffer_get_length(src); i += 2) { in bufferevent_input_filter()
527 buffer = evbuffer_pullup(src, evbuffer_get_length(src)); in bufferevent_output_filter()
[all …]
Dregress_iocp.c274 tt_int_op(evbuffer_get_length(buf), ==, sizeof(junk)); in test_iocp_evbuffer()
277 tt_assert(!evbuffer_get_length(rbuf)); in test_iocp_evbuffer()
282 tt_int_op(evbuffer_get_length(rbuf),==,512); in test_iocp_evbuffer()
Dregress_http.c226 size_t b_sz = evbuffer_get_length(buf); in evbuffer_datacmp()
296 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { in http_writecb()
493 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { in http_half_writecb()
670 evbuffer_drain(bufferevent_get_input(bev), evbuffer_get_length(bufferevent_get_input(bev))); in http_badreq_readcb()
862 if (evbuffer_get_length(b) != 0) { in http_sent_cb()
1632 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(what)) { in http_request_done()
1853 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != 0) { in http_request_empty_done()
1901 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(what)) { in http_dispatcher_test_done()
1903 …(unsigned long)evbuffer_get_length(evhttp_request_get_input_buffer(req)), (unsigned long)strlen(wh… in http_dispatcher_test_done()
2038 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(POST_DATA)) { in http_post_cb()
[all …]
Dtest-ratelim.c135 while (evbuffer_get_length(output) < 8192) { in loud_writecb()
146 size_t len = evbuffer_get_length(input); in discard_readcb()
168 if (evbuffer_get_length(output) > 1024000) in echo_readcb()
176 if (evbuffer_get_length(output) < 512000) in echo_writecb()
Dregress_ssl.c356 if (evbuffer_get_length(b)) in done_writing_cb()
817 size_t len = evbuffer_get_length(in); in wm_transfer()
838 evbuffer_get_length(in), in wm_transfer()
839 evbuffer_get_length(out), in wm_transfer()
Dtest-fdleak.c84 while (evbuffer_get_length(bufferevent_get_input(bev))) { in server_read_cb()
Dregress.gen.c326 while (evbuffer_get_length(evbuf) > 0) { in msg_unmarshal()
640 while (evbuffer_get_length(evbuf) > 0) { in kill_unmarshal()
1093 while (evbuffer_get_length(evbuf) > 0) { in run_unmarshal()
1112 if (tmp->some_bytes_length > evbuffer_get_length(evbuf)) in run_unmarshal()
Dbench_httpclient.c77 size_t n = evbuffer_get_length(input); in readcb()
/external/libevent/
Dbufferevent_filter.c141 evbuffer_get_length(u->output) >= u->wm_write.high; in be_underlying_writebuf_full()
153 evbuffer_get_length(bufev->input) >= bufev->wm_read.high; in be_readbuf_full()
321 evbuffer_get_length(bev->input); in be_filter_process_input()
330 evbuffer_get_length(bevf->underlying->input) && in be_filter_process_input()
358 !evbuffer_get_length(bufev->output)) in be_filter_process_output()
376 evbuffer_get_length(bevf->underlying->output); in be_filter_process_output()
392 evbuffer_get_length(bufev->output) && in be_filter_process_output()
402 evbuffer_get_length(bufev->output) && in be_filter_process_output()
467 if (evbuffer_get_length(underlying->input) > 0 && in be_filter_read_nolock_()
505 if (evbuffer_get_length(bevf->underlying->input) > 0) in bufferevent_filtered_inbuf_cb()
Dbufferevent_pair.c163 dst_size = evbuffer_get_length(dst->input); in be_pair_transfer()
170 n = evbuffer_get_length(src->output); in be_pair_transfer()
174 n = evbuffer_get_length(src->output); in be_pair_transfer()
181 if (evbuffer_get_length(dst->output)) in be_pair_transfer()
201 evbuffer_get_length(downcast(src)->output); in be_pair_wants_to_talk()
235 if ((events & EV_WRITE) && evbuffer_get_length(bufev->output)) in be_pair_enable()
Devent_tagging.c204 size_t len = evbuffer_get_length(evbuf); in decode_tag_internal()
275 evtag_encode_int(evbuf, (ev_uint32_t)evbuffer_get_length(data)); in evtag_marshal_buffer()
322 ev_ssize_t len = evbuffer_get_length(evbuf) - offset; \
451 if (evbuffer_get_length(evbuf) < len) in evtag_unmarshal_header()
503 if (evbuffer_get_length(evbuf) < len) in evtag_unmarshal_int()
529 if (evbuffer_get_length(evbuf) < len) in evtag_unmarshal_int64()
Dbufferevent_openssl.c146 if (evbuffer_get_length(input) == 0) { in bio_bufferevent_read()
171 outlen = evbuffer_get_length(output); in bio_bufferevent_write()
204 ret = evbuffer_get_length(bufferevent_get_input(bufev)) != 0; in bio_bufferevent_ctrl()
207 ret = evbuffer_get_length(bufferevent_get_output(bufev)) != 0; in bio_bufferevent_ctrl()
761 if (evbuffer_get_length(input) >= wm->high) { in bytes_to_read()
765 result = wm->high - evbuffer_get_length(input); in bytes_to_read()
880 evbuffer_get_length(output) && in consider_writing()
881 (!target || (! wm->high || evbuffer_get_length(target) < wm->high))) { in consider_writing()
884 n_to_write = wm->high - evbuffer_get_length(target); in consider_writing()
893 if (evbuffer_get_length(output) == 0) { in consider_writing()
Dhttp.c459 EV_SIZE_ARG(evbuffer_get_length(req->output_buffer))); in evhttp_make_header_request()
561 evbuffer_get_length(req->output_buffer)); in evhttp_make_header_response()
628 evbuffer_get_length(req->output_buffer)) { in evhttp_make_header()
915 if ((buflen = evbuffer_get_length(buf)) == 0) { in evhttp_handle_chunked_read()
985 evbuffer_get_length(req->input_buffer)); in evhttp_handle_chunked_read()
1023 size_t n = evbuffer_get_length(buf); in evhttp_lingering_close()
1074 if ((size_t)(req->body_size + evbuffer_get_length(buf)) < req->body_size) { in evhttp_read_body()
1079 req->body_size += evbuffer_get_length(buf); in evhttp_read_body()
1081 } else if (req->chunk_cb != NULL || evbuffer_get_length(buf) >= (size_t)req->ntoread) { in evhttp_read_body()
1085 size_t n = evbuffer_get_length(buf); in evhttp_read_body()
[all …]
Dbufferevent_sock.c175 howmuch = bufev->wm_read.high - evbuffer_get_length(input); in bufferevent_readcb()
293 if (evbuffer_get_length(bufev->output)) { in bufferevent_writecb()
315 if (evbuffer_get_length(bufev->output) == 0) { in bufferevent_writecb()
330 if (evbuffer_get_length(bufev->output) == 0) { in bufferevent_writecb()
Dbufferevent-internal.h410 evbuffer_get_length(bufev->input) >= bufev->wm_read.low)) in bufferevent_trigger_nolock_()
413 evbuffer_get_length(bufev->output) <= bufev->wm_write.low)) in bufferevent_trigger_nolock_()
Dbufferevent.c127 if (evbuffer_get_length(bev->input) < bev->wm_read.high) in bufferevent_inbuf_wm_check()
143 size = evbuffer_get_length(buf); in bufferevent_inbuf_wm_cb()
624 if (evbuffer_get_length(bufev->input) >= highmark) in bufferevent_setwatermark()
626 else if (evbuffer_get_length(bufev->input) < highmark) in bufferevent_setwatermark()
983 evbuffer_get_length(bev->output)) in bufferevent_generic_adj_timeouts_()
Dbufferevent_async.c218 !evbuffer_get_length(bev->output)) { in bev_async_consider_writing()
223 at_most = evbuffer_get_length(bev->output); in bev_async_consider_writing()
269 cur_size = evbuffer_get_length(bev->input); in bev_async_consider_reading()
/external/libevent/sample/
Dle-proxy.c59 len = evbuffer_get_length(src); in readcb()
67 if (evbuffer_get_length(dst) >= MAX_OUTPUT) { in readcb()
97 if (evbuffer_get_length(b) == 0) { in close_on_finished_writecb()
128 if (evbuffer_get_length( in eventcb()
Dhello-world.c111 if (evbuffer_get_length(output) == 0) { in conn_writecb()
Dhttp-connect.c66 len = evbuffer_get_length(evbuf); in get_cb()
Dhttp-server.c165 while (evbuffer_get_length(buf)) { in dump_request_cb()
/external/libevent/include/event2/
Dbuffer_compat.h111 #define EVBUFFER_LENGTH(x) evbuffer_get_length(x)
Dbuffer.h234 size_t evbuffer_get_length(const struct evbuffer *buf);

12