Lines Matching refs:limit

40 static inline int64_t ratelimit_calculate_delay(RateLimit *limit, uint64_t n)  in ratelimit_calculate_delay()  argument
45 QEMU_LOCK_GUARD(&limit->lock); in ratelimit_calculate_delay()
46 if (!limit->slice_quota) { in ratelimit_calculate_delay()
50 assert(limit->slice_ns); in ratelimit_calculate_delay()
52 if (limit->slice_end_time < now) { in ratelimit_calculate_delay()
55 limit->slice_start_time = now; in ratelimit_calculate_delay()
56 limit->slice_end_time = now + limit->slice_ns; in ratelimit_calculate_delay()
57 limit->dispatched = 0; in ratelimit_calculate_delay()
60 limit->dispatched += n; in ratelimit_calculate_delay()
61 if (limit->dispatched < limit->slice_quota) { in ratelimit_calculate_delay()
69 delay_slices = (double)limit->dispatched / limit->slice_quota; in ratelimit_calculate_delay()
70 limit->slice_end_time = limit->slice_start_time + in ratelimit_calculate_delay()
71 (uint64_t)(delay_slices * limit->slice_ns); in ratelimit_calculate_delay()
72 return limit->slice_end_time - now; in ratelimit_calculate_delay()
75 static inline void ratelimit_init(RateLimit *limit) in ratelimit_init() argument
77 qemu_mutex_init(&limit->lock); in ratelimit_init()
80 static inline void ratelimit_destroy(RateLimit *limit) in ratelimit_destroy() argument
82 qemu_mutex_destroy(&limit->lock); in ratelimit_destroy()
85 static inline void ratelimit_set_speed(RateLimit *limit, uint64_t speed, in ratelimit_set_speed() argument
88 QEMU_LOCK_GUARD(&limit->lock); in ratelimit_set_speed()
89 limit->slice_ns = slice_ns; in ratelimit_set_speed()
91 limit->slice_quota = 0; in ratelimit_set_speed()
93 limit->slice_quota = MAX(((double)speed * slice_ns) / 1000000000ULL, 1); in ratelimit_set_speed()