Blame view

kernel/timer.c 49.8 KB
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
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
  /*
   *  linux/kernel/timer.c
   *
   *  Kernel internal timers, kernel timekeeping, basic process system calls
   *
   *  Copyright (C) 1991, 1992  Linus Torvalds
   *
   *  1997-01-28  Modified by Finn Arne Gangstad to make timers scale better.
   *
   *  1997-09-10  Updated NTP code according to technical memorandum Jan '96
   *              "A Kernel Model for Precision Timekeeping" by Dave Mills
   *  1998-12-24  Fixed a xtime SMP race (we need the xtime_lock rw spinlock to
   *              serialize accesses to xtime/lost_ticks).
   *                              Copyright (C) 1998  Andrea Arcangeli
   *  1999-03-10  Improved NTP compatibility by Ulrich Windl
   *  2002-05-31	Move sys_sysinfo here and make its locking sane, Robert Love
   *  2000-10-05  Implemented scalable SMP per-CPU timer handling.
   *                              Copyright (C) 2000, 2001, 2002  Ingo Molnar
   *              Designed by David S. Miller, Alexey Kuznetsov and Ingo Molnar
   */
  
  #include <linux/kernel_stat.h>
  #include <linux/module.h>
  #include <linux/interrupt.h>
  #include <linux/percpu.h>
  #include <linux/init.h>
  #include <linux/mm.h>
  #include <linux/swap.h>
  #include <linux/notifier.h>
  #include <linux/thread_info.h>
  #include <linux/time.h>
  #include <linux/jiffies.h>
  #include <linux/posix-timers.h>
  #include <linux/cpu.h>
  #include <linux/syscalls.h>
97a41e261   Adrian Bunk   [PATCH] kernel/: ...
36
  #include <linux/delay.h>
79bf2bb33   Thomas Gleixner   [PATCH] tick-mana...
37
  #include <linux/tick.h>
82f67cd9f   Ingo Molnar   [PATCH] Add debug...
38
  #include <linux/kallsyms.h>
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
39
40
41
42
43
44
  
  #include <asm/uaccess.h>
  #include <asm/unistd.h>
  #include <asm/div64.h>
  #include <asm/timex.h>
  #include <asm/io.h>
ecea8d19c   Thomas Gleixner   [PATCH] jiffies_6...
45
46
47
  u64 jiffies_64 __cacheline_aligned_in_smp = INITIAL_JIFFIES;
  
  EXPORT_SYMBOL(jiffies_64);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
48
49
50
  /*
   * per-CPU timer vector definitions:
   */
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
  #define TVN_BITS (CONFIG_BASE_SMALL ? 4 : 6)
  #define TVR_BITS (CONFIG_BASE_SMALL ? 6 : 8)
  #define TVN_SIZE (1 << TVN_BITS)
  #define TVR_SIZE (1 << TVR_BITS)
  #define TVN_MASK (TVN_SIZE - 1)
  #define TVR_MASK (TVR_SIZE - 1)
  
  typedef struct tvec_s {
  	struct list_head vec[TVN_SIZE];
  } tvec_t;
  
  typedef struct tvec_root_s {
  	struct list_head vec[TVR_SIZE];
  } tvec_root_t;
  
  struct tvec_t_base_s {
3691c5199   Oleg Nesterov   [PATCH] kill __in...
67
68
  	spinlock_t lock;
  	struct timer_list *running_timer;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
69
  	unsigned long timer_jiffies;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
70
71
72
73
74
75
76
77
  	tvec_root_t tv1;
  	tvec_t tv2;
  	tvec_t tv3;
  	tvec_t tv4;
  	tvec_t tv5;
  } ____cacheline_aligned_in_smp;
  
  typedef struct tvec_t_base_s tvec_base_t;
ba6edfcd1   Andrew Morton   [PATCH] timer ini...
78

3691c5199   Oleg Nesterov   [PATCH] kill __in...
79
80
  tvec_base_t boot_tvec_bases;
  EXPORT_SYMBOL(boot_tvec_bases);
51d8c5edd   Josh Triplett   [PATCH] timer: Fi...
81
  static DEFINE_PER_CPU(tvec_base_t *, tvec_bases) = &boot_tvec_bases;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
82

4c36a5dec   Arjan van de Ven   [PATCH] round_jif...
83
84
85
86
87
  /**
   * __round_jiffies - function to round jiffies to a full second
   * @j: the time in (absolute) jiffies that should be rounded
   * @cpu: the processor number on which the timeout will happen
   *
72fd4a35a   Robert P. J. Day   [PATCH] Numerous ...
88
   * __round_jiffies() rounds an absolute time in the future (in jiffies)
4c36a5dec   Arjan van de Ven   [PATCH] round_jif...
89
90
91
92
93
94
95
96
97
98
99
100
   * up or down to (approximately) full seconds. This is useful for timers
   * for which the exact time they fire does not matter too much, as long as
   * they fire approximately every X seconds.
   *
   * By rounding these timers to whole seconds, all such timers will fire
   * at the same time, rather than at various times spread out. The goal
   * of this is to have the CPU wake up less, which saves power.
   *
   * The exact rounding is skewed for each processor to avoid all
   * processors firing at the exact same time, which could lead
   * to lock contention or spurious cache line bouncing.
   *
72fd4a35a   Robert P. J. Day   [PATCH] Numerous ...
101
   * The return value is the rounded version of the @j parameter.
4c36a5dec   Arjan van de Ven   [PATCH] round_jif...
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
   */
  unsigned long __round_jiffies(unsigned long j, int cpu)
  {
  	int rem;
  	unsigned long original = j;
  
  	/*
  	 * We don't want all cpus firing their timers at once hitting the
  	 * same lock or cachelines, so we skew each extra cpu with an extra
  	 * 3 jiffies. This 3 jiffies came originally from the mm/ code which
  	 * already did this.
  	 * The skew is done by adding 3*cpunr, then round, then subtract this
  	 * extra offset again.
  	 */
  	j += cpu * 3;
  
  	rem = j % HZ;
  
  	/*
  	 * If the target jiffie is just after a whole second (which can happen
  	 * due to delays of the timer irq, long irq off times etc etc) then
  	 * we should round down to the whole second, not up. Use 1/4th second
  	 * as cutoff for this rounding as an extreme upper bound for this.
  	 */
  	if (rem < HZ/4) /* round down */
  		j = j - rem;
  	else /* round up */
  		j = j - rem + HZ;
  
  	/* now that we have rounded, subtract the extra skew again */
  	j -= cpu * 3;
  
  	if (j <= jiffies) /* rounding ate our timeout entirely; */
  		return original;
  	return j;
  }
  EXPORT_SYMBOL_GPL(__round_jiffies);
  
  /**
   * __round_jiffies_relative - function to round jiffies to a full second
   * @j: the time in (relative) jiffies that should be rounded
   * @cpu: the processor number on which the timeout will happen
   *
72fd4a35a   Robert P. J. Day   [PATCH] Numerous ...
145
   * __round_jiffies_relative() rounds a time delta  in the future (in jiffies)
4c36a5dec   Arjan van de Ven   [PATCH] round_jif...
146
147
148
149
150
151
152
153
154
155
156
157
   * up or down to (approximately) full seconds. This is useful for timers
   * for which the exact time they fire does not matter too much, as long as
   * they fire approximately every X seconds.
   *
   * By rounding these timers to whole seconds, all such timers will fire
   * at the same time, rather than at various times spread out. The goal
   * of this is to have the CPU wake up less, which saves power.
   *
   * The exact rounding is skewed for each processor to avoid all
   * processors firing at the exact same time, which could lead
   * to lock contention or spurious cache line bouncing.
   *
72fd4a35a   Robert P. J. Day   [PATCH] Numerous ...
158
   * The return value is the rounded version of the @j parameter.
4c36a5dec   Arjan van de Ven   [PATCH] round_jif...
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
   */
  unsigned long __round_jiffies_relative(unsigned long j, int cpu)
  {
  	/*
  	 * In theory the following code can skip a jiffy in case jiffies
  	 * increments right between the addition and the later subtraction.
  	 * However since the entire point of this function is to use approximate
  	 * timeouts, it's entirely ok to not handle that.
  	 */
  	return  __round_jiffies(j + jiffies, cpu) - jiffies;
  }
  EXPORT_SYMBOL_GPL(__round_jiffies_relative);
  
  /**
   * round_jiffies - function to round jiffies to a full second
   * @j: the time in (absolute) jiffies that should be rounded
   *
72fd4a35a   Robert P. J. Day   [PATCH] Numerous ...
176
   * round_jiffies() rounds an absolute time in the future (in jiffies)
4c36a5dec   Arjan van de Ven   [PATCH] round_jif...
177
178
179
180
181
182
183
184
   * up or down to (approximately) full seconds. This is useful for timers
   * for which the exact time they fire does not matter too much, as long as
   * they fire approximately every X seconds.
   *
   * By rounding these timers to whole seconds, all such timers will fire
   * at the same time, rather than at various times spread out. The goal
   * of this is to have the CPU wake up less, which saves power.
   *
72fd4a35a   Robert P. J. Day   [PATCH] Numerous ...
185
   * The return value is the rounded version of the @j parameter.
4c36a5dec   Arjan van de Ven   [PATCH] round_jif...
186
187
188
189
190
191
192
193
194
195
196
   */
  unsigned long round_jiffies(unsigned long j)
  {
  	return __round_jiffies(j, raw_smp_processor_id());
  }
  EXPORT_SYMBOL_GPL(round_jiffies);
  
  /**
   * round_jiffies_relative - function to round jiffies to a full second
   * @j: the time in (relative) jiffies that should be rounded
   *
72fd4a35a   Robert P. J. Day   [PATCH] Numerous ...
197
   * round_jiffies_relative() rounds a time delta  in the future (in jiffies)
4c36a5dec   Arjan van de Ven   [PATCH] round_jif...
198
199
200
201
202
203
204
205
   * up or down to (approximately) full seconds. This is useful for timers
   * for which the exact time they fire does not matter too much, as long as
   * they fire approximately every X seconds.
   *
   * By rounding these timers to whole seconds, all such timers will fire
   * at the same time, rather than at various times spread out. The goal
   * of this is to have the CPU wake up less, which saves power.
   *
72fd4a35a   Robert P. J. Day   [PATCH] Numerous ...
206
   * The return value is the rounded version of the @j parameter.
4c36a5dec   Arjan van de Ven   [PATCH] round_jif...
207
208
209
210
211
212
   */
  unsigned long round_jiffies_relative(unsigned long j)
  {
  	return __round_jiffies_relative(j, raw_smp_processor_id());
  }
  EXPORT_SYMBOL_GPL(round_jiffies_relative);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
213
214
215
216
  static inline void set_running_timer(tvec_base_t *base,
  					struct timer_list *timer)
  {
  #ifdef CONFIG_SMP
3691c5199   Oleg Nesterov   [PATCH] kill __in...
217
  	base->running_timer = timer;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
218
219
  #endif
  }
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
  static void internal_add_timer(tvec_base_t *base, struct timer_list *timer)
  {
  	unsigned long expires = timer->expires;
  	unsigned long idx = expires - base->timer_jiffies;
  	struct list_head *vec;
  
  	if (idx < TVR_SIZE) {
  		int i = expires & TVR_MASK;
  		vec = base->tv1.vec + i;
  	} else if (idx < 1 << (TVR_BITS + TVN_BITS)) {
  		int i = (expires >> TVR_BITS) & TVN_MASK;
  		vec = base->tv2.vec + i;
  	} else if (idx < 1 << (TVR_BITS + 2 * TVN_BITS)) {
  		int i = (expires >> (TVR_BITS + TVN_BITS)) & TVN_MASK;
  		vec = base->tv3.vec + i;
  	} else if (idx < 1 << (TVR_BITS + 3 * TVN_BITS)) {
  		int i = (expires >> (TVR_BITS + 2 * TVN_BITS)) & TVN_MASK;
  		vec = base->tv4.vec + i;
  	} else if ((signed long) idx < 0) {
  		/*
  		 * Can happen if you add a timer with expires == jiffies,
  		 * or you set a timer to go off in the past
  		 */
  		vec = base->tv1.vec + (base->timer_jiffies & TVR_MASK);
  	} else {
  		int i;
  		/* If the timeout is larger than 0xffffffff on 64-bit
  		 * architectures then we use the maximum timeout:
  		 */
  		if (idx > 0xffffffffUL) {
  			idx = 0xffffffffUL;
  			expires = idx + base->timer_jiffies;
  		}
  		i = (expires >> (TVR_BITS + 3 * TVN_BITS)) & TVN_MASK;
  		vec = base->tv5.vec + i;
  	}
  	/*
  	 * Timers are FIFO:
  	 */
  	list_add_tail(&timer->entry, vec);
  }
