Lines Matching refs:io_next
158 STAILQ_REMOVE_HEAD(&head, io_next); in _proxy_event_handler_dequeue()
160 io->io_next.stqe_next = NULL; in _proxy_event_handler_dequeue()
163 STAILQ_INSERT_TAIL(&be->io_head, io, io_next); in _proxy_event_handler_dequeue()
303 STAILQ_REMOVE_HEAD(&be->io_head, io_next); in _proxy_flush_backend_queue()
457 STAILQ_REMOVE_HEAD(&be->io_head, io_next); in _drive_machine_next()
459 assert(p != be->io_next); // don't remove what we need to flush. in _drive_machine_next()
884 STAILQ_REMOVE_HEAD(&be->io_head, io_next); in _reset_bad_backend()
896 be->io_next = NULL; // also reset the write offset. in _reset_bad_backend()
924 if (be->io_next == NULL) { in _prep_pending_write()
928 io = be->io_next; in _prep_pending_write()
931 for (; io; io = STAILQ_NEXT(io, io_next)) { in _prep_pending_write()
949 io_pending_proxy_t *io = be->io_next; in _post_pending_write()
954 for (; io; io = STAILQ_NEXT(io, io_next)) { in _post_pending_write()
992 be->io_next = io; in _post_pending_write()
995 io_pending_proxy_t *nio = STAILQ_NEXT(io, io_next); in _post_pending_write()
997 be->io_next = nio; in _post_pending_write()
999 be->io_next = NULL; in _post_pending_write()
1003 be->io_next = NULL; in _post_pending_write()
1020 if (be->io_next) { in _flush_pending_write()
1050 if (be->io_next) { in _flush_pending_tls_write()