Home
last modified time | relevance | path

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

12

/netbsd-src/external/bsd/libevent/dist/test/
H A Dregress_buffer.c189 tt_assert(evbuffer_get_length(evb) == 7); in test_evbuffer()
197 tt_assert(evbuffer_get_length(evb) == 1); in test_evbuffer()
205 tt_assert(evbuffer_get_length(evb_two) == 0); in test_evbuffer()
206 tt_assert(evbuffer_get_length(evb) == 7); in test_evbuffer()
212 tt_assert(evbuffer_get_length(evb) == 7 + 512); in test_evbuffer()
242 tt_assert(evbuffer_get_length(evb_two) == 0); in test_evbuffer()
243 tt_assert(evbuffer_get_length(evb) == i * sizeof(buffer)); in test_evbuffer()
248 tt_assert(evbuffer_get_length(evb_two) == sz_tmp); in test_evbuffer()
249 tt_assert(evbuffer_get_length(evb) == sizeof(buffer) / 2); in test_evbuffer()
283 tt_assert(evbuffer_get_length(evb) >= 10000); in test_evbuffer()
[all …]
H A Dregress_zlib.c180 } while (evbuffer_get_length(src) > 0); in zlib_input_filter()
234 } while (evbuffer_get_length(src) > 0); in zlib_output_filter()
248 if (evbuffer_get_length(bufferevent_get_input(bev)) == 8333) { in readcb()
257 if (evbuffer_get_length(evbuf) == 8333) { in readcb()
268 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { in writecb()
H A Dregress_bufferevent.c111 if (evbuffer_get_length(bev->input) == 8333) { in readcb()
120 if (evbuffer_get_length(evbuf) == 8333) { in readcb()
131 if (evbuffer_get_length(bev->output) == 0) { in writecb()
374 int len = (int)evbuffer_get_length(bev->input); in wm_readcb()
396 assert(evbuffer_get_length(bev->output) <= 100); in wm_writecb()
397 if (evbuffer_get_length(bev->output) == 0) { in wm_writecb()
398 evbuffer_drain(bev->output, evbuffer_get_length(bev->output)); in wm_writecb()
505 buffer = evbuffer_pullup(src, evbuffer_get_length(src)); in bufferevent_input_filter()
506 for (i = 0; i < evbuffer_get_length(src); i += 2) { in bufferevent_input_filter()
531 buffer = evbuffer_pullup(src, evbuffer_get_length(src)); in bufferevent_output_filter()
[all …]
H A Dregress_iocp.c275 tt_int_op(evbuffer_get_length(buf), ==, sizeof(junk)); in test_iocp_evbuffer()
278 tt_assert(!evbuffer_get_length(rbuf)); in test_iocp_evbuffer()
283 tt_int_op(evbuffer_get_length(rbuf),==,512); in test_iocp_evbuffer()
H A Dregress_http.c231 size_t b_sz = evbuffer_get_length(buf); in evbuffer_datacmp()
301 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { in http_writecb()
498 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { in http_half_writecb()
675 evbuffer_drain(bufferevent_get_input(bev), evbuffer_get_length(bufferevent_get_input(bev))); in http_badreq_readcb()
867 if (evbuffer_get_length(b) != 0) { in http_sent_cb()
1637 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(what)) { in http_request_done()
1858 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != 0) { in http_request_empty_done()
1906 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(what)) { in http_dispatcher_test_done()
1908 …(unsigned long)evbuffer_get_length(evhttp_request_get_input_buffer(req)), (unsigned long)strlen(wh… in http_dispatcher_test_done()
2043 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(POST_DATA)) { in http_post_cb()
[all …]
H A Dtest-ratelim.c136 while (evbuffer_get_length(output) < 8192) { in loud_writecb()
147 size_t len = evbuffer_get_length(input); in discard_readcb()
169 if (evbuffer_get_length(output) > 1024000) in echo_readcb()
177 if (evbuffer_get_length(output) < 512000) in echo_writecb()
H A Dregress.gen.c327 while (evbuffer_get_length(evbuf) > 0) { in msg_unmarshal()
641 while (evbuffer_get_length(evbuf) > 0) { in kill_unmarshal()
1094 while (evbuffer_get_length(evbuf) > 0) { in run_unmarshal()
1113 if (tmp->some_bytes_length > evbuffer_get_length(evbuf)) in run_unmarshal()
H A Dregress_ssl.c359 if (evbuffer_get_length(b)) in done_writing_cb()
819 size_t len = evbuffer_get_length(in); in wm_transfer()
840 evbuffer_get_length(in), in wm_transfer()
841 evbuffer_get_length(out), in wm_transfer()
H A Dtest-fdleak.c87 while (evbuffer_get_length(bufferevent_get_input(bev))) { in server_read_cb()
H A Dbench_httpclient.c78 size_t n = evbuffer_get_length(input); in readcb()
/netbsd-src/external/bsd/libevent/dist/
H A Dbufferevent_filter.c144 evbuffer_get_length(u->output) >= u->wm_write.high; in be_underlying_writebuf_full()
156 evbuffer_get_length(bufev->input) >= bufev->wm_read.high; in be_readbuf_full()
324 evbuffer_get_length(bev->input); in be_filter_process_input()
333 evbuffer_get_length(bevf->underlying->input) && in be_filter_process_input()
361 !evbuffer_get_length(bufev->output)) in be_filter_process_output()
379 evbuffer_get_length(bevf->underlying->output); in be_filter_process_output()
395 evbuffer_get_length(bufev->output) && in be_filter_process_output()
405 evbuffer_get_length(bufev->output) && in be_filter_process_output()
470 if (evbuffer_get_length(underlying->input) > 0 && in be_filter_read_nolock_()
508 if (evbuffer_get_length(bevf->underlying->input) > 0) in bufferevent_filtered_inbuf_cb()
H A Dbufferevent_pair.c166 dst_size = evbuffer_get_length(dst->input); in be_pair_transfer()
173 n = evbuffer_get_length(src->output); in be_pair_transfer()
177 n = evbuffer_get_length(src->output); in be_pair_transfer()
184 if (evbuffer_get_length(dst->output)) in be_pair_transfer()
204 evbuffer_get_length(downcast(src)->output); in be_pair_wants_to_talk()
238 if ((events & EV_WRITE) && evbuffer_get_length(bufev->output)) in be_pair_enable()
H A Devent_tagging.c208 size_t len = evbuffer_get_length(evbuf); in decode_tag_internal()
279 evtag_encode_int(evbuf, (ev_uint32_t)evbuffer_get_length(data)); in evtag_marshal_buffer()
326 ev_ssize_t len = evbuffer_get_length(evbuf) - offset; \
455 if (evbuffer_get_length(evbuf) < len) in evtag_unmarshal_header()
507 if (evbuffer_get_length(evbuf) < len) in evtag_unmarshal_int()
533 if (evbuffer_get_length(evbuf) < len) in evtag_unmarshal_int64()
H A Dbufferevent_openssl.c149 if (evbuffer_get_length(input) == 0) { in bio_bufferevent_read()
174 outlen = evbuffer_get_length(output); in bio_bufferevent_write()
207 ret = evbuffer_get_length(bufferevent_get_input(bufev)) != 0; in bio_bufferevent_ctrl()
210 ret = evbuffer_get_length(bufferevent_get_output(bufev)) != 0; in bio_bufferevent_ctrl()
764 if (evbuffer_get_length(input) >= wm->high) { in bytes_to_read()
768 result = wm->high - evbuffer_get_length(input); in bytes_to_read()
883 evbuffer_get_length(output) && in consider_writing()
884 (!target || (! wm->high || evbuffer_get_length(target) < wm->high))) { in consider_writing()
887 n_to_write = wm->high - evbuffer_get_length(target); in consider_writing()
896 if (evbuffer_get_length(output) == 0) { in consider_writing()
H A Dhttp.c463 EV_SIZE_ARG(evbuffer_get_length(req->output_buffer))); in evhttp_make_header_request()
565 evbuffer_get_length(req->output_buffer)); in evhttp_make_header_response()
632 evbuffer_get_length(req->output_buffer)) { in evhttp_make_header()
919 if ((buflen = evbuffer_get_length(buf)) == 0) { in evhttp_handle_chunked_read()
989 evbuffer_get_length(req->input_buffer)); in evhttp_handle_chunked_read()
1027 size_t n = evbuffer_get_length(buf); in evhttp_lingering_close()
1078 if ((size_t)(req->body_size + evbuffer_get_length(buf)) < req->body_size) { in evhttp_read_body()
1083 req->body_size += evbuffer_get_length(buf); in evhttp_read_body()
1085 } else if (req->chunk_cb != NULL || evbuffer_get_length(buf) >= (size_t)req->ntoread) { in evhttp_read_body()
1089 size_t n = evbuffer_get_length(buf); in evhttp_read_body()
[all …]
H A Dbufferevent_sock.c178 howmuch = bufev->wm_read.high - evbuffer_get_length(input); in bufferevent_readcb()
296 if (evbuffer_get_length(bufev->output)) { in bufferevent_writecb()
318 if (evbuffer_get_length(bufev->output) == 0) { in bufferevent_writecb()
333 if (evbuffer_get_length(bufev->output) == 0) { in bufferevent_writecb()
H A Dbufferevent-internal.h412 evbuffer_get_length(bufev->input) >= bufev->wm_read.low)) in bufferevent_trigger_nolock_()
415 evbuffer_get_length(bufev->output) <= bufev->wm_write.low)) in bufferevent_trigger_nolock_()
H A Dbufferevent.c131 if (evbuffer_get_length(bev->input) < bev->wm_read.high) in bufferevent_inbuf_wm_check()
147 size = evbuffer_get_length(buf); in bufferevent_inbuf_wm_cb()
628 if (evbuffer_get_length(bufev->input) >= highmark) in bufferevent_setwatermark()
630 else if (evbuffer_get_length(bufev->input) < highmark) in bufferevent_setwatermark()
987 evbuffer_get_length(bev->output)) in bufferevent_generic_adj_timeouts_()
H A Dbufferevent_async.c221 !evbuffer_get_length(bev->output)) { in bev_async_consider_writing()
226 at_most = evbuffer_get_length(bev->output); in bev_async_consider_writing()
272 cur_size = evbuffer_get_length(bev->input); in bev_async_consider_reading()
/netbsd-src/external/bsd/libevent/dist/sample/
H A Dle-proxy.c60 len = evbuffer_get_length(src); in readcb()
68 if (evbuffer_get_length(dst) >= MAX_OUTPUT) { in readcb()
98 if (evbuffer_get_length(b) == 0) { in close_on_finished_writecb()
129 if (evbuffer_get_length( in eventcb()
H A Dhello-world.c112 if (evbuffer_get_length(output) == 0) { in conn_writecb()
H A Dhttp-connect.c69 len = evbuffer_get_length(evbuf); in get_cb()
/netbsd-src/external/bsd/ntp/dist/sntp/libevent/test/
H A Dregress_iocp.c276 tt_int_op(evbuffer_get_length(buf), ==, sizeof(junk)); in test_iocp_evbuffer()
279 tt_assert(!evbuffer_get_length(rbuf)); in test_iocp_evbuffer()
284 tt_int_op(evbuffer_get_length(rbuf),==,512); in test_iocp_evbuffer()
/netbsd-src/external/bsd/libevent/dist/include/event2/
H A Dbuffer_compat.h112 #define EVBUFFER_LENGTH(x) evbuffer_get_length(x)
H A Dbuffer.h235 size_t evbuffer_get_length(const struct evbuffer *buf);

12