82f67cd9f   Ingo Molnar   [PATCH] Add debug...
261
262
263
264
265
266
267
268
269
270
271
  #ifdef CONFIG_TIMER_STATS
  void __timer_stats_timer_set_start_info(struct timer_list *timer, void *addr)
  {
  	if (timer->start_site)
  		return;
  
  	timer->start_site = addr;
  	memcpy(timer->start_comm, current->comm, TASK_COMM_LEN);
  	timer->start_pid = current->pid;
  }
  #endif
2aae4a108   Rolf Eike Beer   [PATCH] Fix kerne...
272
  /**
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
273
274
275
276
277
278
279
280
281
   * init_timer - initialize a timer.
   * @timer: the timer to be initialized
   *
   * init_timer() must be done to a timer prior calling *any* of the
   * other timer functions.
   */
  void fastcall init_timer(struct timer_list *timer)
  {
  	timer->entry.next = NULL;
bfe5d8341   Paul Mackerras   [PATCH] Define __...
282
  	timer->base = __raw_get_cpu_var(tvec_bases);
82f67cd9f   Ingo Molnar   [PATCH] Add debug...
283
284
285
286
287
  #ifdef CONFIG_TIMER_STATS
  	timer->start_site = NULL;
  	timer->start_pid = -1;
  	memset(timer->start_comm, 0, TASK_COMM_LEN);
  #endif
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
288
289
290
291
  }
  EXPORT_SYMBOL(init_timer);
  
  static inline void detach_timer(struct timer_list *timer,
82f67cd9f   Ingo Molnar   [PATCH] Add debug...
292
  				int clear_pending)
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
293
294
295
296
297
298
299
300
301
302
  {
  	struct list_head *entry = &timer->entry;
  
  	__list_del(entry->prev, entry->next);
  	if (clear_pending)
  		entry->next = NULL;
  	entry->prev = LIST_POISON2;
  }
  
  /*
3691c5199   Oleg Nesterov   [PATCH] kill __in...
303
   * We are using hashed locking: holding per_cpu(tvec_bases).lock
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
304
305
306
307
308
309
310
311
312
313
   * means that all timers which are tied to this base via timer->base are
   * locked, and the base itself is locked too.
   *
   * So __run_timers/migrate_timers can safely modify all timers which could
   * be found on ->tvX lists.
   *
   * When the timer's base is locked, and the timer removed from list, it is
   * possible to set timer->base = NULL and drop the lock: the timer remains
   * locked.
   */
3691c5199   Oleg Nesterov   [PATCH] kill __in...
314
  static tvec_base_t *lock_timer_base(struct timer_list *timer,
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
315
  					unsigned long *flags)
89e7e374d   Josh Triplett   [PATCH] timer: ad...
316
  	__acquires(timer->base->lock)
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
317
  {
3691c5199   Oleg Nesterov   [PATCH] kill __in...
318
  	tvec_base_t *base;
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
319
320
321
322
323
324
325
326
327
328
329
330
331
  
  	for (;;) {
  		base = timer->base;
  		if (likely(base != NULL)) {
  			spin_lock_irqsave(&base->lock, *flags);
  			if (likely(base == timer->base))
  				return base;
  			/* The timer has migrated to another CPU */
  			spin_unlock_irqrestore(&base->lock, *flags);
  		}
  		cpu_relax();
  	}
  }
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
332
333
  int __mod_timer(struct timer_list *timer, unsigned long expires)
  {
3691c5199   Oleg Nesterov   [PATCH] kill __in...
334
  	tvec_base_t *base, *new_base;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
335
336
  	unsigned long flags;
  	int ret = 0;
82f67cd9f   Ingo Molnar   [PATCH] Add debug...
337
  	timer_stats_timer_set_start_info(timer);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
338
  	BUG_ON(!timer->function);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
339

55c888d6d   Oleg Nesterov   [PATCH] timers fi...
340
341
342
343
344
345
  	base = lock_timer_base(timer, &flags);
  
  	if (timer_pending(timer)) {
  		detach_timer(timer, 0);
  		ret = 1;
  	}
a4a6198b8   Jan Beulich   [PATCH] tvec_base...
346
  	new_base = __get_cpu_var(tvec_bases);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
347

3691c5199   Oleg Nesterov   [PATCH] kill __in...
348
  	if (base != new_base) {
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
349
  		/*
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
350
351
352
353
354
  		 * We are trying to schedule the timer on the local CPU.
  		 * However we can't change timer's base while it is running,
  		 * otherwise del_timer_sync() can't detect that the timer's
  		 * handler yet has not finished. This also guarantees that
  		 * the timer is serialized wrt itself.
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
355
  		 */
a2c348fe0   Oleg Nesterov   [PATCH] __mod_tim...
356
  		if (likely(base->running_timer != timer)) {
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
357
358
359
  			/* See the comment in lock_timer_base() */
  			timer->base = NULL;
  			spin_unlock(&base->lock);
a2c348fe0   Oleg Nesterov   [PATCH] __mod_tim...
360
361
362
  			base = new_base;
  			spin_lock(&base->lock);
  			timer->base = base;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
363
364
  		}
  	}
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
365
  	timer->expires = expires;
a2c348fe0   Oleg Nesterov   [PATCH] __mod_tim...
366
367
  	internal_add_timer(base, timer);
  	spin_unlock_irqrestore(&base->lock, flags);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
368
369
370
371
372
  
  	return ret;
  }
  
  EXPORT_SYMBOL(__mod_timer);
2aae4a108   Rolf Eike Beer   [PATCH] Fix kerne...
373
  /**
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
374
375
376
377
378
379
380
381
   * add_timer_on - start a timer on a particular CPU
   * @timer: the timer to be added
   * @cpu: the CPU to start it on
   *
   * This is not very scalable on SMP. Double adds are not possible.
   */
  void add_timer_on(struct timer_list *timer, int cpu)
  {
a4a6198b8   Jan Beulich   [PATCH] tvec_base...
382
  	tvec_base_t *base = per_cpu(tvec_bases, cpu);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
383
    	unsigned long flags;
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
384

82f67cd9f   Ingo Molnar   [PATCH] Add debug...
385
  	timer_stats_timer_set_start_info(timer);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
386
    	BUG_ON(timer_pending(timer) || !timer->function);
3691c5199   Oleg Nesterov   [PATCH] kill __in...
387
388
  	spin_lock_irqsave(&base->lock, flags);
  	timer->base = base;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
389
  	internal_add_timer(base, timer);
3691c5199   Oleg Nesterov   [PATCH] kill __in...
390
  	spin_unlock_irqrestore(&base->lock, flags);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
391
  }
2aae4a108   Rolf Eike Beer   [PATCH] Fix kerne...
392
  /**
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
393
394
   * mod_timer - modify a timer's timeout
   * @timer: the timer to be modified
2aae4a108   Rolf Eike Beer   [PATCH] Fix kerne...
395
   * @expires: new timeout in jiffies
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
396
   *
72fd4a35a   Robert P. J. Day   [PATCH] Numerous ...
397
   * mod_timer() is a more efficient way to update the expire field of an
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
398
399
400
401
402
403
404
405
406
407
408
409
410
411
412
413
414
   * active timer (if the timer is inactive it will be activated)
   *
   * mod_timer(timer, expires) is equivalent to:
   *
   *     del_timer(timer); timer->expires = expires; add_timer(timer);
   *
   * Note that if there are multiple unserialized concurrent users of the
   * same timer, then mod_timer() is the only safe way to modify the timeout,
   * since add_timer() cannot modify an already running timer.
   *
   * The function returns whether it has modified a pending timer or not.
   * (ie. mod_timer() of an inactive timer returns 0, mod_timer() of an
   * active timer returns 1.)
   */
  int mod_timer(struct timer_list *timer, unsigned long expires)
  {
  	BUG_ON(!timer->function);
82f67cd9f   Ingo Molnar   [PATCH] Add debug...
415
  	timer_stats_timer_set_start_info(timer);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
416
417
418
419
420
421
422
423
424
425
426
427
  	/*
  	 * This is a common optimization triggered by the
  	 * networking code - if the timer is re-modified
  	 * to be the same thing then just return:
  	 */
  	if (timer->expires == expires && timer_pending(timer))
  		return 1;
  
  	return __mod_timer(timer, expires);
  }
  
  EXPORT_SYMBOL(mod_timer);
2aae4a108   Rolf Eike Beer   [PATCH] Fix kerne...
428
  /**
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
429
430
431
432
433
434
435
436
437
438
439
440
   * del_timer - deactive a timer.
   * @timer: the timer to be deactivated
   *
   * del_timer() deactivates a timer - this works on both active and inactive
   * timers.
   *
   * The function returns whether it has deactivated a pending timer or not.
   * (ie. del_timer() of an inactive timer returns 0, del_timer() of an
   * active timer returns 1.)
   */
  int del_timer(struct timer_list *timer)
  {
3691c5199   Oleg Nesterov   [PATCH] kill __in...
441
  	tvec_base_t *base;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
442
  	unsigned long flags;
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
443
  	int ret = 0;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
444

82f67cd9f   Ingo Molnar   [PATCH] Add debug...
445
  	timer_stats_timer_clear_start_info(timer);
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
446
447
448
449
450
451
  	if (timer_pending(timer)) {
  		base = lock_timer_base(timer, &flags);
  		if (timer_pending(timer)) {
  			detach_timer(timer, 1);
  			ret = 1;
  		}
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
452
  		spin_unlock_irqrestore(&base->lock, flags);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
453
  	}
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
454

55c888d6d   Oleg Nesterov   [PATCH] timers fi...
455
  	return ret;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
456
457
458
459
460
  }
  
  EXPORT_SYMBOL(del_timer);
  
  #ifdef CONFIG_SMP
2aae4a108   Rolf Eike Beer   [PATCH] Fix kerne...
461
462
463
464
  /**
   * try_to_del_timer_sync - Try to deactivate a timer
   * @timer: timer do del
   *
fd450b731   Oleg Nesterov   [PATCH] timers: i...
465
466
467
468
469
470
471
   * This function tries to deactivate a timer. Upon successful (ret >= 0)
   * exit the timer is not queued and the handler is not running on any CPU.
   *
   * It must not be called from interrupt contexts.
   */
  int try_to_del_timer_sync(struct timer_list *timer)
  {
3691c5199   Oleg Nesterov   [PATCH] kill __in...
472
  	tvec_base_t *base;
fd450b731   Oleg Nesterov   [PATCH] timers: i...
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
  	unsigned long flags;
  	int ret = -1;
  
  	base = lock_timer_base(timer, &flags);
  
  	if (base->running_timer == timer)
  		goto out;
  
  	ret = 0;
  	if (timer_pending(timer)) {
  		detach_timer(timer, 1);
  		ret = 1;
  	}
  out:
  	spin_unlock_irqrestore(&base->lock, flags);
  
  	return ret;
  }
