139,13 → 139,13 |
int local_scheduler_level = 0; |
|
switch (contract->policy) { |
case FSF_POSIX: |
case FSF_RR: |
local_scheduler_level = POSIXSTAR_register_level(fsf_server_level,5000,32); |
break; |
case FSF_EDF: |
local_scheduler_level = EDFSTAR_register_level(fsf_server_level); |
break; |
case FSF_RM: |
case FSF_FP: |
local_scheduler_level = RMSTAR_register_level(fsf_server_level); |
break; |
case FSF_NONE: |
511,7 → 511,7 |
|
local_scheduler_level = SERVER_get_local_scheduler_level_from_budget(fsf_server_level,server); |
if (local_scheduler_level==-1) |
return FSF_ERR_UNKNOWN_APPSCHEDULED_THREAD; |
return FSF_ERR_UNKNOWN_SCHEDULED_THREAD; |
|
scheduler_id = SERVER_get_local_scheduler_id_from_budget(fsf_server_level,server); |
|
521,7 → 521,7 |
/* Check if thread is already bind */ |
switch(scheduler_id) { |
|
case FSF_RM: |
case FSF_FP: |
{ |
TASK_MODEL *m=(TASK_MODEL*)(sched_params->params); |
HARD_TASK_MODEL *h=(HARD_TASK_MODEL *)(sched_params->params); |
565,7 → 565,7 |
} |
break; |
|
case FSF_POSIX: |
case FSF_RR: |
{ |
TASK_MODEL *m=(TASK_MODEL*)(sched_params->params); |
|
628,7 → 628,7 |
|
local_scheduler_level = SERVER_get_local_scheduler_level_from_budget(fsf_server_level,server); |
if (local_scheduler_level==-1) |
return FSF_ERR_UNKNOWN_APPSCHEDULED_THREAD; |
return FSF_ERR_UNKNOWN_SCHEDULED_THREAD; |
|
scheduler_id = SERVER_get_local_scheduler_id_from_budget(fsf_server_level,server); |
|
690,7 → 690,7 |
|
/* Check if thread is already bind */ |
switch (scheduler_id) { |
case FSF_POSIX: |
case FSF_RR: |
|
nrt_task_def_arg(*(NRT_TASK_MODEL *)(local_scheduler_arg->params),arg); |
nrt_task_def_level(*(NRT_TASK_MODEL *)(local_scheduler_arg->params),local_scheduler_level); |
719,7 → 719,7 |
|
break; |
|
case FSF_RM: |
case FSF_FP: |
|
hard_task_def_arg(*(HARD_TASK_MODEL *)(local_scheduler_arg->params),arg); |
hard_task_def_level(*(HARD_TASK_MODEL *)(local_scheduler_arg->params),local_scheduler_level); |
786,7 → 786,7 |
scheduler_id = SERVER_get_local_scheduler_id_from_pid(fsf_server_level, thread); |
|
switch (scheduler_id) { |
case FSF_POSIX: |
case FSF_RR: |
POSIXSTAR_set_nopreemtive_current(local_scheduler_level); |
return 1; |
break; |
794,7 → 794,7 |
EDFSTAR_set_nopreemtive_current(local_scheduler_level); |
return 1; |
break; |
case FSF_RM: |
case FSF_FP: |
RMSTAR_set_nopreemtive_current(local_scheduler_level); |
return 1; |
break; |
817,7 → 817,7 |
scheduler_id = SERVER_get_local_scheduler_id_from_pid(fsf_server_level, thread); |
|
switch (scheduler_id) { |
case FSF_POSIX: |
case FSF_RR: |
POSIXSTAR_unset_nopreemtive_current(local_scheduler_level); |
return 1; |
break; |
825,7 → 825,7 |
EDFSTAR_unset_nopreemtive_current(local_scheduler_level); |
return 1; |
break; |
case FSF_RM: |
case FSF_FP: |
RMSTAR_unset_nopreemtive_current(local_scheduler_level); |
return 1; |
break; |
850,13 → 850,13 |
scheduler_id = SERVER_get_local_scheduler_id_from_pid(fsf_server_level, thread); |
|
switch (scheduler_id) { |
case FSF_POSIX: |
case FSF_RR: |
*server = POSIXSTAR_getbudget(local_scheduler_level,thread); |
return 0; |
case FSF_EDF: |
*server = EDFSTAR_getbudget(local_scheduler_level,thread); |
return 0; |
case FSF_RM: |
case FSF_FP: |
*server = RMSTAR_getbudget(local_scheduler_level,thread); |
return 0; |
case FSF_NONE: |
898,7 → 898,7 |
scheduler_id = SERVER_get_local_scheduler_id_from_budget(fsf_server_level,server); |
|
switch (scheduler_id) { |
case FSF_POSIX: |
case FSF_RR: |
|
/* Check if some thread use the server */ |
if(POSIXSTAR_budget_has_thread(local_scheduler_level,server)) |
911,7 → 911,7 |
return FSF_ERR_NOT_CONTRACTED_SERVER; |
break; |
|
case FSF_RM: |
case FSF_FP: |
/* Check if some thread use the server */ |
if(RMSTAR_budget_has_thread(local_scheduler_level,server)) |
return FSF_ERR_NOT_CONTRACTED_SERVER; |