141 bev_async_del_write(struct bufferevent_async *beva)  in bev_async_del_write()  argument
143 	struct bufferevent *bev = &beva->bev.bev;  in bev_async_del_write()
145 	if (beva->write_added) {  in bev_async_del_write()
146 		beva->write_added = 0;  in bev_async_del_write()
152 bev_async_del_read(struct bufferevent_async *beva)  in bev_async_del_read()  argument
154 	struct bufferevent *bev = &beva->bev.bev;  in bev_async_del_read()
156 	if (beva->read_added) {  in bev_async_del_read()
157 		beva->read_added = 0;  in bev_async_del_read()
163 bev_async_add_write(struct bufferevent_async *beva)  in bev_async_add_write()  argument
165 	struct bufferevent *bev = &beva->bev.bev;  in bev_async_add_write()
167 	if (!beva->write_added) {  in bev_async_add_write()
168 		beva->write_added = 1;  in bev_async_add_write()
174 bev_async_add_read(struct bufferevent_async *beva)  in bev_async_add_read()  argument
176 	struct bufferevent *bev = &beva->bev.bev;  in bev_async_add_read()
178 	if (!beva->read_added) {  in bev_async_add_read()
179 		beva->read_added = 1;  in bev_async_add_read()
185 bev_async_consider_writing(struct bufferevent_async *beva)  in bev_async_consider_writing()  argument
189 	struct bufferevent *bev = &beva->bev.bev;  in bev_async_consider_writing()
193 	if (beva->write_in_progress || beva->bev.connecting)  in bev_async_consider_writing()
195 	if (!beva->ok || !(bev->enabled&EV_WRITE) ||  in bev_async_consider_writing()
197 		bev_async_del_write(beva);  in bev_async_consider_writing()
205 	limit = (int)bufferevent_get_write_max_(&beva->bev);  in bev_async_consider_writing()
209 	if (beva->bev.write_suspended) {  in bev_async_consider_writing()
210 		bev_async_del_write(beva);  in bev_async_consider_writing()
217 	    &beva->write_overlapped)) {  in bev_async_consider_writing()
219 		beva->ok = 0;  in bev_async_consider_writing()
222 		beva->write_in_progress = at_most;  in bev_async_consider_writing()
223 		bufferevent_decrement_write_buckets_(&beva->bev, at_most);  in bev_async_consider_writing()
224 		bev_async_add_write(beva);  in bev_async_consider_writing()
229 bev_async_consider_reading(struct bufferevent_async *beva)  in bev_async_consider_reading()  argument
235 	struct bufferevent *bev = &beva->bev.bev;  in bev_async_consider_reading()
239 	if (beva->read_in_progress || beva->bev.connecting)  in bev_async_consider_reading()
241 	if (!beva->ok || !(bev->enabled&EV_READ)) {  in bev_async_consider_reading()
242 		bev_async_del_read(beva);  in bev_async_consider_reading()
251 			bev_async_del_read(beva);  in bev_async_consider_reading()
261 	limit = (int)bufferevent_get_read_max_(&beva->bev);  in bev_async_consider_reading()
265 	if (beva->bev.read_suspended) {  in bev_async_consider_reading()
266 		bev_async_del_read(beva);  in bev_async_consider_reading()
271 	if (evbuffer_launch_read_(bev->input, at_most, &beva->read_overlapped)) {  in bev_async_consider_reading()
272 		beva->ok = 0;  in bev_async_consider_reading()
276 		beva->read_in_progress = at_most;  in bev_async_consider_reading()
277 		bufferevent_decrement_read_buckets_(&beva->bev, at_most);  in bev_async_consider_reading()
278 		bev_async_add_read(beva);  in bev_async_consider_reading()