| /freebsd/contrib/ntp/sntp/libevent/test/ |
| H A D | regress_buffer.c | 185 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 …]
|
| H A D | regress_zlib.c | 177 } 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 D | regress_bufferevent.c | 107 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 …]
|
| H A D | regress_iocp.c | 274 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 D | regress_http.c | 226 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 …]
|
| H A D | test-ratelim.c | 135 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()
|
| /freebsd/contrib/libevent/test/ |
| H A D | regress_buffer.c | 185 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 …]
|
| H A D | regress_zlib.c | 177 } 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 D | regress_bufferevent.c | 107 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 …]
|
| H A D | regress_iocp.c | 274 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 D | regress_http.c | 226 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 …]
|
| /freebsd/contrib/ntp/sntp/libevent/ |
| H A D | bufferevent_filter.c | 141 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 D | bufferevent_pair.c | 163 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 D | event_tagging.c | 204 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 D | bufferevent_openssl.c | 146 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 D | http.c | 459 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 …]
|
| H A D | bufferevent_sock.c | 175 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/contrib/libevent/ |
| H A D | bufferevent_filter.c | 141 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 D | bufferevent_pair.c | 163 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 D | event_tagging.c | 204 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 D | bufferevent_openssl.c | 146 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 D | http.c | 459 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 …]
|
| H A D | bufferevent_sock.c | 175 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/contrib/ntp/sntp/libevent/sample/ |
| H A D | le-proxy.c | 59 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/contrib/libevent/sample/ |
| H A D | le-proxy.c | 59 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()
|