Searched refs:io_q (Results 1 – 4 of 4) sorted by relevance
/openbmc/qemu/block/ |
H A D | io_uring.c | 58 LuringQueue io_q; member 71 QSIMPLEQ_INSERT_TAIL(&s->io_q.submit_queue, luringcb, next); in luring_resubmit() 72 s->io_q.in_queue++; in luring_resubmit() 162 s->io_q.in_flight--; in luring_process_completions() 234 while (s->io_q.in_queue > 0) { in ioq_submit() 239 QSIMPLEQ_FOREACH_SAFE(luringcb, &s->io_q.submit_queue, next, in ioq_submit() 247 QSIMPLEQ_REMOVE_HEAD(&s->io_q.submit_queue, next); in ioq_submit() 258 s->io_q.in_flight += ret; in ioq_submit() 259 s->io_q.in_queue -= ret; in ioq_submit() 261 s->io_q.blocked = (s->io_q.in_queue > 0); in ioq_submit() [all …]
|
H A D | linux-aio.c | 64 LaioQueue io_q; member 223 s->io_q.in_flight--; in qemu_laio_process_completions() 244 if (!QSIMPLEQ_EMPTY(&s->io_q.pending)) { in qemu_laio_process_completions_and_submit() 282 static void ioq_init(LaioQueue *io_q) in ioq_init() argument 284 QSIMPLEQ_INIT(&io_q->pending); in ioq_init() 285 io_q->in_queue = 0; in ioq_init() 286 io_q->in_flight = 0; in ioq_init() 287 io_q->blocked = false; in ioq_init() 298 if (s->io_q.in_flight >= MAX_EVENTS) { in ioq_submit() 302 QSIMPLEQ_FOREACH(aiocb, &s->io_q.pending, next) { in ioq_submit() [all …]
|
/openbmc/linux/drivers/scsi/bfa/ |
H A D | bfa_fcpim.h | 205 struct list_head io_q; /* queue of affected IOs */ member 225 struct list_head io_q; /* queue of active IO requests */ member
|
H A D | bfa_fcpim.c | 30 WARN_ON(!list_empty(&(__itnim)->io_q)); \ 976 list_for_each_safe(qe, qen, &itnim->io_q) { in bfa_itnim_iocdisable_cleanup() 1019 list_for_each_safe(qe, qen, &itnim->io_q) { in bfa_itnim_cleanup() 1127 INIT_LIST_HEAD(&itnim->io_q); in bfa_itnim_attach() 1239 list_add_tail(&ioim->qe, &itnim->io_q); in bfa_itnim_iotov_online() 2956 list_add_tail(&ioim->qe, &itnim->io_q); in bfa_ioim_alloc() 3311 INIT_LIST_HEAD(&tskim->io_q); in bfa_tskim_gather_ios() 3316 list_for_each_safe(qe, qen, &itnim->io_q) { in bfa_tskim_gather_ios() 3322 list_add_tail(&ioim->qe, &tskim->io_q); in bfa_tskim_gather_ios() 3364 list_for_each_safe(qe, qen, &tskim->io_q) { in bfa_tskim_cleanup_ios() [all …]
|