Lines Matching refs:bev

80 	struct bufferevent_private bev;  member
93 evutil_offsetof(struct bufferevent_async, bev.bev),
104 upcast(struct bufferevent *bev) in upcast() argument
107 if (bev->be_ops != &bufferevent_ops_async) in upcast()
109 bev_a = EVUTIL_UPCAST(bev, struct bufferevent_async, bev.bev); in upcast()
118 EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev)); in upcast_connect()
127 EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev)); in upcast_read()
136 EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev)); in upcast_write()
143 struct bufferevent *bev = &beva->bev.bev; in bev_async_del_write() local
147 event_base_del_virtual_(bev->ev_base); in bev_async_del_write()
154 struct bufferevent *bev = &beva->bev.bev; in bev_async_del_read() local
158 event_base_del_virtual_(bev->ev_base); in bev_async_del_read()
165 struct bufferevent *bev = &beva->bev.bev; in bev_async_add_write() local
169 event_base_add_virtual_(bev->ev_base); in bev_async_add_write()
176 struct bufferevent *bev = &beva->bev.bev; in bev_async_add_read() local
180 event_base_add_virtual_(bev->ev_base); in bev_async_add_read()
189 struct bufferevent *bev = &beva->bev.bev; in bev_async_consider_writing() local
193 if (beva->write_in_progress || beva->bev.connecting) in bev_async_consider_writing()
195 if (!beva->ok || !(bev->enabled&EV_WRITE) || in bev_async_consider_writing()
196 !evbuffer_get_length(bev->output)) { in bev_async_consider_writing()
201 at_most = evbuffer_get_length(bev->output); in bev_async_consider_writing()
205 limit = (int)bufferevent_get_write_max_(&beva->bev); in bev_async_consider_writing()
209 if (beva->bev.write_suspended) { in bev_async_consider_writing()
215 bufferevent_incref_(bev); in bev_async_consider_writing()
216 if (evbuffer_launch_write_(bev->output, at_most, in bev_async_consider_writing()
218 bufferevent_decref_(bev); in bev_async_consider_writing()
220 bufferevent_run_eventcb_(bev, BEV_EVENT_ERROR, 0); in bev_async_consider_writing()
223 bufferevent_decrement_write_buckets_(&beva->bev, at_most); in bev_async_consider_writing()
235 struct bufferevent *bev = &beva->bev.bev; in bev_async_consider_reading() local
239 if (beva->read_in_progress || beva->bev.connecting) in bev_async_consider_reading()
241 if (!beva->ok || !(bev->enabled&EV_READ)) { in bev_async_consider_reading()
247 cur_size = evbuffer_get_length(bev->input); in bev_async_consider_reading()
248 read_high = bev->wm_read.high; in bev_async_consider_reading()
261 limit = (int)bufferevent_get_read_max_(&beva->bev); in bev_async_consider_reading()
265 if (beva->bev.read_suspended) { in bev_async_consider_reading()
270 bufferevent_incref_(bev); in bev_async_consider_reading()
271 if (evbuffer_launch_read_(bev->input, at_most, &beva->read_overlapped)) { in bev_async_consider_reading()
273 bufferevent_run_eventcb_(bev, BEV_EVENT_ERROR, 0); in bev_async_consider_reading()
274 bufferevent_decref_(bev); in bev_async_consider_reading()
277 bufferevent_decrement_read_buckets_(&beva->bev, at_most); in bev_async_consider_reading()
289 struct bufferevent *bev = arg; in be_async_outbuf_callback() local
290 struct bufferevent_async *bev_async = upcast(bev); in be_async_outbuf_callback()
295 bufferevent_incref_and_lock_(bev); in be_async_outbuf_callback()
300 bufferevent_decref_and_unlock_(bev); in be_async_outbuf_callback()
308 struct bufferevent *bev = arg; in be_async_inbuf_callback() local
309 struct bufferevent_async *bev_async = upcast(bev); in be_async_inbuf_callback()
314 bufferevent_incref_and_lock_(bev); in be_async_inbuf_callback()
319 bufferevent_decref_and_unlock_(bev); in be_async_inbuf_callback()
330 if (bev_async->bev.connecting) { in be_async_enable()
351 be_async_disable(struct bufferevent *bev, short what) in be_async_disable() argument
353 struct bufferevent_async *bev_async = upcast(bev); in be_async_disable()
359 BEV_DEL_GENERIC_READ_TIMEOUT(bev); in be_async_disable()
363 BEV_DEL_GENERIC_WRITE_TIMEOUT(bev); in be_async_disable()
371 be_async_destruct(struct bufferevent *bev) in be_async_destruct() argument
373 struct bufferevent_async *bev_async = upcast(bev); in be_async_destruct()
374 struct bufferevent_private *bev_p = BEV_UPCAST(bev); in be_async_destruct()
377 EVUTIL_ASSERT(!upcast(bev)->write_in_progress && in be_async_destruct()
378 !upcast(bev)->read_in_progress); in be_async_destruct()
383 fd = evbuffer_overlapped_get_fd_(bev->input); in be_async_destruct()
387 evbuffer_overlapped_set_fd_(bev->input, INVALID_SOCKET); in be_async_destruct()
394 bev_async_set_wsa_error(struct bufferevent *bev, struct event_overlapped *eo) in bev_async_set_wsa_error() argument
399 fd = evbuffer_overlapped_get_fd_(bev->input); in bev_async_set_wsa_error()
404 be_async_flush(struct bufferevent *bev, short what, in be_async_flush() argument
415 struct bufferevent *bev = &bev_a->bev.bev; in connect_complete() local
418 BEV_LOCK(bev); in connect_complete()
420 EVUTIL_ASSERT(bev_a->bev.connecting); in connect_complete()
421 bev_a->bev.connecting = 0; in connect_complete()
422 sock = evbuffer_overlapped_get_fd_(bev_a->bev.bev.input); in connect_complete()
427 bufferevent_async_set_connected_(bev); in connect_complete()
429 bev_async_set_wsa_error(bev, eo); in connect_complete()
431 bufferevent_run_eventcb_(bev, in connect_complete()
434 event_base_del_virtual_(bev->ev_base); in connect_complete()
436 bufferevent_decref_and_unlock_(bev); in connect_complete()
444 struct bufferevent *bev = &bev_a->bev.bev; in read_complete() local
447 BEV_LOCK(bev); in read_complete()
451 evbuffer_commit_read_(bev->input, nbytes); in read_complete()
454 bufferevent_decrement_read_buckets_(&bev_a->bev, -amount_unread); in read_complete()
457 bev_async_set_wsa_error(bev, eo); in read_complete()
461 BEV_RESET_GENERIC_READ_TIMEOUT(bev); in read_complete()
462 bufferevent_trigger_nolock_(bev, EV_READ, 0); in read_complete()
467 bufferevent_run_eventcb_(bev, what, 0); in read_complete()
471 bufferevent_run_eventcb_(bev, what, 0); in read_complete()
475 bufferevent_decref_and_unlock_(bev); in read_complete()
483 struct bufferevent *bev = &bev_a->bev.bev; in write_complete() local
487 BEV_LOCK(bev); in write_complete()
491 evbuffer_commit_write_(bev->output, nbytes); in write_complete()
495 bufferevent_decrement_write_buckets_(&bev_a->bev, in write_complete()
500 bev_async_set_wsa_error(bev, eo); in write_complete()
504 BEV_RESET_GENERIC_WRITE_TIMEOUT(bev); in write_complete()
505 bufferevent_trigger_nolock_(bev, EV_WRITE, 0); in write_complete()
510 bufferevent_run_eventcb_(bev, what, 0); in write_complete()
514 bufferevent_run_eventcb_(bev, what, 0); in write_complete()
518 bufferevent_decref_and_unlock_(bev); in write_complete()
526 struct bufferevent *bev; in bufferevent_async_new_() local
546 bev = &bev_a->bev.bev; in bufferevent_async_new_()
547 if (!(bev->input = evbuffer_overlapped_new_(fd))) { in bufferevent_async_new_()
551 if (!(bev->output = evbuffer_overlapped_new_(fd))) { in bufferevent_async_new_()
552 evbuffer_free(bev->input); in bufferevent_async_new_()
557 if (bufferevent_init_common_(&bev_a->bev, base, &bufferevent_ops_async, in bufferevent_async_new_()
561 evbuffer_add_cb(bev->input, be_async_inbuf_callback, bev); in bufferevent_async_new_()
562 evbuffer_add_cb(bev->output, be_async_outbuf_callback, bev); in bufferevent_async_new_()
568 bufferevent_init_generic_timeout_cbs_(bev); in bufferevent_async_new_()
572 return bev; in bufferevent_async_new_()
574 bufferevent_free(&bev_a->bev.bev); in bufferevent_async_new_()
579 bufferevent_async_set_connected_(struct bufferevent *bev) in bufferevent_async_set_connected_() argument
581 struct bufferevent_async *bev_async = upcast(bev); in bufferevent_async_set_connected_()
583 bufferevent_init_generic_timeout_cbs_(bev); in bufferevent_async_set_connected_()
585 be_async_enable(bev, bev->enabled); in bufferevent_async_set_connected_()
589 bufferevent_async_can_connect_(struct bufferevent *bev) in bufferevent_async_can_connect_() argument
594 if (BEV_IS_ASYNC(bev) && in bufferevent_async_can_connect_()
595 event_base_get_iocp_(bev->ev_base) && in bufferevent_async_can_connect_()
603 bufferevent_async_connect_(struct bufferevent *bev, evutil_socket_t fd, in bufferevent_async_connect_() argument
607 struct bufferevent_async *bev_async = upcast(bev); in bufferevent_async_connect_()
635 event_base_add_virtual_(bev->ev_base); in bufferevent_async_connect_()
636 bufferevent_incref_(bev); in bufferevent_async_connect_()
642 event_base_del_virtual_(bev->ev_base); in bufferevent_async_connect_()
643 bufferevent_decref_(bev); in bufferevent_async_connect_()
649 be_async_ctrl(struct bufferevent *bev, enum bufferevent_ctrl_op op, in be_async_ctrl() argument
654 data->fd = evbuffer_overlapped_get_fd_(bev->input); in be_async_ctrl()
659 if (data->fd == evbuffer_overlapped_get_fd_(bev->input)) in be_async_ctrl()
661 if (!(iocp = event_base_get_iocp_(bev->ev_base))) in be_async_ctrl()
665 evbuffer_overlapped_set_fd_(bev->input, data->fd); in be_async_ctrl()
666 evbuffer_overlapped_set_fd_(bev->output, data->fd); in be_async_ctrl()
670 struct bufferevent_async *bev_a = upcast(bev); in be_async_ctrl()
671 evutil_socket_t fd = evbuffer_overlapped_get_fd_(bev->input); in be_async_ctrl()
673 (bev_a->bev.options & BEV_OPT_CLOSE_ON_FREE)) { in be_async_ctrl()
675 evbuffer_overlapped_set_fd_(bev->input, INVALID_SOCKET); in be_async_ctrl()