Searched refs:bufev (Results 1 - 14 of 14) sorted by relevance

/freebsd-9.3-release/contrib/pf/libevent/
H A Devbuffer.c75 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 Devent.h263 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 Dbufferevent.c68 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 Dbufferevent_sock.c108 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 Dbufferevent-internal.h294 /** 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 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_filter.c70 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 Dhttp.c195 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 Dbufferevent_openssl.c165 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 Dhttp-internal.h60 struct bufferevent *bufev; member in struct:evhttp_connection
/freebsd-9.3-release/contrib/ntp/sntp/libevent/include/event2/
H A Dbufferevent.h205 @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 Dbufferevent_compat.h82 @param bufev the bufferevent to be modified
86 void bufferevent_settimeout(struct bufferevent *bufev,
H A Dbufferevent_ssl.h118 bufferevent_openssl_get_ssl(struct bufferevent *bufev);
/freebsd-9.3-release/contrib/pf/ftp-proxy/
H A Dftp-proxy.c134 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,

Completed in 137 milliseconds