128 	struct bufferevent_async *bev_a;  in upcast()  local
131 	bev_a = EVUTIL_UPCAST(bev, struct bufferevent_async, bev.bev);  in upcast()
132 	return bev_a;  in upcast()
138 	struct bufferevent_async *bev_a;  in upcast_connect()  local
139 	bev_a = EVUTIL_UPCAST(eo, struct bufferevent_async, connect_overlapped);  in upcast_connect()
140 	EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev));  in upcast_connect()
141 	return bev_a;  in upcast_connect()
147 	struct bufferevent_async *bev_a;  in upcast_read()  local
148 	bev_a = EVUTIL_UPCAST(eo, struct bufferevent_async, read_overlapped);  in upcast_read()
149 	EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev));  in upcast_read()
150 	return bev_a;  in upcast_read()
156 	struct bufferevent_async *bev_a;  in upcast_write()  local
157 	bev_a = EVUTIL_UPCAST(eo, struct bufferevent_async, write_overlapped);  in upcast_write()
158 	EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev));  in upcast_write()
159 	return bev_a;  in upcast_write()
436 	struct bufferevent_async *bev_a = upcast_connect(eo);  in connect_complete()  local
437 	struct bufferevent *bev = &bev_a->bev.bev;  in connect_complete()
442 	EVUTIL_ASSERT(bev_a->bev.connecting);  in connect_complete()
443 	bev_a->bev.connecting = 0;  in connect_complete()
444 	sock = evbuffer_overlapped_get_fd_(bev_a->bev.bev.input);  in connect_complete()
464 	struct bufferevent_async *bev_a = upcast_read(eo);  in read_complete()  local
465 	struct bufferevent *bev = &bev_a->bev.bev;  in read_complete()
469 	EVUTIL_ASSERT(bev_a->read_in_progress);  in read_complete()
471 	amount_unread = bev_a->read_in_progress - nbytes;  in read_complete()
473 	bev_a->read_in_progress = 0;  in read_complete()
475 		bufferevent_decrement_read_buckets_(&bev_a->bev, -amount_unread);  in read_complete()
480 	if (bev_a->ok) {  in read_complete()
484 			bev_async_consider_reading(bev_a);  in read_complete()
487 			bev_a->ok = 0;  in read_complete()
491 			bev_a->ok = 0;  in read_complete()
503 	struct bufferevent_async *bev_a = upcast_write(eo);  in write_complete()  local
504 	struct bufferevent *bev = &bev_a->bev.bev;  in write_complete()
509 	EVUTIL_ASSERT(bev_a->write_in_progress);  in write_complete()
511 	amount_unwritten = bev_a->write_in_progress - nbytes;  in write_complete()
513 	bev_a->write_in_progress = 0;  in write_complete()
516 		bufferevent_decrement_write_buckets_(&bev_a->bev,  in write_complete()
523 	if (bev_a->ok) {  in write_complete()
527 			bev_async_consider_writing(bev_a);  in write_complete()
530 			bev_a->ok = 0;  in write_complete()
534 			bev_a->ok = 0;  in write_complete()
546 	struct bufferevent_async *bev_a;  in bufferevent_async_new_()  local
560 	if (!(bev_a = mm_calloc(1, sizeof(struct bufferevent_async))))  in bufferevent_async_new_()
563 	bev = &bev_a->bev.bev;  in bufferevent_async_new_()
565 		mm_free(bev_a);  in bufferevent_async_new_()
570 		mm_free(bev_a);  in bufferevent_async_new_()
574 	if (bufferevent_init_common_(&bev_a->bev, base, &bufferevent_ops_async,  in bufferevent_async_new_()
581 	event_overlapped_init_(&bev_a->connect_overlapped, connect_complete);  in bufferevent_async_new_()
582 	event_overlapped_init_(&bev_a->read_overlapped, read_complete);  in bufferevent_async_new_()
583 	event_overlapped_init_(&bev_a->write_overlapped, write_complete);  in bufferevent_async_new_()
587 	bev_a->ok = fd >= 0;  in bufferevent_async_new_()
591 	bufferevent_free(&bev_a->bev.bev);  in bufferevent_async_new_()
673 		struct bufferevent_async *bev_a = upcast(bev);  in be_async_ctrl()  local
686 		bev_a->ok = data->fd >= 0;  in be_async_ctrl()
690 		struct bufferevent_async *bev_a = upcast(bev);  in be_async_ctrl()  local
693 		    (bev_a->bev.options & BEV_OPT_CLOSE_ON_FREE)) {  in be_async_ctrl()
697 		bev_a->ok = 0;  in be_async_ctrl()