mirrors/qemu
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

qemu-file: make qemu_file_[sg]et_rate_limit() use an uint64_t

Browse Source 
It is really size_t.  Everything else uses uint64_t, so move this to
uint64_t as well.  A size can't be negative anyways.

Signed-off-by: Juan Quintela <quintela@redhat.com>
Reviewed-by: Cédric Le Goater <clg@kaod.org>
Message-Id: <20230508130909.65420-5-quintela@redhat.com>
This commit is contained in:
Juan Quintela 2023-05-08 15:08:52 +02:00
parent 9d3ebbe217
commit bffc0441d5
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
migration/qemu-file.c
View File

@ -44,7 +44,7 @@ struct QEMUFile {
* Maximum amount of data in bytes to transfer during one * Maximum amount of data in bytes to transfer during one
* rate limiting time window * rate limiting time window
*/ */
int64_t rate_limit_max; uint64_t rate_limit_max;
/* /*
* Total amount of data in bytes queued for transfer * Total amount of data in bytes queued for transfer
* during this rate limiting time window * during this rate limiting time window
@ -738,12 +738,12 @@ int qemu_file_rate_limit(QEMUFile *f)
return 0; return 0;
} }
int64_t qemu_file_get_rate_limit(QEMUFile *f) uint64_t qemu_file_get_rate_limit(QEMUFile *f)
{ {
return f->rate_limit_max; return f->rate_limit_max;
} }
void qemu_file_set_rate_limit(QEMUFile *f, int64_t limit) void qemu_file_set_rate_limit(QEMUFile *f, uint64_t limit)
{ {
/* /*
* 'limit' is per second. But we check it each 100 miliseconds. * 'limit' is per second. But we check it each 100 miliseconds.

4
migration/qemu-file.h
View File

@ -139,8 +139,8 @@ void qemu_file_reset_rate_limit(QEMUFile *f);
* need to be applied to the rate limiting calcuations * need to be applied to the rate limiting calcuations
*/ */
void qemu_file_acct_rate_limit(QEMUFile *f, int64_t len); void qemu_file_acct_rate_limit(QEMUFile *f, int64_t len);
void qemu_file_set_rate_limit(QEMUFile *f, int64_t new_rate); void qemu_file_set_rate_limit(QEMUFile *f, uint64_t new_rate);
int64_t qemu_file_get_rate_limit(QEMUFile *f); uint64_t qemu_file_get_rate_limit(QEMUFile *f);
int qemu_file_get_error_obj(QEMUFile *f, Error **errp); int qemu_file_get_error_obj(QEMUFile *f, Error **errp);
int qemu_file_get_error_obj_any(QEMUFile *f1, QEMUFile *f2, Error **errp); int qemu_file_get_error_obj_any(QEMUFile *f1, QEMUFile *f2, Error **errp);
void qemu_file_set_error_obj(QEMUFile *f, int ret, Error *err); void qemu_file_set_error_obj(QEMUFile *f, int ret, Error *err);