sntp/libevent/bufferevent_async.c

106 	struct bufferevent_async *bev_a;
109 	bev_a = EVUTIL_UPCAST(bev, struct bufferevent_async, bev.bev);
110 	return bev_a;
116 	struct bufferevent_async *bev_a;
117 	bev_a = EVUTIL_UPCAST(eo, struct bufferevent_async, connect_overlapped);
118 	EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev));
119 	return bev_a;
125 	struct bufferevent_async *bev_a;
126 	bev_a = EVUTIL_UPCAST(eo, struct bufferevent_async, read_overlapped);
127 	EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev));
128 	return bev_a;
134 	struct bufferevent_async *bev_a;
135 	bev_a = EVUTIL_UPCAST(eo, struct bufferevent_async, write_overlapped);
136 	EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev));
137 	return bev_a;
414 	struct bufferevent_async *bev_a = upcast_connect(eo);
415 	struct bufferevent *bev = &bev_a->bev.bev;
420 	EVUTIL_ASSERT(bev_a->bev.connecting);
421 	bev_a->bev.connecting = 0;
422 	sock = evbuffer_overlapped_get_fd_(bev_a->bev.bev.input);
443 	struct bufferevent_async *bev_a = upcast_read(eo);
444 	struct bufferevent *bev = &bev_a->bev.bev;
448 	EVUTIL_ASSERT(bev_a->read_in_progress);
450 	amount_unread = bev_a->read_in_progress - nbytes;
452 	bev_a->read_in_progress = 0;
454 		bufferevent_decrement_read_buckets_(&bev_a->bev, -amount_unread);
459 	if (bev_a->ok) {
463 			bev_async_consider_reading(bev_a);
466 			bev_a->ok = 0;
470 			bev_a->ok = 0;
482 	struct bufferevent_async *bev_a = upcast_write(eo);
483 	struct bufferevent *bev = &bev_a->bev.bev;
488 	EVUTIL_ASSERT(bev_a->write_in_progress);
490 	amount_unwritten = bev_a->write_in_progress - nbytes;
492 	bev_a->write_in_progress = 0;
495 		bufferevent_decrement_write_buckets_(&bev_a->bev,
502 	if (bev_a->ok) {
506 			bev_async_consider_writing(bev_a);
509 			bev_a->ok = 0;
513 			bev_a->ok = 0;
525 	struct bufferevent_async *bev_a;
543 	if (!(bev_a = mm_calloc(1, sizeof(struct bufferevent_async))))
546 	bev = &bev_a->bev.bev;
548 		mm_free(bev_a);
553 		mm_free(bev_a);
557 	if (bufferevent_init_common_(&bev_a->bev, base, &bufferevent_ops_async,
564 	event_overlapped_init_(&bev_a->connect_overlapped, connect_complete);
565 	event_overlapped_init_(&bev_a->read_overlapped, read_complete);
566 	event_overlapped_init_(&bev_a->write_overlapped, write_complete);
570 	bev_a->ok = fd >= 0;
574 	bufferevent_free(&bev_a->bev.bev);
670 		struct bufferevent_async *bev_a = upcast(bev);
673 		    (bev_a->bev.options & BEV_OPT_CLOSE_ON_FREE)) {
677 		bev_a->ok = 0;