HomeSort by: relevance | last modified time | path
    Searched defs:bev (Results 1 - 25 of 33) sorted by relevancy

1 2

  /src/external/bsd/libevent/dist/sample/
hello-world.c 93 struct bufferevent *bev; local
95 bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE);
96 if (!bev) {
101 bufferevent_setcb(bev, NULL, conn_writecb, conn_eventcb, NULL);
102 bufferevent_enable(bev, EV_WRITE);
103 bufferevent_disable(bev, EV_READ);
105 bufferevent_write(bev, MESSAGE, strlen(MESSAGE));
109 conn_writecb(struct bufferevent *bev, void *user_data)
111 struct evbuffer *output = bufferevent_get_output(bev);
114 bufferevent_free(bev);
    [all...]
https-client.c 61 struct bufferevent *bev = (struct bufferevent *) ctx; local
68 while ((oslerr = bufferevent_get_openssl_error(bev))) {
231 struct bufferevent *bev; local
434 bev = bufferevent_socket_new(base, -1, BEV_OPT_CLOSE_ON_FREE);
437 bev = bufferevent_openssl_socket_new(base, -1, ssl,
442 if (bev == NULL) {
447 bufferevent_openssl_set_allow_dirty_shutdown(bev, 1);
451 evcon = evhttp_connection_base_bufferevent_new(base, NULL, bev,
466 req = evhttp_request_new(http_request_done, bev);
  /src/external/bsd/libevent/dist/test/
test-fdleak.c 85 server_read_cb(struct bufferevent *bev, void *ctx)
87 while (evbuffer_get_length(bufferevent_get_input(bev))) {
89 bufferevent_read(bev, &tmp, 1);
90 bufferevent_write(bev, &tmp, 1);
96 server_event_cb(struct bufferevent *bev, short events, void *ctx)
102 bufferevent_free(bev);
104 event_base_loopbreak(bufferevent_get_base(bev));
115 struct bufferevent *bev = bufferevent_socket_new(base, sock, local
117 bufferevent_setcb(bev, server_read_cb, NULL, server_event_cb, NULL);
118 bufferevent_enable(bev, EV_READ|EV_WRITE)
213 struct bufferevent *bev = bufferevent_socket_new(base, -1, local
    [all...]
test-ratelim.c 129 loud_writecb(struct bufferevent *bev, void *ctx)
132 struct evbuffer *output = bufferevent_get_output(bev);
143 discard_readcb(struct bufferevent *bev, void *ctx)
146 struct evbuffer *input = bufferevent_get_input(bev);
153 write_on_connectedcb(struct bufferevent *bev, short what, void *ctx)
156 loud_writecb(bev, ctx);
158 bufferevent_enable(bev, EV_READ|EV_WRITE);
163 echo_readcb(struct bufferevent *bev, void *ctx)
165 struct evbuffer *input = bufferevent_get_input(bev);
166 struct evbuffer *output = bufferevent_get_output(bev);
196 struct bufferevent *bev; local
218 struct bufferevent *bev = arg; local
    [all...]
regress_ssl.c 291 bufferevent_openssl_check_fd(struct bufferevent *bev, int filter)
293 tt_fd_op(bufferevent_getfd(bev), !=, EVUTIL_INVALID_SOCKET);
294 tt_fd_op(bufferevent_setfd(bev, EVUTIL_INVALID_SOCKET), ==, 0);
296 tt_fd_op(bufferevent_getfd(bev), !=, EVUTIL_INVALID_SOCKET);
298 tt_fd_op(bufferevent_getfd(bev), ==, EVUTIL_INVALID_SOCKET);
305 bufferevent_openssl_check_freed(struct bufferevent *bev)
307 tt_int_op(event_pending(&bev->ev_read, EVLIST_ALL, NULL), ==, 0);
308 tt_int_op(event_pending(&bev->ev_write, EVLIST_ALL, NULL), ==, 0);
315 free_on_cb(struct bufferevent *bev, void *ctx)
317 TT_BLATHER(("free_on_cb: %p", bev));
576 struct bufferevent *bev = arg; local
584 struct bufferevent *bev; local
736 struct bufferevent *bev; local
810 struct bufferevent *bev; member in struct:wm_context
862 struct bufferevent *bev; local
890 struct bufferevent *bev; local
    [all...]
  /src/external/bsd/ntp/dist/sntp/libevent/test/
test-fdleak.c 84 server_read_cb(struct bufferevent *bev, void *ctx)
86 while (evbuffer_get_length(bufferevent_get_input(bev))) {
88 bufferevent_read(bev, &tmp, 1);
89 bufferevent_write(bev, &tmp, 1);
95 server_event_cb(struct bufferevent *bev, short events, void *ctx)
101 bufferevent_free(bev);
103 event_base_loopbreak(bufferevent_get_base(bev));
114 struct bufferevent *bev = bufferevent_socket_new(base, sock, local
116 bufferevent_setcb(bev, server_read_cb, NULL, server_event_cb, NULL);
117 bufferevent_enable(bev, EV_READ|EV_WRITE)
212 struct bufferevent *bev = bufferevent_socket_new(base, -1, local
    [all...]
test-ratelim.c 130 loud_writecb(struct bufferevent *bev, void *ctx)
133 struct evbuffer *output = bufferevent_get_output(bev);
144 discard_readcb(struct bufferevent *bev, void *ctx)
147 struct evbuffer *input = bufferevent_get_input(bev);
154 write_on_connectedcb(struct bufferevent *bev, short what, void *ctx)
157 loud_writecb(bev, ctx);
159 bufferevent_enable(bev, EV_READ|EV_WRITE);
164 echo_readcb(struct bufferevent *bev, void *ctx)
166 struct evbuffer *input = bufferevent_get_input(bev);
167 struct evbuffer *output = bufferevent_get_output(bev);
197 struct bufferevent *bev; local
219 struct bufferevent *bev = arg; local
    [all...]
  /src/sys/arch/landisk/dev/
btn_obio.c 223 struct btn_event *bev = (void *)arg; local
225 btn_event_send(bev, BUTTON_EVENT_PRESSED);
button.c 121 btn_queue_event(button_event_t *bev)
127 btn_event_queue[btn_event_queue_head] = *bev;
135 btn_get_event(button_event_t *bev)
141 *bev = btn_event_queue[btn_event_queue_tail];
230 button_event_t bev; local
243 if (btn_get_event(&bev)) {
245 return (uiomove(&bev, BUTTON_EVENT_MSG_SIZE, uio));
365 btn_event_register(struct btn_event *bev)
369 LIST_INSERT_HEAD(&btn_event_list, bev, bev_list);
376 btn_event_unregister(struct btn_event *bev)
    [all...]
  /src/external/bsd/libevent/dist/
bufferevent_pair.c 49 struct bufferevent_private bev; member in struct:bufferevent_pair
56 /* Given a bufferevent that's really a bev part of a bufferevent_pair,
59 upcast(struct bufferevent *bev)
62 if (!BEV_IS_PAIR(bev))
64 bev_p = EVUTIL_UPCAST(bev, struct bufferevent_pair, bev.bev);
65 EVUTIL_ASSERT(BEV_IS_PAIR(&bev_p->bev.bev));
69 #define downcast(bev_pair) (&(bev_pair)->bev.bev
    [all...]
bufferevent_async.c 84 struct bufferevent_private bev; member in struct:bufferevent_async
97 evutil_offsetof(struct bufferevent_async, bev.bev),
108 be_async_run_eventcb(struct bufferevent *bev, short what, int options)
109 { bufferevent_run_eventcb_(bev, what, options|BEV_TRIG_DEFER_CALLBACKS); }
112 be_async_trigger_nolock(struct bufferevent *bev, short what, int options)
113 { bufferevent_trigger_nolock_(bev, what, options|BEV_TRIG_DEFER_CALLBACKS); }
129 upcast(struct bufferevent *bev)
132 if (!BEV_IS_ASYNC(bev))
134 bev_a = EVUTIL_UPCAST(bev, struct bufferevent_async, bev.bev)
168 struct bufferevent *bev = &beva->bev.bev; local
179 struct bufferevent *bev = &beva->bev.bev; local
190 struct bufferevent *bev = &beva->bev.bev; local
201 struct bufferevent *bev = &beva->bev.bev; local
214 struct bufferevent *bev = &beva->bev.bev; local
260 struct bufferevent *bev = &beva->bev.bev; local
314 struct bufferevent *bev = arg; local
333 struct bufferevent *bev = arg; local
440 struct bufferevent *bev = &bev_a->bev.bev; local
468 struct bufferevent *bev = &bev_a->bev.bev; local
507 struct bufferevent *bev = &bev_a->bev.bev; local
550 struct bufferevent *bev; local
    [all...]
bufferevent_filter.c 84 struct bufferevent_private bev; member in struct:bufferevent_filtered
108 evutil_offsetof(struct bufferevent_filtered, bev.bev),
118 /* Given a bufferevent that's really the bev filter of a bufferevent_filtered,
121 upcast(struct bufferevent *bev)
124 if (!BEV_IS_FILTER(bev))
126 bev_f = (void*)( ((char*)bev) -
127 evutil_offsetof(struct bufferevent_filtered, bev.bev));
128 EVUTIL_ASSERT(BEV_IS_FILTER(&bev_f->bev.bev))
310 struct bufferevent *bev = downcast(bevf); local
428 struct bufferevent *bev = downcast(bevf); local
491 struct bufferevent *bev = downcast(bevf); local
520 struct bufferevent *bev = downcast(bevf); local
535 struct bufferevent *bev = downcast(bevf); local
557 struct bufferevent *bev = downcast(bevf); local
    [all...]
bufferevent_sock.c 92 evutil_offsetof(struct bufferevent_private, bev),
103 bufferevent_socket_get_conn_address_(struct bufferevent *bev)
105 struct bufferevent_private *bev_p = BEV_UPCAST(bev);
110 bufferevent_socket_set_conn_address_fd_(struct bufferevent *bev,
113 struct bufferevent_private *bev_p = BEV_UPCAST(bev);
123 bufferevent_socket_set_conn_address_(struct bufferevent *bev,
126 struct bufferevent_private *bev_p = BEV_UPCAST(bev);
366 bufev = &bufev_p->bev;
383 bufferevent_socket_connect(struct bufferevent *bev,
386 struct bufferevent_private *bufev_p = BEV_UPCAST(bev);
463 struct bufferevent *bev = arg; local
    [all...]
bufferevent_ratelim.c 116 bufferevent_update_buckets(struct bufferevent_private *bev)
118 /* Must hold lock on bev. */
121 event_base_gettimeofday_cached(bev->bev.ev_base, &now);
122 tick = ev_token_bucket_get_tick_(&now, bev->rate_limiting->cfg);
123 if (tick != bev->rate_limiting->limit.last_updated)
124 ev_token_bucket_update_(&bev->rate_limiting->limit,
125 bev->rate_limiting->cfg, tick);
200 bufferevent_get_rlim_max_(struct bufferevent_private *bev, int is_write)
202 /* needs lock on bev. *
355 struct bufferevent_private *bev; local
380 struct bufferevent_private *bev; local
400 struct bufferevent_private *bev = arg; local
451 struct bufferevent_private *bev; local
493 struct bufferevent_private *bev, *first; local
512 struct bufferevent_private *bev, *first; local
    [all...]
bufferevent-internal.h 158 struct bufferevent bev; member in struct:bufferevent_private
264 struct bufferevent bev;
266 then mem_offset should be offsetof(struct bufferevent_x, bev)
432 void bufferevent_init_generic_timeout_cbs_(struct bufferevent *bev);
438 int bufferevent_generic_adj_timeouts_(struct bufferevent *bev);
440 int bufferevent_generic_adj_existing_timeouts_(struct bufferevent *bev);
443 enum bufferevent_options bufferevent_get_options_(struct bufferevent *bev);
447 bufferevent_socket_get_conn_address_(struct bufferevent *bev);
451 bufferevent_socket_set_conn_address_fd_(struct bufferevent *bev, evutil_socket_t fd);
455 bufferevent_socket_set_conn_address_(struct bufferevent *bev, struct sockaddr *addr, size_t addrlen)
    [all...]
bufferevent.c 67 static void bufferevent_cancel_all_(struct bufferevent *bev);
125 static void bufferevent_inbuf_wm_check(struct bufferevent *bev)
127 if (!bev->wm_read.high)
129 if (!(bev->enabled & EV_READ))
131 if (evbuffer_get_length(bev->input) < bev->wm_read.high)
134 bufferevent_trigger(bev, EV_READ, BEV_OPT_DEFER_CALLBACKS);
159 struct bufferevent *bufev = &bufev_private->bev;
193 struct bufferevent *bufev = &bufev_private->bev;
238 (bevp)->bev.ev_base,
948 struct bufferevent *bev = ctx; local
957 struct bufferevent *bev = ctx; local
    [all...]
bufferevent_openssl.c 295 struct bufferevent_private bev; member in struct:bufferevent_openssl
345 evutil_offsetof(struct bufferevent_openssl, bev.bev),
358 upcast(struct bufferevent *bev)
361 if (!BEV_IS_OPENSSL(bev))
363 bev_o = (void*)( ((char*)bev) -
364 evutil_offsetof(struct bufferevent_openssl, bev.bev));
365 EVUTIL_ASSERT(BEV_IS_OPENSSL(&bev_o->bev.bev));
393 struct bufferevent *bev = &bev_ssl->bev.bev; local
416 struct bufferevent *bev = &bev_ssl->bev.bev; local
434 struct bufferevent *bev = &bev_ssl->bev.bev; local
448 struct bufferevent *bev = &bev_ssl->bev.bev; local
474 struct bufferevent *bev = &bev_ssl->bev.bev; local
488 struct bufferevent *bev = &bev_ssl->bev.bev; local
589 struct bufferevent *bev = &bev_ssl->bev.bev; local
660 struct bufferevent *bev = &bev_ssl->bev.bev; local
843 struct bufferevent *bev = &bev_ssl->bev.bev; local
868 struct bufferevent *bev = &bev_ssl->bev.bev; local
977 struct bufferevent *bev = &bev_ssl->bev.bev; local
994 struct bufferevent *bev = &bev_ssl->bev.bev; local
1103 struct bufferevent *bev = &bev_ssl->bev.bev; local
1424 struct bufferevent *bev; local
    [all...]
  /src/external/bsd/ntp/dist/sntp/libevent/
bufferevent_pair.c 48 struct bufferevent_private bev; member in struct:bufferevent_pair
55 /* Given a bufferevent that's really a bev part of a bufferevent_pair,
58 upcast(struct bufferevent *bev)
61 if (!BEV_IS_PAIR(bev))
63 bev_p = EVUTIL_UPCAST(bev, struct bufferevent_pair, bev.bev);
64 EVUTIL_ASSERT(BEV_IS_PAIR(&bev_p->bev.bev));
68 #define downcast(bev_pair) (&(bev_pair)->bev.bev
    [all...]
bufferevent_async.c 83 struct bufferevent_private bev; member in struct:bufferevent_async
96 evutil_offsetof(struct bufferevent_async, bev.bev),
107 be_async_run_eventcb(struct bufferevent *bev, short what, int options)
108 { bufferevent_run_eventcb_(bev, what, options|BEV_TRIG_DEFER_CALLBACKS); }
111 be_async_trigger_nolock(struct bufferevent *bev, short what, int options)
112 { bufferevent_trigger_nolock_(bev, what, options|BEV_TRIG_DEFER_CALLBACKS); }
128 upcast(struct bufferevent *bev)
131 if (!BEV_IS_ASYNC(bev))
133 bev_a = EVUTIL_UPCAST(bev, struct bufferevent_async, bev.bev)
167 struct bufferevent *bev = &beva->bev.bev; local
178 struct bufferevent *bev = &beva->bev.bev; local
189 struct bufferevent *bev = &beva->bev.bev; local
200 struct bufferevent *bev = &beva->bev.bev; local
213 struct bufferevent *bev = &beva->bev.bev; local
259 struct bufferevent *bev = &beva->bev.bev; local
313 struct bufferevent *bev = arg; local
332 struct bufferevent *bev = arg; local
439 struct bufferevent *bev = &bev_a->bev.bev; local
467 struct bufferevent *bev = &bev_a->bev.bev; local
506 struct bufferevent *bev = &bev_a->bev.bev; local
549 struct bufferevent *bev; local
    [all...]
bufferevent_filter.c 83 struct bufferevent_private bev; member in struct:bufferevent_filtered
107 evutil_offsetof(struct bufferevent_filtered, bev.bev),
117 /* Given a bufferevent that's really the bev filter of a bufferevent_filtered,
120 upcast(struct bufferevent *bev)
123 if (!BEV_IS_FILTER(bev))
125 bev_f = (void*)( ((char*)bev) -
126 evutil_offsetof(struct bufferevent_filtered, bev.bev));
127 EVUTIL_ASSERT(BEV_IS_FILTER(&bev_f->bev.bev))
309 struct bufferevent *bev = downcast(bevf); local
427 struct bufferevent *bev = downcast(bevf); local
490 struct bufferevent *bev = downcast(bevf); local
519 struct bufferevent *bev = downcast(bevf); local
534 struct bufferevent *bev = downcast(bevf); local
556 struct bufferevent *bev = downcast(bevf); local
    [all...]
bufferevent_sock.c 91 evutil_offsetof(struct bufferevent_private, bev),
102 bufferevent_socket_get_conn_address_(struct bufferevent *bev)
104 struct bufferevent_private *bev_p = BEV_UPCAST(bev);
109 bufferevent_socket_set_conn_address_fd_(struct bufferevent *bev,
112 struct bufferevent_private *bev_p = BEV_UPCAST(bev);
122 bufferevent_socket_set_conn_address_(struct bufferevent *bev,
125 struct bufferevent_private *bev_p = BEV_UPCAST(bev);
365 bufev = &bufev_p->bev;
382 bufferevent_socket_connect(struct bufferevent *bev,
385 struct bufferevent_private *bufev_p = BEV_UPCAST(bev);
462 struct bufferevent *bev = arg; local
    [all...]
bufferevent_ratelim.c 116 bufferevent_update_buckets(struct bufferevent_private *bev)
118 /* Must hold lock on bev. */
121 event_base_gettimeofday_cached(bev->bev.ev_base, &now);
122 tick = ev_token_bucket_get_tick_(&now, bev->rate_limiting->cfg);
123 if (tick != bev->rate_limiting->limit.last_updated)
124 ev_token_bucket_update_(&bev->rate_limiting->limit,
125 bev->rate_limiting->cfg, tick);
200 bufferevent_get_rlim_max_(struct bufferevent_private *bev, int is_write)
202 /* needs lock on bev. *
355 struct bufferevent_private *bev; local
380 struct bufferevent_private *bev; local
400 struct bufferevent_private *bev = arg; local
451 struct bufferevent_private *bev; local
493 struct bufferevent_private *bev, *first; local
512 struct bufferevent_private *bev, *first; local
    [all...]
bufferevent-internal.h 158 struct bufferevent bev; member in struct:bufferevent_private
264 struct bufferevent bev;
266 then mem_offset should be offsetof(struct bufferevent_x, bev)
432 void bufferevent_init_generic_timeout_cbs_(struct bufferevent *bev);
438 int bufferevent_generic_adj_timeouts_(struct bufferevent *bev);
440 int bufferevent_generic_adj_existing_timeouts_(struct bufferevent *bev);
443 enum bufferevent_options bufferevent_get_options_(struct bufferevent *bev);
447 bufferevent_socket_get_conn_address_(struct bufferevent *bev);
451 bufferevent_socket_set_conn_address_fd_(struct bufferevent *bev, evutil_socket_t fd);
455 bufferevent_socket_set_conn_address_(struct bufferevent *bev, struct sockaddr *addr, size_t addrlen)
    [all...]
bufferevent.c 65 static void bufferevent_cancel_all_(struct bufferevent *bev);
123 static void bufferevent_inbuf_wm_check(struct bufferevent *bev)
125 if (!bev->wm_read.high)
127 if (!(bev->enabled & EV_READ))
129 if (evbuffer_get_length(bev->input) < bev->wm_read.high)
132 bufferevent_trigger(bev, EV_READ, BEV_OPT_DEFER_CALLBACKS);
157 struct bufferevent *bufev = &bufev_private->bev;
191 struct bufferevent *bufev = &bufev_private->bev;
236 (bevp)->bev.ev_base,
946 struct bufferevent *bev = ctx; local
955 struct bufferevent *bev = ctx; local
    [all...]
bufferevent_openssl.c 294 struct bufferevent_private bev; member in struct:bufferevent_openssl
344 evutil_offsetof(struct bufferevent_openssl, bev.bev),
357 upcast(struct bufferevent *bev)
360 if (!BEV_IS_OPENSSL(bev))
362 bev_o = (void*)( ((char*)bev) -
363 evutil_offsetof(struct bufferevent_openssl, bev.bev));
364 EVUTIL_ASSERT(BEV_IS_OPENSSL(&bev_o->bev.bev));
392 struct bufferevent *bev = &bev_ssl->bev.bev; local
415 struct bufferevent *bev = &bev_ssl->bev.bev; local
433 struct bufferevent *bev = &bev_ssl->bev.bev; local
447 struct bufferevent *bev = &bev_ssl->bev.bev; local
473 struct bufferevent *bev = &bev_ssl->bev.bev; local
487 struct bufferevent *bev = &bev_ssl->bev.bev; local
588 struct bufferevent *bev = &bev_ssl->bev.bev; local
659 struct bufferevent *bev = &bev_ssl->bev.bev; local
842 struct bufferevent *bev = &bev_ssl->bev.bev; local
867 struct bufferevent *bev = &bev_ssl->bev.bev; local
976 struct bufferevent *bev = &bev_ssl->bev.bev; local
993 struct bufferevent *bev = &bev_ssl->bev.bev; local
1102 struct bufferevent *bev = &bev_ssl->bev.bev; local
1423 struct bufferevent *bev; local
    [all...]

Completed in 32 milliseconds

1 2