Home
last modified time | relevance | path

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

123

/freebsd-14.2/contrib/ntp/sntp/libevent/test/
H A Dregress_buffer.c185 tt_assert(evbuffer_get_length(evb) == 7); in test_evbuffer()
193 tt_assert(evbuffer_get_length(evb) == 1); in test_evbuffer()
202 tt_assert(evbuffer_get_length(evb) == 7); in test_evbuffer()
963 len = evbuffer_get_length(buf); in test_evbuffer_add2()
1048 len = evbuffer_get_length(buf); in test_evbuffer_reference2()
1069 while (evbuffer_get_length(b)) { in addfile_test_writecb()
2153 tt_int_op(evbuffer_get_length(buf1), ==, evbuffer_get_length(buf1)); in test_evbuffer_multicast()
2569 orig_length = evbuffer_get_length(buf); in test_evbuffer_freeze()
2598 len = evbuffer_get_length(tmp_buf); in test_evbuffer_freeze()
2629 len = evbuffer_get_length(buf); in test_evbuffer_freeze()
[all …]
H A 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()
H A 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()
502 for (i = 0; i < evbuffer_get_length(src); i += 2) { in bufferevent_input_filter()
528 for (i = 0; i < evbuffer_get_length(src); ++i) { in bufferevent_output_filter()
532 evbuffer_drain(src, evbuffer_get_length(src)); in bufferevent_output_filter()
1267 size_t read_size = evbuffer_get_length(input); in bufferevent_filter_data_stuck_readcb()
[all …]
H A 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()
H A 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()
862 if (evbuffer_get_length(b) != 0) { in http_sent_cb()
1853 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != 0) { in http_request_empty_done()
3095 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { in http_incomplete_writecb()
3280 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { in http_chunked_writecb()
3496 if (evbuffer_get_length(reply) != expected_len) { in http_stream_in_test_()
3498 (unsigned long)evbuffer_get_length(reply), in http_stream_in_test_()
4629 (int)evbuffer_get_length(body), in http_request_extra_body_test()
[all …]
/freebsd-14.2/contrib/libevent/test/
H A Dregress_buffer.c185 tt_assert(evbuffer_get_length(evb) == 7); in test_evbuffer()
193 tt_assert(evbuffer_get_length(evb) == 1); in test_evbuffer()
202 tt_assert(evbuffer_get_length(evb) == 7); in test_evbuffer()
963 len = evbuffer_get_length(buf); in test_evbuffer_add2()
1048 len = evbuffer_get_length(buf); in test_evbuffer_reference2()
1069 while (evbuffer_get_length(b)) { in addfile_test_writecb()
2153 tt_int_op(evbuffer_get_length(buf1), ==, evbuffer_get_length(buf1)); in test_evbuffer_multicast()
2569 orig_length = evbuffer_get_length(buf); in test_evbuffer_freeze()
2598 len = evbuffer_get_length(tmp_buf); in test_evbuffer_freeze()
2629 len = evbuffer_get_length(buf); in test_evbuffer_freeze()
[all …]
H A 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()
H A 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()
502 for (i = 0; i < evbuffer_get_length(src); i += 2) { in bufferevent_input_filter()
528 for (i = 0; i < evbuffer_get_length(src); ++i) { in bufferevent_output_filter()
532 evbuffer_drain(src, evbuffer_get_length(src)); in bufferevent_output_filter()
1267 size_t read_size = evbuffer_get_length(input); in bufferevent_filter_data_stuck_readcb()
[all …]
H A 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()
H A 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()
862 if (evbuffer_get_length(b) != 0) { in http_sent_cb()
1853 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != 0) { in http_request_empty_done()
3095 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { in http_incomplete_writecb()
3280 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { in http_chunked_writecb()
3496 if (evbuffer_get_length(reply) != expected_len) { in http_stream_in_test_()
3498 (unsigned long)evbuffer_get_length(reply), in http_stream_in_test_()
4629 (int)evbuffer_get_length(body), in http_request_extra_body_test()
[all …]
/freebsd-14.2/contrib/ntp/sntp/libevent/
H A 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()
H A 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()
H A 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()
H A 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()
H A Dhttp.c561 evbuffer_get_length(req->output_buffer)); in evhttp_make_header_response()
628 evbuffer_get_length(req->output_buffer)) { in evhttp_make_header()
985 evbuffer_get_length(req->input_buffer)); in evhttp_handle_chunked_read()
1023 size_t n = evbuffer_get_length(buf); in evhttp_lingering_close()
1079 req->body_size += evbuffer_get_length(buf); in evhttp_read_body()
1085 size_t n = evbuffer_get_length(buf); in evhttp_read_body()
1109 evbuffer_get_length(req->input_buffer)); in evhttp_read_body()
1167 total_len = evbuffer_get_length(input); in evhttp_read_cb()
1207 if (evbuffer_get_length(output) > 0) in evhttp_write_connectioncb()
2905 if (evbuffer_get_length(databuf) == 0) in evhttp_send_reply_chunk_with_cb()
[all …]
H A 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()
/freebsd-14.2/contrib/libevent/
H A 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()
H A 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()
H A 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()
H A 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()
H A Dhttp.c561 evbuffer_get_length(req->output_buffer)); in evhttp_make_header_response()
628 evbuffer_get_length(req->output_buffer)) { in evhttp_make_header()
985 evbuffer_get_length(req->input_buffer)); in evhttp_handle_chunked_read()
1023 size_t n = evbuffer_get_length(buf); in evhttp_lingering_close()
1079 req->body_size += evbuffer_get_length(buf); in evhttp_read_body()
1085 size_t n = evbuffer_get_length(buf); in evhttp_read_body()
1109 evbuffer_get_length(req->input_buffer)); in evhttp_read_body()
1167 total_len = evbuffer_get_length(input); in evhttp_read_cb()
1207 if (evbuffer_get_length(output) > 0) in evhttp_write_connectioncb()
2905 if (evbuffer_get_length(databuf) == 0) in evhttp_send_reply_chunk_with_cb()
[all …]
/freebsd-14.2/contrib/ntp/sntp/libevent/sample/
H A 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()
/freebsd-14.2/contrib/libevent/sample/
H A 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()
/freebsd-14.2/contrib/ntp/sntp/libevent/include/event2/
H A Dbuffer_compat.h111 #define EVBUFFER_LENGTH(x) evbuffer_get_length(x)
/freebsd-14.2/contrib/libevent/include/event2/
H A Dbuffer_compat.h111 #define EVBUFFER_LENGTH(x) evbuffer_get_length(x)

123