Subversion Repositories shark

Compare Revisions

Ignore whitespace Rev 951 → Rev 952

/shark/trunk/ports/first/first-server.c
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;