Searched defs:bufev (Results 1 - 9 of 9) sorted by relevance

/external/libevent/
H A Dbufferevent_filter.c70 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 Dbufferevent_pair.c96 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 Dbufferevent_sock.c129 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 Dhttp-internal.h60 struct bufferevent *bufev; member in struct:evhttp_connection
H A Dbufferevent-internal.h319 /** 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 Dbufferevent.c67 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 Dbufferevent_openssl.c162 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 Dhttp.c198 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 Dregress_http.c1414 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);

Completed in 572 milliseconds