451     ThrottleDirection dir;  in throttle_group_restart_tgm()  local
454         for (dir = THROTTLE_READ; dir < THROTTLE_MAX; dir++) {  in throttle_group_restart_tgm()
455             QEMUTimer *t = tgm->throttle_timers.timers[dir];  in throttle_group_restart_tgm()
459                 timer_cb(tgm, dir);  in throttle_group_restart_tgm()
462                 throttle_group_restart_queue(tgm, dir);  in throttle_group_restart_tgm()
547     ThrottleDirection dir;  in throttle_group_register_tgm()  local
557     for (dir = THROTTLE_READ; dir < THROTTLE_MAX; dir++) {  in throttle_group_register_tgm()
558         if (!tg->tokens[dir]) {  in throttle_group_register_tgm()
559             tg->tokens[dir] = tgm;  in throttle_group_register_tgm()
561         qemu_co_queue_init(&tgm->throttled_reqs[dir]);  in throttle_group_register_tgm()
590     ThrottleDirection dir;  in throttle_group_unregister_tgm()  local
601         for (dir = THROTTLE_READ; dir < THROTTLE_MAX; dir++) {  in throttle_group_unregister_tgm()
602             assert(tgm->pending_reqs[dir] == 0);  in throttle_group_unregister_tgm()
603             assert(qemu_co_queue_empty(&tgm->throttled_reqs[dir]));  in throttle_group_unregister_tgm()
604             assert(!timer_pending(tgm->throttle_timers.timers[dir]));  in throttle_group_unregister_tgm()
605             if (tg->tokens[dir] == tgm) {  in throttle_group_unregister_tgm()
611                 tg->tokens[dir] = token;  in throttle_group_unregister_tgm()
636     ThrottleDirection dir;  in throttle_group_detach_aio_context()  local
639     for (dir = THROTTLE_READ; dir < THROTTLE_MAX; dir++) {  in throttle_group_detach_aio_context()
640         assert(tgm->pending_reqs[dir] == 0);  in throttle_group_detach_aio_context()
641         assert(qemu_co_queue_empty(&tgm->throttled_reqs[dir]));  in throttle_group_detach_aio_context()
646         for (dir = THROTTLE_READ; dir < THROTTLE_MAX; dir++) {  in throttle_group_detach_aio_context()
647             if (timer_pending(tt->timers[dir])) {  in throttle_group_detach_aio_context()
648                 tg->any_timer_armed[dir] = false;  in throttle_group_detach_aio_context()
649                 schedule_next_request(tgm, dir);  in throttle_group_detach_aio_context()