ASSERT(clist_empty(&q->done_list));
struct asio_request *r;
- while (r = clist_head(&q->idle_list))
+ while (r = clist_remove_head(&q->idle_list))
{
- clist_remove(&r->work.n);
big_free(r->buffer, q->buffer_size);
xfree(r);
}
q->running_requests++;
r->submitted = 1;
r->work.go = asio_handler;
- r->work.returned = NULL;
+ r->work.priority = 0;
work_submit(&q->queue, &r->work);
}