mirror of https://github.com/proxmox/mirror_qemu
throttle: introduce enum ThrottleDirection
Use enum ThrottleDirection instead of number index. Reviewed-by: Alberto Garcia <berto@igalia.com> Reviewed-by: Hanna Czenczek <hreitz@redhat.com> Signed-off-by: zhenwei pi <pizhenwei@bytedance.com> Message-Id: <20230728022006.1098509-2-pizhenwei@bytedance.com> Signed-off-by: Hanna Czenczek <hreitz@redhat.com>master
parent
f5fe7c17ac
commit
8ba02c24ea
|
@ -99,13 +99,18 @@ typedef struct ThrottleState {
|
||||||
int64_t previous_leak; /* timestamp of the last leak done */
|
int64_t previous_leak; /* timestamp of the last leak done */
|
||||||
} ThrottleState;
|
} ThrottleState;
|
||||||
|
|
||||||
|
typedef enum {
|
||||||
|
THROTTLE_READ = 0,
|
||||||
|
THROTTLE_WRITE,
|
||||||
|
THROTTLE_MAX
|
||||||
|
} ThrottleDirection;
|
||||||
|
|
||||||
typedef struct ThrottleTimers {
|
typedef struct ThrottleTimers {
|
||||||
QEMUTimer *timers[2]; /* timers used to do the throttling */
|
QEMUTimer *timers[THROTTLE_MAX]; /* timers used to do the throttling */
|
||||||
QEMUClockType clock_type; /* the clock used */
|
QEMUClockType clock_type; /* the clock used */
|
||||||
|
|
||||||
/* Callbacks */
|
/* Callbacks */
|
||||||
QEMUTimerCB *read_timer_cb;
|
QEMUTimerCB *timer_cb[THROTTLE_MAX];
|
||||||
QEMUTimerCB *write_timer_cb;
|
|
||||||
void *timer_opaque;
|
void *timer_opaque;
|
||||||
} ThrottleTimers;
|
} ThrottleTimers;
|
||||||
|
|
||||||
|
|
|
@ -199,10 +199,12 @@ static bool throttle_compute_timer(ThrottleState *ts,
|
||||||
void throttle_timers_attach_aio_context(ThrottleTimers *tt,
|
void throttle_timers_attach_aio_context(ThrottleTimers *tt,
|
||||||
AioContext *new_context)
|
AioContext *new_context)
|
||||||
{
|
{
|
||||||
tt->timers[0] = aio_timer_new(new_context, tt->clock_type, SCALE_NS,
|
tt->timers[THROTTLE_READ] =
|
||||||
tt->read_timer_cb, tt->timer_opaque);
|
aio_timer_new(new_context, tt->clock_type, SCALE_NS,
|
||||||
tt->timers[1] = aio_timer_new(new_context, tt->clock_type, SCALE_NS,
|
tt->timer_cb[THROTTLE_READ], tt->timer_opaque);
|
||||||
tt->write_timer_cb, tt->timer_opaque);
|
tt->timers[THROTTLE_WRITE] =
|
||||||
|
aio_timer_new(new_context, tt->clock_type, SCALE_NS,
|
||||||
|
tt->timer_cb[THROTTLE_WRITE], tt->timer_opaque);
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
@ -236,8 +238,8 @@ void throttle_timers_init(ThrottleTimers *tt,
|
||||||
memset(tt, 0, sizeof(ThrottleTimers));
|
memset(tt, 0, sizeof(ThrottleTimers));
|
||||||
|
|
||||||
tt->clock_type = clock_type;
|
tt->clock_type = clock_type;
|
||||||
tt->read_timer_cb = read_timer_cb;
|
tt->timer_cb[THROTTLE_READ] = read_timer_cb;
|
||||||
tt->write_timer_cb = write_timer_cb;
|
tt->timer_cb[THROTTLE_WRITE] = write_timer_cb;
|
||||||
tt->timer_opaque = timer_opaque;
|
tt->timer_opaque = timer_opaque;
|
||||||
throttle_timers_attach_aio_context(tt, aio_context);
|
throttle_timers_attach_aio_context(tt, aio_context);
|
||||||
}
|
}
|
||||||
|
@ -256,7 +258,7 @@ void throttle_timers_detach_aio_context(ThrottleTimers *tt)
|
||||||
{
|
{
|
||||||
int i;
|
int i;
|
||||||
|
|
||||||
for (i = 0; i < 2; i++) {
|
for (i = 0; i < THROTTLE_MAX; i++) {
|
||||||
throttle_timer_destroy(&tt->timers[i]);
|
throttle_timer_destroy(&tt->timers[i]);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
Loading…
Reference in New Issue