0,0 → 1,148 |
/* |
* Project: S.Ha.R.K. |
* |
* Coordinators: |
* Giorgio Buttazzo <giorgio@sssup.it> |
* Paolo Gai <pj@gandalf.sssup.it> |
* |
* Authors : |
* Giacomo Guidi <giacomo@gandalf.sssup.it> |
* |
* ReTiS Lab (Scuola Superiore S.Anna - Pisa - Italy) |
* |
* http://www.sssup.it |
* http://retis.sssup.it |
* http://shark.sssup.it |
*/ |
|
/* |
* Copyright (C) 2000 Paolo Gai |
* |
* This program is free software; you can redistribute it and/or modify |
* it under the terms of the GNU General Public License as published by |
* the Free Software Foundation; either version 2 of the License, or |
* (at your option) any later version. |
* |
* This program is distributed in the hope that it will be useful, |
* but WITHOUT ANY WARRANTY; without even the implied warranty of |
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the |
* GNU General Public License for more details. |
* |
* You should have received a copy of the GNU General Public License |
* along with this program; if not, write to the Free Software |
* Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA |
*/ |
|
#include "kernel/kern.h" |
|
#include "fsf_contract.h" |
|
#include "stdlib.h" |
#include "unistd.h" |
#include "string.h" |
|
#include "pthread.h" |
|
#include "drivers/keyb.h" |
#include "drivers/glib.h" |
|
#define SERVER_I_PERIOD 40000 |
#define SERVER_I_BUDGET 10000 |
#define SERVER_P_PERIOD 40000 |
#define SERVER_P_BUDGET 10000 |
#define SERVER_B_PERIOD 40000 |
#define SERVER_B_BUDGET 1000 |
|
struct timespec server_I_period = {0,SERVER_I_PERIOD*1000}; |
struct timespec server_I_budget = {0,SERVER_I_BUDGET*1000}; |
struct timespec server_P_period = {0,SERVER_P_PERIOD*1000}; |
struct timespec server_P_budget = {0,SERVER_P_BUDGET*1000}; |
struct timespec server_B_period = {0,SERVER_B_PERIOD*1000}; |
struct timespec server_B_budget = {0,SERVER_B_BUDGET*1000}; |
|
fsf_server_id_t server_I, server_P, server_B; |
fsf_contract_parameters_t contract_I, contract_P, contract_B; |
|
pthread_t pI,pP,pB; |
|
TASK decoder(void *arg) |
{ |
|
int i; |
|
cprintf("Decoder Start %d\n",exec_shadow); |
|
for (i=0;i<100000;i++); |
|
cprintf("Decoder End %d\n",exec_shadow); |
|
task_endcycle(); |
|
return NULL; |
|
} |
|
int init_mpeg_server() { |
|
int err; |
HARD_TASK_MODEL ht; |
|
fsf_initialize_contract(&contract_I); |
fsf_set_contract_basic_parameters(&contract_I,&server_I_budget,&server_I_period,NULL,NULL,FSF_DEFAULT_WORKLOAD); |
fsf_set_local_scheduler_parameter(&contract_I, FSF_SCHEDULER_MPEG); |
|
fsf_initialize_contract(&contract_P); |
fsf_set_contract_basic_parameters(&contract_P,&server_P_budget,&server_P_period,NULL,NULL,FSF_DEFAULT_WORKLOAD); |
fsf_set_local_scheduler_parameter(&contract_P, FSF_SCHEDULER_MPEG); |
|
fsf_initialize_contract(&contract_B); |
fsf_set_contract_basic_parameters(&contract_B,&server_B_budget,&server_B_period,NULL,NULL,FSF_DEFAULT_WORKLOAD); |
fsf_set_local_scheduler_parameter(&contract_B, FSF_SCHEDULER_MPEG); |
|
err = fsf_negotiate_contract(&contract_I,&server_I); |
if (err) cprintf("(FSF ERROR %d)",err); |
err = fsf_negotiate_contract(&contract_P,&server_P); |
if (err) cprintf("(FSF ERROR %d)",err); |
err = fsf_negotiate_contract(&contract_B,&server_B); |
if (err) cprintf("(FSF ERROR %d)",err); |
|
hard_task_default_model(ht); |
|
fsf_create_thread(server_I, &pI, NULL, decoder, NULL, &ht); |
cprintf("Server I %d\n",pI); |
|
fsf_create_thread(server_P, &pP, NULL, decoder, NULL, &ht); |
cprintf("Server P %d\n",pP); |
|
fsf_create_thread(server_B, &pB, NULL, decoder, NULL, &ht); |
cprintf("Server B %d\n",pB); |
|
return 0; |
|
} |
|
int main () { |
|
init_mpeg_server(); |
TIME T,Q; |
|
T = 40000; |
Q = 10000; |
MPEGSTAR_rescale(server_I,Q,T); |
task_activate(pI); |
|
T = 80000; |
Q = 10000; |
MPEGSTAR_rescale(server_P,Q,T); |
task_activate(pP); |
|
T = 120000; |
Q = 1000; |
MPEGSTAR_rescale(server_B,Q,T); |
task_activate(pB); |
|
while(1); |
|
return 0; |
|
} |