]>
git.proxmox.com Git - mirror_qemu.git/blob - include/qemu/throttle.h
2 * QEMU throttling infrastructure
4 * Copyright (C) Nodalink, EURL. 2013-2014
5 * Copyright (C) Igalia, S.L. 2015
8 * BenoƮt Canet <benoit.canet@nodalink.com>
9 * Alberto Garcia <berto@igalia.com>
11 * This program is free software; you can redistribute it and/or
12 * modify it under the terms of the GNU General Public License as
13 * published by the Free Software Foundation; either version 2 or
14 * (at your option) version 3 of the License.
16 * This program is distributed in the hope that it will be useful,
17 * but WITHOUT ANY WARRANTY; without even the implied warranty of
18 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
19 * GNU General Public License for more details.
21 * You should have received a copy of the GNU General Public License
22 * along with this program; if not, see <http://www.gnu.org/licenses/>.
29 #include "qemu-common.h"
30 #include "qemu/timer.h"
43 * The max parameter of the leaky bucket throttling algorithm can be used to
44 * allow the guest to do bursts.
45 * The max value is a pool of I/O that the guest can use without being throttled
46 * at all. Throttling is triggered once this pool is empty.
49 typedef struct LeakyBucket
{
50 double avg
; /* average goal in units per second */
51 double max
; /* leaky bucket max burst in units */
52 double level
; /* bucket level in units */
55 /* The following structure is used to configure a ThrottleState
56 * It contains a bit of state: the bucket field of the LeakyBucket structure.
57 * However it allows to keep the code clean and the bucket field is reset to
58 * zero at the right time.
60 typedef struct ThrottleConfig
{
61 LeakyBucket buckets
[BUCKETS_COUNT
]; /* leaky buckets */
62 uint64_t op_size
; /* size of an operation in bytes */
65 typedef struct ThrottleState
{
66 ThrottleConfig cfg
; /* configuration */
67 int64_t previous_leak
; /* timestamp of the last leak done */
70 typedef struct ThrottleTimers
{
71 QEMUTimer
*timers
[2]; /* timers used to do the throttling */
72 QEMUClockType clock_type
; /* the clock used */
75 QEMUTimerCB
*read_timer_cb
;
76 QEMUTimerCB
*write_timer_cb
;
80 /* operations on single leaky buckets */
81 void throttle_leak_bucket(LeakyBucket
*bkt
, int64_t delta
);
83 int64_t throttle_compute_wait(LeakyBucket
*bkt
);
85 /* expose timer computation function for unit tests */
86 bool throttle_compute_timer(ThrottleState
*ts
,
89 int64_t *next_timestamp
);
91 /* init/destroy cycle */
92 void throttle_init(ThrottleState
*ts
);
94 void throttle_timers_init(ThrottleTimers
*tt
,
95 AioContext
*aio_context
,
96 QEMUClockType clock_type
,
97 QEMUTimerCB
*read_timer_cb
,
98 QEMUTimerCB
*write_timer_cb
,
101 void throttle_timers_destroy(ThrottleTimers
*tt
);
103 void throttle_timers_detach_aio_context(ThrottleTimers
*tt
);
105 void throttle_timers_attach_aio_context(ThrottleTimers
*tt
,
106 AioContext
*new_context
);
108 bool throttle_timers_are_initialized(ThrottleTimers
*tt
);
111 bool throttle_enabled(ThrottleConfig
*cfg
);
113 bool throttle_conflicting(ThrottleConfig
*cfg
);
115 bool throttle_is_valid(ThrottleConfig
*cfg
);
117 void throttle_config(ThrottleState
*ts
,
119 ThrottleConfig
*cfg
);
121 void throttle_get_config(ThrottleState
*ts
, ThrottleConfig
*cfg
);
124 bool throttle_schedule_timer(ThrottleState
*ts
,
128 void throttle_account(ThrottleState
*ts
, bool is_write
, uint64_t size
);