Searched refs:throttled_reqs (Results 1 – 4 of 4) sorted by relevance
25 qemu_co_enter_next(&fst->throttled_reqs[false], NULL); in fsdev_throttle_read_timer_cb()31 qemu_co_enter_next(&fst->throttled_reqs[true], NULL); in fsdev_throttle_write_timer_cb()92 qemu_co_queue_init(&fst->throttled_reqs[0]); in fsdev_throttle_init()93 qemu_co_queue_init(&fst->throttled_reqs[1]); in fsdev_throttle_init()104 !qemu_co_queue_empty(&fst->throttled_reqs[direction])) { in fsdev_co_throttle_request()105 qemu_co_queue_wait(&fst->throttled_reqs[direction], NULL); in fsdev_co_throttle_request()110 if (!qemu_co_queue_empty(&fst->throttled_reqs[direction]) && in fsdev_co_throttle_request()112 qemu_co_queue_next(&fst->throttled_reqs[direction]); in fsdev_co_throttle_request()
26 CoQueue throttled_reqs[THROTTLE_MAX]; member
40 CoQueue throttled_reqs[THROTTLE_MAX]; member
307 ret = qemu_co_queue_next(&tgm->throttled_reqs[direction]); in throttle_group_co_restart_queue()383 qemu_co_queue_wait(&tgm->throttled_reqs[direction], in throttle_group_co_io_limits_intercept()561 qemu_co_queue_init(&tgm->throttled_reqs[dir]); in throttle_group_register_tgm()603 assert(qemu_co_queue_empty(&tgm->throttled_reqs[dir])); in throttle_group_unregister_tgm()641 assert(qemu_co_queue_empty(&tgm->throttled_reqs[dir])); in throttle_group_detach_aio_context()