Blame view
lib/ratelimit.c
1.29 KB
5f97a5a87
|
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 |
/* * ratelimit.c - Do something with rate limit. * * Isolated from kernel/printk.c by Dave Young <hidave.darkstar@gmail.com> * * This file is released under the GPLv2. * */ #include <linux/kernel.h> #include <linux/jiffies.h> #include <linux/module.h> /* * __ratelimit - rate limiting * @ratelimit_jiffies: minimum time in jiffies between two callbacks * @ratelimit_burst: number of callbacks we do before ratelimiting * * This enforces a rate limit: not more than @ratelimit_burst callbacks * in every ratelimit_jiffies */ int __ratelimit(int ratelimit_jiffies, int ratelimit_burst) { static DEFINE_SPINLOCK(ratelimit_lock); static unsigned toks = 10 * 5 * HZ; static unsigned long last_msg; static int missed; unsigned long flags; unsigned long now = jiffies; spin_lock_irqsave(&ratelimit_lock, flags); toks += now - last_msg; last_msg = now; if (toks > (ratelimit_burst * ratelimit_jiffies)) toks = ratelimit_burst * ratelimit_jiffies; if (toks >= ratelimit_jiffies) { int lost = missed; missed = 0; toks -= ratelimit_jiffies; spin_unlock_irqrestore(&ratelimit_lock, flags); if (lost) printk(KERN_WARNING "%s: %d messages suppressed ", __func__, lost); return 1; } missed++; spin_unlock_irqrestore(&ratelimit_lock, flags); return 0; } EXPORT_SYMBOL(__ratelimit); |