2aae4a108   Rolf Eike Beer   [PATCH] Fix kerne...
491
  /**
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
492
493
494
495
496
497
498
   * del_timer_sync - deactivate a timer and wait for the handler to finish.
   * @timer: the timer to be deactivated
   *
   * This function only differs from del_timer() on SMP: besides deactivating
   * the timer it also makes sure the handler has finished executing on other
   * CPUs.
   *
72fd4a35a   Robert P. J. Day   [PATCH] Numerous ...
499
   * Synchronization rules: Callers must prevent restarting of the timer,
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
500
501
   * otherwise this function is meaningless. It must not be called from
   * interrupt contexts. The caller must not hold locks which would prevent
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
502
503
504
   * completion of the timer's handler. The timer's handler must not call
   * add_timer_on(). Upon exit the timer is not queued and the handler is
   * not running on any CPU.
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
505
506
   *
   * The function returns whether it has deactivated a pending timer or not.
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
507
508
509
   */
  int del_timer_sync(struct timer_list *timer)
  {
fd450b731   Oleg Nesterov   [PATCH] timers: i...
510
511
512
513
  	for (;;) {
  		int ret = try_to_del_timer_sync(timer);
  		if (ret >= 0)
  			return ret;
a0009652a   Andrew Morton   [PATCH] del_timer...
514
  		cpu_relax();
fd450b731   Oleg Nesterov   [PATCH] timers: i...
515
  	}
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
516
  }
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
517

55c888d6d   Oleg Nesterov   [PATCH] timers fi...
518
  EXPORT_SYMBOL(del_timer_sync);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
519
520
521
522
523
  #endif
  
  static int cascade(tvec_base_t *base, tvec_t *tv, int index)
  {
  	/* cascade all the timers from tv up one level */
3439dd86e   Porpoise   [PATCH] When CONF...
524
525
526
527
  	struct timer_list *timer, *tmp;
  	struct list_head tv_list;
  
  	list_replace_init(tv->vec + index, &tv_list);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
528

1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
529
  	/*
3439dd86e   Porpoise   [PATCH] When CONF...
530
531
  	 * We are removing _all_ timers from the list, so we
  	 * don't have to detach them individually.
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
532
  	 */
3439dd86e   Porpoise   [PATCH] When CONF...
533
534
535
  	list_for_each_entry_safe(timer, tmp, &tv_list, entry) {
  		BUG_ON(timer->base != base);
  		internal_add_timer(base, timer);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
536
  	}
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
537
538
539
  
  	return index;
  }
2aae4a108   Rolf Eike Beer   [PATCH] Fix kerne...
540
541
542
  #define INDEX(N) ((base->timer_jiffies >> (TVR_BITS + (N) * TVN_BITS)) & TVN_MASK)
  
  /**
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
543
544
545
546
547
548
   * __run_timers - run all expired timers (if any) on this CPU.
   * @base: the timer vector to be processed.
   *
   * This function cascades all vectors and executes all expired timer
   * vectors.
   */
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
549
550
551
  static inline void __run_timers(tvec_base_t *base)
  {
  	struct timer_list *timer;
3691c5199   Oleg Nesterov   [PATCH] kill __in...
552
  	spin_lock_irq(&base->lock);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
553
  	while (time_after_eq(jiffies, base->timer_jiffies)) {
626ab0e69   Oleg Nesterov   [PATCH] list: use...
554
  		struct list_head work_list;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
555
556
  		struct list_head *head = &work_list;
   		int index = base->timer_jiffies & TVR_MASK;
626ab0e69   Oleg Nesterov   [PATCH] list: use...
557

1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
558
559
560
561
562
563
564
565
  		/*
  		 * Cascade timers:
  		 */
  		if (!index &&
  			(!cascade(base, &base->tv2, INDEX(0))) &&
  				(!cascade(base, &base->tv3, INDEX(1))) &&
  					!cascade(base, &base->tv4, INDEX(2)))
  			cascade(base, &base->tv5, INDEX(3));
626ab0e69   Oleg Nesterov   [PATCH] list: use...
566
567
  		++base->timer_jiffies;
  		list_replace_init(base->tv1.vec + index, &work_list);
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
568
  		while (!list_empty(head)) {
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
569
570
571
572
573
574
  			void (*fn)(unsigned long);
  			unsigned long data;
  
  			timer = list_entry(head->next,struct timer_list,entry);
   			fn = timer->function;
   			data = timer->data;
82f67cd9f   Ingo Molnar   [PATCH] Add debug...
575
  			timer_stats_account_timer(timer);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
576
  			set_running_timer(base, timer);
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
577
  			detach_timer(timer, 1);
3691c5199   Oleg Nesterov   [PATCH] kill __in...
578
  			spin_unlock_irq(&base->lock);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
579
  			{
be5b4fbd0   Jesper Juhl   [PATCH] preempt_c...
580
  				int preempt_count = preempt_count();
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
581
582
  				fn(data);
  				if (preempt_count != preempt_count()) {
be5b4fbd0   Jesper Juhl   [PATCH] preempt_c...
583
584
585
586
587
588
  					printk(KERN_WARNING "huh, entered %p "
  					       "with preempt_count %08x, exited"
  					       " with %08x?
  ",
  					       fn, preempt_count,
  					       preempt_count());
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
589
590
591
  					BUG();
  				}
  			}
3691c5199   Oleg Nesterov   [PATCH] kill __in...
592
  			spin_lock_irq(&base->lock);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
593
594
595
  		}
  	}
  	set_running_timer(base, NULL);
3691c5199   Oleg Nesterov   [PATCH] kill __in...
596
  	spin_unlock_irq(&base->lock);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
597
  }
fd064b9b7   Thomas Gleixner   [PATCH] Extend ne...
598
  #if defined(CONFIG_NO_IDLE_HZ) || defined(CONFIG_NO_HZ)
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
599
600
601
602
603
  /*
   * Find out when the next timer event is due to happen. This
   * is used on S/390 to stop all activity when a cpus is idle.
   * This functions needs to be called disabled.
   */
1cfd68496   Thomas Gleixner   [PATCH] Fix casca...
604
  static unsigned long __next_timer_interrupt(tvec_base_t *base)
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
605
  {
1cfd68496   Thomas Gleixner   [PATCH] Fix casca...
606
607
608
  	unsigned long timer_jiffies = base->timer_jiffies;
  	unsigned long expires = timer_jiffies + (LONG_MAX >> 1);
  	int index, slot, array, found = 0;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
609
  	struct timer_list *nte;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
610
  	tvec_t *varray[4];
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
611
612
  
  	/* Look for timer events in tv1. */
1cfd68496   Thomas Gleixner   [PATCH] Fix casca...
613
  	index = slot = timer_jiffies & TVR_MASK;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
614
  	do {
1cfd68496   Thomas Gleixner   [PATCH] Fix casca...
615
616
  		list_for_each_entry(nte, base->tv1.vec + slot, entry) {
  			found = 1;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
617
  			expires = nte->expires;
1cfd68496   Thomas Gleixner   [PATCH] Fix casca...
618
619
620
621
  			/* Look at the cascade bucket(s)? */
  			if (!index || slot < index)
  				goto cascade;
  			return expires;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
622
  		}
1cfd68496   Thomas Gleixner   [PATCH] Fix casca...
623
624
625
626
627
628
629
630
  		slot = (slot + 1) & TVR_MASK;
  	} while (slot != index);
  
  cascade:
  	/* Calculate the next cascade event */
  	if (index)
  		timer_jiffies += TVR_SIZE - index;
  	timer_jiffies >>= TVR_BITS;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
631
632
633
634
635
636
  
  	/* Check tv2-tv5. */
  	varray[0] = &base->tv2;
  	varray[1] = &base->tv3;
  	varray[2] = &base->tv4;
  	varray[3] = &base->tv5;
1cfd68496   Thomas Gleixner   [PATCH] Fix casca...
637
638
639
640
641
  
  	for (array = 0; array < 4; array++) {
  		tvec_t *varp = varray[array];
  
  		index = slot = timer_jiffies & TVN_MASK;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
642
  		do {
1cfd68496   Thomas Gleixner   [PATCH] Fix casca...
643
644
  			list_for_each_entry(nte, varp->vec + slot, entry) {
  				found = 1;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
645
646
  				if (time_before(nte->expires, expires))
  					expires = nte->expires;
1cfd68496   Thomas Gleixner   [PATCH] Fix casca...
647
648
649
650
651
652
653
654
655
656
657
658
659
660
661
662
663
  			}
  			/*
  			 * Do we still search for the first timer or are
  			 * we looking up the cascade buckets ?
  			 */
  			if (found) {
  				/* Look at the cascade bucket(s)? */
  				if (!index || slot < index)
  					break;
  				return expires;
  			}
  			slot = (slot + 1) & TVN_MASK;
  		} while (slot != index);
  
  		if (index)
  			timer_jiffies += TVN_SIZE - index;
  		timer_jiffies >>= TVN_BITS;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
664
  	}
1cfd68496   Thomas Gleixner   [PATCH] Fix casca...
665
666
  	return expires;
  }
69239749e   Tony Lindgren   [PATCH] fix next_...
667

1cfd68496   Thomas Gleixner   [PATCH] Fix casca...
668
669
670
671
672
673
674
675
676
677
678
679
  /*
   * Check, if the next hrtimer event is before the next timer wheel
   * event:
   */
  static unsigned long cmp_next_hrtimer_event(unsigned long now,
  					    unsigned long expires)
  {
  	ktime_t hr_delta = hrtimer_get_next_event();
  	struct timespec tsdelta;
  
  	if (hr_delta.tv64 == KTIME_MAX)
  		return expires;
0662b7132   Zachary Amsden   [PATCH] Fix a NO_...
680

1cfd68496   Thomas Gleixner   [PATCH] Fix casca...
681
682
  	if (hr_delta.tv64 <= TICK_NSEC)
  		return now;
69239749e   Tony Lindgren   [PATCH] fix next_...
683

1cfd68496   Thomas Gleixner   [PATCH] Fix casca...
684
685
686
687
  	tsdelta = ktime_to_timespec(hr_delta);
  	now += timespec_to_jiffies(&tsdelta);
  	if (time_before(now, expires))
  		return now;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
688
689
  	return expires;
  }
1cfd68496   Thomas Gleixner   [PATCH] Fix casca...
690
691
692
693
  
  /**
   * next_timer_interrupt - return the jiffy of the next pending timer
   */
fd064b9b7   Thomas Gleixner   [PATCH] Extend ne...
694
  unsigned long get_next_timer_interrupt(unsigned long now)
1cfd68496   Thomas Gleixner   [PATCH] Fix casca...
695
696
  {
  	tvec_base_t *base = __get_cpu_var(tvec_bases);
fd064b9b7   Thomas Gleixner   [PATCH] Extend ne...
697
  	unsigned long expires;
1cfd68496   Thomas Gleixner   [PATCH] Fix casca...
698
699
700
701
702
703
704
705
706
707
  
  	spin_lock(&base->lock);
  	expires = __next_timer_interrupt(base);
  	spin_unlock(&base->lock);
  
  	if (time_before_eq(expires, now))
  		return now;
  
  	return cmp_next_hrtimer_event(now, expires);
  }
fd064b9b7   Thomas Gleixner   [PATCH] Extend ne...
708
709
710
711
712
713
714
  
  #ifdef CONFIG_NO_IDLE_HZ
  unsigned long next_timer_interrupt(void)
  {
  	return get_next_timer_interrupt(jiffies);
  }
  #endif
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
715
716
717
  #endif
  
  /******************************************************************/
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
718
719
720
721
722
723
724
725
726
727
728
729
  /* 
   * The current time 
   * wall_to_monotonic is what we need to add to xtime (or xtime corrected 
   * for sub jiffie times) to get to monotonic time.  Monotonic is pegged
   * at zero at system boot time, so wall_to_monotonic will be negative,
   * however, we will ALWAYS keep the tv_nsec part positive so we can use
   * the usual normalization.
   */
  struct timespec xtime __attribute__ ((aligned (16)));
  struct timespec wall_to_monotonic __attribute__ ((aligned (16)));
  
  EXPORT_SYMBOL(xtime);
