163 bev_async_del_write(struct bufferevent_async *beva)  in bev_async_del_write()  argument
165 	struct bufferevent *bev = &beva->bev.bev;  in bev_async_del_write()
167 	if (beva->write_added) {  in bev_async_del_write()
168 		beva->write_added = 0;  in bev_async_del_write()
174 bev_async_del_read(struct bufferevent_async *beva)  in bev_async_del_read()  argument
176 	struct bufferevent *bev = &beva->bev.bev;  in bev_async_del_read()
178 	if (beva->read_added) {  in bev_async_del_read()
179 		beva->read_added = 0;  in bev_async_del_read()
185 bev_async_add_write(struct bufferevent_async *beva)  in bev_async_add_write()  argument
187 	struct bufferevent *bev = &beva->bev.bev;  in bev_async_add_write()
189 	if (!beva->write_added) {  in bev_async_add_write()
190 		beva->write_added = 1;  in bev_async_add_write()
196 bev_async_add_read(struct bufferevent_async *beva)  in bev_async_add_read()  argument
198 	struct bufferevent *bev = &beva->bev.bev;  in bev_async_add_read()
200 	if (!beva->read_added) {  in bev_async_add_read()
201 		beva->read_added = 1;  in bev_async_add_read()
207 bev_async_consider_writing(struct bufferevent_async *beva)  in bev_async_consider_writing()  argument
211 	struct bufferevent *bev = &beva->bev.bev;  in bev_async_consider_writing()
215 	if (beva->write_in_progress || beva->bev.connecting)  in bev_async_consider_writing()
217 	if (!beva->ok || !(bev->enabled&EV_WRITE) ||  in bev_async_consider_writing()
219 		bev_async_del_write(beva);  in bev_async_consider_writing()
227 	limit = (int)bufferevent_get_write_max_(&beva->bev);  in bev_async_consider_writing()
231 	if (beva->bev.write_suspended) {  in bev_async_consider_writing()
232 		bev_async_del_write(beva);  in bev_async_consider_writing()
239 	    &beva->write_overlapped)) {  in bev_async_consider_writing()
241 		beva->ok = 0;  in bev_async_consider_writing()
244 		beva->write_in_progress = at_most;  in bev_async_consider_writing()
245 		bufferevent_decrement_write_buckets_(&beva->bev, at_most);  in bev_async_consider_writing()
246 		bev_async_add_write(beva);  in bev_async_consider_writing()
251 bev_async_consider_reading(struct bufferevent_async *beva)  in bev_async_consider_reading()  argument
257 	struct bufferevent *bev = &beva->bev.bev;  in bev_async_consider_reading()
261 	if (beva->read_in_progress || beva->bev.connecting)  in bev_async_consider_reading()
263 	if (!beva->ok || !(bev->enabled&EV_READ)) {  in bev_async_consider_reading()
264 		bev_async_del_read(beva);  in bev_async_consider_reading()
273 			bev_async_del_read(beva);  in bev_async_consider_reading()
283 	limit = (int)bufferevent_get_read_max_(&beva->bev);  in bev_async_consider_reading()
287 	if (beva->bev.read_suspended) {  in bev_async_consider_reading()
288 		bev_async_del_read(beva);  in bev_async_consider_reading()
293 	if (evbuffer_launch_read_(bev->input, at_most, &beva->read_overlapped)) {  in bev_async_consider_reading()
294 		beva->ok = 0;  in bev_async_consider_reading()
298 		beva->read_in_progress = at_most;  in bev_async_consider_reading()
299 		bufferevent_decrement_read_buckets_(&beva->bev, at_most);  in bev_async_consider_reading()
300 		bev_async_add_read(beva);  in bev_async_consider_reading()