/freebsd-9.3-release/contrib/pf/libevent/ |
H A D | evbuffer.c | 75 struct bufferevent *bufev = arg; local 80 if (bufev->wm_read.high == 0 || now < bufev->wm_read.high) { 83 if (bufev->enabled & EV_READ) 84 bufferevent_add(&bufev->ev_read, bufev->timeout_read); 91 struct bufferevent *bufev = arg; local 106 if (bufev->wm_read.high != 0) 107 howmuch = bufev->wm_read.high; 109 res = evbuffer_read(bufev 154 struct bufferevent *bufev = arg; local 225 struct bufferevent *bufev; local 261 bufferevent_priority_set(struct bufferevent *bufev, int priority) argument 274 bufferevent_free(struct bufferevent *bufev) argument 291 bufferevent_write(struct bufferevent *bufev, void *data, size_t size) argument 308 bufferevent_write_buffer(struct bufferevent *bufev, struct evbuffer *buf) argument 320 bufferevent_read(struct bufferevent *bufev, void *data, size_t size) argument 337 bufferevent_enable(struct bufferevent *bufev, short event) argument 353 bufferevent_disable(struct bufferevent *bufev, short event) argument 373 bufferevent_settimeout(struct bufferevent *bufev, int timeout_read, int timeout_write) argument 384 bufferevent_setwatermark(struct bufferevent *bufev, short events, size_t lowmark, size_t highmark) argument 403 bufferevent_base_set(struct event_base *base, struct bufferevent *bufev) argument [all...] |
H A D | event.h | 263 int bufferevent_base_set(struct event_base *base, struct bufferevent *bufev); 264 int bufferevent_priority_set(struct bufferevent *bufev, int pri); 265 void bufferevent_free(struct bufferevent *bufev); 266 int bufferevent_write(struct bufferevent *bufev, void *data, size_t size); 267 int bufferevent_write_buffer(struct bufferevent *bufev, struct evbuffer *buf); 268 size_t bufferevent_read(struct bufferevent *bufev, void *data, size_t size); 269 int bufferevent_enable(struct bufferevent *bufev, short event); 270 int bufferevent_disable(struct bufferevent *bufev, short event); 271 void bufferevent_settimeout(struct bufferevent *bufev,
|
/freebsd-9.3-release/contrib/ntp/sntp/libevent/ |
H A D | bufferevent.c | 68 bufferevent_suspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what) argument 71 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 72 BEV_LOCK(bufev); 74 bufev->be_ops->disable(bufev, EV_READ); 76 BEV_UNLOCK(bufev); 80 bufferevent_unsuspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what) argument 83 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 84 BEV_LOCK(bufev); 86 if (!bufev_private->read_suspended && (bufev 92 bufferevent_suspend_write_(struct bufferevent *bufev, bufferevent_suspend_flags what) argument 104 bufferevent_unsuspend_write_(struct bufferevent *bufev, bufferevent_suspend_flags what) argument 123 struct bufferevent *bufev = arg; local 138 struct bufferevent *bufev = &bufev_private->bev; local 171 struct bufferevent *bufev = &bufev_private->bev; local 222 bufferevent_run_readcb_(struct bufferevent *bufev, int options) argument 238 bufferevent_run_writecb_(struct bufferevent *bufev, int options) argument 259 bufferevent_trigger(struct bufferevent *bufev, short iotype, int options) argument 267 bufferevent_run_eventcb_(struct bufferevent *bufev, short what, int options) argument 284 bufferevent_trigger_event(struct bufferevent *bufev, short what, int options) argument 297 struct bufferevent *bufev = &bufev_private->bev; local 368 bufferevent_setcb(struct bufferevent *bufev, bufferevent_data_cb readcb, bufferevent_data_cb writecb, bufferevent_event_cb eventcb, void *cbarg) argument 383 bufferevent_getcb(struct bufferevent *bufev, bufferevent_data_cb *readcb_ptr, bufferevent_data_cb *writecb_ptr, bufferevent_event_cb *eventcb_ptr, void **cbarg_ptr) argument 403 bufferevent_get_input(struct bufferevent *bufev) argument 409 bufferevent_get_output(struct bufferevent *bufev) argument 415 bufferevent_get_base(struct bufferevent *bufev) argument 421 bufferevent_get_priority(const struct bufferevent *bufev) argument 431 bufferevent_write(struct bufferevent *bufev, const void *data, size_t size) argument 440 bufferevent_write_buffer(struct bufferevent *bufev, struct evbuffer *buf) argument 449 bufferevent_read(struct bufferevent *bufev, void *data, size_t size) argument 455 bufferevent_read_buffer(struct bufferevent *bufev, struct evbuffer *buf) argument 461 bufferevent_enable(struct bufferevent *bufev, short event) argument 484 bufferevent_set_timeouts(struct bufferevent *bufev, const struct timeval *tv_read, const struct timeval *tv_write) argument 511 bufferevent_settimeout(struct bufferevent *bufev, int timeout_read, int timeout_write) argument 534 bufferevent_disable_hard_(struct bufferevent *bufev, short event) argument 552 bufferevent_disable(struct bufferevent *bufev, short event) argument 571 bufferevent_setwatermark(struct bufferevent *bufev, short events, size_t lowmark, size_t highmark) argument 619 bufferevent_getwatermark(struct bufferevent *bufev, short events, size_t *lowmark, size_t *highmark) argument 645 bufferevent_flush(struct bufferevent *bufev, short iotype, enum bufferevent_flush_mode mode) argument 658 bufferevent_incref_and_lock_(struct bufferevent *bufev) argument 685 bufferevent_decref_and_unlock_(struct bufferevent *bufev) argument 729 struct bufferevent *bufev = arg_; local 780 bufferevent_decref_(struct bufferevent *bufev) argument 787 bufferevent_free(struct bufferevent *bufev) argument 796 bufferevent_incref_(struct bufferevent *bufev) argument 807 bufferevent_enable_locking_(struct bufferevent *bufev, void *lock) argument 894 bufferevent_get_enabled(struct bufferevent *bufev) argument [all...] |
H A D | bufferevent_sock.c | 108 struct bufferevent *bufev = arg; local 110 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 113 (bufev->enabled & EV_WRITE) && 114 !event_pending(&bufev->ev_write, EV_WRITE, NULL) && 118 if (be_socket_add(&bufev->ev_write, &bufev->timeout_write) == -1) { 127 struct bufferevent *bufev = arg; local 129 EVUTIL_UPCAST(bufev, struct bufferevent_private, bev); 135 bufferevent_incref_and_lock_(bufev); 145 input = bufev 205 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 596 be_socket_adj_timeouts(struct bufferevent *bufev) argument 627 be_socket_setfd(struct bufferevent *bufev, evutil_socket_t fd) argument 648 bufferevent_priority_set(struct bufferevent *bufev, int priority) argument 673 bufferevent_base_set(struct event_base *base, struct bufferevent *bufev) argument [all...] |
H A D | bufferevent-internal.h | 294 /** For internal use: temporarily stop all reads on bufev, until the conditions 296 void bufferevent_suspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what); 297 /** For internal use: clear the conditions 'what' on bufev, and re-enable 299 void bufferevent_unsuspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what); 301 /** For internal use: temporarily stop all writes on bufev, until the conditions 303 void bufferevent_suspend_write_(struct bufferevent *bufev, bufferevent_suspend_flags what); 304 /** For internal use: clear the conditions 'what' on bufev, and re-enable 306 void bufferevent_unsuspend_write_(struct bufferevent *bufev, bufferevent_suspend_flags what); 320 @param bufev the bufferevent to be disabled 325 int bufferevent_disable_hard_(struct bufferevent *bufev, shor 362 bufferevent_trigger_nolock_(struct bufferevent *bufev, short iotype, int options) 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_filter.c | 70 static int be_filter_flush(struct bufferevent *bufev, 145 struct bufferevent *bufev = downcast(bevf); local 147 bufev->wm_read.high && 148 evbuffer_get_length(bufev->input) >= bufev->wm_read.high; 331 struct bufferevent *bufev = downcast(bevf); local 340 if (!(bufev->enabled & EV_WRITE) || 342 !evbuffer_get_length(bufev->output)) 348 evbuffer_cb_set_flags(bufev->output, bevf->outbuf_cb, 0); 372 (bufev 427 struct bufferevent *bufev = downcast(bevf); local 505 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); 370 bufferevent_setcb(evcon->bufev, 376 bufferevent_enable(evcon->bufev, EV_WRITE); 382 bufferevent_disable(evcon->bufev, EV_WRITE); 389 bufferevent_enable(evcon->bufev, EV_WRITE); 390 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), 395 bufferevent_setcb(evcon->bufev, 435 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), 522 evbuffer_add_printf(bufferevent_get_output(evcon->bufev), 579 struct evbuffer *output = bufferevent_get_output(evcon->bufev); 751 evhttp_write_cb(struct bufferevent *bufev, void *arg) argument 1058 evhttp_read_cb(struct bufferevent *bufev, void *arg) argument 1360 evhttp_error_cb(struct bufferevent *bufev, short what, void *arg) argument 1439 evhttp_connection_cb(struct bufferevent *bufev, short what, void *arg) argument [all...] |
H A D | bufferevent_openssl.c | 165 struct bufferevent *bufev = b->ptr; local 174 output = bufferevent_get_output(bufev); 179 if (bufev->wm_write.high && bufev->wm_write.high <= (outlen+inlen)) { 180 if (bufev->wm_write.high <= outlen) { 185 inlen = bufev->wm_write.high - outlen; 197 struct bufferevent *bufev = b->ptr; local 208 ret = evbuffer_get_length(bufferevent_get_input(bufev)) != 0; 211 ret = evbuffer_get_length(bufferevent_get_output(bufev)) != 0; 337 static int be_openssl_flush(struct bufferevent *bufev, 1257 be_openssl_flush(struct bufferevent *bufev, short iotype, enum bufferevent_flush_mode mode) argument 1305 bufferevent_openssl_get_ssl(struct bufferevent *bufev) argument [all...] |
H A D | http-internal.h | 60 struct bufferevent *bufev; member in struct:evhttp_connection
|
/freebsd-9.3-release/contrib/ntp/sntp/libevent/include/event2/ |
H A D | bufferevent.h | 205 @param bufev an existing bufferevent allocated with 219 @param bufev An existing bufferevent allocated with bufferevent_socket_new() 262 @param bufev a bufferevent struct returned by bufferevent_new() 268 int bufferevent_base_set(struct event_base *base, struct bufferevent *bufev); 281 @param bufev a bufferevent struct 286 int bufferevent_priority_set(struct bufferevent *bufev, int pri); 294 int bufferevent_get_priority(const struct bufferevent *bufev); 302 @param bufev the bufferevent structure to be freed. 305 void bufferevent_free(struct bufferevent *bufev); 311 @param bufev th [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 | 118 bufferevent_openssl_get_ssl(struct bufferevent *bufev);
|
/freebsd-9.3-release/contrib/pf/ftp-proxy/ |
H A D | ftp-proxy.c | 134 client_error(struct bufferevent *bufev __unused, short what, void *arg) 240 client_read(struct bufferevent *bufev, void *arg) argument 248 clientread = bufferevent_read(bufev, s->cbuf + s->cbuf_valid, 907 server_error(struct bufferevent *bufev __unused, short what, void *arg) 1076 server_read(struct bufferevent *bufev, void *arg) argument 1082 bufferevent_settimeout(bufev, timeout, 0); 1086 srvread = bufferevent_read(bufev, s->sbuf + s->sbuf_valid,
|