726c14bf4   Paul Mackerras   [PATCH] Provide a...
730

ad596171e   John Stultz   [PATCH] Time: Use...
731
732
733
  /* XXX - all of this timekeeping code should be later moved to time.c */
  #include <linux/clocksource.h>
  static struct clocksource *clock; /* pointer to current clocksource */
cf3c769b4   John Stultz   [PATCH] Time: Int...
734
735
736
737
738
739
740
741
742
743
744
745
746
747
748
  
  #ifdef CONFIG_GENERIC_TIME
  /**
   * __get_nsec_offset - Returns nanoseconds since last call to periodic_hook
   *
   * private function, must hold xtime_lock lock when being
   * called. Returns the number of nanoseconds since the
   * last call to update_wall_time() (adjusted by NTP scaling)
   */
  static inline s64 __get_nsec_offset(void)
  {
  	cycle_t cycle_now, cycle_delta;
  	s64 ns_offset;
  
  	/* read clocksource: */
a27525497   John Stultz   [PATCH] time: ren...
749
  	cycle_now = clocksource_read(clock);
cf3c769b4   John Stultz   [PATCH] Time: Int...
750
751
  
  	/* calculate the delta since the last update_wall_time: */
19923c190   Roman Zippel   [PATCH] fix and o...
752
  	cycle_delta = (cycle_now - clock->cycle_last) & clock->mask;
cf3c769b4   John Stultz   [PATCH] Time: Int...
753
754
755
756
757
758
759
760
761
762
763
764
765
766
767
768
769
770
771
772
773
774
775
776
777
778
779
780
781
782
783
  
  	/* convert to nanoseconds: */
  	ns_offset = cyc2ns(clock, cycle_delta);
  
  	return ns_offset;
  }
  
  /**
   * __get_realtime_clock_ts - Returns the time of day in a timespec
   * @ts:		pointer to the timespec to be set
   *
   * Returns the time of day in a timespec. Used by
   * do_gettimeofday() and get_realtime_clock_ts().
   */
  static inline void __get_realtime_clock_ts(struct timespec *ts)
  {
  	unsigned long seq;
  	s64 nsecs;
  
  	do {
  		seq = read_seqbegin(&xtime_lock);
  
  		*ts = xtime;
  		nsecs = __get_nsec_offset();
  
  	} while (read_seqretry(&xtime_lock, seq));
  
  	timespec_add_ns(ts, nsecs);
  }
  
  /**
a27525497   John Stultz   [PATCH] time: ren...
784
   * getnstimeofday - Returns the time of day in a timespec
cf3c769b4   John Stultz   [PATCH] Time: Int...
785
786
787
788
789
790
791
792
793
794
795
796
797
798
799
800
801
802
803
804
805
806
807
808
809
810
811
812
813
814
815
816
817
818
819
820
821
822
823
824
825
826
827
828
829
830
831
832
833
834
835
   * @ts:		pointer to the timespec to be set
   *
   * Returns the time of day in a timespec.
   */
  void getnstimeofday(struct timespec *ts)
  {
  	__get_realtime_clock_ts(ts);
  }
  
  EXPORT_SYMBOL(getnstimeofday);
  
  /**
   * do_gettimeofday - Returns the time of day in a timeval
   * @tv:		pointer to the timeval to be set
   *
   * NOTE: Users should be converted to using get_realtime_clock_ts()
   */
  void do_gettimeofday(struct timeval *tv)
  {
  	struct timespec now;
  
  	__get_realtime_clock_ts(&now);
  	tv->tv_sec = now.tv_sec;
  	tv->tv_usec = now.tv_nsec/1000;
  }
  
  EXPORT_SYMBOL(do_gettimeofday);
  /**
   * do_settimeofday - Sets the time of day
   * @tv:		pointer to the timespec variable containing the new time
   *
   * Sets the time of day to the new time and update NTP and notify hrtimers
   */
  int do_settimeofday(struct timespec *tv)
  {
  	unsigned long flags;
  	time_t wtm_sec, sec = tv->tv_sec;
  	long wtm_nsec, nsec = tv->tv_nsec;
  
  	if ((unsigned long)tv->tv_nsec >= NSEC_PER_SEC)
  		return -EINVAL;
  
  	write_seqlock_irqsave(&xtime_lock, flags);
  
  	nsec -= __get_nsec_offset();
  
  	wtm_sec  = wall_to_monotonic.tv_sec + (xtime.tv_sec - sec);
  	wtm_nsec = wall_to_monotonic.tv_nsec + (xtime.tv_nsec - nsec);
  
  	set_normalized_timespec(&xtime, sec, nsec);
  	set_normalized_timespec(&wall_to_monotonic, wtm_sec, wtm_nsec);
e154ff3d2   Roman Zippel   [PATCH] adjust cl...
836
  	clock->error = 0;
cf3c769b4   John Stultz   [PATCH] Time: Int...
837
838
839
840
841
842
843
844
845
846
847
848
849
850
851
852
853
  	ntp_clear();
  
  	write_sequnlock_irqrestore(&xtime_lock, flags);
  
  	/* signal hrtimers about time change */
  	clock_was_set();
  
  	return 0;
  }
  
  EXPORT_SYMBOL(do_settimeofday);
  
  /**
   * change_clocksource - Swaps clocksources if a new one is available
   *
   * Accumulates current time interval and initializes new clocksource
   */
5d8b34fdc   Thomas Gleixner   [PATCH] clocksour...
854
  static void change_clocksource(void)
cf3c769b4   John Stultz   [PATCH] Time: Int...
855
856
857
858
  {
  	struct clocksource *new;
  	cycle_t now;
  	u64 nsec;
5d8b34fdc   Thomas Gleixner   [PATCH] clocksour...
859

a27525497   John Stultz   [PATCH] time: ren...
860
  	new = clocksource_get_next();
5d8b34fdc   Thomas Gleixner   [PATCH] clocksour...
861
862
863
864
865
866
867
868
869
870
871
872
873
874
  
  	if (clock == new)
  		return;
  
  	now = clocksource_read(new);
  	nsec =  __get_nsec_offset();
  	timespec_add_ns(&xtime, nsec);
  
  	clock = new;
  	clock->cycle_last = now;
  
  	clock->error = 0;
  	clock->xtime_nsec = 0;
  	clocksource_calculate_interval(clock, NTP_INTERVAL_LENGTH);
79bf2bb33   Thomas Gleixner   [PATCH] tick-mana...
875
  	tick_clock_notify();
5d8b34fdc   Thomas Gleixner   [PATCH] clocksour...
876
877
878
  	printk(KERN_INFO "Time: %s clocksource has been installed.
  ",
  	       clock->name);
cf3c769b4   John Stultz   [PATCH] Time: Int...
879
880
  }
  #else
5d8b34fdc   Thomas Gleixner   [PATCH] clocksour...
881
  static inline void change_clocksource(void) { }
cf3c769b4   John Stultz   [PATCH] Time: Int...
882
883
884
885
886
887
888
889
890
891
892
893
  #endif
  
  /**
   * timeofday_is_continuous - check to see if timekeeping is free running
   */
  int timekeeping_is_continuous(void)
  {
  	unsigned long seq;
  	int ret;
  
  	do {
  		seq = read_seqbegin(&xtime_lock);
5d8b34fdc   Thomas Gleixner   [PATCH] clocksour...
894
  		ret = clock->flags & CLOCK_SOURCE_VALID_FOR_HRES;
cf3c769b4   John Stultz   [PATCH] Time: Int...
895
896
897
898
899
  
  	} while (read_seqretry(&xtime_lock, seq));
  
  	return ret;
  }
411187fb0   John Stultz   [PATCH] GTOD: per...
900
901
902
903
904
905
906
907
908
909
910
911
912
  /**
   * read_persistent_clock -  Return time in seconds from the persistent clock.
   *
   * Weak dummy function for arches that do not yet support it.
   * Returns seconds from epoch using the battery backed persistent clock.
   * Returns zero if unsupported.
   *
   *  XXX - Do be sure to remove it once all arches implement it.
   */
  unsigned long __attribute__((weak)) read_persistent_clock(void)
  {
  	return 0;
  }
726c14bf4   Paul Mackerras   [PATCH] Provide a...
913
  /*
ad596171e   John Stultz   [PATCH] Time: Use...
914
   * timekeeping_init - Initializes the clocksource and common timekeeping values
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
915
   */
ad596171e   John Stultz   [PATCH] Time: Use...
916
  void __init timekeeping_init(void)
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
917
  {
ad596171e   John Stultz   [PATCH] Time: Use...
918
  	unsigned long flags;
411187fb0   John Stultz   [PATCH] GTOD: per...
919
  	unsigned long sec = read_persistent_clock();
ad596171e   John Stultz   [PATCH] Time: Use...
920
921
  
  	write_seqlock_irqsave(&xtime_lock, flags);
b0ee75561   Roman Zippel   [PATCH] ntp: add ...
922
923
  
  	ntp_clear();
a27525497   John Stultz   [PATCH] time: ren...
924
  	clock = clocksource_get_next();
f4304ab21   John Stultz   [PATCH] HZ free ntp
925
  	clocksource_calculate_interval(clock, NTP_INTERVAL_LENGTH);
19923c190   Roman Zippel   [PATCH] fix and o...
926
  	clock->cycle_last = clocksource_read(clock);
b0ee75561   Roman Zippel   [PATCH] ntp: add ...
927

411187fb0   John Stultz   [PATCH] GTOD: per...
928
929
930
931
  	xtime.tv_sec = sec;
  	xtime.tv_nsec = 0;
  	set_normalized_timespec(&wall_to_monotonic,
  		-xtime.tv_sec, -xtime.tv_nsec);
ad596171e   John Stultz   [PATCH] Time: Use...
932
933
  	write_sequnlock_irqrestore(&xtime_lock, flags);
  }
411187fb0   John Stultz   [PATCH] GTOD: per...
934
  /* flag for if timekeeping is suspended */
3e143475c   John Stultz   [PATCH] improve t...
935
  static int timekeeping_suspended;
411187fb0   John Stultz   [PATCH] GTOD: per...
936
937
  /* time in seconds when suspend began */
  static unsigned long timekeeping_suspend_time;
