Lines Matching refs:io_head
163 STAILQ_INSERT_TAIL(&be->io_head, io, io_next); in _proxy_event_handler_dequeue()
192 assert(STAILQ_EMPTY(&bec->io_head)); in _cleanup_backend()
301 while (!STAILQ_EMPTY(&be->io_head)) { in _proxy_flush_backend_queue()
302 io = STAILQ_FIRST(&be->io_head); in _proxy_flush_backend_queue()
303 STAILQ_REMOVE_HEAD(&be->io_head, io_next); in _proxy_flush_backend_queue()
333 STAILQ_CONCAT(&bec->io_head, &be->io_head); in proxy_run_backend_queue()
457 STAILQ_REMOVE_HEAD(&be->io_head, io_next); in _drive_machine_next()
480 p = STAILQ_FIRST(&be->io_head); in proxy_backend_drive_machine()
697 if (STAILQ_EMPTY(&be->io_head)) { in proxy_backend_drive_machine()
706 p = STAILQ_FIRST(&be->io_head); in proxy_backend_drive_machine()
882 while (!STAILQ_EMPTY(&be->io_head)) { in _reset_bad_backend()
883 io = STAILQ_FIRST(&be->io_head); in _reset_bad_backend()
884 STAILQ_REMOVE_HEAD(&be->io_head, io_next); in _reset_bad_backend()
895 STAILQ_INIT(&be->io_head); in _reset_bad_backend()
926 io = STAILQ_FIRST(&be->io_head); in _prep_pending_write()
951 io = STAILQ_FIRST(&be->io_head); in _post_pending_write()
1010 if (STAILQ_EMPTY(&be->io_head)) { in _flush_pending_write()
1039 if (STAILQ_EMPTY(&be->io_head)) { in _flush_pending_tls_write()
1371 if (!STAILQ_EMPTY(&be->io_head)) { in proxy_backend_tls_handler()
1433 if (!STAILQ_EMPTY(&be->io_head)) { in proxy_backend_handler()