diff options
| author | zhenwei pi <pizhenwei@bytedance.com> | 2023-07-28 10:20:03 +0800 |
|---|---|---|
| committer | Hanna Czenczek <hreitz@redhat.com> | 2023-08-29 10:49:24 +0200 |
| commit | e76f201f69e76653f3e7301f2183421d9267e2f5 (patch) | |
| tree | a2cb010b6cb8e03c74bd72d6fed5c196dab3df64 /fsdev/qemu-fsdev-throttle.c | |
| parent | 27cf12298a2e3cb168880b6c7a36ea8cfbd8afb0 (diff) | |
| download | focaccia-qemu-e76f201f69e76653f3e7301f2183421d9267e2f5.tar.gz focaccia-qemu-e76f201f69e76653f3e7301f2183421d9267e2f5.zip | |
throttle: use enum ThrottleDirection instead of bool is_write
enum ThrottleDirection is already there, use ThrottleDirection instead of 'bool is_write' for throttle API, also modify related codes from block, fsdev, cryptodev and tests. Reviewed-by: Hanna Czenczek <hreitz@redhat.com> Signed-off-by: zhenwei pi <pizhenwei@bytedance.com> Message-Id: <20230728022006.1098509-7-pizhenwei@bytedance.com> Signed-off-by: Hanna Czenczek <hreitz@redhat.com>
Diffstat (limited to 'fsdev/qemu-fsdev-throttle.c')
| -rw-r--r-- | fsdev/qemu-fsdev-throttle.c | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/fsdev/qemu-fsdev-throttle.c b/fsdev/qemu-fsdev-throttle.c index 5c83a1cc09..1c137d6f0f 100644 --- a/fsdev/qemu-fsdev-throttle.c +++ b/fsdev/qemu-fsdev-throttle.c @@ -97,16 +97,18 @@ void fsdev_throttle_init(FsThrottle *fst) void coroutine_fn fsdev_co_throttle_request(FsThrottle *fst, bool is_write, struct iovec *iov, int iovcnt) { + ThrottleDirection direction = is_write ? THROTTLE_WRITE : THROTTLE_READ; + if (throttle_enabled(&fst->cfg)) { - if (throttle_schedule_timer(&fst->ts, &fst->tt, is_write) || + if (throttle_schedule_timer(&fst->ts, &fst->tt, direction) || !qemu_co_queue_empty(&fst->throttled_reqs[is_write])) { qemu_co_queue_wait(&fst->throttled_reqs[is_write], NULL); } - throttle_account(&fst->ts, is_write, iov_size(iov, iovcnt)); + throttle_account(&fst->ts, direction, iov_size(iov, iovcnt)); if (!qemu_co_queue_empty(&fst->throttled_reqs[is_write]) && - !throttle_schedule_timer(&fst->ts, &fst->tt, is_write)) { + !throttle_schedule_timer(&fst->ts, &fst->tt, direction)) { qemu_co_queue_next(&fst->throttled_reqs[is_write]); } } |