2aae4a108   Rolf Eike Beer   [PATCH] Fix kerne...
938
  /**
ad596171e   John Stultz   [PATCH] Time: Use...
939
940
941
942
   * timekeeping_resume - Resumes the generic timekeeping subsystem.
   * @dev:	unused
   *
   * This is for the generic clocksource timekeeping.
8ef386092   Atsushi Nemoto   [PATCH] kill wall...
943
   * xtime/wall_to_monotonic/jiffies/etc are
ad596171e   John Stultz   [PATCH] Time: Use...
944
945
946
947
948
   * still managed by arch specific suspend/resume code.
   */
  static int timekeeping_resume(struct sys_device *dev)
  {
  	unsigned long flags;
411187fb0   John Stultz   [PATCH] GTOD: per...
949
  	unsigned long now = read_persistent_clock();
ad596171e   John Stultz   [PATCH] Time: Use...
950
951
  
  	write_seqlock_irqsave(&xtime_lock, flags);
411187fb0   John Stultz   [PATCH] GTOD: per...
952
953
954
955
956
957
958
959
  
  	if (now && (now > timekeeping_suspend_time)) {
  		unsigned long sleep_length = now - timekeeping_suspend_time;
  
  		xtime.tv_sec += sleep_length;
  		wall_to_monotonic.tv_sec -= sleep_length;
  	}
  	/* re-base the last cycle value */
19923c190   Roman Zippel   [PATCH] fix and o...
960
  	clock->cycle_last = clocksource_read(clock);
3e143475c   John Stultz   [PATCH] improve t...
961
962
963
  	clock->error = 0;
  	timekeeping_suspended = 0;
  	write_sequnlock_irqrestore(&xtime_lock, flags);
411187fb0   John Stultz   [PATCH] GTOD: per...
964
965
  
  	touch_softlockup_watchdog();
d316c57ff   Thomas Gleixner   [PATCH] clockeven...
966
967
  	/* Resume hrtimers */
  	clock_was_set();
411187fb0   John Stultz   [PATCH] GTOD: per...
968

3e143475c   John Stultz   [PATCH] improve t...
969
970
971
972
973
974
975
976
977
  	return 0;
  }
  
  static int timekeeping_suspend(struct sys_device *dev, pm_message_t state)
  {
  	unsigned long flags;
  
  	write_seqlock_irqsave(&xtime_lock, flags);
  	timekeeping_suspended = 1;
411187fb0   John Stultz   [PATCH] GTOD: per...
978
  	timekeeping_suspend_time = read_persistent_clock();
ad596171e   John Stultz   [PATCH] Time: Use...
979
980
981
982
983
984
985
  	write_sequnlock_irqrestore(&xtime_lock, flags);
  	return 0;
  }
  
  /* sysfs resume/suspend bits for timekeeping */
  static struct sysdev_class timekeeping_sysclass = {
  	.resume		= timekeeping_resume,
3e143475c   John Stultz   [PATCH] improve t...
986
  	.suspend	= timekeeping_suspend,
ad596171e   John Stultz   [PATCH] Time: Use...
987
988
989
990
991
992
993
994
995
996
997
998
999
1000
1001
1002
1003
1004
1005
  	set_kset_name("timekeeping"),
  };
  
  static struct sys_device device_timer = {
  	.id		= 0,
  	.cls		= &timekeeping_sysclass,
  };
  
  static int __init timekeeping_init_device(void)
  {
  	int error = sysdev_class_register(&timekeeping_sysclass);
  	if (!error)
  		error = sysdev_register(&device_timer);
  	return error;
  }
  
  device_initcall(timekeeping_init_device);
  
  /*
e154ff3d2   Roman Zippel   [PATCH] adjust cl...
1006
   * If the error is already larger, we look ahead even further
19923c190   Roman Zippel   [PATCH] fix and o...
1007
1008
   * to compensate for late or lost adjustments.
   */
f5f1a24a2   Daniel Walker   [PATCH] clocksour...
1009
1010
  static __always_inline int clocksource_bigadjust(s64 error, s64 *interval,
  						 s64 *offset)
19923c190   Roman Zippel   [PATCH] fix and o...
1011
  {
e154ff3d2   Roman Zippel   [PATCH] adjust cl...
1012
1013
1014
  	s64 tick_error, i;
  	u32 look_ahead, adj;
  	s32 error2, mult;
19923c190   Roman Zippel   [PATCH] fix and o...
1015
1016
  
  	/*
e154ff3d2   Roman Zippel   [PATCH] adjust cl...
1017
1018
1019
1020
1021
1022
1023
  	 * Use the current error value to determine how much to look ahead.
  	 * The larger the error the slower we adjust for it to avoid problems
  	 * with losing too many ticks, otherwise we would overadjust and
  	 * produce an even larger error.  The smaller the adjustment the
  	 * faster we try to adjust for it, as lost ticks can do less harm
  	 * here.  This is tuned so that an error of about 1 msec is adusted
  	 * within about 1 sec (or 2^20 nsec in 2^SHIFT_HZ ticks).
19923c190   Roman Zippel   [PATCH] fix and o...
1024
  	 */
e154ff3d2   Roman Zippel   [PATCH] adjust cl...
1025
1026
1027
1028
  	error2 = clock->error >> (TICK_LENGTH_SHIFT + 22 - 2 * SHIFT_HZ);
  	error2 = abs(error2);
  	for (look_ahead = 0; error2 > 0; look_ahead++)
  		error2 >>= 2;
19923c190   Roman Zippel   [PATCH] fix and o...
1029
1030
  
  	/*
e154ff3d2   Roman Zippel   [PATCH] adjust cl...
1031
1032
  	 * Now calculate the error in (1 << look_ahead) ticks, but first
  	 * remove the single look ahead already included in the error.
19923c190   Roman Zippel   [PATCH] fix and o...
1033
  	 */
f5f1a24a2   Daniel Walker   [PATCH] clocksour...
1034
1035
  	tick_error = current_tick_length() >>
  		(TICK_LENGTH_SHIFT - clock->shift + 1);
e154ff3d2   Roman Zippel   [PATCH] adjust cl...
1036
1037
1038
1039
1040
1041
1042
1043
1044
1045
1046
  	tick_error -= clock->xtime_interval >> 1;
  	error = ((error - tick_error) >> look_ahead) + tick_error;
  
  	/* Finally calculate the adjustment shift value.  */
  	i = *interval;
  	mult = 1;
  	if (error < 0) {
  		error = -error;
  		*interval = -*interval;
  		*offset = -*offset;
  		mult = -1;
19923c190   Roman Zippel   [PATCH] fix and o...
1047
  	}
e154ff3d2   Roman Zippel   [PATCH] adjust cl...
1048
1049
  	for (adj = 0; error > i; adj++)
  		error >>= 1;
19923c190   Roman Zippel   [PATCH] fix and o...
1050
1051
1052
  
  	*interval <<= adj;
  	*offset <<= adj;
e154ff3d2   Roman Zippel   [PATCH] adjust cl...
1053
  	return mult << adj;
19923c190   Roman Zippel   [PATCH] fix and o...
1054
1055
1056
1057
1058
1059
1060
1061
1062
1063
1064
1065
1066
1067
  }
  
  /*
   * Adjust the multiplier to reduce the error value,
   * this is optimized for the most common adjustments of -1,0,1,
   * for other values we can do a bit more work.
   */
  static void clocksource_adjust(struct clocksource *clock, s64 offset)
  {
  	s64 error, interval = clock->cycle_interval;
  	int adj;
  
  	error = clock->error >> (TICK_LENGTH_SHIFT - clock->shift - 1);
  	if (error > interval) {
e154ff3d2   Roman Zippel   [PATCH] adjust cl...
1068
1069
1070
1071
1072
  		error >>= 2;
  		if (likely(error <= interval))
  			adj = 1;
  		else
  			adj = clocksource_bigadjust(error, &interval, &offset);
19923c190   Roman Zippel   [PATCH] fix and o...
1073
  	} else if (error < -interval) {
e154ff3d2   Roman Zippel   [PATCH] adjust cl...
1074
1075
1076
1077
1078
1079
1080
  		error >>= 2;
  		if (likely(error >= -interval)) {
  			adj = -1;
  			interval = -interval;
  			offset = -offset;
  		} else
  			adj = clocksource_bigadjust(error, &interval, &offset);
19923c190   Roman Zippel   [PATCH] fix and o...
1081
1082
1083
1084
1085
1086
  	} else
  		return;
  
  	clock->mult += adj;
  	clock->xtime_interval += interval;
  	clock->xtime_nsec -= offset;
f5f1a24a2   Daniel Walker   [PATCH] clocksour...
1087
1088
  	clock->error -= (interval - offset) <<
  			(TICK_LENGTH_SHIFT - clock->shift);
19923c190   Roman Zippel   [PATCH] fix and o...
1089
  }
2aae4a108   Rolf Eike Beer   [PATCH] Fix kerne...
1090
  /**
ad596171e   John Stultz   [PATCH] Time: Use...
1091
1092
1093
1094
1095
1096
   * update_wall_time - Uses the current clocksource to increment the wall time
   *
   * Called from the timer interrupt, must hold a write on xtime_lock.
   */
  static void update_wall_time(void)
  {
19923c190   Roman Zippel   [PATCH] fix and o...
1097
  	cycle_t offset;
ad596171e   John Stultz   [PATCH] Time: Use...
1098

3e143475c   John Stultz   [PATCH] improve t...
1099
1100
1101
  	/* Make sure we're fully resumed: */
  	if (unlikely(timekeeping_suspended))
  		return;
5eb6d2053   John Stultz   [PATCH] Time: Use...
1102

19923c190   Roman Zippel   [PATCH] fix and o...
1103
1104
1105
1106
1107
  #ifdef CONFIG_GENERIC_TIME
  	offset = (clocksource_read(clock) - clock->cycle_last) & clock->mask;
  #else
  	offset = clock->cycle_interval;
  #endif
3e143475c   John Stultz   [PATCH] improve t...
1108
  	clock->xtime_nsec += (s64)xtime.tv_nsec << clock->shift;
ad596171e   John Stultz   [PATCH] Time: Use...
1109
1110
1111
1112
  
  	/* normally this loop will run just once, however in the
  	 * case of lost or late ticks, it will accumulate correctly.
  	 */
19923c190   Roman Zippel   [PATCH] fix and o...
1113
  	while (offset >= clock->cycle_interval) {
ad596171e   John Stultz   [PATCH] Time: Use...
1114
  		/* accumulate one interval */
19923c190   Roman Zippel   [PATCH] fix and o...
1115
1116
1117
1118
1119
1120
1121
1122
1123
  		clock->xtime_nsec += clock->xtime_interval;
  		clock->cycle_last += clock->cycle_interval;
  		offset -= clock->cycle_interval;
  
  		if (clock->xtime_nsec >= (u64)NSEC_PER_SEC << clock->shift) {
  			clock->xtime_nsec -= (u64)NSEC_PER_SEC << clock->shift;
  			xtime.tv_sec++;
  			second_overflow();
  		}
ad596171e   John Stultz   [PATCH] Time: Use...
1124

5eb6d2053   John Stultz   [PATCH] Time: Use...
1125
  		/* interpolator bits */
19923c190   Roman Zippel   [PATCH] fix and o...
1126
  		time_interpolator_update(clock->xtime_interval
5eb6d2053   John Stultz   [PATCH] Time: Use...
1127
  						>> clock->shift);
5eb6d2053   John Stultz   [PATCH] Time: Use...
1128
1129
  
  		/* accumulate error between NTP and clock interval */
19923c190   Roman Zippel   [PATCH] fix and o...
1130
1131
1132
  		clock->error += current_tick_length();
  		clock->error -= clock->xtime_interval << (TICK_LENGTH_SHIFT - clock->shift);
  	}
5eb6d2053   John Stultz   [PATCH] Time: Use...
1133

19923c190   Roman Zippel   [PATCH] fix and o...
1134
1135
  	/* correct the clock when NTP error is too big */
  	clocksource_adjust(clock, offset);
5eb6d2053   John Stultz   [PATCH] Time: Use...
1136

5eb6d2053   John Stultz   [PATCH] Time: Use...
1137
  	/* store full nanoseconds into xtime */
e154ff3d2   Roman Zippel   [PATCH] adjust cl...
1138
  	xtime.tv_nsec = (s64)clock->xtime_nsec >> clock->shift;
19923c190   Roman Zippel   [PATCH] fix and o...
1139
  	clock->xtime_nsec -= (s64)xtime.tv_nsec << clock->shift;
cf3c769b4   John Stultz   [PATCH] Time: Int...
1140
1141
  
  	/* check to see if there is a new clocksource to use */
5d8b34fdc   Thomas Gleixner   [PATCH] clocksour...
1142
  	change_clocksource();
acc9a9dcd   John Stultz   [PATCH] generic: ...
1143
  	update_vsyscall(&xtime, clock);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1144
1145
1146
1147
1148
1149
1150
1151
1152
1153
1154
1155
1156
1157
1158
1159
1160
1161
1162
1163
1164
1165
1166
1167
1168
1169
1170
1171
  }
  
  /*
   * Called from the timer interrupt handler to charge one tick to the current 
   * process.  user_tick is 1 if the tick is user time, 0 for system.
   */
  void update_process_times(int user_tick)
  {
  	struct task_struct *p = current;
  	int cpu = smp_processor_id();
  
  	/* Note: this timer irq context must be accounted for as well. */
  	if (user_tick)
  		account_user_time(p, jiffies_to_cputime(1));
  	else
  		account_system_time(p, HARDIRQ_OFFSET, jiffies_to_cputime(1));
  	run_local_timers();
  	if (rcu_pending(cpu))
  		rcu_check_callbacks(cpu, user_tick);
  	scheduler_tick();
   	run_posix_cpu_timers(p);
  }
  
  /*
   * Nr of active tasks - counted in fixed-point numbers
   */
  static unsigned long count_active_tasks(void)
  {
db1b1fefc   Jack Steiner   [PATCH] sched: re...
1172
  	return nr_active() * FIXED_1;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1173
1174
1175
1176
1177
1178
1179
1180
1181
1182
1183
1184
1185
1186
1187
1188
1189
1190
1191
1192
1193
1194
  }
  
  /*
   * Hmm.. Changed this, as the GNU make sources (load.c) seems to
   * imply that avenrun[] is the standard name for this kind of thing.
   * Nothing else seems to be standardized: the fractional size etc
   * all seem to differ on different machines.
   *
   * Requires xtime_lock to access.
   */
  unsigned long avenrun[3];
  
  EXPORT_SYMBOL(avenrun);
  
  /*
   * calc_load - given tick count, update the avenrun load estimates.
   * This is called while holding a write_lock on xtime_lock.
   */
  static inline void calc_load(unsigned long ticks)
  {
  	unsigned long active_tasks; /* fixed-point */
  	static int count = LOAD_FREQ;
cd7175edf   Eric Dumazet   [PATCH] Optimize ...
1195
1196
1197
1198
1199
1200
1201
1202
1203
  	count -= ticks;
  	if (unlikely(count < 0)) {
  		active_tasks = count_active_tasks();
  		do {
  			CALC_LOAD(avenrun[0], EXP_1, active_tasks);
  			CALC_LOAD(avenrun[1], EXP_5, active_tasks);
  			CALC_LOAD(avenrun[2], EXP_15, active_tasks);
  			count += LOAD_FREQ;
  		} while (count < 0);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1204
1205
  	}
  }
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1206
1207
1208
1209
  /*
   * This read-write spinlock protects us from races in SMP while
   * playing with xtime and avenrun.
   */
