/external/libevent/ |
H A D | bufferevent_filter.c | 70 static int be_filter_flush(struct bufferevent *bufev, 150 struct bufferevent *bufev = downcast(bevf); local 152 bufev->wm_read.high && 153 evbuffer_get_length(bufev->input) >= bufev->wm_read.high; 347 struct bufferevent *bufev = downcast(bevf); local 356 if (!(bufev->enabled & EV_WRITE) || 358 !evbuffer_get_length(bufev->output)) 364 evbuffer_cb_clear_flags(bufev->output, bevf->outbuf_cb, 389 (bufev 443 struct bufferevent *bufev = downcast(bevf); local 573 be_filter_flush(struct bufferevent *bufev, short iotype, enum bufferevent_flush_mode mode) argument [all...] |
H A D | bufferevent_pair.c | 96 struct bufferevent_pair *bufev; local 97 if (! (bufev = mm_calloc(1, sizeof(struct bufferevent_pair)))) 99 if (bufferevent_init_common_(&bufev->bev, base, &bufferevent_ops_pair, 101 mm_free(bufev); 104 if (!evbuffer_add_cb(bufev->bev.bev.output, be_pair_outbuf_cb, bufev)) { 105 bufferevent_free(downcast(bufev)); 109 bufferevent_init_generic_timeout_cbs_(&bufev->bev.bev); 111 return bufev; 225 be_pair_enable(struct bufferevent *bufev, shor argument 241 be_pair_transfer(downcast(partner), bufev, 0); local [all...] |
H A D | bufferevent_sock.c | 129 struct bufferevent *bufev = arg; local 131 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 134 (bufev->enabled & EV_WRITE) && 135 !event_pending(&bufev->ev_write, EV_WRITE, NULL) && 139 if (bufferevent_add_event_(&bufev->ev_write, &bufev->timeout_write) == -1) { 148 struct bufferevent *bufev = arg; local 150 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 156 bufferevent_incref_and_lock_(bufev); 166 input = bufev 230 struct bufferevent *bufev = arg; local 347 struct bufferevent *bufev; local 564 struct bufferevent *bufev; local 576 be_socket_enable(struct bufferevent *bufev, short event) argument 588 be_socket_disable(struct bufferevent *bufev, short event) argument 605 be_socket_destruct(struct bufferevent *bufev) argument 629 be_socket_setfd(struct bufferevent *bufev, evutil_socket_t fd) argument 658 bufferevent_priority_set(struct bufferevent *bufev, int priority) argument 683 bufferevent_base_set(struct event_base *base, struct bufferevent *bufev) argument [all...] |
H A D | http-internal.h | 60 struct bufferevent *bufev; member in struct:evhttp_connection
|
H A D | bufferevent-internal.h | 319 /** For internal use: temporarily stop all reads on bufev, until the conditions 321 void bufferevent_suspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what); 322 /** For internal use: clear the conditions 'what' on bufev, and re-enable 324 void bufferevent_unsuspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what); 326 /** For internal use: temporarily stop all writes on bufev, until the conditions 328 void bufferevent_suspend_write_(struct bufferevent *bufev, bufferevent_suspend_flags what); 329 /** For internal use: clear the conditions 'what' on bufev, and re-enable 331 void bufferevent_unsuspend_write_(struct bufferevent *bufev, bufferevent_suspend_flags what); 345 @param bufev the bufferevent to be disabled 350 int bufferevent_disable_hard_(struct bufferevent *bufev, shor 390 bufferevent_trigger_nolock_(struct bufferevent *bufev, short iotype, int options) argument [all...] |
H A D | bufferevent.c | 67 bufferevent_suspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what) argument 70 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 71 BEV_LOCK(bufev); 73 bufev->be_ops->disable(bufev, EV_READ); 75 BEV_UNLOCK(bufev); 79 bufferevent_unsuspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what) argument 82 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 83 BEV_LOCK(bufev); 85 if (!bufev_private->read_suspended && (bufev 91 bufferevent_suspend_write_(struct bufferevent *bufev, bufferevent_suspend_flags what) argument 103 bufferevent_unsuspend_write_(struct bufferevent *bufev, bufferevent_suspend_flags what) argument 122 struct bufferevent *bufev = arg; local 137 struct bufferevent *bufev = &bufev_private->bev; local 170 struct bufferevent *bufev = &bufev_private->bev; local 221 bufferevent_run_readcb_(struct bufferevent *bufev, int options) argument 237 bufferevent_run_writecb_(struct bufferevent *bufev, int options) argument 258 bufferevent_trigger(struct bufferevent *bufev, short iotype, int options) argument 266 bufferevent_run_eventcb_(struct bufferevent *bufev, short what, int options) argument 283 bufferevent_trigger_event(struct bufferevent *bufev, short what, int options) argument 296 struct bufferevent *bufev = &bufev_private->bev; local 367 bufferevent_setcb(struct bufferevent *bufev, bufferevent_data_cb readcb, bufferevent_data_cb writecb, bufferevent_event_cb eventcb, void *cbarg) argument 382 bufferevent_getcb(struct bufferevent *bufev, bufferevent_data_cb *readcb_ptr, bufferevent_data_cb *writecb_ptr, bufferevent_event_cb *eventcb_ptr, void **cbarg_ptr) argument 402 bufferevent_get_input(struct bufferevent *bufev) argument 408 bufferevent_get_output(struct bufferevent *bufev) argument 414 bufferevent_get_base(struct bufferevent *bufev) argument 420 bufferevent_get_priority(const struct bufferevent *bufev) argument 430 bufferevent_write(struct bufferevent *bufev, const void *data, size_t size) argument 439 bufferevent_write_buffer(struct bufferevent *bufev, struct evbuffer *buf) argument 448 bufferevent_read(struct bufferevent *bufev, void *data, size_t size) argument 454 bufferevent_read_buffer(struct bufferevent *bufev, struct evbuffer *buf) argument 460 bufferevent_enable(struct bufferevent *bufev, short event) argument 483 bufferevent_set_timeouts(struct bufferevent *bufev, const struct timeval *tv_read, const struct timeval *tv_write) argument 510 bufferevent_settimeout(struct bufferevent *bufev, int timeout_read, int timeout_write) argument 533 bufferevent_disable_hard_(struct bufferevent *bufev, short event) argument 551 bufferevent_disable(struct bufferevent *bufev, short event) argument 570 bufferevent_setwatermark(struct bufferevent *bufev, short events, size_t lowmark, size_t highmark) argument 618 bufferevent_getwatermark(struct bufferevent *bufev, short events, size_t *lowmark, size_t *highmark) argument 644 bufferevent_flush(struct bufferevent *bufev, short iotype, enum bufferevent_flush_mode mode) argument 657 bufferevent_incref_and_lock_(struct bufferevent *bufev) argument 684 bufferevent_decref_and_unlock_(struct bufferevent *bufev) argument 728 struct bufferevent *bufev = arg_; local 779 bufferevent_decref(struct bufferevent *bufev) argument 786 bufferevent_free(struct bufferevent *bufev) argument 795 bufferevent_incref(struct bufferevent *bufev) argument 810 bufferevent_enable_locking_(struct bufferevent *bufev, void *lock) argument 897 bufferevent_get_enabled(struct bufferevent *bufev) argument [all...] |
H A D | bufferevent_openssl.c | 162 struct bufferevent *bufev = BIO_get_data(b); local 171 output = bufferevent_get_output(bufev); 176 if (bufev->wm_write.high && bufev->wm_write.high <= (outlen+inlen)) { 177 if (bufev->wm_write.high <= outlen) { 182 inlen = bufev->wm_write.high - outlen; 194 struct bufferevent *bufev = BIO_get_data(b); local 205 ret = evbuffer_get_length(bufferevent_get_input(bufev)) != 0; 208 ret = evbuffer_get_length(bufferevent_get_output(bufev)) != 0; 335 static int be_openssl_flush(struct bufferevent *bufev, 1255 be_openssl_flush(struct bufferevent *bufev, short iotype, enum bufferevent_flush_mode mode) argument 1326 bufferevent_openssl_get_ssl(struct bufferevent *bufev) argument [all...] |
H A D | http.c | 198 static void evhttp_error_cb(struct bufferevent *bufev, short what, void *arg); 373 bufferevent_setcb(evcon->bufev, 379 bufferevent_enable(evcon->bufev, EV_WRITE); 385 bufferevent_disable(evcon->bufev, EV_WRITE); 392 bufferevent_enable(evcon->bufev, EV_WRITE); 393 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), 398 bufferevent_setcb(evcon->bufev, 441 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), 523 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), 597 struct evbuffer *output = bufferevent_get_output(evcon->bufev); 790 evhttp_write_cb(struct bufferevent *bufev, void *arg) argument 1115 evhttp_read_cb(struct bufferevent *bufev, void *arg) argument 1455 evhttp_error_cb(struct bufferevent *bufev, short what, void *arg) argument 1540 evhttp_connection_cb(struct bufferevent *bufev, short what, void *arg) argument [all...] |
/external/libevent/test/ |
H A D | regress_http.c | 1414 struct bufferevent *bufev = NULL; local 1471 bufev = evhttp_connection_get_bufferevent(evcon); 1475 evbuffer_add_cb(bufferevent_get_output(bufev), http_no_write, NULL); 1547 if (bufev) 1548 evbuffer_remove_cb(bufferevent_get_output(bufev), http_no_write, NULL);
|