Mirrors/libhermit
1
0
Fork 0
mirror of https://github.com/hermitcore/libhermit.git synced 2025-03-09 00:00:03 +01:00
Code Issues Releases Wiki Activity

revise get_next_core to return always a valid core

Browse source
This commit is contained in:
Stefan Lankes 2016-08-26 07:01:25 +02:00
parent 5a0d265e1a
commit 2e361e129f
1 changed files with 13 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
hermit/kernel/tasks.c
View file

@ -45,6 +45,7 @@
*/
extern const void tls_start;
extern const void tls_end;
extern atomic_int32_t cpu_online;
#define TLS_OFFSET 8
@ -317,14 +318,18 @@ uint32_t get_next_core_id(void)
if (core_id >= MAX_CORES)
core_id = CORE_ID;
// we assume OpenMP applications
// => number of threads is (normaly) equal to the number of cores
// => search next available core
for(i=0, core_id=(core_id+1)%MAX_CORES; i<MAX_CORES; i++, core_id=(core_id+1)%MAX_CORES)
for(i=0, core_id=(core_id+1)%MAX_CORES; i<2*MAX_CORES; i++, core_id=(core_id+1)%MAX_CORES)
if (readyqueues[core_id].idle)
break;
if (BUILDTIN_EXPECT(!readyqueues[core_id].idle), 0) {
kprintf("BUG: no core available!\n");
return MAX_CORES;
}
return core_id;
}
@ -359,8 +364,12 @@ int clone_task(tid_t* id, entry_point_t ep, void* arg, uint8_t prio)
spinlock_irqsave_lock(&table_lock);
core_id = get_next_core_id();
if ((core_id >= MAX_CORES) || !readyqueues[core_id].idle)
core_id = CORE_ID;
if (BUILTIN_EXPECT(core_id >= MAX_CORES, 0))
{
spinlock_irqsave_unlock(&table_lock);
ret = -EINVAL;
goto out;
}
for(i=0; i<MAX_TASKS; i++) {
if (task_table[i].status == TASK_INVALID) {