Rev 1625 |
Blame |
Compare with Previous |
Last modification |
View Log
| RSS feed
/*
* 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 TEST_PERIOD 50000
mutex_t mux
;
void program_key_end
(KEY_EVT
*k
)
{
exit(1);
}
void print_timer
(int x
, int y
)
{
long nsec
,sec
,min
,hrs
,day
;
struct timespec actual_timer
;
char tmp
[100];
sys_gettime
(&actual_timer
);
nsec
= actual_timer.
tv_nsec;
sec
= actual_timer.
tv_sec;
min
= sec
/ 60;
sec
%= 60;
hrs
= min
/ 60;
min
%= 60;
day
= hrs
/ 24;
hrs
%= 24;
sprintf(tmp
,"Time: %2ld d %2ld h %2ld m %2ld s %12ld ns",day
,hrs
,min
,sec
,(long)nsec
);
//mutex_lock(&mux);
grx_text
(tmp
,x
,y
,rgb16
(255,255,255),0);
//mutex_unlock(&mux);
}
#define LOAD_VARIATION 10
#define MAX_V_QOS 30
#define MIN_V_QOS 2
void *test_task_variable
(void *arg
) {
char tmp
[100];
long long i
;
int task_qos
;
int var_load
, rd_per
;
TIME exectime
;
task_qos
= 7;
var_load
= 5;
rd_per
= 0;
while(1) {
print_timer
(307,10+30*exec_shadow
);
sprintf(tmp
,"Test Thread V QOS = %5d PID = %3d VLOAD = %3d",task_qos
,exec_shadow
,var_load
);
//mutex_lock(&mux);
grx_text
(tmp
,307,20+30*exec_shadow
,rgb16
(255,255,255),0);
//mutex_unlock(&mux);
jet_gettable
(exec_shadow
, &exectime
, 1);
sprintf(tmp
,"Thread Exec Timer = %10d us",(int)exectime
);
grx_text
(tmp
,307,30+30*exec_shadow
,rgb16
(255,255,255),0);
if (rd_per
> LOAD_VARIATION
) {
var_load
+= rand()%3-1;
if (var_load
> 20) var_load
= 20;
if (var_load
< 0) var_load
= 0;
rd_per
= 0;
} else {
rd_per
++;
}
for(i
= 0; i
< 10000*(task_qos
+var_load
); i
++);
}
return NULL
;
}
#define MAX_C_QOS 30
#define MIN_C_QOS 2
void *test_task_constant
(void *arg
) {
char tmp
[100];
long long i
;
int task_qos
;
task_qos
= 7;
while(1) {
print_timer
(307,10+20*exec_shadow
);
sprintf(tmp
,"Test Task C QOS = %5d PID = %3d",task_qos
,exec_shadow
);
//mutex_lock(&mux);
grx_text
(tmp
,307,20+20*exec_shadow
,rgb16
(255,255,255),0);
//mutex_unlock(&mux);
for(i
= 0; i
< 10000*task_qos
; i
++);
}
return NULL
;
}
void draw_box
(int x1
, int y1
, int x2
, int y2
)
{
grx_rect
(x1
,y1
,x2
,y2
,rgb16
(160,160,160));
grx_rect
(x1
+2,y1
+2,x2
-2,y2
-2,rgb16
(210,210,210));
}
void layout_screen
()
{
draw_box
(0,0,300,500);
grx_text
("Application Task List",5,5,rgb16
(255,255,255),0);
draw_box
(303,0,799,500);
grx_text
("Task Output",305,5,rgb16
(255,255,255),0);
draw_box
(0,503,799,599);
grx_line
(140,505,140,597,rgb16
(255,255,255));
grx_line
(140,583,797,583,rgb16
(255,255,255));
grx_text
("Application Statistics",142,507,rgb16
(255,255,255),0);
}
void program_end
()
{
grx_close
();
}
void *mpeg2decoder
(void *arg
);
void add_posixstar_thread
(fsf_server_id_t server
)
{
NRT_TASK_MODEL nrt
;
pthread_t j
= -1;
nrt_task_default_model
(nrt
);
fsf_create_thread
(server
, &j
, NULL
, test_task_variable
, NULL
, &nrt
);
}
void add_edfstar_thread
(fsf_server_id_t server
)
{
pthread_t j
= -1;
HARD_TASK_MODEL ht
;
hard_task_default_model
(ht
);
hard_task_def_mit
(ht
,100000);
hard_task_def_wcet
(ht
,90000);
fsf_create_thread
(server
, &j
, NULL
, mpeg2decoder
, NULL
, &ht
);
}
int main
(int argc
, char **argv
)
{
char ch
;
int err
;
KEY_EVT k
;
PI_mutexattr_t a
;
struct timespec period1
= {0,10000000};
struct timespec period2
= {0,10000000};
struct timespec budget1
= {0,4000000};
struct timespec budget2
= {0,4000000};
fsf_server_id_t server1
, server2
;
fsf_contract_parameters_t contract1
, contract2
;
sys_atrunlevel
(program_end
, NULL
, RUNLEVEL_BEFORE_EXIT
);
k.
flag = ALTL_BIT
;
k.
scan = KEY_C
;
k.
ascii = 'c';
keyb_hook
(k
,program_key_end
);
srand(sys_gettime
(NULL
));
// graphic card Initialization
if (grx_init
() < 1) {
exit(1);
}
if (grx_open
(800, 600, 16) < 0) {
cprintf
("GRX Err\n");
exit(1);
}
layout_screen
();
PI_mutexattr_default
(a
);
mutex_init
(&mux
,&a
);
fsf_initialize_contract
(&contract1
);
fsf_set_contract_basic_parameters
(&contract1
,&budget1
,&period1
,NULL
,NULL
,FSF_DEFAULT_WORKLOAD
);
fsf_initialize_contract
(&contract2
);
fsf_set_contract_basic_parameters
(&contract2
,&budget2
,&period2
,NULL
,NULL
,FSF_DEFAULT_WORKLOAD
);
fsf_set_local_scheduler_parameter
(&contract2
, FSF_SCHEDULER_EDF
);
err
= fsf_negotiate_contract
(&contract1
,&server1
);
if (err
) cprintf
("(FSF ERROR %d)",err
);
err
= fsf_negotiate_contract
(&contract2
,&server2
);
if (err
) cprintf
("(FSF ERROR %d)",err
);
ch
= keyb_getch
(BLOCK
);
while(ch
!= ESC
) {
switch (ch
) {
case '1':
add_posixstar_thread
(server1
);
break;
case '2':
add_edfstar_thread
(server2
);
break;
case '3':
break;
case '4':
break;
case '5':
break;
}
ch
= keyb_getch
(BLOCK
);
}
exit(1);
return 0;
}