sntp/libevent/bufferevent_async.c

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