i2p/haiku-beta6
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

scheduler, kernel/util: Fix style issues

Browse Source
This commit is contained in:
Pawel Dziepak
2013-11-29 04:51:38 +01:00
parent 1987bf19b5
commit 7f8cf14b71
3 changed files with 10 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files
headers/private/kernel/util/MinMaxHeap.h
+2 -2
View File
@@ -198,7 +198,7 @@ MIN_MAX_HEAP_CLASS_NAME::PeekMinimum()
ASSERT(fMaxLastElement == 1); ASSERT(fMaxLastElement == 1);
return fMaxElements[0]; return fMaxElements[0];
} }
return NULL; return NULL;
} }
@@ -213,7 +213,7 @@ MIN_MAX_HEAP_CLASS_NAME::PeekMaximum()
ASSERT(fMinLastElement == 1); ASSERT(fMinLastElement == 1);
return fMinElements[0]; return fMinElements[0];
} }
return NULL; return NULL;
} }
src/system/kernel/scheduler/RunQueue.h
+1 -1
View File
@@ -156,7 +156,7 @@ RUN_QUEUE_CLASS_NAME::ConstIterator::Next()
fNext = link->fNext; fNext = link->fNext;
if (fNext == NULL) if (fNext == NULL)
_FindNextPriority(); _FindNextPriority();
return current; return current;
} }
src/system/kernel/scheduler/scheduler.cpp
+7 -7
View File
@@ -830,7 +830,7 @@ reschedule_event(timer* /* unused */)
} }
static inline bool static inline bool
quantum_ended(Thread* thread, bool wasPreempted, bool hasYielded) quantum_ended(Thread* thread, bool wasPreempted, bool hasYielded)
{ {
scheduler_thread_data* schedulerThreadData = thread->scheduler_data; scheduler_thread_data* schedulerThreadData = thread->scheduler_data;
@@ -902,7 +902,7 @@ compute_quantum(Thread* thread)
== gCPUToCore[smp_get_current_cpu()]); == gCPUToCore[smp_get_current_cpu()]);
CoreEntry* core = &gCoreEntries[schedulerThreadData->previous_core]; CoreEntry* core = &gCoreEntries[schedulerThreadData->previous_core];
int32 threadCount = (core->fThreadCount + 1) / core->fCPUCount; int32 threadCount = (core->fThreadCount + 1) / core->fCPUCount;
if (threadCount > 1) { if (threadCount > 1) {
quantum = max_c(min_c(kMaximumLatency / threadCount, quantum), quantum = max_c(min_c(kMaximumLatency / threadCount, quantum),
kThreadQuantum / 3); kThreadQuantum / 3);
} }
@@ -1252,7 +1252,7 @@ reschedule(void)
nextThread->scheduler_data->last_interrupt_time nextThread->scheduler_data->last_interrupt_time
= gCPU[thisCPU].interrupt_time; = gCPU[thisCPU].interrupt_time;
if (!thread_is_idle_thread(nextThread)) if (!thread_is_idle_thread(nextThread))
update_cpu_performance(nextThread, thisCore); update_cpu_performance(nextThread, thisCore);
if (nextThread != oldThread || oldThread->cpu->preempted) { if (nextThread != oldThread || oldThread->cpu->preempted) {
@@ -1311,7 +1311,7 @@ scheduler_on_thread_init(Thread* thread)
thread->scheduler_data->Init(); thread->scheduler_data->Init();
if (thread_is_idle_thread(thread)) { if (thread_is_idle_thread(thread)) {
static int32 gIdleThreadsID; static int32 sIdleThreadsID;
int32 cpu = atomic_add(&gIdleThreadsID, 1); int32 cpu = atomic_add(&gIdleThreadsID, 1);
thread->previous_cpu = &gCPU[cpu]; thread->previous_cpu = &gCPU[cpu];
@@ -1344,7 +1344,7 @@ scheduler_start(void)
static inline void static inline void
acquire_big_scheduler_lock(void) acquire_big_scheduler_lock(void)
{ {
for (int32_t i = 0; i < smp_get_num_cpus(); i++) for (int32 i = 0; i < smp_get_num_cpus(); i++)
acquire_write_spinlock(&gCPUEntries[i].fSchedulerModeLock); acquire_write_spinlock(&gCPUEntries[i].fSchedulerModeLock);
} }
@@ -1352,7 +1352,7 @@ acquire_big_scheduler_lock(void)
static inline void static inline void
release_big_scheduler_lock(void) release_big_scheduler_lock(void)
{ {
for (int32_t i = 0; i < smp_get_num_cpus(); i++) for (int32 i = 0; i < smp_get_num_cpus(); i++)
release_write_spinlock(&gCPUEntries[i].fSchedulerModeLock); release_write_spinlock(&gCPUEntries[i].fSchedulerModeLock);
} }
@@ -1471,7 +1471,7 @@ scheduler_set_cpu_enabled(int32 cpu, bool enabled)
package->fIdleCores.Add(core); package->fIdleCores.Add(core);
if (package->fCoreCount == 1) if (package->fCoreCount == 1)
gIdlePackageList->Add(package); gIdlePackageList->Add(package);
} }
if (enabled) { if (enabled) {