bev_a             104 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	struct bufferevent_async *bev_a;
bev_a             107 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	bev_a = EVUTIL_UPCAST(bev, struct bufferevent_async, bev.bev);
bev_a             108 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	return bev_a;
bev_a             114 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	struct bufferevent_async *bev_a;
bev_a             115 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	bev_a = EVUTIL_UPCAST(eo, struct bufferevent_async, connect_overlapped);
bev_a             116 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev));
bev_a             117 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	return bev_a;
bev_a             123 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	struct bufferevent_async *bev_a;
bev_a             124 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	bev_a = EVUTIL_UPCAST(eo, struct bufferevent_async, read_overlapped);
bev_a             125 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev));
bev_a             126 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	return bev_a;
bev_a             132 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	struct bufferevent_async *bev_a;
bev_a             133 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	bev_a = EVUTIL_UPCAST(eo, struct bufferevent_async, write_overlapped);
bev_a             134 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	EVUTIL_ASSERT(BEV_IS_ASYNC(&bev_a->bev.bev));
bev_a             135 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	return bev_a;
bev_a             416 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	struct bufferevent_async *bev_a = upcast_connect(eo);
bev_a             417 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	struct bufferevent *bev = &bev_a->bev.bev;
bev_a             422 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	EVUTIL_ASSERT(bev_a->bev.connecting);
bev_a             423 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	bev_a->bev.connecting = 0;
bev_a             424 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	sock = _evbuffer_overlapped_get_fd(bev_a->bev.bev.input);
bev_a             445 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	struct bufferevent_async *bev_a = upcast_read(eo);
bev_a             446 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	struct bufferevent *bev = &bev_a->bev.bev;
bev_a             450 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	EVUTIL_ASSERT(bev_a->read_in_progress);
bev_a             452 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	amount_unread = bev_a->read_in_progress - nbytes;
bev_a             454 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	bev_a->read_in_progress = 0;
bev_a             456 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		_bufferevent_decrement_read_buckets(&bev_a->bev, -amount_unread);
bev_a             461 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	if (bev_a->ok) {
bev_a             466 opal/mca/event/libevent2022/libevent/bufferevent_async.c 			bev_async_consider_reading(bev_a);
bev_a             469 opal/mca/event/libevent2022/libevent/bufferevent_async.c 			bev_a->ok = 0;
bev_a             473 opal/mca/event/libevent2022/libevent/bufferevent_async.c 			bev_a->ok = 0;
bev_a             485 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	struct bufferevent_async *bev_a = upcast_write(eo);
bev_a             486 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	struct bufferevent *bev = &bev_a->bev.bev;
bev_a             491 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	EVUTIL_ASSERT(bev_a->write_in_progress);
bev_a             493 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	amount_unwritten = bev_a->write_in_progress - nbytes;
bev_a             495 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	bev_a->write_in_progress = 0;
bev_a             498 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		_bufferevent_decrement_write_buckets(&bev_a->bev,
bev_a             505 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	if (bev_a->ok) {
bev_a             511 opal/mca/event/libevent2022/libevent/bufferevent_async.c 			bev_async_consider_writing(bev_a);
bev_a             514 opal/mca/event/libevent2022/libevent/bufferevent_async.c 			bev_a->ok = 0;
bev_a             518 opal/mca/event/libevent2022/libevent/bufferevent_async.c 			bev_a->ok = 0;
bev_a             530 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	struct bufferevent_async *bev_a;
bev_a             548 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	if (!(bev_a = mm_calloc(1, sizeof(struct bufferevent_async))))
bev_a             551 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	bev = &bev_a->bev.bev;
bev_a             553 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		mm_free(bev_a);
bev_a             558 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		mm_free(bev_a);
bev_a             562 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	if (bufferevent_init_common(&bev_a->bev, base, &bufferevent_ops_async,
bev_a             569 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	event_overlapped_init(&bev_a->connect_overlapped, connect_complete);
bev_a             570 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	event_overlapped_init(&bev_a->read_overlapped, read_complete);
bev_a             571 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	event_overlapped_init(&bev_a->write_overlapped, write_complete);
bev_a             573 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	bev_a->ok = fd >= 0;
bev_a             574 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	if (bev_a->ok)
bev_a             579 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	bufferevent_free(&bev_a->bev.bev);
bev_a             675 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		struct bufferevent_async *bev_a = upcast(bev);
bev_a             678 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		    (bev_a->bev.options & BEV_OPT_CLOSE_ON_FREE)) {
bev_a             681 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		bev_a->ok = 0;