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

/openbsd-current/lib/libevent/
H A Devbuffer.c67 struct bufferevent *bufev = arg; local
72 if (bufev->wm_read.high == 0 || now < bufev->wm_read.high) {
75 if (bufev->enabled & EV_READ)
76 bufferevent_add(&bufev->ev_read, bufev->timeout_read);
83 struct bufferevent *bufev = arg; local
98 if (bufev->wm_read.high != 0) {
99 howmuch = bufev->wm_read.high - EVBUFFER_LENGTH(bufev
154 struct bufferevent *bufev = arg; local
217 struct bufferevent *bufev; local
249 bufferevent_setcb(struct bufferevent *bufev, evbuffercb readcb, evbuffercb writecb, everrorcb errorcb, void *cbarg) argument
260 bufferevent_setfd(struct bufferevent *bufev, int fd) argument
276 bufferevent_priority_set(struct bufferevent *bufev, int priority) argument
289 bufferevent_free(struct bufferevent *bufev) argument
306 bufferevent_write(struct bufferevent *bufev, const void *data, size_t size) argument
323 bufferevent_write_buffer(struct bufferevent *bufev, struct evbuffer *buf) argument
335 bufferevent_read(struct bufferevent *bufev, void *data, size_t size) argument
352 bufferevent_enable(struct bufferevent *bufev, short event) argument
368 bufferevent_disable(struct bufferevent *bufev, short event) argument
388 bufferevent_settimeout(struct bufferevent *bufev, int timeout_read, int timeout_write) argument
404 bufferevent_setwatermark(struct bufferevent *bufev, short events, size_t lowmark, size_t highmark) argument
423 bufferevent_base_set(struct event_base *base, struct bufferevent *bufev) argument
[all...]
H A Devent.h823 @param bufev a bufferevent struct returned by bufferevent_new()
827 int bufferevent_base_set(struct event_base *base, struct bufferevent *bufev);
833 @param bufev a bufferevent struct
837 int bufferevent_priority_set(struct bufferevent *bufev, int pri);
843 @param bufev the bufferevent structure to be freed.
845 void bufferevent_free(struct bufferevent *bufev);
851 @param bufev the bufferevent object for which to change callbacks
862 void bufferevent_setcb(struct bufferevent *bufev,
868 @param bufev the bufferevent object for which to change the file descriptor
871 void bufferevent_setfd(struct bufferevent *bufev, in
[all...]
/openbsd-current/usr.sbin/ldapd/
H A Devbuffer_tls.c71 struct bufferevent *bufev = buftls->bt_bufev; local
87 if (bufev->wm_read.high != 0) {
88 howmuch = bufev->wm_read.high - EVBUFFER_LENGTH(bufev->input);
91 struct evbuffer *buf = bufev->input;
92 event_del(&bufev->ev_read);
94 bufferevent_read_pressure_cb, bufev);
99 res = evtls_read(bufev->input, fd, howmuch, ctx);
102 bufferevent_add(&bufev->ev_read, bufev
152 struct bufferevent *bufev = buftls->bt_bufev; local
210 struct bufferevent *bufev = buftls->bt_bufev; local
252 buffertls_set(struct buffertls *buftls, struct bufferevent *bufev, struct tls *ctx, int fd) argument
265 struct bufferevent *bufev = buftls->bt_bufev; local
278 struct bufferevent *bufev = buftls->bt_bufev; local
[all...]
/openbsd-current/usr.sbin/syslogd/
H A Devbuffer_tls.c71 struct bufferevent *bufev = buftls->bt_bufev; local
87 if (bufev->wm_read.high != 0) {
88 howmuch = bufev->wm_read.high - EVBUFFER_LENGTH(bufev->input);
91 struct evbuffer *buf = bufev->input;
92 event_del(&bufev->ev_read);
94 bufferevent_read_pressure_cb, bufev);
99 res = evtls_read(bufev->input, fd, howmuch, ctx);
102 bufferevent_add(&bufev->ev_read, bufev
153 struct bufferevent *bufev = buftls->bt_bufev; local
211 struct bufferevent *bufev = buftls->bt_bufev; local
253 buffertls_set(struct buffertls *buftls, struct bufferevent *bufev, struct tls *ctx, int fd) argument
266 struct bufferevent *bufev = buftls->bt_bufev; local
279 struct bufferevent *bufev = buftls->bt_bufev; local
[all...]
H A Dsyslogd.c329 int tcpbuf_countmsg(struct bufferevent *bufev);
1290 tcp_readcb(struct bufferevent *bufev, void *arg) argument
1296 while (EVBUFFER_LENGTH(bufev->input) > 0) {
1300 len = octet_counting(bufev->input, &msg, 1);
1302 len = non_transparent_framing(bufev->input, &msg);
1318 evbuffer_drain(bufev->input, len);
1321 if (EVBUFFER_LENGTH(bufev->input) >= 5 + 1 + LOG_MAXLINE + 1) {
1322 log_debug(", use %zu bytes", EVBUFFER_LENGTH(bufev->input));
1323 EVBUFFER_DATA(bufev->input)[5 + 1 + LOG_MAXLINE] = '\0';
1324 printline(p->p_hostname, EVBUFFER_DATA(bufev
1331 tcp_closecb(struct bufferevent *bufev, short event, void *arg) argument
1374 tcp_dropcb(struct bufferevent *bufev, void *arg) argument
1387 tcp_writecb(struct bufferevent *bufev, void *arg) argument
1407 tcp_errorcb(struct bufferevent *bufev, short event, void *arg) argument
1467 struct bufferevent *bufev = f->f_un.f_forw.f_bufev; local
1612 tcpbuf_countmsg(struct bufferevent *bufev) argument
[all...]
/openbsd-current/usr.sbin/httpd/
H A Dserver.c783 struct bufferevent *bufev = arg; local
784 struct client *clt = bufev->cbarg;
796 if (bufev->wm_read.high != 0)
797 howmuch = MINIMUM(sizeof(rbuf), bufev->wm_read.high);
813 if (evbuffer_add(bufev->input, rbuf, len) == -1) {
818 server_bufferevent_add(&bufev->ev_read, bufev->timeout_read);
820 len = EVBUFFER_LENGTH(bufev->input);
821 if (bufev->wm_read.low != 0 && len < bufev
845 struct bufferevent *bufev = arg; local
[all...]
/openbsd-current/usr.sbin/relayd/
H A Drelay.c2475 struct bufferevent *bufev = arg; local
2476 struct ctl_relay_event *cre = bufev->cbarg;
2487 if (bufev->wm_read.high != 0)
2488 howmuch = MINIMUM(sizeof(rbuf), bufev->wm_read.high);
2504 if (evbuffer_add(bufev->input, rbuf, ret) == -1) {
2509 relay_bufferevent_add(&bufev->ev_read, bufev->timeout_read);
2511 len = EVBUFFER_LENGTH(bufev->input);
2512 if (bufev->wm_read.low != 0 && len < bufev
2536 struct bufferevent *bufev = arg; local
[all...]
/openbsd-current/usr.bin/tmux/
H A Dcmd-pipe-pane.c190 cmd_pipe_pane_read_callback(__unused struct bufferevent *bufev, void *data) argument
207 cmd_pipe_pane_write_callback(__unused struct bufferevent *bufev, void *data) argument
218 cmd_pipe_pane_error_callback(__unused struct bufferevent *bufev, argument
H A Djob.c289 job_read_callback(__unused struct bufferevent *bufev, void *data) argument
303 job_write_callback(__unused struct bufferevent *bufev, void *data) argument
319 job_error_callback(__unused struct bufferevent *bufev, __unused short events, argument
H A Dcontrol.c538 control_error_callback(__unused struct bufferevent *bufev, argument
548 control_read_callback(__unused struct bufferevent *bufev, void *data) argument
723 control_write_callback(__unused struct bufferevent *bufev, void *data) argument
H A Dwindow.c1001 window_pane_read_callback(__unused struct bufferevent *bufev, void *data) argument
1029 window_pane_error_callback(__unused struct bufferevent *bufev, argument
/openbsd-current/usr.bin/cu/
H A Dcu.c315 stream_read(struct bufferevent *bufev, void *data) argument
354 stream_error(struct bufferevent *bufev, short what, void *data) argument
360 line_read(struct bufferevent *bufev, void *data) argument
378 line_error(struct bufferevent *bufev, short what, void *data) argument
/openbsd-current/usr.sbin/ftp-proxy/
H A Dftp-proxy.c127 client_error(struct bufferevent *bufev, short what, void *arg) argument
233 client_read(struct bufferevent *bufev, void *arg) argument
241 read = bufferevent_read(bufev, s->cbuf + s->cbuf_valid,
925 server_error(struct bufferevent *bufev, short what, void *arg) argument
1075 server_read(struct bufferevent *bufev, void *arg) argument
1081 bufferevent_settimeout(bufev, timeout, 0);
1085 read = bufferevent_read(bufev, s->sbuf + s->sbuf_valid,

Completed in 374 milliseconds