Home
last modified time | relevance | path

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

/minix3/external/bsd/libevent/dist/
H A Dbufferevent_filter.c135 evbuffer_get_length(u->output) >= u->wm_write.high; in be_underlying_writebuf_full()
147 evbuffer_get_length(bufev->input) >= bufev->wm_read.high; in be_readbuf_full()
299 evbuffer_get_length(bev->input); in be_filter_process_input()
308 evbuffer_get_length(bevf->underlying->input) && in be_filter_process_input()
336 !evbuffer_get_length(bufev->output)) in be_filter_process_output()
353 evbuffer_get_length(bevf->underlying->output); in be_filter_process_output()
369 evbuffer_get_length(bufev->output) && in be_filter_process_output()
374 evbuffer_get_length(bufev->output) <= bufev->wm_write.low) { in be_filter_process_output()
380 evbuffer_get_length(bufev->output) && in be_filter_process_output()
440 evbuffer_get_length(bufev->input) >= bufev->wm_read.low) in be_filter_readcb()
H A Dbufferevent_pair.c164 dst_size = evbuffer_get_length(dst->input); in be_pair_transfer()
171 n = evbuffer_get_length(src->output); in be_pair_transfer()
175 n = evbuffer_get_length(src->output); in be_pair_transfer()
182 if (evbuffer_get_length(dst->output)) in be_pair_transfer()
188 src_size = evbuffer_get_length(src->output); in be_pair_transfer()
189 dst_size = evbuffer_get_length(dst->input); in be_pair_transfer()
209 evbuffer_get_length(downcast(src)->output); in be_pair_wants_to_talk()
243 if ((events & EV_WRITE) && evbuffer_get_length(bufev->output)) in be_pair_enable()
H A Devent_tagging.c201 size_t len = evbuffer_get_length(evbuf); in decode_tag_internal()
265 evtag_encode_int(evbuf, (ev_uint32_t)evbuffer_get_length(data)); in evtag_marshal_buffer()
312 ev_ssize_t len = evbuffer_get_length(evbuf) - offset; \
441 if (evbuffer_get_length(evbuf) < len) in evtag_unmarshal_header()
493 if (evbuffer_get_length(evbuf) < len) in evtag_unmarshal_int()
519 if (evbuffer_get_length(evbuf) < len) in evtag_unmarshal_int64()
H A Dbufferevent_openssl.c147 if (evbuffer_get_length(input) == 0) { in bio_bufferevent_read()
172 outlen = evbuffer_get_length(output); in bio_bufferevent_write()
205 ret = evbuffer_get_length(bufferevent_get_input(bufev)) != 0; in bio_bufferevent_ctrl()
208 ret = evbuffer_get_length(bufferevent_get_output(bufev)) != 0; in bio_bufferevent_ctrl()
710 if (evbuffer_get_length(output) <= bev->wm_write.low) in do_write()
745 if (evbuffer_get_length(input) >= wm->high) { in bytes_to_read()
749 result = wm->high - evbuffer_get_length(input); in bytes_to_read()
827 if (evbuffer_get_length(input) >= bev->wm_read.low) { in consider_reading()
855 if (evbuffer_get_length(input) >= bev->wm_read.low) { in consider_writing()
870 evbuffer_get_length(output) && in consider_writing()
[all …]
H A Dbufferevent_sock.c153 howmuch = bufev->wm_read.high - evbuffer_get_length(input); in bufferevent_readcb()
188 if (evbuffer_get_length(input) >= bufev->wm_read.low) in bufferevent_readcb()
268 if (evbuffer_get_length(bufev->output)) { in bufferevent_writecb()
290 if (evbuffer_get_length(bufev->output) == 0) { in bufferevent_writecb()
299 evbuffer_get_length(bufev->output) <= bufev->wm_write.low) { in bufferevent_writecb()
306 if (evbuffer_get_length(bufev->output) == 0) { in bufferevent_writecb()
H A Dbufferevent_async.c197 !evbuffer_get_length(bev->output)) { in bev_async_consider_writing()
202 at_most = evbuffer_get_length(bev->output); in bev_async_consider_writing()
248 cur_size = evbuffer_get_length(bev->input); in bev_async_consider_reading()
467 if (evbuffer_get_length(bev->input) >= bev->wm_read.low) in read_complete()
511 if (evbuffer_get_length(bev->output) <= in write_complete()
H A Dhttp.c466 EV_SIZE_ARG(evbuffer_get_length(req->output_buffer))); in evhttp_make_header_request()
570 evbuffer_get_length(req->output_buffer)); in evhttp_make_header_response()
617 if (evbuffer_get_length(req->output_buffer) > 0) { in evhttp_make_header()
854 if ((buflen = evbuffer_get_length(buf)) == 0) { in evhttp_handle_chunked_read()
924 evbuffer_get_length(req->input_buffer)); in evhttp_handle_chunked_read()
985 if ((size_t)(req->body_size + evbuffer_get_length(buf)) < req->body_size) { in evhttp_read_body()
990 req->body_size += evbuffer_get_length(buf); in evhttp_read_body()
992 } else if (req->chunk_cb != NULL || evbuffer_get_length(buf) >= (size_t)req->ntoread) { in evhttp_read_body()
996 size_t n = evbuffer_get_length(buf); in evhttp_read_body()
1016 if (evbuffer_get_length(req->input_buffer) > 0 && req->chunk_cb != NULL) { in evhttp_read_body()
[all …]
H A Dbufferevent.c127 size = evbuffer_get_length(buf); in bufferevent_inbuf_wm_cb()
551 if (evbuffer_get_length(bufev->input) >= highmark) in bufferevent_setwatermark()
553 else if (evbuffer_get_length(bufev->input) < highmark) in bufferevent_setwatermark()
848 evbuffer_get_length(bev->output)) in _bufferevent_generic_adj_timeouts()
H A Dbuffer.c598 evbuffer_get_length(const struct evbuffer *buffer) in evbuffer_get_length() function
3060 cb->size_before_suspend = evbuffer_get_length(buffer);
3075 cb->cb(buffer, sz, evbuffer_get_length(buffer), cb->cbarg);
H A Devrpc.c294 evbuffer_get_length(req->input_buffer) <= 0) in evrpc_request_cb()
/minix3/external/bsd/libevent/dist/test/
H A Dregress_buffer.c184 tt_assert(evbuffer_get_length(evb) == 7); in test_evbuffer()
192 tt_assert(evbuffer_get_length(evb) == 1); in test_evbuffer()
200 tt_assert(evbuffer_get_length(evb_two) == 0); in test_evbuffer()
201 tt_assert(evbuffer_get_length(evb) == 7); in test_evbuffer()
207 tt_assert(evbuffer_get_length(evb) == 7 + 512); in test_evbuffer()
237 tt_assert(evbuffer_get_length(evb_two) == 0); in test_evbuffer()
238 tt_assert(evbuffer_get_length(evb) == i * sizeof(buffer)); in test_evbuffer()
243 tt_assert(evbuffer_get_length(evb_two) == sz_tmp); in test_evbuffer()
244 tt_assert(evbuffer_get_length(evb) == sizeof(buffer) / 2); in test_evbuffer()
278 tt_assert(evbuffer_get_length(evb) >= 10000); in test_evbuffer()
[all …]
H A Dregress_bufferevent.c97 if (evbuffer_get_length(bev->input) == 8333) { in readcb()
106 if (evbuffer_get_length(evbuf) == 8333) { in readcb()
117 if (evbuffer_get_length(bev->output) == 0) { in writecb()
198 int len = (int)evbuffer_get_length(bev->input); in wm_readcb()
220 assert(evbuffer_get_length(bev->output) <= 100); in wm_writecb()
221 if (evbuffer_get_length(bev->output) == 0) { in wm_writecb()
222 evbuffer_drain(bev->output, evbuffer_get_length(bev->output)); in wm_writecb()
309 buffer = evbuffer_pullup(src, evbuffer_get_length(src)); in bufferevent_input_filter()
310 for (i = 0; i < evbuffer_get_length(src); i += 2) { in bufferevent_input_filter()
314 if (i + 2 > evbuffer_get_length(src)) in bufferevent_input_filter()
[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 Dtest-ratelim.c99 while (evbuffer_get_length(output) < 8192) { in loud_writecb()
110 size_t len = evbuffer_get_length(input); in discard_readcb()
132 if (evbuffer_get_length(output) > 1024000) in echo_readcb()
140 if (evbuffer_get_length(output) < 512000) in echo_writecb()
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.c181 size_t b_sz = evbuffer_get_length(buf); in evbuffer_datacmp()
249 if (evbuffer_get_length(bufferevent_get_output(bev)) == 0) { in http_writecb()
534 evbuffer_drain(bufferevent_get_input(bev), evbuffer_get_length(bufferevent_get_input(bev))); in http_badreq_readcb()
1138 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(what)) { in http_request_done()
1354 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != 0) { in http_request_empty_done()
1397 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(what)) { in http_dispatcher_test_done()
1399 …(unsigned long)evbuffer_get_length(evhttp_request_get_input_buffer(req)), (unsigned long)strlen(wh… in http_dispatcher_test_done()
1536 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(POST_DATA)) { in http_post_cb()
1538 …(unsigned long) evbuffer_get_length(evhttp_request_get_input_buffer(req)), (unsigned long) strlen(… in http_post_cb()
1579 if (evbuffer_get_length(evhttp_request_get_input_buffer(req)) != strlen(what)) { in http_postrequest_done()
[all …]
H A Dbench_httpclient.c78 size_t n = evbuffer_get_length(input); in readcb()
H A Dregress.gen.c319 while (evbuffer_get_length(evbuf) > 0) { in msg_unmarshal()
636 while (evbuffer_get_length(evbuf) > 0) { in kill_unmarshal()
1091 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.c215 if (evbuffer_get_length(b)) in done_writing_cb()
/minix3/external/bsd/libevent/dist/sample/
H A Dle-proxy.c53 len = evbuffer_get_length(src); in readcb()
61 if (evbuffer_get_length(dst) >= MAX_OUTPUT) { in readcb()
91 if (evbuffer_get_length(b) == 0) { in close_on_finished_writecb()
122 if (evbuffer_get_length( in eventcb()
H A Dhello-world.c113 if (evbuffer_get_length(output) == 0) { in conn_writecb()
H A Dhttp-server.c133 while (evbuffer_get_length(buf)) { in dump_request_cb()
/minix3/external/bsd/libevent/dist/include/event2/
H A Dbuffer_compat.h107 #define EVBUFFER_LENGTH(x) evbuffer_get_length(x)
H A Dbuffer.h220 size_t evbuffer_get_length(const struct evbuffer *buf);