Home
last modified time | relevance | path

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

/NextBSD/contrib/ntp/sntp/libevent/test/
HDregress_buffer.c183 tt_assert(evbuffer_get_length(evb) == 7); in test_evbuffer()
191 tt_assert(evbuffer_get_length(evb) == 1); in test_evbuffer()
199 tt_assert(evbuffer_get_length(evb_two) == 0); in test_evbuffer()
200 tt_assert(evbuffer_get_length(evb) == 7); in test_evbuffer()
206 tt_assert(evbuffer_get_length(evb) == 7 + 512); in test_evbuffer()
236 tt_assert(evbuffer_get_length(evb_two) == 0); in test_evbuffer()
237 tt_assert(evbuffer_get_length(evb) == i * sizeof(buffer)); in test_evbuffer()
242 tt_assert(evbuffer_get_length(evb_two) == sz_tmp); in test_evbuffer()
243 tt_assert(evbuffer_get_length(evb) == sizeof(buffer) / 2); in test_evbuffer()
277 tt_assert(evbuffer_get_length(evb) >= 10000); in test_evbuffer()
[all …]
HDregress_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()
HDregress_bufferevent.c94 if (evbuffer_get_length(bev->input) == 8333) { in readcb()
103 if (evbuffer_get_length(evbuf) == 8333) { in readcb()
114 if (evbuffer_get_length(bev->output) == 0) { in writecb()
344 int len = (int)evbuffer_get_length(bev->input); in wm_readcb()
366 assert(evbuffer_get_length(bev->output) <= 100); in wm_writecb()
367 if (evbuffer_get_length(bev->output) == 0) { in wm_writecb()
368 evbuffer_drain(bev->output, evbuffer_get_length(bev->output)); in wm_writecb()
475 buffer = evbuffer_pullup(src, evbuffer_get_length(src)); in bufferevent_input_filter()
476 for (i = 0; i < evbuffer_get_length(src); i += 2) { in bufferevent_input_filter()
480 if (i + 2 > evbuffer_get_length(src)) in bufferevent_input_filter()
[all …]
HDregress_http.c201 size_t b_sz = evbuffer_get_length(buf); in evbuffer_datacmp()
269 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { in http_writecb()
577 evbuffer_drain(bufferevent_get_input(bev), evbuffer_get_length(bufferevent_get_input(bev))); in http_badreq_readcb()
769 if (evbuffer_get_length(b) != 0) { in http_sent_cb()
1341 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(what)) { in http_request_done()
1557 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != 0) { in http_request_empty_done()
1600 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(what)) { in http_dispatcher_test_done()
1602 …(unsigned long)evbuffer_get_length(evhttp_request_get_input_buffer(req)), (unsigned long)strlen(wh… in http_dispatcher_test_done()
1739 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(POST_DATA)) { in http_post_cb()
1741 …(unsigned long) evbuffer_get_length(evhttp_request_get_input_buffer(req)), (unsigned long) strlen(… in http_post_cb()
[all …]
HDtest-ratelim.c119 while (evbuffer_get_length(output) < 8192) { in loud_writecb()
130 size_t len = evbuffer_get_length(input); in discard_readcb()
152 if (evbuffer_get_length(output) > 1024000) in echo_readcb()
160 if (evbuffer_get_length(output) < 512000) in echo_writecb()
HDregress_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()
HDtest-fdleak.c84 while (evbuffer_get_length(bufferevent_get_input(bev))) { in server_read_cb()
HDbench_httpclient.c77 size_t n = evbuffer_get_length(input); in readcb()
HDregress_ssl.c219 if (evbuffer_get_length(b)) in done_writing_cb()
/NextBSD/contrib/ntp/sntp/libevent/
HDbufferevent_filter.c136 evbuffer_get_length(u->output) >= u->wm_write.high; in be_underlying_writebuf_full()
148 evbuffer_get_length(bufev->input) >= bufev->wm_read.high; in be_readbuf_full()
305 evbuffer_get_length(bev->input); in be_filter_process_input()
314 evbuffer_get_length(bevf->underlying->input) && in be_filter_process_input()
342 !evbuffer_get_length(bufev->output)) in be_filter_process_output()
359 evbuffer_get_length(bevf->underlying->output); in be_filter_process_output()
375 evbuffer_get_length(bufev->output) && in be_filter_process_output()
385 evbuffer_get_length(bufev->output) && in be_filter_process_output()
HDbufferevent_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()
HDevent_tagging.c199 size_t len = evbuffer_get_length(evbuf); in decode_tag_internal()
270 evtag_encode_int(evbuf, (ev_uint32_t)evbuffer_get_length(data)); in evtag_marshal_buffer()
317 ev_ssize_t len = evbuffer_get_length(evbuf) - offset; \
446 if (evbuffer_get_length(evbuf) < len) in evtag_unmarshal_header()
498 if (evbuffer_get_length(evbuf) < len) in evtag_unmarshal_int()
524 if (evbuffer_get_length(evbuf) < len) in evtag_unmarshal_int64()
HDbufferevent_openssl.c150 if (evbuffer_get_length(input) == 0) { in bio_bufferevent_read()
175 outlen = evbuffer_get_length(output); in bio_bufferevent_write()
208 ret = evbuffer_get_length(bufferevent_get_input(bufev)) != 0; in bio_bufferevent_ctrl()
211 ret = evbuffer_get_length(bufferevent_get_output(bufev)) != 0; in bio_bufferevent_ctrl()
751 if (evbuffer_get_length(input) >= wm->high) { in bytes_to_read()
755 result = wm->high - evbuffer_get_length(input); in bytes_to_read()
870 evbuffer_get_length(output) && in consider_writing()
871 (!target || (! wm->high || evbuffer_get_length(target) < wm->high))) { in consider_writing()
874 n_to_write = wm->high - evbuffer_get_length(target); in consider_writing()
883 if (evbuffer_get_length(output) == 0) { in consider_writing()
HDhttp.c444 EV_SIZE_ARG(evbuffer_get_length(req->output_buffer))); in evhttp_make_header_request()
548 evbuffer_get_length(req->output_buffer)); in evhttp_make_header_response()
597 if (evbuffer_get_length(req->output_buffer) > 0) { in evhttp_make_header()
865 if ((buflen = evbuffer_get_length(buf)) == 0) { in evhttp_handle_chunked_read()
935 evbuffer_get_length(req->input_buffer)); in evhttp_handle_chunked_read()
996 if ((size_t)(req->body_size + evbuffer_get_length(buf)) < req->body_size) { in evhttp_read_body()
1001 req->body_size += evbuffer_get_length(buf); in evhttp_read_body()
1003 } else if (req->chunk_cb != NULL || evbuffer_get_length(buf) >= (size_t)req->ntoread) { in evhttp_read_body()
1007 size_t n = evbuffer_get_length(buf); in evhttp_read_body()
1027 if (evbuffer_get_length(req->input_buffer) > 0 && req->chunk_cb != NULL) { in evhttp_read_body()
[all …]
HDbufferevent_sock.c152 howmuch = bufev->wm_read.high - evbuffer_get_length(input); in bufferevent_readcb()
266 if (evbuffer_get_length(bufev->output)) { in bufferevent_writecb()
288 if (evbuffer_get_length(bufev->output) == 0) { in bufferevent_writecb()
303 if (evbuffer_get_length(bufev->output) == 0) { in bufferevent_writecb()
HDbufferevent-internal.h365 evbuffer_get_length(bufev->input) >= bufev->wm_read.low)) in bufferevent_trigger_nolock_()
368 evbuffer_get_length(bufev->output) <= bufev->wm_write.low)) in bufferevent_trigger_nolock_()
HDbufferevent_async.c196 !evbuffer_get_length(bev->output)) { in bev_async_consider_writing()
201 at_most = evbuffer_get_length(bev->output); in bev_async_consider_writing()
247 cur_size = evbuffer_get_length(bev->input); in bev_async_consider_reading()
HDbufferevent.c126 size = evbuffer_get_length(buf); in bufferevent_inbuf_wm_cb()
602 if (evbuffer_get_length(bufev->input) >= highmark) in bufferevent_setwatermark()
604 else if (evbuffer_get_length(bufev->input) < highmark) in bufferevent_setwatermark()
959 evbuffer_get_length(bev->output)) in bufferevent_generic_adj_timeouts_()
HDbuffer.c606 evbuffer_get_length(const struct evbuffer *buffer) in evbuffer_get_length() function
3401 cb->size_before_suspend = evbuffer_get_length(buffer);
3416 cb->cb(buffer, sz, evbuffer_get_length(buffer), cb->cbarg);
HDevrpc.c292 evbuffer_get_length(req->input_buffer) <= 0) in evrpc_request_cb()
/NextBSD/contrib/ntp/sntp/libevent/include/event2/
HDbuffer_compat.h110 #define EVBUFFER_LENGTH(x) evbuffer_get_length(x)
HDbuffer.h234 size_t evbuffer_get_length(const struct evbuffer *buf);