| /src/external/bsd/libevent/dist/ |
| bufferevent_pair.c | 99 struct bufferevent_pair *bufev; local
100 if (! (bufev = mm_calloc(1, sizeof(struct bufferevent_pair))))
102 if (bufferevent_init_common_(&bufev->bev, base, &bufferevent_ops_pair,
104 mm_free(bufev);
107 if (!evbuffer_add_cb(bufev->bev.bev.output, be_pair_outbuf_cb, bufev)) {
108 bufferevent_free(downcast(bufev));
112 bufferevent_init_generic_timeout_cbs_(&bufev->bev.bev);
114 return bufev;
228 be_pair_enable(struct bufferevent *bufev, short events
244 be_pair_transfer(downcast(partner), bufev, 0); local
[all...] |
| bufferevent_filter.c | 73 static int be_filter_flush(struct bufferevent *bufev,
153 struct bufferevent *bufev = downcast(bevf); local
155 bufev->wm_read.high &&
156 evbuffer_get_length(bufev->input) >= bufev->wm_read.high;
350 struct bufferevent *bufev = downcast(bevf); local
359 if (!(bufev->enabled & EV_WRITE) ||
361 !evbuffer_get_length(bufev->output))
367 evbuffer_cb_clear_flags(bufev->output, bevf->outbuf_cb,
392 (bufev->enabled & EV_WRITE) &
446 struct bufferevent *bufev = downcast(bevf); local
[all...] |
| bufferevent_sock.c | 136 struct bufferevent *bufev = arg; local
137 struct bufferevent_private *bufev_p = BEV_UPCAST(bufev);
140 (bufev->enabled & EV_WRITE) &&
141 !event_pending(&bufev->ev_write, EV_WRITE, NULL) &&
145 if (bufferevent_add_event_(&bufev->ev_write, &bufev->timeout_write) == -1) {
154 struct bufferevent *bufev = arg; local
155 struct bufferevent_private *bufev_p = BEV_UPCAST(bufev);
161 bufferevent_incref_and_lock_(bufev);
171 input = bufev->input
235 struct bufferevent *bufev = arg; local
351 struct bufferevent *bufev; local
559 struct bufferevent *bufev; local
[all...] |
| http-internal.h | 58 struct bufferevent *bufev; member in struct:evhttp_connection
|
| bufferevent.c | 71 bufferevent_suspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what)
73 struct bufferevent_private *bufev_private = BEV_UPCAST(bufev);
74 BEV_LOCK(bufev);
76 bufev->be_ops->disable(bufev, EV_READ);
78 BEV_UNLOCK(bufev);
82 bufferevent_unsuspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what)
84 struct bufferevent_private *bufev_private = BEV_UPCAST(bufev);
85 BEV_LOCK(bufev);
87 if (!bufev_private->read_suspended && (bufev->enabled & EV_READ)
144 struct bufferevent *bufev = arg; local
159 struct bufferevent *bufev = &bufev_private->bev; local
193 struct bufferevent *bufev = &bufev_private->bev; local
318 struct bufferevent *bufev = &bufev_private->bev; local
753 struct bufferevent *bufev = arg_; local
[all...] |
| bufferevent_openssl.c | 164 struct bufferevent *bufev = BIO_get_data(b); local
173 output = bufferevent_get_output(bufev);
178 if (bufev->wm_write.high && bufev->wm_write.high <= (outlen+inlen)) {
179 if (bufev->wm_write.high <= outlen) {
184 inlen = bufev->wm_write.high - outlen;
196 struct bufferevent *bufev = BIO_get_data(b); local
207 ret = evbuffer_get_length(bufferevent_get_input(bufev)) != 0;
210 ret = evbuffer_get_length(bufferevent_get_output(bufev)) != 0;
339 static int be_openssl_flush(struct bufferevent *bufev,
[all...] |
| /src/external/bsd/ntp/dist/sntp/libevent/ |
| bufferevent_pair.c | 98 struct bufferevent_pair *bufev; local
99 if (! (bufev = mm_calloc(1, sizeof(struct bufferevent_pair))))
101 if (bufferevent_init_common_(&bufev->bev, base, &bufferevent_ops_pair,
103 mm_free(bufev);
106 if (!evbuffer_add_cb(bufev->bev.bev.output, be_pair_outbuf_cb, bufev)) {
107 bufferevent_free(downcast(bufev));
111 bufferevent_init_generic_timeout_cbs_(&bufev->bev.bev);
113 return bufev;
227 be_pair_enable(struct bufferevent *bufev, short events
243 be_pair_transfer(downcast(partner), bufev, 0); local
[all...] |
| bufferevent_filter.c | 72 static int be_filter_flush(struct bufferevent *bufev,
152 struct bufferevent *bufev = downcast(bevf); local
154 bufev->wm_read.high &&
155 evbuffer_get_length(bufev->input) >= bufev->wm_read.high;
349 struct bufferevent *bufev = downcast(bevf); local
358 if (!(bufev->enabled & EV_WRITE) ||
360 !evbuffer_get_length(bufev->output))
366 evbuffer_cb_clear_flags(bufev->output, bevf->outbuf_cb,
391 (bufev->enabled & EV_WRITE) &
445 struct bufferevent *bufev = downcast(bevf); local
[all...] |
| bufferevent_sock.c | 135 struct bufferevent *bufev = arg; local
136 struct bufferevent_private *bufev_p = BEV_UPCAST(bufev);
139 (bufev->enabled & EV_WRITE) &&
140 !event_pending(&bufev->ev_write, EV_WRITE, NULL) &&
144 if (bufferevent_add_event_(&bufev->ev_write, &bufev->timeout_write) == -1) {
153 struct bufferevent *bufev = arg; local
154 struct bufferevent_private *bufev_p = BEV_UPCAST(bufev);
160 bufferevent_incref_and_lock_(bufev);
170 input = bufev->input
234 struct bufferevent *bufev = arg; local
350 struct bufferevent *bufev; local
558 struct bufferevent *bufev; local
[all...] |
| http-internal.h | 59 struct bufferevent *bufev; member in struct:evhttp_connection
|
| bufferevent.c | 69 bufferevent_suspend_read_(struct bufferevent *bufev, bufferevent_suspend_flags what)
71 struct bufferevent_private *bufev_private = BEV_UPCAST(bufev);
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)
82 struct bufferevent_private *bufev_private = BEV_UPCAST(bufev);
83 BEV_LOCK(bufev);
85 if (!bufev_private->read_suspended && (bufev->enabled & EV_READ)
142 struct bufferevent *bufev = arg; local
157 struct bufferevent *bufev = &bufev_private->bev; local
191 struct bufferevent *bufev = &bufev_private->bev; local
316 struct bufferevent *bufev = &bufev_private->bev; local
751 struct bufferevent *bufev = arg_; local
[all...] |
| bufferevent_openssl.c | 163 struct bufferevent *bufev = BIO_get_data(b); local
172 output = bufferevent_get_output(bufev);
177 if (bufev->wm_write.high && bufev->wm_write.high <= (outlen+inlen)) {
178 if (bufev->wm_write.high <= outlen) {
183 inlen = bufev->wm_write.high - outlen;
195 struct bufferevent *bufev = BIO_get_data(b); local
206 ret = evbuffer_get_length(bufferevent_get_input(bufev)) != 0;
209 ret = evbuffer_get_length(bufferevent_get_output(bufev)) != 0;
338 static int be_openssl_flush(struct bufferevent *bufev,
[all...] |
| /src/external/bsd/libevent/dist/test/ |
| regress_http.c | 1462 struct bufferevent *bufev = NULL; local
1519 bufev = evhttp_connection_get_bufferevent(evcon);
1523 evbuffer_add_cb(bufferevent_get_output(bufev), http_no_write, NULL);
1595 if (bufev)
1596 evbuffer_remove_cb(bufferevent_get_output(bufev), http_no_write, NULL);
|
| /src/external/bsd/ntp/dist/sntp/libevent/test/ |
| regress_http.c | 1459 struct bufferevent *bufev = NULL; local
1516 bufev = evhttp_connection_get_bufferevent(evcon);
1520 evbuffer_add_cb(bufferevent_get_output(bufev), http_no_write, NULL);
1592 if (bufev)
1593 evbuffer_remove_cb(bufferevent_get_output(bufev), http_no_write, NULL);
|
