| /openbsd-src/lib/libevent/ |
| H A D | evbuffer.c | 67 struct bufferevent *bufev = arg; in bufferevent_read_pressure_cb() local
72 if (bufev->wm_read.high == 0 || now < bufev->wm_read.high) { in bufferevent_read_pressure_cb()
75 if (bufev->enabled & EV_READ) in bufferevent_read_pressure_cb()
76 bufferevent_add(&bufev->ev_read, bufev->timeout_read); in bufferevent_read_pressure_cb()
83 struct bufferevent *bufev = arg; in bufferevent_readcb() local
98 if (bufev->wm_read.high != 0) { in bufferevent_readcb()
99 howmuch = bufev->wm_read.high - EVBUFFER_LENGTH(bufev->input); in bufferevent_readcb()
102 struct evbuffer *buf = bufev->input; in bufferevent_readcb()
103 event_del(&bufev->ev_read); in bufferevent_readcb()
105 bufferevent_read_pressure_cb, bufev); in bufferevent_readcb()
[all …]
|
| H A D | event.h | 827 int bufferevent_base_set(struct event_base *base, struct bufferevent *bufev);
837 int bufferevent_priority_set(struct bufferevent *bufev, int pri);
845 void bufferevent_free(struct bufferevent *bufev);
862 void bufferevent_setcb(struct bufferevent *bufev,
871 void bufferevent_setfd(struct bufferevent *bufev, int fd);
886 int bufferevent_write(struct bufferevent *bufev,
899 int bufferevent_write_buffer(struct bufferevent *bufev, struct evbuffer *buf);
912 size_t bufferevent_read(struct bufferevent *bufev, void *data, size_t size);
922 int bufferevent_enable(struct bufferevent *bufev, short event);
933 int bufferevent_disable(struct bufferevent *bufev, short event);
[all …]
|
| /openbsd-src/usr.sbin/syslogd/ |
| H A D | evbuffer_tls.c | 71 struct bufferevent *bufev = buftls->bt_bufev; in buffertls_readcb() local
87 if (bufev->wm_read.high != 0) { in buffertls_readcb()
88 howmuch = bufev->wm_read.high - EVBUFFER_LENGTH(bufev->input); in buffertls_readcb()
91 struct evbuffer *buf = bufev->input; in buffertls_readcb()
92 event_del(&bufev->ev_read); in buffertls_readcb()
94 bufferevent_read_pressure_cb, bufev); in buffertls_readcb()
99 res = evtls_read(bufev->input, fd, howmuch, ctx); in buffertls_readcb()
102 bufferevent_add(&bufev->ev_read, bufev in buffertls_readcb()
153 struct bufferevent *bufev = buftls->bt_bufev; buffertls_writecb() local
211 struct bufferevent *bufev = buftls->bt_bufev; buffertls_handshakecb() local
253 buffertls_set(struct buffertls * buftls,struct bufferevent * bufev,struct tls * ctx,int fd) buffertls_set() argument
266 struct bufferevent *bufev = buftls->bt_bufev; buffertls_accept() local
279 struct bufferevent *bufev = buftls->bt_bufev; buffertls_connect() local
[all...] |
| H A D | syslogd.c | 330 int tcpbuf_countmsg(struct bufferevent *bufev);
1214 tls_handshakecb(struct bufferevent *bufev, void *arg)
1238 bufferevent_setcb(bufev, tcp_readcb, NULL, tcp_closecb, p); in octet_counting()
1319 tcp_readcb(struct bufferevent *bufev, void *arg) in tcp_readcb()
1325 while (EVBUFFER_LENGTH(bufev->input) > 0) { in tcp_readcb()
1329 len = octet_counting(bufev->input, &msg, 1); in tcp_readcb()
1331 len = non_transparent_framing(bufev->input, &msg); in tcp_readcb()
1347 evbuffer_drain(bufev->input, len); in tcp_closecb()
1350 if (EVBUFFER_LENGTH(bufev->input) >= 5 + 1 + LOG_MAXLINE + 1) { in tcp_closecb()
1351 log_debug(", use %zu bytes", EVBUFFER_LENGTH(bufev in tcp_closecb()
1215 tls_handshakecb(struct bufferevent * bufev,void * arg) tls_handshakecb() argument
1303 tcp_readcb(struct bufferevent * bufev,void * arg) tcp_readcb() argument
1336 EVBUFFER_DATA(bufev->input)[5 + 1 + LOG_MAXLINE] = '\0'; tcp_readcb() local
1344 tcp_closecb(struct bufferevent * bufev,short event,void * arg) tcp_closecb() argument
1387 tcp_dropcb(struct bufferevent * bufev,void * arg) tcp_dropcb() argument
1400 tcp_writecb(struct bufferevent * bufev,void * arg) tcp_writecb() argument
1420 tcp_errorcb(struct bufferevent * bufev,short event,void * arg) tcp_errorcb() argument
1480 struct bufferevent *bufev = f->f_un.f_forw.f_bufev; tcp_connectcb() local
1624 tcpbuf_countmsg(struct bufferevent * bufev) tcpbuf_countmsg() argument
[all...] |
| /openbsd-src/usr.sbin/ldapd/ |
| H A D | evbuffer_tls.c | 71 struct bufferevent *bufev = buftls->bt_bufev; in buffertls_readcb() local
87 if (bufev->wm_read.high != 0) { in buffertls_readcb()
88 howmuch = bufev->wm_read.high - EVBUFFER_LENGTH(bufev->input); in buffertls_readcb()
91 struct evbuffer *buf = bufev->input; in buffertls_readcb()
92 event_del(&bufev->ev_read); in buffertls_readcb()
94 bufferevent_read_pressure_cb, bufev); in buffertls_readcb()
99 res = evtls_read(bufev->input, fd, howmuch, ctx); in buffertls_readcb()
102 bufferevent_add(&bufev->ev_read, bufev->timeout_read); in buffertls_readcb()
105 event_del(&bufev->ev_write); in buffertls_readcb()
106 event_set(&bufev->ev_write, fd, EV_WRITE, buffertls_readcb, in buffertls_readcb()
[all …]
|
| /openbsd-src/usr.sbin/httpd/ |
| H A D | server.c | 783 struct bufferevent *bufev = arg; in server_tls_readcb() local
784 struct client *clt = bufev->cbarg; in server_tls_readcb()
796 if (bufev->wm_read.high != 0) in server_tls_readcb()
797 howmuch = MINIMUM(sizeof(rbuf), bufev->wm_read.high); in server_tls_readcb()
813 if (evbuffer_add(bufev->input, rbuf, len) == -1) { in server_tls_readcb()
818 server_bufferevent_add(&bufev->ev_read, bufev->timeout_read); in server_tls_readcb()
820 len = EVBUFFER_LENGTH(bufev->input); in server_tls_readcb()
821 if (bufev->wm_read.low != 0 && len < bufev->wm_read.low) in server_tls_readcb()
823 if (bufev->wm_read.high != 0 && len > bufev->wm_read.high) { in server_tls_readcb()
824 struct evbuffer *buf = bufev->input; in server_tls_readcb()
[all …]
|
| /openbsd-src/usr.sbin/relayd/ |
| H A D | relay.c | 2494 struct bufferevent *bufev = arg; in relay_tls_readcb()
2495 struct ctl_relay_event *cre = bufev->cbarg; in relay_tls_readcb()
2506 if (bufev->wm_read.high != 0) in relay_tls_readcb()
2507 howmuch = MINIMUM(sizeof(rbuf), bufev->wm_read.high); in relay_tls_readcb()
2523 if (evbuffer_add(bufev->input, rbuf, ret) == -1) { in relay_tls_readcb()
2528 relay_bufferevent_add(&bufev->ev_read, bufev->timeout_read); in relay_tls_readcb()
2530 len = EVBUFFER_LENGTH(bufev->input); in relay_tls_readcb()
2531 if (bufev->wm_read.low != 0 && len < bufev in relay_tls_readcb()
2475 struct bufferevent *bufev = arg; relay_tls_readcb() local
2536 struct bufferevent *bufev = arg; relay_tls_writecb() local
[all...] |
| /openbsd-src/usr.bin/tmux/ |
| H A D | cmd-pipe-pane.c | 190 cmd_pipe_pane_read_callback(__unused struct bufferevent *bufev, void *data) in cmd_pipe_pane_read_callback() argument
207 cmd_pipe_pane_write_callback(__unused struct bufferevent *bufev, void *data) in cmd_pipe_pane_write_callback() argument
218 cmd_pipe_pane_error_callback(__unused struct bufferevent *bufev, in cmd_pipe_pane_error_callback() argument
|
| H A D | job.c | 296 job_read_callback(__unused struct bufferevent *bufev, void *data)
310 job_write_callback(__unused struct bufferevent *bufev, void *data) in job_write_callback()
326 job_error_callback(__unused struct bufferevent *bufev, __unused short events, in job_error_callback()
289 job_read_callback(__unused struct bufferevent * bufev,void * data) job_read_callback() argument
303 job_write_callback(__unused struct bufferevent * bufev,void * data) job_write_callback() argument
319 job_error_callback(__unused struct bufferevent * bufev,__unused short events,void * data) job_error_callback() argument
|
| H A D | control.c | 538 control_error_callback(__unused struct bufferevent *bufev, in control_error_callback() argument
548 control_read_callback(__unused struct bufferevent *bufev, void *data) in control_read_callback() argument
723 control_write_callback(__unused struct bufferevent *bufev, void *data) in control_write_callback() argument
|
| H A D | window.c | 1026 window_pane_read_callback(__unused struct bufferevent *bufev, void *data) in window_pane_read_callback()
1054 window_pane_error_callback(__unused struct bufferevent *bufev,
1001 window_pane_read_callback(__unused struct bufferevent * bufev,void * data) window_pane_read_callback() argument
1029 window_pane_error_callback(__unused struct bufferevent * bufev,__unused short what,void * data) window_pane_error_callback() argument
|
| /openbsd-src/usr.bin/cu/ |
| H A D | cu.c | 315 stream_read(struct bufferevent *bufev, void *data) in stream_read() argument
354 stream_error(struct bufferevent *bufev, short what, void *data) in stream_error() argument
360 line_read(struct bufferevent *bufev, void *data) in line_read() argument
378 line_error(struct bufferevent *bufev, short what, void *data) in line_error() argument
|
| /openbsd-src/usr.sbin/ftp-proxy/ |
| H A D | ftp-proxy.c | 127 client_error(struct bufferevent *bufev, short what, void *arg) in client_error() argument
233 client_read(struct bufferevent *bufev, void *arg) in client_read() argument
241 read = bufferevent_read(bufev, s->cbuf + s->cbuf_valid, in client_read()
925 server_error(struct bufferevent *bufev, short what, void *arg) in server_error() argument
1075 server_read(struct bufferevent *bufev, void *arg) in server_read() argument
1081 bufferevent_settimeout(bufev, timeout, 0); in server_read()
1085 read = bufferevent_read(bufev, s->sbuf + s->sbuf_valid, in server_read()
|