Home
last modified time | relevance | path

Searched refs:input (Results 1 – 16 of 16) sorted by relevance

/libevent-2.1.12/
H A Dbufferevent_async.c269 cur_size = evbuffer_get_length(bev->input); in bev_async_consider_reading()
405 fd = evbuffer_overlapped_get_fd_(bev->input); in be_async_destruct()
421 fd = evbuffer_overlapped_get_fd_(bev->input); in bev_async_set_wsa_error()
444 sock = evbuffer_overlapped_get_fd_(bev_a->bev.bev.input); in connect_complete()
472 evbuffer_commit_read_(bev->input, nbytes); in read_complete()
564 if (!(bev->input = evbuffer_overlapped_new_(fd))) { in bufferevent_async_new_()
569 evbuffer_free(bev->input); in bufferevent_async_new_()
578 evbuffer_add_cb(bev->input, be_async_inbuf_callback, bev); in bufferevent_async_new_()
670 data->fd = evbuffer_overlapped_get_fd_(bev->input); in be_async_ctrl()
676 if (data->fd == evbuffer_overlapped_get_fd_(bev->input)) in be_async_ctrl()
[all …]
H A Dbufferevent_filter.c153 evbuffer_get_length(bufev->input) >= bufev->wm_read.high; in be_readbuf_full()
211 bufev_f->inbuf_cb = evbuffer_add_cb(downcast(bufev_f)->input, in bufferevent_filter_new()
266 evbuffer_remove_cb_entry(bev->input, bevf->inbuf_cb); in be_filter_destruct()
321 evbuffer_get_length(bev->input); in be_filter_process_input()
323 res = bevf->process_in(bevf->underlying->input, in be_filter_process_input()
324 bev->input, limit, state, bevf->context); in be_filter_process_input()
330 evbuffer_get_length(bevf->underlying->input) && in be_filter_process_input()
467 if (evbuffer_get_length(underlying->input) > 0 && in be_filter_read_nolock_()
474 evbuffer_cb_set_flags(bufev->input, bevf->inbuf_cb, in be_filter_read_nolock_()
503 evbuffer_cb_clear_flags(bev->input, bevf->inbuf_cb, in bufferevent_filtered_inbuf_cb()
[all …]
H A Dbufferevent_pair.c141 evbuffer_freeze(downcast(bufev1)->input, 0); in bufferevent_pair_new()
143 evbuffer_freeze(downcast(bufev2)->input, 0); in bufferevent_pair_new()
160 evbuffer_unfreeze(dst->input, 0); in be_pair_transfer()
163 dst_size = evbuffer_get_length(dst->input); in be_pair_transfer()
166 evbuffer_remove_buffer(src->output, dst->input, n); in be_pair_transfer()
171 evbuffer_add_buffer(dst->input, src->output); in be_pair_transfer()
175 evbuffer_add_buffer(dst->input, src->output); in be_pair_transfer()
191 evbuffer_freeze(dst->input, 0); in be_pair_transfer()
H A Dbufferevent.c316 if (!bufev->input) { in bufferevent_init_common_()
317 if ((bufev->input = evbuffer_new()) == NULL) in bufferevent_init_common_()
371 evbuffer_set_parent_(bufev->input, bufev); in bufferevent_init_common_()
377 if (bufev->input) { in bufferevent_init_common_()
378 evbuffer_free(bufev->input); in bufferevent_init_common_()
379 bufev->input = NULL; in bufferevent_init_common_()
426 return bufev->input; in bufferevent_get_input()
616 evbuffer_add_cb(bufev->input, in bufferevent_setwatermark()
620 evbuffer_cb_set_flags(bufev->input, in bufferevent_setwatermark()
631 evbuffer_cb_clear_flags(bufev->input, in bufferevent_setwatermark()
[all …]
H A Dbufferevent_sock.c153 struct evbuffer *input; in bufferevent_readcb() local
168 input = bufev->input; in bufferevent_readcb()
175 howmuch = bufev->wm_read.high - evbuffer_get_length(input); in bufferevent_readcb()
189 evbuffer_unfreeze(input, 0); in bufferevent_readcb()
190 …res = evbuffer_read(input, fd, (int)howmuch); /* XXXX evbuffer_read would do better to take and re… in bufferevent_readcb()
191 evbuffer_freeze(input, 0); in bufferevent_readcb()
373 evbuffer_freeze(bufev->input, 0); in bufferevent_socket_new()
629 evbuffer_unfreeze(bufev->input, 0); in be_socket_setfd()
H A Dbufferevent_openssl.c136 struct evbuffer *input; in bio_bufferevent_read() local
145 input = bufferevent_get_input(BIO_get_data(b)); in bio_bufferevent_read()
146 if (evbuffer_get_length(input) == 0) { in bio_bufferevent_read()
151 r = evbuffer_remove(input, out, outlen); in bio_bufferevent_read()
587 struct evbuffer *input = bev->input; in do_read() local
599 n = evbuffer_reserve_space(input, n_to_read, space, 2); in do_read()
643 evbuffer_commit_space(input, space, n_used); in do_read()
741 struct evbuffer *input = bev->bev.bev.input; in bytes_to_read() local
761 if (evbuffer_get_length(input) >= wm->high) { in bytes_to_read()
765 result = wm->high - evbuffer_get_length(input); in bytes_to_read()
H A Dbufferevent-internal.h410 evbuffer_get_length(bufev->input) >= bufev->wm_read.low)) in bufferevent_trigger_nolock_()
H A DDoxyfile58 # configuration options related to the input files
222 # contain include files that are not input files but should be processed by
H A Dhttp.c586 static enum expect evhttp_have_expect(struct evhttp_request *req, int input) in evhttp_have_expect() argument
589 struct evkeyvalq *h = input ? req->input_headers : req->output_headers; in evhttp_have_expect()
1163 struct evbuffer *input; in evhttp_read_cb() local
1166 input = bufferevent_get_input(evcon->bufev); in evhttp_read_cb()
1167 total_len = evbuffer_get_length(input); in evhttp_read_cb()
H A DChangeLog-1.4211 …o support for hooks on rpc input and output; can be used to implement rpc independent processing s…
H A Dwhatsnew-2.0.txt332 input or output memory buffer. In previous versions, the implementation
H A DChangeLog-2.01058 …an fail rather than asserting when the user gives it bad input. event_set still dies on bad input.
1212 …o Support input/output filters for bufferevents; somewhat similar to libio's model. This will all…
/libevent-2.1.12/test/
H A Dbench_httpclient.c76 struct evbuffer *input = bufferevent_get_input(b); in readcb() local
77 size_t n = evbuffer_get_length(input); in readcb()
80 evbuffer_drain(input, n); in readcb()
H A Dtest-ratelim.c145 struct evbuffer *input = bufferevent_get_input(bev); in discard_readcb() local
146 size_t len = evbuffer_get_length(input); in discard_readcb()
147 evbuffer_drain(input, len); in discard_readcb()
164 struct evbuffer *input = bufferevent_get_input(bev); in echo_readcb() local
167 evbuffer_add_buffer(output, input); in echo_readcb()
H A Dregress_bufferevent.c107 if (evbuffer_get_length(bev->input) == 8333) { in readcb()
370 int len = (int)evbuffer_get_length(bev->input); in wm_readcb()
1266 struct evbuffer *input = bufferevent_get_input(bev); in bufferevent_filter_data_stuck_readcb() local
1267 size_t read_size = evbuffer_get_length(input); in bufferevent_filter_data_stuck_readcb()
1268 evbuffer_drain(input, read_size); in bufferevent_filter_data_stuck_readcb()
/libevent-2.1.12/include/event2/
H A Dbufferevent_struct.h88 struct evbuffer *input; member