| 
									
										
										
										
											2008-04-29 00:59:43 -07:00
										 |  |  | /*
 | 
					
						
							|  |  |  |  * ratelimit.c - Do something with rate limit. | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  * Isolated from kernel/printk.c by Dave Young <hidave.darkstar@gmail.com> | 
					
						
							|  |  |  |  * | 
					
						
							| 
									
										
										
										
											2008-07-25 01:45:58 -07:00
										 |  |  |  * 2008-05-01 rewrite the function and use a ratelimit_state data struct as | 
					
						
							|  |  |  |  * parameter. Now every user can use their own standalone ratelimit_state. | 
					
						
							|  |  |  |  * | 
					
						
							| 
									
										
										
										
											2008-04-29 00:59:43 -07:00
										 |  |  |  * This file is released under the GPLv2. | 
					
						
							|  |  |  |  */ | 
					
						
							|  |  |  | 
 | 
					
						
							| 
									
										
										
										
											2009-09-22 16:18:09 +02:00
										 |  |  | #include <linux/ratelimit.h>
 | 
					
						
							| 
									
										
										
										
											2008-04-29 00:59:43 -07:00
										 |  |  | #include <linux/jiffies.h>
 | 
					
						
							| 
									
										
										
										
											2011-11-16 21:29:17 -05:00
										 |  |  | #include <linux/export.h>
 | 
					
						
							| 
									
										
										
										
											2008-04-29 00:59:43 -07:00
										 |  |  | 
 | 
					
						
							|  |  |  | /*
 | 
					
						
							|  |  |  |  * __ratelimit - rate limiting | 
					
						
							| 
									
										
										
										
											2008-07-25 01:45:58 -07:00
										 |  |  |  * @rs: ratelimit_state data | 
					
						
							| 
									
										
										
										
											2010-04-06 14:35:01 -07:00
										 |  |  |  * @func: name of calling function | 
					
						
							| 
									
										
										
										
											2008-04-29 00:59:43 -07:00
										 |  |  |  * | 
					
						
							| 
									
										
										
										
											2010-04-06 14:35:01 -07:00
										 |  |  |  * This enforces a rate limit: not more than @rs->burst callbacks | 
					
						
							|  |  |  |  * in every @rs->interval | 
					
						
							|  |  |  |  * | 
					
						
							|  |  |  |  * RETURNS: | 
					
						
							|  |  |  |  * 0 means callbacks will be suppressed. | 
					
						
							|  |  |  |  * 1 means go ahead and do it. | 
					
						
							| 
									
										
										
										
											2008-04-29 00:59:43 -07:00
										 |  |  |  */ | 
					
						
							| 
									
										
										
										
											2009-10-23 14:58:11 +02:00
										 |  |  | int ___ratelimit(struct ratelimit_state *rs, const char *func) | 
					
						
							| 
									
										
										
										
											2008-04-29 00:59:43 -07:00
										 |  |  | { | 
					
						
							| 
									
										
										
										
											2008-07-28 15:46:21 -07:00
										 |  |  | 	unsigned long flags; | 
					
						
							| 
									
										
										
										
											2009-09-22 14:44:11 +02:00
										 |  |  | 	int ret; | 
					
						
							| 
									
										
										
										
											2008-07-28 15:46:21 -07:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2008-07-25 01:45:58 -07:00
										 |  |  | 	if (!rs->interval) | 
					
						
							|  |  |  | 		return 1; | 
					
						
							| 
									
										
										
										
											2008-04-29 00:59:43 -07:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2009-09-22 14:44:11 +02:00
										 |  |  | 	/*
 | 
					
						
							|  |  |  | 	 * If we contend on this state's lock then almost | 
					
						
							|  |  |  | 	 * by definition we are too busy to print a message, | 
					
						
							|  |  |  | 	 * in addition to the one that will be printed by | 
					
						
							|  |  |  | 	 * the entity that is holding the lock already: | 
					
						
							|  |  |  | 	 */ | 
					
						
							| 
									
										
										
										
											2009-07-25 17:50:36 +02:00
										 |  |  | 	if (!raw_spin_trylock_irqsave(&rs->lock, flags)) | 
					
						
							| 
									
										
										
										
											2010-04-06 14:35:03 -07:00
										 |  |  | 		return 0; | 
					
						
							| 
									
										
										
										
											2009-09-22 14:44:11 +02:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2008-07-25 01:45:58 -07:00
										 |  |  | 	if (!rs->begin) | 
					
						
							|  |  |  | 		rs->begin = jiffies; | 
					
						
							| 
									
										
										
										
											2008-04-29 00:59:43 -07:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2008-07-25 01:45:58 -07:00
										 |  |  | 	if (time_is_before_jiffies(rs->begin + rs->interval)) { | 
					
						
							|  |  |  | 		if (rs->missed) | 
					
						
							|  |  |  | 			printk(KERN_WARNING "%s: %d callbacks suppressed\n", | 
					
						
							| 
									
										
										
										
											2009-10-23 14:58:11 +02:00
										 |  |  | 				func, rs->missed); | 
					
						
							| 
									
										
										
										
											2009-09-22 14:44:11 +02:00
										 |  |  | 		rs->begin   = 0; | 
					
						
							| 
									
										
										
										
											2008-07-25 01:45:58 -07:00
										 |  |  | 		rs->printed = 0; | 
					
						
							| 
									
										
										
										
											2009-09-22 14:44:11 +02:00
										 |  |  | 		rs->missed  = 0; | 
					
						
							| 
									
										
										
										
											2008-04-29 00:59:43 -07:00
										 |  |  | 	} | 
					
						
							| 
									
										
										
										
											2009-09-22 14:44:11 +02:00
										 |  |  | 	if (rs->burst && rs->burst > rs->printed) { | 
					
						
							|  |  |  | 		rs->printed++; | 
					
						
							|  |  |  | 		ret = 1; | 
					
						
							|  |  |  | 	} else { | 
					
						
							|  |  |  | 		rs->missed++; | 
					
						
							|  |  |  | 		ret = 0; | 
					
						
							|  |  |  | 	} | 
					
						
							| 
									
										
										
										
											2009-07-25 17:50:36 +02:00
										 |  |  | 	raw_spin_unlock_irqrestore(&rs->lock, flags); | 
					
						
							| 
									
										
										
										
											2008-07-25 01:45:58 -07:00
										 |  |  | 
 | 
					
						
							| 
									
										
										
										
											2009-09-22 14:44:11 +02:00
										 |  |  | 	return ret; | 
					
						
							| 
									
										
										
										
											2008-04-29 00:59:43 -07:00
										 |  |  | } | 
					
						
							| 
									
										
										
										
											2009-10-23 14:58:11 +02:00
										 |  |  | EXPORT_SYMBOL(___ratelimit); |