5809f9d44   Eric Dumazet   [PATCH] x86-64: g...
1210
  __attribute__((weak)) __cacheline_aligned_in_smp DEFINE_SEQLOCK(xtime_lock);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1211
1212
  
  EXPORT_SYMBOL(xtime_lock);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1213
1214
1215
1216
1217
1218
  
  /*
   * This function runs timers and the timer-tq in bottom half context.
   */
  static void run_timer_softirq(struct softirq_action *h)
  {
a4a6198b8   Jan Beulich   [PATCH] tvec_base...
1219
  	tvec_base_t *base = __get_cpu_var(tvec_bases);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1220

82f67cd9f   Ingo Molnar   [PATCH] Add debug...
1221
  	hrtimer_run_queues();
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1222
1223
1224
1225
1226
1227
1228
1229
1230
1231
  	if (time_after_eq(jiffies, base->timer_jiffies))
  		__run_timers(base);
  }
  
  /*
   * Called by the local, per-CPU timer interrupt on SMP.
   */
  void run_local_timers(void)
  {
  	raise_softirq(TIMER_SOFTIRQ);
6687a97d4   Ingo Molnar   [PATCH] timer-irq...
1232
  	softlockup_tick();
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1233
1234
1235
1236
1237
1238
  }
  
  /*
   * Called by the timer interrupt. xtime_lock must already be taken
   * by the timer IRQ!
   */
3171a0305   Atsushi Nemoto   [PATCH] simplify ...
1239
  static inline void update_times(unsigned long ticks)
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1240
  {
ad596171e   John Stultz   [PATCH] Time: Use...
1241
  	update_wall_time();
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1242
1243
1244
1245
1246
1247
1248
1249
  	calc_load(ticks);
  }
    
  /*
   * The 64-bit jiffies value is not atomic - you MUST NOT read it
   * without sampling the sequence number in xtime_lock.
   * jiffies is defined in the linker script...
   */
