d/freebsd-nq
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Lots of whitespace cleanup.

Browse Source 
Fix for broken if condition.

Submitted by:	nate@
This commit is contained in:
Stephan Uphoff 2005-06-09 19:43:08 +00:00
parent 038164a116
commit a3f2d84279
2 changed files with 13 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
sys/kern/kern_switch.c
View File

@ -428,7 +428,6 @@ maybe_preempt_in_ksegrp(struct thread *td)
return;
#if defined(IPI_PREEMPTION) && defined(PREEMPTION)
#if !defined(FULL_PREEMPTION)
if (td->td_priority <= PRI_MAX_ITHD)
#endif /* ! FULL_PREEMPTION */
@ -676,10 +675,12 @@ maybe_preempt(struct thread *td)
TD_IS_INHIBITED(ctd) || td->td_kse->ke_state != KES_THREAD)
return (0);
#ifndef FULL_PREEMPTION
if ((pri > PRI_MAX_ITHD) &&
!(cpri >= PRI_MIN_IDLE))
if (pri > PRI_MAX_ITHD)
return (0);
#endif
if (cpri >= PRI_MIN_IDLE)
return (0);
if (ctd->td_critnest > 1) {
CTR1(KTR_PROC, "maybe_preempt: in critical section %d",
ctd->td_critnest);

19
sys/kern/sched_4bsd.c
View File

@ -1084,9 +1084,7 @@ forward_wakeup(int cpunum)
#endif
#ifdef SMP
static void
kick_other_cpu(int pri,int cpuid);
static void kick_other_cpu(int pri,int cpuid);
static void
kick_other_cpu(int pri,int cpuid)
@ -1104,7 +1102,6 @@ kick_other_cpu(int pri,int cpuid)
return;
#if defined(IPI_PREEMPTION) && defined(PREEMPTION)
#if !defined(FULL_PREEMPTION)
if (pri <= PRI_MAX_ITHD)
#endif /* ! FULL_PREEMPTION */
@ -1118,14 +1115,12 @@ kick_other_cpu(int pri,int cpuid)
ipi_selected( pcpu->pc_cpumask , IPI_AST);
return;
}
#endif /* SMP */
void
sched_add(struct thread *td, int flags)
#ifdef SMP
{
struct kse *ke;
int forwarded = 0;
int cpu;
@ -1163,7 +1158,7 @@ sched_add(struct thread *td, int flags)
ke->ke_runq = &runq;
}
if ((single_cpu) && (cpu != PCPU_GET(cpuid))) {
if (single_cpu && (cpu != PCPU_GET(cpuid))) {
kick_other_cpu(td->td_priority,cpu);
} else {
@ -1174,11 +1169,10 @@ sched_add(struct thread *td, int flags)
if (!idle && ((flags & SRQ_INTR) == 0) &&
(idle_cpus_mask & ~(hlt_cpus_mask | me)))
forwarded = forward_wakeup(cpu);
}
if (!forwarded) {
if (((flags & SRQ_YIELDING) == 0) && maybe_preempt(td))
if ((flags & SRQ_YIELDING) == 0 && maybe_preempt(td))
return;
else
maybe_resched(td);
@ -1191,10 +1185,7 @@ sched_add(struct thread *td, int flags)
runq_add(ke->ke_runq, ke, flags);
ke->ke_state = KES_ONRUNQ;
}
#else /* SMP */
{
struct kse *ke;
ke = td->td_kse;
@ -1207,8 +1198,6 @@ sched_add(struct thread *td, int flags)
CTR5(KTR_SCHED, "sched_add: %p(%s) prio %d by %p(%s)",
td, td->td_proc->p_comm, td->td_priority, curthread,
curthread->td_proc->p_comm);
CTR2(KTR_RUNQ, "sched_add: adding kse:%p (td:%p) to runq", ke, td);
ke->ke_runq = &runq;
@ -1234,10 +1223,8 @@ sched_add(struct thread *td, int flags)
ke->ke_state = KES_ONRUNQ;
maybe_resched(td);
}
#endif /* SMP */
void
sched_rem(struct thread *td)
{