| /openbsd/lib/libevent/ |
| H A D | evbuffer.c | 76 bufferevent_add(&bufev->ev_read, bufev->timeout_read); in bufferevent_read_pressure_cb()
124 bufferevent_add(&bufev->ev_read, bufev->timeout_read); in bufferevent_readcb()
128 if (bufev->wm_read.low != 0 && len < bufev->wm_read.low) in bufferevent_readcb()
140 (*bufev->readcb)(bufev, bufev->cbarg); in bufferevent_readcb()
144 bufferevent_add(&bufev->ev_read, bufev->timeout_read); in bufferevent_readcb()
148 (*bufev->errorcb)(bufev, what, bufev->cbarg); in bufferevent_readcb()
189 (*bufev->writecb)(bufev, bufev->cbarg); in bufferevent_writecb()
199 (*bufev->errorcb)(bufev, what, bufev->cbarg); in bufferevent_writecb()
268 event_base_set(bufev->ev_base, &bufev->ev_read); in bufferevent_setfd()
269 event_base_set(bufev->ev_base, &bufev->ev_write); in bufferevent_setfd()
[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,
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);
943 void bufferevent_settimeout(struct bufferevent *bufev,
[all …]
|
| /openbsd/usr.sbin/ldapd/ |
| H A D | evbuffer_tls.c | 102 bufferevent_add(&bufev->ev_read, bufev->timeout_read); in buffertls_readcb()
108 bufferevent_add(&bufev->ev_write, bufev->timeout_write); in buffertls_readcb()
123 bufferevent_add(&bufev->ev_read, bufev->timeout_read); in buffertls_readcb()
129 if (bufev->wm_read.low != 0 && len < bufev->wm_read.low) in buffertls_readcb()
141 (*bufev->readcb)(bufev, bufev->cbarg); in buffertls_readcb()
145 (*bufev->errorcb)(bufev, what, bufev->cbarg); in buffertls_readcb()
188 bufferevent_add(&bufev->ev_read, bufev->timeout_read); in buffertls_writecb()
198 (*bufev->writecb)(bufev, bufev->cbarg); in buffertls_writecb()
203 (*bufev->errorcb)(bufev, what, bufev->cbarg); in buffertls_writecb()
248 (*bufev->errorcb)(bufev, what, bufev->cbarg); in buffertls_handshakecb()
[all …]
|
| /openbsd/usr.sbin/syslogd/ |
| H A D | evbuffer_tls.c | 102 bufferevent_add(&bufev->ev_read, bufev->timeout_read); in buffertls_readcb()
108 bufferevent_add(&bufev->ev_write, bufev->timeout_write); in buffertls_readcb()
124 bufferevent_add(&bufev->ev_read, bufev->timeout_read); in buffertls_readcb()
130 if (bufev->wm_read.low != 0 && len < bufev->wm_read.low) in buffertls_readcb()
142 (*bufev->readcb)(bufev, bufev->cbarg); in buffertls_readcb()
146 (*bufev->errorcb)(bufev, what, bufev->cbarg); in buffertls_readcb()
189 bufferevent_add(&bufev->ev_read, bufev->timeout_read); in buffertls_writecb()
199 (*bufev->writecb)(bufev, bufev->cbarg); in buffertls_writecb()
204 (*bufev->errorcb)(bufev, what, bufev->cbarg); in buffertls_writecb()
249 (*bufev->errorcb)(bufev, what, bufev->cbarg); in buffertls_handshakecb()
[all …]
|
| H A D | syslogd.c | 1325 while (EVBUFFER_LENGTH(bufev->input) > 0) { in tcp_readcb()
1347 evbuffer_drain(bufev->input, len); in tcp_readcb()
1354 evbuffer_drain(bufev->input, -1); in tcp_readcb()
1412 evbuffer_drain(bufev->input, -1); in tcp_dropcb()
1468 buf = EVBUFFER_DATA(bufev->output); in tcp_errorcb()
1469 end = buf + EVBUFFER_LENGTH(bufev->output); in tcp_errorcb()
1480 evbuffer_drain(bufev->output, -1); in tcp_errorcb()
1513 bufferevent_setfd(bufev, s); in tcp_connectcb()
1640 tcpbuf_countmsg(struct bufferevent *bufev) in tcpbuf_countmsg() argument
1645 buf = EVBUFFER_DATA(bufev->output); in tcpbuf_countmsg()
[all …]
|
| /openbsd/usr.sbin/httpd/ |
| H A D | server.c | 818 server_bufferevent_add(&bufev->ev_read, bufev->timeout_read); 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()
831 (*bufev->readcb)(bufev, bufev->cbarg); in server_tls_readcb()
835 server_bufferevent_add(&bufev->ev_read, bufev->timeout_read); in server_tls_readcb()
839 (*bufev->errorcb)(bufev, what, bufev->cbarg); in server_tls_readcb()
871 server_bufferevent_add(&bufev->ev_write, bufev->timeout_write); in server_tls_writecb()
874 EVBUFFER_LENGTH(bufev->output) <= bufev->wm_write.low) in server_tls_writecb()
875 (*bufev->writecb)(bufev, bufev->cbarg); in server_tls_writecb()
879 server_bufferevent_add(&bufev->ev_write, bufev->timeout_write); in server_tls_writecb()
[all …]
|
| /openbsd/usr.sbin/relayd/ |
| H A D | relay.c | 2528 relay_bufferevent_add(&bufev->ev_read, bufev->timeout_read); in relay_tls_readcb()
2531 if (bufev->wm_read.low != 0 && len < bufev->wm_read.low) in relay_tls_readcb()
2533 if (bufev->wm_read.high != 0 && len > bufev->wm_read.high) { in relay_tls_readcb()
2541 (*bufev->readcb)(bufev, bufev->cbarg); in relay_tls_readcb()
2545 relay_bufferevent_add(&bufev->ev_read, bufev->timeout_read); in relay_tls_readcb()
2549 (*bufev->errorcb)(bufev, what, bufev->cbarg); in relay_tls_readcb()
2580 relay_bufferevent_add(&bufev->ev_write, bufev->timeout_write); in relay_tls_writecb()
2583 EVBUFFER_LENGTH(bufev->output) <= bufev->wm_write.low) in relay_tls_writecb()
2584 (*bufev->writecb)(bufev, bufev->cbarg); in relay_tls_writecb()
2588 relay_bufferevent_add(&bufev->ev_write, bufev->timeout_write); in relay_tls_writecb()
[all …]
|
| /openbsd/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) in job_read_callback() argument
310 job_write_callback(__unused struct bufferevent *bufev, void *data) in job_write_callback() argument
326 job_error_callback(__unused struct bufferevent *bufev, __unused short events, in 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() argument
1054 window_pane_error_callback(__unused struct bufferevent *bufev, in window_pane_error_callback() argument
|
| /openbsd/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/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()
|