3171a0305   Atsushi Nemoto   [PATCH] simplify ...
1250
  void do_timer(unsigned long ticks)
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1251
  {
3171a0305   Atsushi Nemoto   [PATCH] simplify ...
1252
1253
  	jiffies_64 += ticks;
  	update_times(ticks);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1254
1255
1256
1257
1258
1259
1260
1261
1262
1263
  }
  
  #ifdef __ARCH_WANT_SYS_ALARM
  
  /*
   * For backwards compatibility?  This can be done in libc so Alpha
   * and all newer ports shouldn't need it.
   */
  asmlinkage unsigned long sys_alarm(unsigned int seconds)
  {
c08b8a491   Thomas Gleixner   [PATCH] sys_alarm...
1264
  	return alarm_setitimer(seconds);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1265
1266
1267
1268
1269
1270
1271
1272
1273
1274
1275
1276
1277
1278
1279
1280
1281
1282
1283
1284
1285
1286
1287
1288
1289
1290
  }
  
  #endif
  
  #ifndef __alpha__
  
  /*
   * The Alpha uses getxpid, getxuid, and getxgid instead.  Maybe this
   * should be moved into arch/i386 instead?
   */
  
  /**
   * sys_getpid - return the thread group id of the current process
   *
   * Note, despite the name, this returns the tgid not the pid.  The tgid and
   * the pid are identical unless CLONE_THREAD was specified on clone() in
   * which case the tgid is the same in all threads of the same group.
   *
   * This is SMP safe as current->tgid does not change.
   */
  asmlinkage long sys_getpid(void)
  {
  	return current->tgid;
  }
  
  /*
6997a6faa   Kirill Korotaev   [PATCH] sys_getpp...
1291
1292
1293
1294
   * Accessing ->real_parent is not SMP-safe, it could
   * change from under us. However, we can use a stale
   * value of ->real_parent under rcu_read_lock(), see
   * release_task()->call_rcu(delayed_put_task_struct).
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1295
1296
1297
1298
   */
  asmlinkage long sys_getppid(void)
  {
  	int pid;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1299

6997a6faa   Kirill Korotaev   [PATCH] sys_getpp...
1300
1301
1302
  	rcu_read_lock();
  	pid = rcu_dereference(current->real_parent)->tgid;
  	rcu_read_unlock();
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1303

1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1304
1305
1306
1307
1308
1309
1310
1311
1312
1313
1314
1315
1316
1317
1318
1319
1320
1321
1322
1323
1324
1325
1326
1327
1328
1329
1330
1331
1332
1333
1334
  	return pid;
  }
  
  asmlinkage long sys_getuid(void)
  {
  	/* Only we change this so SMP safe */
  	return current->uid;
  }
  
  asmlinkage long sys_geteuid(void)
  {
  	/* Only we change this so SMP safe */
  	return current->euid;
  }
  
  asmlinkage long sys_getgid(void)
  {
  	/* Only we change this so SMP safe */
  	return current->gid;
  }
  
  asmlinkage long sys_getegid(void)
  {
  	/* Only we change this so SMP safe */
  	return  current->egid;
  }
  
  #endif
  
  static void process_timeout(unsigned long __data)
  {
36c8b5868   Ingo Molnar   [PATCH] sched: cl...
1335
  	wake_up_process((struct task_struct *)__data);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1336
1337
1338
1339
1340
1341
1342
1343
1344
1345
1346
1347
1348
1349
1350
1351
1352
1353
1354
1355
1356
1357
1358
1359
1360
1361
1362
1363
1364
1365
1366
1367
1368
1369
1370
1371
1372
1373
1374
1375
1376
1377
1378
1379
1380
1381
1382
1383
1384
1385
1386
1387
1388
  }
  
  /**
   * schedule_timeout - sleep until timeout
   * @timeout: timeout value in jiffies
   *
   * Make the current task sleep until @timeout jiffies have
   * elapsed. The routine will return immediately unless
   * the current task state has been set (see set_current_state()).
   *
   * You can set the task state as follows -
   *
   * %TASK_UNINTERRUPTIBLE - at least @timeout jiffies are guaranteed to
   * pass before the routine returns. The routine will return 0
   *
   * %TASK_INTERRUPTIBLE - the routine may return early if a signal is
   * delivered to the current task. In this case the remaining time
   * in jiffies will be returned, or 0 if the timer expired in time
   *
   * The current task state is guaranteed to be TASK_RUNNING when this
   * routine returns.
   *
   * Specifying a @timeout value of %MAX_SCHEDULE_TIMEOUT will schedule
   * the CPU away without a bound on the timeout. In this case the return
   * value will be %MAX_SCHEDULE_TIMEOUT.
   *
   * In all cases the return value is guaranteed to be non-negative.
   */
  fastcall signed long __sched schedule_timeout(signed long timeout)
  {
  	struct timer_list timer;
  	unsigned long expire;
  
  	switch (timeout)
  	{
  	case MAX_SCHEDULE_TIMEOUT:
  		/*
  		 * These two special cases are useful to be comfortable
  		 * in the caller. Nothing more. We could take
  		 * MAX_SCHEDULE_TIMEOUT from one of the negative value
  		 * but I' d like to return a valid offset (>=0) to allow
  		 * the caller to do everything it want with the retval.
  		 */
  		schedule();
  		goto out;
  	default:
  		/*
  		 * Another bit of PARANOID. Note that the retval will be
  		 * 0 since no piece of kernel is supposed to do a check
  		 * for a negative retval of schedule_timeout() (since it
  		 * should never happens anyway). You just have the printk()
  		 * that will tell you if something is gone wrong and where.
  		 */
5b149bcc2   Andrew Morton   [PATCH] schedule_...
1389
  		if (timeout < 0) {
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1390
  			printk(KERN_ERR "schedule_timeout: wrong timeout "
5b149bcc2   Andrew Morton   [PATCH] schedule_...
1391
1392
1393
  				"value %lx
  ", timeout);
  			dump_stack();
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1394
1395
1396
1397
1398
1399
  			current->state = TASK_RUNNING;
  			goto out;
  		}
  	}
  
  	expire = timeout + jiffies;
a8db2db1e   Oleg Nesterov   [PATCH] introduce...
1400
1401
  	setup_timer(&timer, process_timeout, (unsigned long)current);
  	__mod_timer(&timer, expire);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1402
1403
1404
1405
1406
1407
1408
1409
  	schedule();
  	del_singleshot_timer_sync(&timer);
  
  	timeout = expire - jiffies;
  
   out:
  	return timeout < 0 ? 0 : timeout;
  }
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1410
  EXPORT_SYMBOL(schedule_timeout);
8a1c17574   Andrew Morton   [PATCH] schedule_...
1411
1412
1413
1414
  /*
   * We can use __set_current_state() here because schedule_timeout() calls
   * schedule() unconditionally.
   */
64ed93a26   Nishanth Aravamudan   [PATCH] add sched...
1415
1416
  signed long __sched schedule_timeout_interruptible(signed long timeout)
  {
a5a0d52c7   Andrew Morton   [PATCH] ntp white...
1417
1418
  	__set_current_state(TASK_INTERRUPTIBLE);
  	return schedule_timeout(timeout);
64ed93a26   Nishanth Aravamudan   [PATCH] add sched...
1419
1420
1421
1422
1423
  }
  EXPORT_SYMBOL(schedule_timeout_interruptible);
  
  signed long __sched schedule_timeout_uninterruptible(signed long timeout)
  {
a5a0d52c7   Andrew Morton   [PATCH] ntp white...
1424
1425
  	__set_current_state(TASK_UNINTERRUPTIBLE);
  	return schedule_timeout(timeout);
64ed93a26   Nishanth Aravamudan   [PATCH] add sched...
1426
1427
  }
  EXPORT_SYMBOL(schedule_timeout_uninterruptible);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1428
1429
1430
1431
1432
  /* Thread ID - the internal kernel "pid" */
  asmlinkage long sys_gettid(void)
  {
  	return current->pid;
  }
2aae4a108   Rolf Eike Beer   [PATCH] Fix kerne...
1433
  /**
d4d23add3   Kyle McMartin   [PATCH] Common co...
1434
   * do_sysinfo - fill in sysinfo struct
2aae4a108   Rolf Eike Beer   [PATCH] Fix kerne...
1435
   * @info: pointer to buffer to fill
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1436
   */ 
d4d23add3   Kyle McMartin   [PATCH] Common co...
1437
  int do_sysinfo(struct sysinfo *info)
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1438
  {
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1439
1440
1441
  	unsigned long mem_total, sav_total;
  	unsigned int mem_unit, bitcount;
  	unsigned long seq;
d4d23add3   Kyle McMartin   [PATCH] Common co...
1442
  	memset(info, 0, sizeof(struct sysinfo));
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1443
1444
1445
1446
1447
1448
1449
1450
1451
1452
1453
1454
1455
1456
1457
1458
1459
1460
1461
  
  	do {
  		struct timespec tp;
  		seq = read_seqbegin(&xtime_lock);
  
  		/*
  		 * This is annoying.  The below is the same thing
  		 * posix_get_clock_monotonic() does, but it wants to
  		 * take the lock which we want to cover the loads stuff
  		 * too.
  		 */
  
  		getnstimeofday(&tp);
  		tp.tv_sec += wall_to_monotonic.tv_sec;
  		tp.tv_nsec += wall_to_monotonic.tv_nsec;
  		if (tp.tv_nsec - NSEC_PER_SEC >= 0) {
  			tp.tv_nsec = tp.tv_nsec - NSEC_PER_SEC;
  			tp.tv_sec++;
  		}
d4d23add3   Kyle McMartin   [PATCH] Common co...
1462
  		info->uptime = tp.tv_sec + (tp.tv_nsec ? 1 : 0);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1463

d4d23add3   Kyle McMartin   [PATCH] Common co...
1464
1465
1466
  		info->loads[0] = avenrun[0] << (SI_LOAD_SHIFT - FSHIFT);
  		info->loads[1] = avenrun[1] << (SI_LOAD_SHIFT - FSHIFT);
  		info->loads[2] = avenrun[2] << (SI_LOAD_SHIFT - FSHIFT);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1467

d4d23add3   Kyle McMartin   [PATCH] Common co...
1468
  		info->procs = nr_threads;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1469
  	} while (read_seqretry(&xtime_lock, seq));
d4d23add3   Kyle McMartin   [PATCH] Common co...
1470
1471
  	si_meminfo(info);
  	si_swapinfo(info);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1472
1473
1474
1475
1476
1477
1478
1479
1480
  
  	/*
  	 * If the sum of all the available memory (i.e. ram + swap)
  	 * is less than can be stored in a 32 bit unsigned long then
  	 * we can be binary compatible with 2.2.x kernels.  If not,
  	 * well, in that case 2.2.x was broken anyways...
  	 *
  	 *  -Erik Andersen <andersee@debian.org>
  	 */
d4d23add3   Kyle McMartin   [PATCH] Common co...
1481
1482
  	mem_total = info->totalram + info->totalswap;
  	if (mem_total < info->totalram || mem_total < info->totalswap)
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1483
1484
  		goto out;
  	bitcount = 0;
d4d23add3   Kyle McMartin   [PATCH] Common co...
1485
  	mem_unit = info->mem_unit;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1486
1487
1488
1489
1490
1491
1492
1493
1494
1495
1496
  	while (mem_unit > 1) {
  		bitcount++;
  		mem_unit >>= 1;
  		sav_total = mem_total;
  		mem_total <<= 1;
  		if (mem_total < sav_total)
  			goto out;
  	}
  
  	/*
  	 * If mem_total did not overflow, multiply all memory values by
d4d23add3   Kyle McMartin   [PATCH] Common co...
1497
  	 * info->mem_unit and set it to 1.  This leaves things compatible
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1498
1499
1500
  	 * with 2.2.x, and also retains compatibility with earlier 2.4.x
  	 * kernels...
  	 */
d4d23add3   Kyle McMartin   [PATCH] Common co...
1501
1502
1503
1504
1505
1506
1507
1508
1509
1510
1511
1512
1513
1514
1515
1516
1517
1518
1519
  	info->mem_unit = 1;
  	info->totalram <<= bitcount;
  	info->freeram <<= bitcount;
  	info->sharedram <<= bitcount;
  	info->bufferram <<= bitcount;
  	info->totalswap <<= bitcount;
  	info->freeswap <<= bitcount;
  	info->totalhigh <<= bitcount;
  	info->freehigh <<= bitcount;
  
  out:
  	return 0;
  }
  
  asmlinkage long sys_sysinfo(struct sysinfo __user *info)
  {
  	struct sysinfo val;
  
  	do_sysinfo(&val);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1520

1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1521
1522
1523
1524
1525
  	if (copy_to_user(info, &val, sizeof(struct sysinfo)))
  		return -EFAULT;
  
  	return 0;
  }
d730e882a   Ingo Molnar   [PATCH] lockdep: ...
1526
1527
1528
1529
1530
1531
  /*
   * lockdep: we want to track each per-CPU base as a separate lock-class,
   * but timer-bases are kmalloc()-ed, so we need to attach separate
   * keys to them:
   */
  static struct lock_class_key base_lock_keys[NR_CPUS];
a4a6198b8   Jan Beulich   [PATCH] tvec_base...
1532
  static int __devinit init_timers_cpu(int cpu)
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1533
1534
1535
  {
  	int j;
  	tvec_base_t *base;
ba6edfcd1   Andrew Morton   [PATCH] timer ini...
1536
  	static char __devinitdata tvec_base_done[NR_CPUS];
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
1537

ba6edfcd1   Andrew Morton   [PATCH] timer ini...
1538
  	if (!tvec_base_done[cpu]) {
a4a6198b8   Jan Beulich   [PATCH] tvec_base...
1539
  		static char boot_done;
a4a6198b8   Jan Beulich   [PATCH] tvec_base...
1540
  		if (boot_done) {
ba6edfcd1   Andrew Morton   [PATCH] timer ini...
1541
1542
1543
  			/*
  			 * The APs use this path later in boot
  			 */
a4a6198b8   Jan Beulich   [PATCH] tvec_base...
1544
1545
1546
1547
1548
  			base = kmalloc_node(sizeof(*base), GFP_KERNEL,
  						cpu_to_node(cpu));
  			if (!base)
  				return -ENOMEM;
  			memset(base, 0, sizeof(*base));
ba6edfcd1   Andrew Morton   [PATCH] timer ini...
1549
  			per_cpu(tvec_bases, cpu) = base;
a4a6198b8   Jan Beulich   [PATCH] tvec_base...
1550
  		} else {
ba6edfcd1   Andrew Morton   [PATCH] timer ini...
1551
1552
1553
1554
1555
1556
  			/*
  			 * This is for the boot CPU - we use compile-time
  			 * static initialisation because per-cpu memory isn't
  			 * ready yet and because the memory allocators are not
  			 * initialised either.
  			 */
a4a6198b8   Jan Beulich   [PATCH] tvec_base...
1557
  			boot_done = 1;
ba6edfcd1   Andrew Morton   [PATCH] timer ini...
1558
  			base = &boot_tvec_bases;
a4a6198b8   Jan Beulich   [PATCH] tvec_base...
1559
  		}
ba6edfcd1   Andrew Morton   [PATCH] timer ini...
1560
1561
1562
  		tvec_base_done[cpu] = 1;
  	} else {
  		base = per_cpu(tvec_bases, cpu);
a4a6198b8   Jan Beulich   [PATCH] tvec_base...
1563
  	}
ba6edfcd1   Andrew Morton   [PATCH] timer ini...
1564

3691c5199   Oleg Nesterov   [PATCH] kill __in...
1565
  	spin_lock_init(&base->lock);
d730e882a   Ingo Molnar   [PATCH] lockdep: ...
1566
  	lockdep_set_class(&base->lock, base_lock_keys + cpu);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1567
1568
1569
1570
1571
1572
1573
1574
1575
1576
  	for (j = 0; j < TVN_SIZE; j++) {
  		INIT_LIST_HEAD(base->tv5.vec + j);
  		INIT_LIST_HEAD(base->tv4.vec + j);
  		INIT_LIST_HEAD(base->tv3.vec + j);
  		INIT_LIST_HEAD(base->tv2.vec + j);
  	}
  	for (j = 0; j < TVR_SIZE; j++)
  		INIT_LIST_HEAD(base->tv1.vec + j);
  
  	base->timer_jiffies = jiffies;
a4a6198b8   Jan Beulich   [PATCH] tvec_base...
1577
  	return 0;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1578
1579
1580
  }
  
  #ifdef CONFIG_HOTPLUG_CPU
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
1581
  static void migrate_timer_list(tvec_base_t *new_base, struct list_head *head)
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1582
1583
1584
1585
1586
  {
  	struct timer_list *timer;
  
  	while (!list_empty(head)) {
  		timer = list_entry(head->next, struct timer_list, entry);
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
1587
  		detach_timer(timer, 0);
3691c5199   Oleg Nesterov   [PATCH] kill __in...
1588
  		timer->base = new_base;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1589
  		internal_add_timer(new_base, timer);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1590
  	}
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1591
1592
1593
1594
1595
1596
1597
1598
1599
  }
  
  static void __devinit migrate_timers(int cpu)
  {
  	tvec_base_t *old_base;
  	tvec_base_t *new_base;
  	int i;
  
  	BUG_ON(cpu_online(cpu));
a4a6198b8   Jan Beulich   [PATCH] tvec_base...
1600
1601
  	old_base = per_cpu(tvec_bases, cpu);
  	new_base = get_cpu_var(tvec_bases);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1602
1603
  
  	local_irq_disable();
3691c5199   Oleg Nesterov   [PATCH] kill __in...
1604
1605
1606
1607
  	spin_lock(&new_base->lock);
  	spin_lock(&old_base->lock);
  
  	BUG_ON(old_base->running_timer);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1608

1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1609
  	for (i = 0; i < TVR_SIZE; i++)
55c888d6d   Oleg Nesterov   [PATCH] timers fi...
1610
1611
1612
1613
1614
1615
1616
  		migrate_timer_list(new_base, old_base->tv1.vec + i);
  	for (i = 0; i < TVN_SIZE; i++) {
  		migrate_timer_list(new_base, old_base->tv2.vec + i);
  		migrate_timer_list(new_base, old_base->tv3.vec + i);
  		migrate_timer_list(new_base, old_base->tv4.vec + i);
  		migrate_timer_list(new_base, old_base->tv5.vec + i);
  	}
3691c5199   Oleg Nesterov   [PATCH] kill __in...
1617
1618
  	spin_unlock(&old_base->lock);
  	spin_unlock(&new_base->lock);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1619
1620
  	local_irq_enable();
  	put_cpu_var(tvec_bases);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1621
1622
  }
  #endif /* CONFIG_HOTPLUG_CPU */
8c78f3075   Chandra Seetharaman   [PATCH] cpu hotpl...
1623
  static int __cpuinit timer_cpu_notify(struct notifier_block *self,
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1624
1625
1626
1627
1628
  				unsigned long action, void *hcpu)
  {
  	long cpu = (long)hcpu;
  	switch(action) {
  	case CPU_UP_PREPARE:
a4a6198b8   Jan Beulich   [PATCH] tvec_base...
1629
1630
  		if (init_timers_cpu(cpu) < 0)
  			return NOTIFY_BAD;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1631
1632
1633
1634
1635
1636
1637
1638
1639
1640
1641
  		break;
  #ifdef CONFIG_HOTPLUG_CPU
  	case CPU_DEAD:
  		migrate_timers(cpu);
  		break;
  #endif
  	default:
  		break;
  	}
  	return NOTIFY_OK;
  }
8c78f3075   Chandra Seetharaman   [PATCH] cpu hotpl...
1642
  static struct notifier_block __cpuinitdata timers_nb = {
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1643
1644
1645
1646
1647
1648
  	.notifier_call	= timer_cpu_notify,
  };
  
  
  void __init init_timers(void)
  {
07dccf334   Akinobu Mita   [PATCH] check ret...
1649
  	int err = timer_cpu_notify(&timers_nb, (unsigned long)CPU_UP_PREPARE,
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1650
  				(void *)(long)smp_processor_id());
07dccf334   Akinobu Mita   [PATCH] check ret...
1651

82f67cd9f   Ingo Molnar   [PATCH] Add debug...
1652
  	init_timer_stats();
07dccf334   Akinobu Mita   [PATCH] check ret...
1653
  	BUG_ON(err == NOTIFY_BAD);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1654
1655
1656
1657
1658
  	register_cpu_notifier(&timers_nb);
  	open_softirq(TIMER_SOFTIRQ, run_timer_softirq, NULL);
  }
  
  #ifdef CONFIG_TIME_INTERPOLATION
67890d708   Christoph Lameter   [PATCH] time_inte...
1659
1660
  struct time_interpolator *time_interpolator __read_mostly;
  static struct time_interpolator *time_interpolator_list __read_mostly;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1661
  static DEFINE_SPINLOCK(time_interpolator_lock);
3db5db4fc   Helge Deller   [PATCH] use cycle...
1662
  static inline cycles_t time_interpolator_get_cycles(unsigned int src)
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1663
1664
1665
1666
1667
1668
1669
1670
1671
1672
  {
  	unsigned long (*x)(void);
  
  	switch (src)
  	{
  		case TIME_SOURCE_FUNCTION:
  			x = time_interpolator->addr;
  			return x();
  
  		case TIME_SOURCE_MMIO64	:
685db65e4   Christoph Lameter   [PATCH] time_inte...
1673
  			return readq_relaxed((void __iomem *)time_interpolator->addr);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1674
1675
  
  		case TIME_SOURCE_MMIO32	:
685db65e4   Christoph Lameter   [PATCH] time_inte...
1676
  			return readl_relaxed((void __iomem *)time_interpolator->addr);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1677
1678
1679
1680
  
  		default: return get_cycles();
  	}
  }
486d46aef   Alex Williamson   [PATCH] optimize ...
1681
  static inline u64 time_interpolator_get_counter(int writelock)
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1682
1683
1684
1685
1686
  {
  	unsigned int src = time_interpolator->source;
  
  	if (time_interpolator->jitter)
  	{
3db5db4fc   Helge Deller   [PATCH] use cycle...
1687
1688
  		cycles_t lcycle;
  		cycles_t now;
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1689
1690
1691
1692
1693
1694
  
  		do {
  			lcycle = time_interpolator->last_cycle;
  			now = time_interpolator_get_cycles(src);
  			if (lcycle && time_after(lcycle, now))
  				return lcycle;
486d46aef   Alex Williamson   [PATCH] optimize ...
1695
1696
1697
1698
1699
1700
1701
1702
1703
  
  			/* When holding the xtime write lock, there's no need
  			 * to add the overhead of the cmpxchg.  Readers are
  			 * force to retry until the write lock is released.
  			 */
  			if (writelock) {
  				time_interpolator->last_cycle = now;
  				return now;
  			}
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1704
1705
1706
1707
1708
1709
1710
1711
1712
1713
1714
1715
1716
  			/* Keep track of the last timer value returned. The use of cmpxchg here
  			 * will cause contention in an SMP environment.
  			 */
  		} while (unlikely(cmpxchg(&time_interpolator->last_cycle, lcycle, now) != lcycle));
  		return now;
  	}
  	else
  		return time_interpolator_get_cycles(src);
  }
  
  void time_interpolator_reset(void)
  {
  	time_interpolator->offset = 0;
486d46aef   Alex Williamson   [PATCH] optimize ...
1717
  	time_interpolator->last_counter = time_interpolator_get_counter(1);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1718
1719
1720
1721
1722
1723
1724
1725
1726
1727
1728
  }
  
  #define GET_TI_NSECS(count,i) (((((count) - i->last_counter) & (i)->mask) * (i)->nsec_per_cyc) >> (i)->shift)
  
  unsigned long time_interpolator_get_offset(void)
  {
  	/* If we do not have a time interpolator set up then just return zero */
  	if (!time_interpolator)
  		return 0;
  
  	return time_interpolator->offset +
486d46aef   Alex Williamson   [PATCH] optimize ...
1729
  		GET_TI_NSECS(time_interpolator_get_counter(0), time_interpolator);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1730
1731
1732
1733
  }
  
  #define INTERPOLATOR_ADJUST 65536
  #define INTERPOLATOR_MAX_SKIP 10*INTERPOLATOR_ADJUST
4c7ee8de9   John Stultz   [PATCH] NTP: Move...
1734
  void time_interpolator_update(long delta_nsec)
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1735
1736
1737
1738
1739
1740
1741
  {
  	u64 counter;
  	unsigned long offset;
  
  	/* If there is no time interpolator set up then do nothing */
  	if (!time_interpolator)
  		return;
a5a0d52c7   Andrew Morton   [PATCH] ntp white...
1742
1743
1744
1745
1746
1747
1748
1749
  	/*
  	 * The interpolator compensates for late ticks by accumulating the late
  	 * time in time_interpolator->offset. A tick earlier than expected will
  	 * lead to a reset of the offset and a corresponding jump of the clock
  	 * forward. Again this only works if the interpolator clock is running
  	 * slightly slower than the regular clock and the tuning logic insures
  	 * that.
  	 */
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1750

486d46aef   Alex Williamson   [PATCH] optimize ...
1751
  	counter = time_interpolator_get_counter(1);
a5a0d52c7   Andrew Morton   [PATCH] ntp white...
1752
1753
  	offset = time_interpolator->offset +
  			GET_TI_NSECS(counter, time_interpolator);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1754
1755
1756
1757
1758
1759
1760
1761
1762
1763
1764
1765
1766
1767
1768
1769
  
  	if (delta_nsec < 0 || (unsigned long) delta_nsec < offset)
  		time_interpolator->offset = offset - delta_nsec;
  	else {
  		time_interpolator->skips++;
  		time_interpolator->ns_skipped += delta_nsec - offset;
  		time_interpolator->offset = 0;
  	}
  	time_interpolator->last_counter = counter;
  
  	/* Tuning logic for time interpolator invoked every minute or so.
  	 * Decrease interpolator clock speed if no skips occurred and an offset is carried.
  	 * Increase interpolator clock speed if we skip too much time.
  	 */
  	if (jiffies % INTERPOLATOR_ADJUST == 0)
  	{
b20367a6c   Jordan Hargrave   [PATCH] x86_64: F...
1770
  		if (time_interpolator->skips == 0 && time_interpolator->offset > tick_nsec)
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1771
1772
1773
1774
1775
1776
1777
1778
1779
1780
1781
1782
1783
1784
1785
1786
1787
1788
1789
1790
1791
1792
1793
  			time_interpolator->nsec_per_cyc--;
  		if (time_interpolator->ns_skipped > INTERPOLATOR_MAX_SKIP && time_interpolator->offset == 0)
  			time_interpolator->nsec_per_cyc++;
  		time_interpolator->skips = 0;
  		time_interpolator->ns_skipped = 0;
  	}
  }
  
  static inline int
  is_better_time_interpolator(struct time_interpolator *new)
  {
  	if (!time_interpolator)
  		return 1;
  	return new->frequency > 2*time_interpolator->frequency ||
  	    (unsigned long)new->drift < (unsigned long)time_interpolator->drift;
  }
  
  void
  register_time_interpolator(struct time_interpolator *ti)
  {
  	unsigned long flags;
  
  	/* Sanity check */
9f31252cb   Eric Sesterhenn   BUG_ON() Conversi...
1794
  	BUG_ON(ti->frequency == 0 || ti->mask == 0);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1795
1796
1797
1798
1799
1800
1801
1802
1803
1804
1805
1806
1807
1808
1809
1810
1811
1812
1813
1814
1815
1816
1817
1818
1819
1820
1821
1822
1823
1824
1825
1826
1827
1828
1829
1830
1831
1832
1833
1834
1835
1836
1837
1838
1839
1840
1841
1842
1843
1844
1845
1846
1847
  
  	ti->nsec_per_cyc = ((u64)NSEC_PER_SEC << ti->shift) / ti->frequency;
  	spin_lock(&time_interpolator_lock);
  	write_seqlock_irqsave(&xtime_lock, flags);
  	if (is_better_time_interpolator(ti)) {
  		time_interpolator = ti;
  		time_interpolator_reset();
  	}
  	write_sequnlock_irqrestore(&xtime_lock, flags);
  
  	ti->next = time_interpolator_list;
  	time_interpolator_list = ti;
  	spin_unlock(&time_interpolator_lock);
  }
  
  void
  unregister_time_interpolator(struct time_interpolator *ti)
  {
  	struct time_interpolator *curr, **prev;
  	unsigned long flags;
  
  	spin_lock(&time_interpolator_lock);
  	prev = &time_interpolator_list;
  	for (curr = *prev; curr; curr = curr->next) {
  		if (curr == ti) {
  			*prev = curr->next;
  			break;
  		}
  		prev = &curr->next;
  	}
  
  	write_seqlock_irqsave(&xtime_lock, flags);
  	if (ti == time_interpolator) {
  		/* we lost the best time-interpolator: */
  		time_interpolator = NULL;
  		/* find the next-best interpolator */
  		for (curr = time_interpolator_list; curr; curr = curr->next)
  			if (is_better_time_interpolator(curr))
  				time_interpolator = curr;
  		time_interpolator_reset();
  	}
  	write_sequnlock_irqrestore(&xtime_lock, flags);
  	spin_unlock(&time_interpolator_lock);
  }
  #endif /* CONFIG_TIME_INTERPOLATION */
  
  /**
   * msleep - sleep safely even with waitqueue interruptions
   * @msecs: Time in milliseconds to sleep for
   */
  void msleep(unsigned int msecs)
  {
  	unsigned long timeout = msecs_to_jiffies(msecs) + 1;
75bcc8c5e   Nishanth Aravamudan   [PATCH] kernel: f...
1848
1849
  	while (timeout)
  		timeout = schedule_timeout_uninterruptible(timeout);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1850
1851
1852
1853
1854
  }
  
  EXPORT_SYMBOL(msleep);
  
  /**
96ec3efdc   Domen Puncer   [PATCH] kernel/ti...
1855
   * msleep_interruptible - sleep waiting for signals
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1856
1857
1858
1859
1860
   * @msecs: Time in milliseconds to sleep for
   */
  unsigned long msleep_interruptible(unsigned int msecs)
  {
  	unsigned long timeout = msecs_to_jiffies(msecs) + 1;
75bcc8c5e   Nishanth Aravamudan   [PATCH] kernel: f...
1861
1862
  	while (timeout && !signal_pending(current))
  		timeout = schedule_timeout_interruptible(timeout);
1da177e4c   Linus Torvalds   Linux-2.6.12-rc2
1863
1864
1865
1866
  	return jiffies_to_msecs(timeout);
  }
  
  EXPORT_SYMBOL(msleep_interruptible);