Subversion Repositories shark

Rev

Rev 1544 | 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.h"
#include "fsf_server.h"

#include "stdlib.h"
#include "unistd.h"
#include "string.h"
#include "pistar.h"

#include "pthread.h"

#include "drivers/glib.h"

#include <tracer.h>

#include "FTrace_udp.h"
#include "FTrace_chunk.h"

#include <drivers/shark_keyb26.h>

#define TEST_PERIOD 50000

mutex_t mux;
int main_chunk;

TASK finish_task() {
   
  #ifdef __NEW_TRACER__
 group_kill(1);
  group_kill(2);
         
  FTrace_OSD_init_udp(1,"192.168.82.43","192.168.82.41");

  FTrace_send_chunk(main_chunk, 0, FTRACE_CHUNK_FLAG_FREE | FTRACE_CHUNK_FLAG_CYC);

  sys_end();

  #else
                                                                                                     
  sys_end();

  #endif

  return NULL;
                                                                                                                             
}

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) {

  struct timespec next_time;
  bool was_deadline_missed = false, was_budget_overran = false;

  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);
      if (!was_deadline_missed)
        grx_text(tmp,307,20+30*exec_shadow,rgb16(255,255,255),0);
      else
        grx_text(tmp,307,20+30*exec_shadow,rgb16(255,0,0),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) {

  struct timespec next_time;
  bool was_deadline_missed = false, was_budget_overran = false;

  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);
      if (!was_deadline_missed)
        grx_text(tmp,307,20+20*exec_shadow,rgb16(255,255,255),0);
      else
        grx_text(tmp,307,20+20*exec_shadow,rgb16(255,0,0),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)
{

  int err;
  pthread_t j = -1;
  static fsf_sched_params_t pr;
  NRT_TASK_MODEL nrt;

  pr.policy=FSF_POSIX;
  pr.params=&nrt;
 
  nrt_task_default_model(nrt);
  nrt_task_def_save_arrivals(nrt);
  nrt_task_def_group(nrt,1);

  err = pthread_create(&j, NULL, test_task_variable, NULL);
  if (err) {
    perror("Could not create task...");
    sys_end();
  }

  err=fsf_bind_local_thread_to_server(server, j, (fsf_sched_params_t *)(&pr));
  if (err) {
    grx_close();
    kern_printf("Could not bind task.. %d", err);
    sys_end();
   
  }


}

void add_edfstar_thread(fsf_server_id_t server)
{

  int err;
  pthread_t j = -1;
  HARD_TASK_MODEL ht;
  static fsf_sched_params_t pr;
 

  pr.policy=FSF_EDF;
  pr.params=&ht;
 

  hard_task_default_model(ht);
  hard_task_def_mit(ht,100000);
  hard_task_def_wcet(ht,90000);
  nrt_task_def_group(ht,2);

 
  err = pthread_create(&j, NULL, mpeg2decoder, NULL);
  if (err) {  
    grx_close();
    perror("Could not create task...");
    sys_end();
  }

 err=fsf_bind_local_thread_to_server(server, j,(fsf_sched_params_t *)(&pr));
 if (err) {
   grx_close();
   perror("Could not bind task..");
   sys_end();
   
 }


}

void ending_system(KEY_EVT *e) {
 
  grx_close();

#ifdef __NEW_TRACER__

  NRT_TASK_MODEL nrt;

  TRACER_LOGEVENT(FTrace_EVT_trace_stop,0,0);
   
  FTrace_disable();
                                                                                                                             
  //group_kill(l->group);

  nrt_task_default_model(nrt);

  task_activate(task_create("Finish",finish_task,&nrt,NULL));

#else

  sys_end();

#endif
}


int main(int argc, char **argv)
{
 
  char ch;
  int err;
 
  //KEY_EVT k;
 
  PI_mutexattr_t a;
  KEY_EVT ev;

  union sigval no_sigval = {0};

  struct timespec period = {0,10000000};
  struct timespec budget = {0,1000000};
  struct timespec period1 = {0,10000000};
  struct timespec period2 = {0,10000000};
  struct timespec budget1 = {0,3000000};
  struct timespec budget2 = {0,3000000};

  fsf_server_id_t server1, server2;
  fsf_contract_parameters_t contract1, contract2;
  union sigval sval;
 

  ev.ascii = 'c';
  ev.scan  = KEY_C;
  ev.status = KEY_PRESSED;
  ev.flag = CNTR_BIT;
  keyb_hook(ev, ending_system, FALSE);

#ifdef __NEW_TRACER__
 
  main_chunk = FTrace_chunk_create(10000000, 1000, FTRACE_CHUNK_FLAG_FREE | FTRACE_CHUNK_FLAG_CYC);
                                                                                                                             
  FTrace_actual_chunk_select(main_chunk);
                                                                                                                             
  FTrace_enable();  

#endif

  TRACER_LOGEVENT(FTrace_EVT_trace_start,0,0);
 
  PI_mutexattr_default(a);
  FSF_start_service_task();
 
  mutex_init(&mux,&a);

  fsf_initialize_contract(&contract1);
  fsf_set_contract_basic_parameters(&contract1,&budget1,&period1,FSF_DEFAULT_WORKLOAD);
  fsf_set_contract_timing_requirements(&contract1,true,NULL,0,no_sigval,0,no_sigval);
  fsf_initialize_contract(&contract2);
  fsf_set_contract_scheduling_policy(&contract1, FSF_POSIX);
  fsf_set_contract_basic_parameters(&contract2,&budget2,&period2,FSF_DEFAULT_WORKLOAD);
  fsf_set_contract_timing_requirements(&contract2,true,NULL,0,no_sigval,0,no_sigval);
  fsf_set_contract_scheduling_policy(&contract2, FSF_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);
  //graphic card Initialization
  if (grx_init() < 1) {
     sys_end();
  }

  if (grx_open(800, 600, 16) < 0) {
    cprintf("GRX Err\n");
    sys_end();
  }

  layout_screen();

  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':        
              fsf_set_contract_basic_parameters(&contract2,&budget,&period,FSF_DEFAULT_WORKLOAD);
              fsf_request_contract_renegotiation(&contract2,server2, 0, sval);                           
              break;
            case '4':
              ending_system(NULL);
                break;
            case '5':
                break;
          }

    ch = keyb_getch(BLOCK);
               
  }

  ending_system(NULL);
 
 return 0;

}