Home
last modified time | relevance | path

Searched refs:io_q (Results 1 – 4 of 4) sorted by relevance

/openbmc/qemu/block/
H A Dio_uring.c58 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 Dlinux-aio.c64 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 Dbfa_fcpim.h205 struct list_head io_q; /* queue of affected IOs */ member
225 struct list_head io_q; /* queue of active IO requests */ member
H A Dbfa_fcpim.c30 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 …]