Home
last modified time | relevance | path

Searched refs:tgm (Results 1 – 5 of 5) sorted by relevance

/openbmc/qemu/block/
H A Dthrottle-groups.c40 static void timer_cb(ThrottleGroupMember *tgm, ThrottleDirection direction);
167 const char *throttle_group_get_name(ThrottleGroupMember *tgm) in throttle_group_get_name() argument
169 ThrottleGroup *tg = container_of(tgm->throttle_state, ThrottleGroup, ts); in throttle_group_get_name()
181 static ThrottleGroupMember *throttle_group_next_tgm(ThrottleGroupMember *tgm) in throttle_group_next_tgm() argument
183 ThrottleState *ts = tgm->throttle_state; in throttle_group_next_tgm()
185 ThrottleGroupMember *next = QLIST_NEXT(tgm, round_robin); in throttle_group_next_tgm()
203 static inline bool tgm_has_pending_reqs(ThrottleGroupMember *tgm, in tgm_has_pending_reqs() argument
206 return tgm->pending_reqs[direction]; in tgm_has_pending_reqs()
219 static ThrottleGroupMember *next_throttle_token(ThrottleGroupMember *tgm, in next_throttle_token() argument
222 ThrottleState *ts = tgm->throttle_state; in next_throttle_token()
[all …]
H A Dthrottle.c79 ThrottleGroupMember *tgm = bs->opaque; in throttle_open() local
98 throttle_group_register_tgm(tgm, group, bdrv_get_aio_context(bs)); in throttle_open()
107 ThrottleGroupMember *tgm = bs->opaque; in throttle_close() local
108 throttle_group_unregister_tgm(tgm); in throttle_close()
123 ThrottleGroupMember *tgm = bs->opaque; in throttle_co_preadv() local
124 throttle_group_co_io_limits_intercept(tgm, bytes, THROTTLE_READ); in throttle_co_preadv()
133 ThrottleGroupMember *tgm = bs->opaque; in throttle_co_pwritev() local
134 throttle_group_co_io_limits_intercept(tgm, bytes, THROTTLE_WRITE); in throttle_co_pwritev()
143 ThrottleGroupMember *tgm = bs->opaque; in throttle_co_pwrite_zeroes() local
144 throttle_group_co_io_limits_intercept(tgm, bytes, THROTTLE_WRITE); in throttle_co_pwrite_zeroes()
[all …]
H A Dblock-backend.c861 ThrottleGroupMember *tgm = &blk->public.throttle_group_member; in blk_remove_bs() local
867 if (tgm->throttle_state) { in blk_remove_bs()
876 throttle_group_detach_aio_context(tgm); in blk_remove_bs()
877 throttle_group_attach_aio_context(tgm, qemu_get_aio_context()); in blk_remove_bs()
902 ThrottleGroupMember *tgm = &blk->public.throttle_group_member; in blk_insert_bs() local
917 if (tgm->throttle_state) { in blk_insert_bs()
918 throttle_group_detach_aio_context(tgm); in blk_insert_bs()
919 throttle_group_attach_aio_context(tgm, bdrv_get_aio_context(bs)); in blk_insert_bs()
2414 ThrottleGroupMember *tgm = &blk->public.throttle_group_member; in blk_root_set_aio_ctx_commit() local
2417 if (tgm->throttle_state) { in blk_root_set_aio_ctx_commit()
[all …]
/openbmc/qemu/include/block/
H A Dthrottle-groups.h65 const char *throttle_group_get_name(ThrottleGroupMember *tgm);
70 void throttle_group_config(ThrottleGroupMember *tgm, ThrottleConfig *cfg);
71 void throttle_group_get_config(ThrottleGroupMember *tgm, ThrottleConfig *cfg);
73 void throttle_group_register_tgm(ThrottleGroupMember *tgm,
76 void throttle_group_unregister_tgm(ThrottleGroupMember *tgm);
77 void throttle_group_restart_tgm(ThrottleGroupMember *tgm);
79 void coroutine_fn throttle_group_co_io_limits_intercept(ThrottleGroupMember *tgm,
82 void throttle_group_attach_aio_context(ThrottleGroupMember *tgm,
84 void throttle_group_detach_aio_context(ThrottleGroupMember *tgm);
/openbmc/qemu/tests/unit/
H A Dtest-throttle.c29 static ThrottleGroupMember tgm; variable
159 tt = &tgm.throttle_timers; in test_init()
191 tt = &tgm.throttle_timers; in test_init_readonly()
223 tt = &tgm.throttle_timers; in test_init_writeonly()