/external/libevent/ |
H A D | bufferevent.c | 66 bufferevent_suspend_read(struct bufferevent *bufev, bufferevent_suspend_flags what) argument 69 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 70 BEV_LOCK(bufev); 72 bufev->be_ops->disable(bufev, EV_READ); 74 BEV_UNLOCK(bufev); 78 bufferevent_unsuspend_read(struct bufferevent *bufev, bufferevent_suspend_flags what) argument 81 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 82 BEV_LOCK(bufev); 84 if (!bufev_private->read_suspended && (bufev 90 bufferevent_suspend_write(struct bufferevent *bufev, bufferevent_suspend_flags what) argument 102 bufferevent_unsuspend_write(struct bufferevent *bufev, bufferevent_suspend_flags what) argument 121 struct bufferevent *bufev = arg; local 136 struct bufferevent *bufev = &bufev_private->bev; local 169 struct bufferevent *bufev = &bufev_private->bev; local 220 _bufferevent_run_readcb(struct bufferevent *bufev) argument 237 _bufferevent_run_writecb(struct bufferevent *bufev) argument 254 _bufferevent_run_eventcb(struct bufferevent *bufev, short what) argument 277 struct bufferevent *bufev = &bufev_private->bev; local 344 bufferevent_setcb(struct bufferevent *bufev, bufferevent_data_cb readcb, bufferevent_data_cb writecb, bufferevent_event_cb eventcb, void *cbarg) argument 359 bufferevent_get_input(struct bufferevent *bufev) argument 365 bufferevent_get_output(struct bufferevent *bufev) argument 371 bufferevent_get_base(struct bufferevent *bufev) argument 377 bufferevent_write(struct bufferevent *bufev, const void *data, size_t size) argument 386 bufferevent_write_buffer(struct bufferevent *bufev, struct evbuffer *buf) argument 395 bufferevent_read(struct bufferevent *bufev, void *data, size_t size) argument 401 bufferevent_read_buffer(struct bufferevent *bufev, struct evbuffer *buf) argument 407 bufferevent_enable(struct bufferevent *bufev, short event) argument 430 bufferevent_set_timeouts(struct bufferevent *bufev, const struct timeval *tv_read, const struct timeval *tv_write) argument 457 bufferevent_settimeout(struct bufferevent *bufev, int timeout_read, int timeout_write) argument 480 bufferevent_disable_hard(struct bufferevent *bufev, short event) argument 498 bufferevent_disable(struct bufferevent *bufev, short event) argument 517 bufferevent_setwatermark(struct bufferevent *bufev, short events, size_t lowmark, size_t highmark) argument 565 bufferevent_flush(struct bufferevent *bufev, short iotype, enum bufferevent_flush_mode mode) argument 578 _bufferevent_incref_and_lock(struct bufferevent *bufev) argument 605 _bufferevent_decref_and_unlock(struct bufferevent *bufev) argument 669 bufferevent_decref(struct bufferevent *bufev) argument 676 bufferevent_free(struct bufferevent *bufev) argument 685 bufferevent_incref(struct bufferevent *bufev) argument 696 bufferevent_enable_locking(struct bufferevent *bufev, void *lock) argument 769 bufferevent_get_enabled(struct bufferevent *bufev) argument [all...] |
H A D | bufferevent_sock.c | 106 struct bufferevent *bufev = arg; local 108 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 111 (bufev->enabled & EV_WRITE) && 112 !event_pending(&bufev->ev_write, EV_WRITE, NULL) && 116 if (be_socket_add(&bufev->ev_write, &bufev->timeout_write) == -1) { 125 struct bufferevent *bufev = arg; local 127 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 133 _bufferevent_incref_and_lock(bufev); 143 input = bufev 204 struct bufferevent *bufev = arg; local 321 struct bufferevent *bufev; local 539 struct bufferevent *bufev; local 551 be_socket_enable(struct bufferevent *bufev, short event) argument 565 be_socket_disable(struct bufferevent *bufev, short event) argument 582 be_socket_destruct(struct bufferevent *bufev) argument 599 be_socket_adj_timeouts(struct bufferevent *bufev) argument 621 be_socket_setfd(struct bufferevent *bufev, evutil_socket_t fd) argument 642 bufferevent_priority_set(struct bufferevent *bufev, int priority) argument 663 bufferevent_base_set(struct event_base *base, struct bufferevent *bufev) argument [all...] |
H A D | bufferevent-internal.h | 275 /** For internal use: temporarily stop all reads on bufev, until the conditions 277 void bufferevent_suspend_read(struct bufferevent *bufev, bufferevent_suspend_flags what); 278 /** For internal use: clear the conditions 'what' on bufev, and re-enable 280 void bufferevent_unsuspend_read(struct bufferevent *bufev, bufferevent_suspend_flags what); 282 /** For internal use: temporarily stop all writes on bufev, until the conditions 284 void bufferevent_suspend_write(struct bufferevent *bufev, bufferevent_suspend_flags what); 285 /** For internal use: clear the conditions 'what' on bufev, and re-enable 287 void bufferevent_unsuspend_write(struct bufferevent *bufev, bufferevent_suspend_flags what); 301 @param bufev the bufferevent to be disabled 306 int bufferevent_disable_hard(struct bufferevent *bufev, shor [all...] |
H A D | bufferevent_pair.c | 94 struct bufferevent_pair *bufev; local 95 if (! (bufev = mm_calloc(1, sizeof(struct bufferevent_pair)))) 97 if (bufferevent_init_common(&bufev->bev, base, &bufferevent_ops_pair, 99 mm_free(bufev); 102 if (!evbuffer_add_cb(bufev->bev.bev.output, be_pair_outbuf_cb, bufev)) { 103 bufferevent_free(downcast(bufev)); 107 _bufferevent_init_generic_timeout_cbs(&bufev->bev.bev); 109 return bufev; 230 be_pair_enable(struct bufferevent *bufev, shor argument 246 be_pair_transfer(downcast(partner), bufev, 0); local [all...] |
H A D | bufferevent_filter.c | 67 static int be_filter_flush(struct bufferevent *bufev, 141 struct bufferevent *bufev = downcast(bevf); local 143 bufev->wm_read.high && 144 evbuffer_get_length(bufev->input) >= bufev->wm_read.high; 322 struct bufferevent *bufev = downcast(bevf); local 331 if (!(bufev->enabled & EV_WRITE) || 333 !evbuffer_get_length(bufev->output)) 339 evbuffer_cb_set_flags(bufev->output, bevf->outbuf_cb, 0); 363 (bufev 419 struct bufferevent *bufev = downcast(bevf); local 471 be_filter_flush(struct bufferevent *bufev, short iotype, enum bufferevent_flush_mode mode) argument [all...] |
H A D | http.c | 195 static void evhttp_error_cb(struct bufferevent *bufev, short what, void *arg); 389 bufferevent_setcb(evcon->bufev, 395 bufferevent_enable(evcon->bufev, EV_WRITE); 401 bufferevent_disable(evcon->bufev, EV_WRITE); 408 bufferevent_enable(evcon->bufev, EV_WRITE); 409 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), 414 bufferevent_setcb(evcon->bufev, 454 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), 541 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), 596 struct evbuffer *output = bufferevent_get_output(evcon->bufev); 754 evhttp_write_cb(struct bufferevent *bufev, void *arg) argument 1044 evhttp_read_cb(struct bufferevent *bufev, void *arg) argument 1323 evhttp_error_cb(struct bufferevent *bufev, short what, void *arg) argument 1387 evhttp_connection_cb(struct bufferevent *bufev, short what, void *arg) argument [all...] |
H A D | bufferevent_openssl.c | 159 struct bufferevent *bufev = b->ptr; local 168 output = bufferevent_get_output(bufev); 173 if (bufev->wm_write.high && bufev->wm_write.high <= (outlen+inlen)) { 174 if (bufev->wm_write.high <= outlen) { 179 inlen = bufev->wm_write.high - outlen; 191 struct bufferevent *bufev = b->ptr; local 202 ret = evbuffer_get_length(bufferevent_get_input(bufev)) != 0; 205 ret = evbuffer_get_length(bufferevent_get_output(bufev)) != 0; 330 static int be_openssl_flush(struct bufferevent *bufev, 1234 be_openssl_flush(struct bufferevent *bufev, short iotype, enum bufferevent_flush_mode mode) argument 1280 bufferevent_openssl_get_ssl(struct bufferevent *bufev) argument [all...] |
H A D | http-internal.h | 68 struct bufferevent *bufev; member in struct:evhttp_connection
|
/external/libevent/include/event2/ |
H A D | bufferevent.h | 199 @param bufev an existing bufferevent allocated with 212 @param bufev An existing bufferevent allocated with bufferevent_socket_new() 253 @param bufev a bufferevent struct returned by bufferevent_new() 258 int bufferevent_base_set(struct event_base *base, struct bufferevent *bufev); 270 @param bufev a bufferevent struct 274 int bufferevent_priority_set(struct bufferevent *bufev, int pri); 280 @param bufev the bufferevent structure to be freed. 282 void bufferevent_free(struct bufferevent *bufev); 288 @param bufev the bufferevent object for which to change callbacks 299 void bufferevent_setcb(struct bufferevent *bufev, [all...] |
H A D | bufferevent_compat.h | 82 @param bufev the bufferevent to be modified 86 void bufferevent_settimeout(struct bufferevent *bufev,
|
H A D | bufferevent_ssl.h | 93 bufferevent_openssl_get_ssl(struct bufferevent *bufev);
|