/openbsd-current/lib/libevent/ |
H A D | evbuffer.c | 67 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 D | event.h | 823 @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 D | evbuffer_tls.c | 71 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 D | evbuffer_tls.c | 71 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 D | syslogd.c | 329 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 D | server.c | 783 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 D | relay.c | 2475 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 D | cmd-pipe-pane.c | 190 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 D | job.c | 289 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 D | control.c | 538 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 D | window.c | 1001 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 D | cu.c | 315 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 D | ftp-proxy.c | 127 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,
|