aboutsummaryrefslogtreecommitdiffstats
path: root/kernel
diff options
context:
space:
mode:
authorPaul Mackerras <paulus@samba.org>2005-10-27 23:38:53 -0400
committerPaul Mackerras <paulus@samba.org>2005-10-27 23:38:53 -0400
commit4542437679de448de0f75bc901dab380d6a5bc5b (patch)
tree1a436c9b6f9459c3938e2bb1ab7ad2c888d0003c /kernel
parent2227718ca2f7d5fcc2741c1bbca4d0c2efd340ce (diff)
parent741b2252a5e14d6c60a913c77a6099abe73a854a (diff)
Merge in v2.6.14 by hand
Diffstat (limited to 'kernel')
-rw-r--r--kernel/posix-cpu-timers.c94
-rw-r--r--kernel/sched.c1
2 files changed, 53 insertions, 42 deletions
diff --git a/kernel/posix-cpu-timers.c b/kernel/posix-cpu-timers.c
index 7a51a5597c33..bf374fceb39c 100644
--- a/kernel/posix-cpu-timers.c
+++ b/kernel/posix-cpu-timers.c
@@ -91,7 +91,7 @@ static inline union cpu_time_count cpu_time_sub(clockid_t which_clock,
91 * Update expiry time from increment, and increase overrun count, 91 * Update expiry time from increment, and increase overrun count,
92 * given the current clock sample. 92 * given the current clock sample.
93 */ 93 */
94static inline void bump_cpu_timer(struct k_itimer *timer, 94static void bump_cpu_timer(struct k_itimer *timer,
95 union cpu_time_count now) 95 union cpu_time_count now)
96{ 96{
97 int i; 97 int i;
@@ -110,7 +110,7 @@ static inline void bump_cpu_timer(struct k_itimer *timer,
110 for (i = 0; incr < delta - incr; i++) 110 for (i = 0; incr < delta - incr; i++)
111 incr = incr << 1; 111 incr = incr << 1;
112 for (; i >= 0; incr >>= 1, i--) { 112 for (; i >= 0; incr >>= 1, i--) {
113 if (delta <= incr) 113 if (delta < incr)
114 continue; 114 continue;
115 timer->it.cpu.expires.sched += incr; 115 timer->it.cpu.expires.sched += incr;
116 timer->it_overrun += 1 << i; 116 timer->it_overrun += 1 << i;
@@ -128,7 +128,7 @@ static inline void bump_cpu_timer(struct k_itimer *timer,
128 for (i = 0; cputime_lt(incr, cputime_sub(delta, incr)); i++) 128 for (i = 0; cputime_lt(incr, cputime_sub(delta, incr)); i++)
129 incr = cputime_add(incr, incr); 129 incr = cputime_add(incr, incr);
130 for (; i >= 0; incr = cputime_halve(incr), i--) { 130 for (; i >= 0; incr = cputime_halve(incr), i--) {
131 if (cputime_le(delta, incr)) 131 if (cputime_lt(delta, incr))
132 continue; 132 continue;
133 timer->it.cpu.expires.cpu = 133 timer->it.cpu.expires.cpu =
134 cputime_add(timer->it.cpu.expires.cpu, incr); 134 cputime_add(timer->it.cpu.expires.cpu, incr);
@@ -380,14 +380,9 @@ int posix_cpu_timer_create(struct k_itimer *new_timer)
380int posix_cpu_timer_del(struct k_itimer *timer) 380int posix_cpu_timer_del(struct k_itimer *timer)
381{ 381{
382 struct task_struct *p = timer->it.cpu.task; 382 struct task_struct *p = timer->it.cpu.task;
383 int ret = 0;
383 384
384 if (timer->it.cpu.firing) 385 if (likely(p != NULL)) {
385 return TIMER_RETRY;
386
387 if (unlikely(p == NULL))
388 return 0;
389
390 if (!list_empty(&timer->it.cpu.entry)) {
391 read_lock(&tasklist_lock); 386 read_lock(&tasklist_lock);
392 if (unlikely(p->signal == NULL)) { 387 if (unlikely(p->signal == NULL)) {
393 /* 388 /*
@@ -396,18 +391,20 @@ int posix_cpu_timer_del(struct k_itimer *timer)
396 */ 391 */
397 BUG_ON(!list_empty(&timer->it.cpu.entry)); 392 BUG_ON(!list_empty(&timer->it.cpu.entry));
398 } else { 393 } else {
399 /*
400 * Take us off the task's timer list.
401 */
402 spin_lock(&p->sighand->siglock); 394 spin_lock(&p->sighand->siglock);
403 list_del(&timer->it.cpu.entry); 395 if (timer->it.cpu.firing)
396 ret = TIMER_RETRY;
397 else
398 list_del(&timer->it.cpu.entry);
404 spin_unlock(&p->sighand->siglock); 399 spin_unlock(&p->sighand->siglock);
405 } 400 }
406 read_unlock(&tasklist_lock); 401 read_unlock(&tasklist_lock);
402
403 if (!ret)
404 put_task_struct(p);
407 } 405 }
408 put_task_struct(p);
409 406
410 return 0; 407 return ret;
411} 408}
412 409
413/* 410/*
@@ -424,8 +421,6 @@ static void cleanup_timers(struct list_head *head,
424 cputime_t ptime = cputime_add(utime, stime); 421 cputime_t ptime = cputime_add(utime, stime);
425 422
426 list_for_each_entry_safe(timer, next, head, entry) { 423 list_for_each_entry_safe(timer, next, head, entry) {
427 put_task_struct(timer->task);
428 timer->task = NULL;
429 list_del_init(&timer->entry); 424 list_del_init(&timer->entry);
430 if (cputime_lt(timer->expires.cpu, ptime)) { 425 if (cputime_lt(timer->expires.cpu, ptime)) {
431 timer->expires.cpu = cputime_zero; 426 timer->expires.cpu = cputime_zero;
@@ -437,8 +432,6 @@ static void cleanup_timers(struct list_head *head,
437 432
438 ++head; 433 ++head;
439 list_for_each_entry_safe(timer, next, head, entry) { 434 list_for_each_entry_safe(timer, next, head, entry) {
440 put_task_struct(timer->task);
441 timer->task = NULL;
442 list_del_init(&timer->entry); 435 list_del_init(&timer->entry);
443 if (cputime_lt(timer->expires.cpu, utime)) { 436 if (cputime_lt(timer->expires.cpu, utime)) {
444 timer->expires.cpu = cputime_zero; 437 timer->expires.cpu = cputime_zero;
@@ -450,8 +443,6 @@ static void cleanup_timers(struct list_head *head,
450 443
451 ++head; 444 ++head;
452 list_for_each_entry_safe(timer, next, head, entry) { 445 list_for_each_entry_safe(timer, next, head, entry) {
453 put_task_struct(timer->task);
454 timer->task = NULL;
455 list_del_init(&timer->entry); 446 list_del_init(&timer->entry);
456 if (timer->expires.sched < sched_time) { 447 if (timer->expires.sched < sched_time) {
457 timer->expires.sched = 0; 448 timer->expires.sched = 0;
@@ -495,6 +486,9 @@ static void process_timer_rebalance(struct task_struct *p,
495 struct task_struct *t = p; 486 struct task_struct *t = p;
496 unsigned int nthreads = atomic_read(&p->signal->live); 487 unsigned int nthreads = atomic_read(&p->signal->live);
497 488
489 if (!nthreads)
490 return;
491
498 switch (clock_idx) { 492 switch (clock_idx) {
499 default: 493 default:
500 BUG(); 494 BUG();
@@ -503,7 +497,7 @@ static void process_timer_rebalance(struct task_struct *p,
503 left = cputime_div(cputime_sub(expires.cpu, val.cpu), 497 left = cputime_div(cputime_sub(expires.cpu, val.cpu),
504 nthreads); 498 nthreads);
505 do { 499 do {
506 if (!unlikely(t->exit_state)) { 500 if (!unlikely(t->flags & PF_EXITING)) {
507 ticks = cputime_add(prof_ticks(t), left); 501 ticks = cputime_add(prof_ticks(t), left);
508 if (cputime_eq(t->it_prof_expires, 502 if (cputime_eq(t->it_prof_expires,
509 cputime_zero) || 503 cputime_zero) ||
@@ -518,7 +512,7 @@ static void process_timer_rebalance(struct task_struct *p,
518 left = cputime_div(cputime_sub(expires.cpu, val.cpu), 512 left = cputime_div(cputime_sub(expires.cpu, val.cpu),
519 nthreads); 513 nthreads);
520 do { 514 do {
521 if (!unlikely(t->exit_state)) { 515 if (!unlikely(t->flags & PF_EXITING)) {
522 ticks = cputime_add(virt_ticks(t), left); 516 ticks = cputime_add(virt_ticks(t), left);
523 if (cputime_eq(t->it_virt_expires, 517 if (cputime_eq(t->it_virt_expires,
524 cputime_zero) || 518 cputime_zero) ||
@@ -533,7 +527,7 @@ static void process_timer_rebalance(struct task_struct *p,
533 nsleft = expires.sched - val.sched; 527 nsleft = expires.sched - val.sched;
534 do_div(nsleft, nthreads); 528 do_div(nsleft, nthreads);
535 do { 529 do {
536 if (!unlikely(t->exit_state)) { 530 if (!unlikely(t->flags & PF_EXITING)) {
537 ns = t->sched_time + nsleft; 531 ns = t->sched_time + nsleft;
538 if (t->it_sched_expires == 0 || 532 if (t->it_sched_expires == 0 ||
539 t->it_sched_expires > ns) { 533 t->it_sched_expires > ns) {
@@ -572,6 +566,9 @@ static void arm_timer(struct k_itimer *timer, union cpu_time_count now)
572 struct cpu_timer_list *next; 566 struct cpu_timer_list *next;
573 unsigned long i; 567 unsigned long i;
574 568
569 if (CPUCLOCK_PERTHREAD(timer->it_clock) && (p->flags & PF_EXITING))
570 return;
571
575 head = (CPUCLOCK_PERTHREAD(timer->it_clock) ? 572 head = (CPUCLOCK_PERTHREAD(timer->it_clock) ?
576 p->cpu_timers : p->signal->cpu_timers); 573 p->cpu_timers : p->signal->cpu_timers);
577 head += CPUCLOCK_WHICH(timer->it_clock); 574 head += CPUCLOCK_WHICH(timer->it_clock);
@@ -582,17 +579,15 @@ static void arm_timer(struct k_itimer *timer, union cpu_time_count now)
582 listpos = head; 579 listpos = head;
583 if (CPUCLOCK_WHICH(timer->it_clock) == CPUCLOCK_SCHED) { 580 if (CPUCLOCK_WHICH(timer->it_clock) == CPUCLOCK_SCHED) {
584 list_for_each_entry(next, head, entry) { 581 list_for_each_entry(next, head, entry) {
585 if (next->expires.sched > nt->expires.sched) { 582 if (next->expires.sched > nt->expires.sched)
586 listpos = &next->entry;
587 break; 583 break;
588 } 584 listpos = &next->entry;
589 } 585 }
590 } else { 586 } else {
591 list_for_each_entry(next, head, entry) { 587 list_for_each_entry(next, head, entry) {
592 if (cputime_gt(next->expires.cpu, nt->expires.cpu)) { 588 if (cputime_gt(next->expires.cpu, nt->expires.cpu))
593 listpos = &next->entry;
594 break; 589 break;
595 } 590 listpos = &next->entry;
596 } 591 }
597 } 592 }
598 list_add(&nt->entry, listpos); 593 list_add(&nt->entry, listpos);
@@ -736,9 +731,15 @@ int posix_cpu_timer_set(struct k_itimer *timer, int flags,
736 * Disarm any old timer after extracting its expiry time. 731 * Disarm any old timer after extracting its expiry time.
737 */ 732 */
738 BUG_ON(!irqs_disabled()); 733 BUG_ON(!irqs_disabled());
734
735 ret = 0;
739 spin_lock(&p->sighand->siglock); 736 spin_lock(&p->sighand->siglock);
740 old_expires = timer->it.cpu.expires; 737 old_expires = timer->it.cpu.expires;
741 list_del_init(&timer->it.cpu.entry); 738 if (unlikely(timer->it.cpu.firing)) {
739 timer->it.cpu.firing = -1;
740 ret = TIMER_RETRY;
741 } else
742 list_del_init(&timer->it.cpu.entry);
742 spin_unlock(&p->sighand->siglock); 743 spin_unlock(&p->sighand->siglock);
743 744
744 /* 745 /*
@@ -786,7 +787,7 @@ int posix_cpu_timer_set(struct k_itimer *timer, int flags,
786 } 787 }
787 } 788 }
788 789
789 if (unlikely(timer->it.cpu.firing)) { 790 if (unlikely(ret)) {
790 /* 791 /*
791 * We are colliding with the timer actually firing. 792 * We are colliding with the timer actually firing.
792 * Punt after filling in the timer's old value, and 793 * Punt after filling in the timer's old value, and
@@ -794,8 +795,6 @@ int posix_cpu_timer_set(struct k_itimer *timer, int flags,
794 * it as an overrun (thanks to bump_cpu_timer above). 795 * it as an overrun (thanks to bump_cpu_timer above).
795 */ 796 */
796 read_unlock(&tasklist_lock); 797 read_unlock(&tasklist_lock);
797 timer->it.cpu.firing = -1;
798 ret = TIMER_RETRY;
799 goto out; 798 goto out;
800 } 799 }
801 800
@@ -961,14 +960,16 @@ void posix_cpu_timer_get(struct k_itimer *timer, struct itimerspec *itp)
961static void check_thread_timers(struct task_struct *tsk, 960static void check_thread_timers(struct task_struct *tsk,
962 struct list_head *firing) 961 struct list_head *firing)
963{ 962{
963 int maxfire;
964 struct list_head *timers = tsk->cpu_timers; 964 struct list_head *timers = tsk->cpu_timers;
965 965
966 maxfire = 20;
966 tsk->it_prof_expires = cputime_zero; 967 tsk->it_prof_expires = cputime_zero;
967 while (!list_empty(timers)) { 968 while (!list_empty(timers)) {
968 struct cpu_timer_list *t = list_entry(timers->next, 969 struct cpu_timer_list *t = list_entry(timers->next,
969 struct cpu_timer_list, 970 struct cpu_timer_list,
970 entry); 971 entry);
971 if (cputime_lt(prof_ticks(tsk), t->expires.cpu)) { 972 if (!--maxfire || cputime_lt(prof_ticks(tsk), t->expires.cpu)) {
972 tsk->it_prof_expires = t->expires.cpu; 973 tsk->it_prof_expires = t->expires.cpu;
973 break; 974 break;
974 } 975 }
@@ -977,12 +978,13 @@ static void check_thread_timers(struct task_struct *tsk,
977 } 978 }
978 979
979 ++timers; 980 ++timers;
981 maxfire = 20;
980 tsk->it_virt_expires = cputime_zero; 982 tsk->it_virt_expires = cputime_zero;
981 while (!list_empty(timers)) { 983 while (!list_empty(timers)) {
982 struct cpu_timer_list *t = list_entry(timers->next, 984 struct cpu_timer_list *t = list_entry(timers->next,
983 struct cpu_timer_list, 985 struct cpu_timer_list,
984 entry); 986 entry);
985 if (cputime_lt(virt_ticks(tsk), t->expires.cpu)) { 987 if (!--maxfire || cputime_lt(virt_ticks(tsk), t->expires.cpu)) {
986 tsk->it_virt_expires = t->expires.cpu; 988 tsk->it_virt_expires = t->expires.cpu;
987 break; 989 break;
988 } 990 }
@@ -991,12 +993,13 @@ static void check_thread_timers(struct task_struct *tsk,
991 } 993 }
992 994
993 ++timers; 995 ++timers;
996 maxfire = 20;
994 tsk->it_sched_expires = 0; 997 tsk->it_sched_expires = 0;
995 while (!list_empty(timers)) { 998 while (!list_empty(timers)) {
996 struct cpu_timer_list *t = list_entry(timers->next, 999 struct cpu_timer_list *t = list_entry(timers->next,
997 struct cpu_timer_list, 1000 struct cpu_timer_list,
998 entry); 1001 entry);
999 if (tsk->sched_time < t->expires.sched) { 1002 if (!--maxfire || tsk->sched_time < t->expires.sched) {
1000 tsk->it_sched_expires = t->expires.sched; 1003 tsk->it_sched_expires = t->expires.sched;
1001 break; 1004 break;
1002 } 1005 }
@@ -1013,6 +1016,7 @@ static void check_thread_timers(struct task_struct *tsk,
1013static void check_process_timers(struct task_struct *tsk, 1016static void check_process_timers(struct task_struct *tsk,
1014 struct list_head *firing) 1017 struct list_head *firing)
1015{ 1018{
1019 int maxfire;
1016 struct signal_struct *const sig = tsk->signal; 1020 struct signal_struct *const sig = tsk->signal;
1017 cputime_t utime, stime, ptime, virt_expires, prof_expires; 1021 cputime_t utime, stime, ptime, virt_expires, prof_expires;
1018 unsigned long long sched_time, sched_expires; 1022 unsigned long long sched_time, sched_expires;
@@ -1045,12 +1049,13 @@ static void check_process_timers(struct task_struct *tsk,
1045 } while (t != tsk); 1049 } while (t != tsk);
1046 ptime = cputime_add(utime, stime); 1050 ptime = cputime_add(utime, stime);
1047 1051
1052 maxfire = 20;
1048 prof_expires = cputime_zero; 1053 prof_expires = cputime_zero;
1049 while (!list_empty(timers)) { 1054 while (!list_empty(timers)) {
1050 struct cpu_timer_list *t = list_entry(timers->next, 1055 struct cpu_timer_list *t = list_entry(timers->next,
1051 struct cpu_timer_list, 1056 struct cpu_timer_list,
1052 entry); 1057 entry);
1053 if (cputime_lt(ptime, t->expires.cpu)) { 1058 if (!--maxfire || cputime_lt(ptime, t->expires.cpu)) {
1054 prof_expires = t->expires.cpu; 1059 prof_expires = t->expires.cpu;
1055 break; 1060 break;
1056 } 1061 }
@@ -1059,12 +1064,13 @@ static void check_process_timers(struct task_struct *tsk,
1059 } 1064 }
1060 1065
1061 ++timers; 1066 ++timers;
1067 maxfire = 20;
1062 virt_expires = cputime_zero; 1068 virt_expires = cputime_zero;
1063 while (!list_empty(timers)) { 1069 while (!list_empty(timers)) {
1064 struct cpu_timer_list *t = list_entry(timers->next, 1070 struct cpu_timer_list *t = list_entry(timers->next,
1065 struct cpu_timer_list, 1071 struct cpu_timer_list,
1066 entry); 1072 entry);
1067 if (cputime_lt(utime, t->expires.cpu)) { 1073 if (!--maxfire || cputime_lt(utime, t->expires.cpu)) {
1068 virt_expires = t->expires.cpu; 1074 virt_expires = t->expires.cpu;
1069 break; 1075 break;
1070 } 1076 }
@@ -1073,12 +1079,13 @@ static void check_process_timers(struct task_struct *tsk,
1073 } 1079 }
1074 1080
1075 ++timers; 1081 ++timers;
1082 maxfire = 20;
1076 sched_expires = 0; 1083 sched_expires = 0;
1077 while (!list_empty(timers)) { 1084 while (!list_empty(timers)) {
1078 struct cpu_timer_list *t = list_entry(timers->next, 1085 struct cpu_timer_list *t = list_entry(timers->next,
1079 struct cpu_timer_list, 1086 struct cpu_timer_list,
1080 entry); 1087 entry);
1081 if (sched_time < t->expires.sched) { 1088 if (!--maxfire || sched_time < t->expires.sched) {
1082 sched_expires = t->expires.sched; 1089 sched_expires = t->expires.sched;
1083 break; 1090 break;
1084 } 1091 }
@@ -1161,6 +1168,9 @@ static void check_process_timers(struct task_struct *tsk,
1161 unsigned long long sched_left, sched; 1168 unsigned long long sched_left, sched;
1162 const unsigned int nthreads = atomic_read(&sig->live); 1169 const unsigned int nthreads = atomic_read(&sig->live);
1163 1170
1171 if (!nthreads)
1172 return;
1173
1164 prof_left = cputime_sub(prof_expires, utime); 1174 prof_left = cputime_sub(prof_expires, utime);
1165 prof_left = cputime_sub(prof_left, stime); 1175 prof_left = cputime_sub(prof_left, stime);
1166 prof_left = cputime_div(prof_left, nthreads); 1176 prof_left = cputime_div(prof_left, nthreads);
@@ -1197,7 +1207,7 @@ static void check_process_timers(struct task_struct *tsk,
1197 1207
1198 do { 1208 do {
1199 t = next_thread(t); 1209 t = next_thread(t);
1200 } while (unlikely(t->exit_state)); 1210 } while (unlikely(t->flags & PF_EXITING));
1201 } while (t != tsk); 1211 } while (t != tsk);
1202 } 1212 }
1203} 1213}
diff --git a/kernel/sched.c b/kernel/sched.c
index 1f31a528fdba..1e5cafdf4e27 100644
--- a/kernel/sched.c
+++ b/kernel/sched.c
@@ -3879,6 +3879,7 @@ EXPORT_SYMBOL(cpu_present_map);
3879 3879
3880#ifndef CONFIG_SMP 3880#ifndef CONFIG_SMP
3881cpumask_t cpu_online_map = CPU_MASK_ALL; 3881cpumask_t cpu_online_map = CPU_MASK_ALL;
3882EXPORT_SYMBOL_GPL(cpu_online_map);
3882cpumask_t cpu_possible_map = CPU_MASK_ALL; 3883cpumask_t cpu_possible_map = CPU_MASK_ALL;
3883#endif 3884#endif
3884 3885