beva              139 opal/mca/event/libevent2022/libevent/bufferevent_async.c bev_async_del_write(struct bufferevent_async *beva)
beva              141 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	struct bufferevent *bev = &beva->bev.bev;
beva              143 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	if (beva->write_added) {
beva              144 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		beva->write_added = 0;
beva              150 opal/mca/event/libevent2022/libevent/bufferevent_async.c bev_async_del_read(struct bufferevent_async *beva)
beva              152 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	struct bufferevent *bev = &beva->bev.bev;
beva              154 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	if (beva->read_added) {
beva              155 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		beva->read_added = 0;
beva              161 opal/mca/event/libevent2022/libevent/bufferevent_async.c bev_async_add_write(struct bufferevent_async *beva)
beva              163 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	struct bufferevent *bev = &beva->bev.bev;
beva              165 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	if (!beva->write_added) {
beva              166 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		beva->write_added = 1;
beva              172 opal/mca/event/libevent2022/libevent/bufferevent_async.c bev_async_add_read(struct bufferevent_async *beva)
beva              174 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	struct bufferevent *bev = &beva->bev.bev;
beva              176 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	if (!beva->read_added) {
beva              177 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		beva->read_added = 1;
beva              183 opal/mca/event/libevent2022/libevent/bufferevent_async.c bev_async_consider_writing(struct bufferevent_async *beva)
beva              187 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	struct bufferevent *bev = &beva->bev.bev;
beva              191 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	if (beva->write_in_progress || beva->bev.connecting)
beva              193 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	if (!beva->ok || !(bev->enabled&EV_WRITE) ||
beva              195 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		bev_async_del_write(beva);
beva              203 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	limit = (int)_bufferevent_get_write_max(&beva->bev);
beva              207 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	if (beva->bev.write_suspended) {
beva              208 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		bev_async_del_write(beva);
beva              215 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	    &beva->write_overlapped)) {
beva              217 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		beva->ok = 0;
beva              220 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		beva->write_in_progress = at_most;
beva              221 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		_bufferevent_decrement_write_buckets(&beva->bev, at_most);
beva              222 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		bev_async_add_write(beva);
beva              227 opal/mca/event/libevent2022/libevent/bufferevent_async.c bev_async_consider_reading(struct bufferevent_async *beva)
beva              233 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	struct bufferevent *bev = &beva->bev.bev;
beva              237 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	if (beva->read_in_progress || beva->bev.connecting)
beva              239 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	if (!beva->ok || !(bev->enabled&EV_READ)) {
beva              240 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		bev_async_del_read(beva);
beva              249 opal/mca/event/libevent2022/libevent/bufferevent_async.c 			bev_async_del_read(beva);
beva              259 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	limit = (int)_bufferevent_get_read_max(&beva->bev);
beva              263 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	if (beva->bev.read_suspended) {
beva              264 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		bev_async_del_read(beva);
beva              269 opal/mca/event/libevent2022/libevent/bufferevent_async.c 	if (evbuffer_launch_read(bev->input, at_most, &beva->read_overlapped)) {
beva              270 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		beva->ok = 0;
beva              274 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		beva->read_in_progress = at_most;
beva              275 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		_bufferevent_decrement_read_buckets(&beva->bev, at_most);
beva              276 opal/mca/event/libevent2022/libevent/bufferevent_async.c 		bev_async_add_read(beva);