Subversion Repositories shark

/*

 * Project: S.Ha.R.K.

 *

 * Coordinators:

 *   Giorgio Buttazzo    <giorgio@sssup.it>

 *   Paolo Gai           <pj@gandalf.sssup.it>

 *

 * Authors     :

 *   Paolo Gai           <pj@gandalf.sssup.it>

 *   (see the web pages for full authors list)

 *

 * ReTiS Lab (Scuola Superiore S.Anna - Pisa - Italy)

 *

 * http://www.sssup.it

 * http://retis.sssup.it

 * http://shark.sssup.it

 */

/*

 ------------

 CVS :        $Id: mix.c,v 1.2 2002-11-11 08:02:43 pj Exp $

 File:        $File$

 Revision:    $Revision: 1.2 $

 Last update: $Date: 2002-11-11 08:02:43 $

 ------------

*/

/*

 * Copyright (C) 2000 Giorgio Buttazzo and 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

 *

 */

/*--------------------------------------------------------------*/

/*              DEMO with 9 INDEPENDENT TASKS                   */

/*--------------------------------------------------------------*/

#include <kernel/kern.h>

#include <drivers/glib.h>

#include <drivers/keyb.h>

#include <semaphore.h>

#include <stdlib.h>

#include <math.h>

#define PIG     3.1415

#define ESC     27              /* ASCII code for ESCAPE        */

#define DURATA  10000           /* counter duration in tick     */

#define LW      200             /* window length                */

#define HW      150             /* window height                */

#define HLOAD   30              /* Y level for the max load     */

#define LLOAD   (HW-HLOAD-5)    /* length for the max load      */

#define XWL     10              /* left X of LEFT window        */

#define XWM     220             /* left X of MIDDLE window      */

#define XWR     430             /* left X RIGHT window          */

#define YWH     5               /* top Y of HIGH window         */

#define YWM     165             /* top Y of MIDDLE window       */

#define YWL     325             /* top Y of LOW window          */

char    fbuf[1000];             /* buffer for reading a file    */

int     flen;                   /* file length                  */

int     fine = 0;               /* ending flag                  */

sem_t   mx_mat, mx_grf;         /* mutex semaphores             */

int     wcet[10];               /* array of task wcets          */

int     period[10];             /* array of task periods        */

double  load(long);             /* load evaluation function     */

PID     ptas;

char    talk[5][25] =  {" SHARK Demonstration ",

                        " RETIS Lab -- Scuola ",

                        " Superiore   S. Anna ",

                        " HARD REAL-TIME DEMO ",

                        "    June 5,  2001    "};

/*------------------------------------------------------*/

/*              file reading                            */

/*------------------------------------------------------*/

void    read_file(void)

{

  int   err;

  DOS_FILE *fp;

  fp = DOS_fopen("mix.dat","r");

  if (!fp) {

    err = DOS_error();

    cprintf("Error %d opening myfile.txt...\n", err);

    flen = 0;

    return;

  }

  flen = DOS_fread(&fbuf, 1, 1000, fp);

  cprintf("Read %d bytes from file\n", flen);

  DOS_fclose(fp);

}

/*------------------------------------------------------*/

/*              get data from buffer                    */

/*------------------------------------------------------*/

void    get_par(void)

{

  int   x = 0;

  int   i;

  for (i=1; i<=8; i++) {

    while ((fbuf[x] != ':') && (x < flen)) x++;

    x++;

    sscanf(&fbuf[x], "%d %d", &period[i], &wcet[i]);

    cprintf("per[%d] = %d, wcet[%d] = %d\n",

            i, period[i], i, wcet[i]);

  }

}

/*--------------------------------------------------------------*/

void    byebye()

{

  grx_close();

  kern_printf("Bye Bye!\n");

}

/*--------------------------------------------------------------*/

void    finish1()

{

  sys_end();

}

/*--------------------------------------------------------------*/

void    finish2()

{

  fine = 1;

}

/****************************************************************/

/*                      PROCESSO OROLOGIO                       */

/****************************************************************/

#define LLAN    40              /* length of watch stick        */

TASK    watch()

{

  int   x0 = XWL + LW/2;

  int   y0 = YWH + HW/2;

  int   grad;

  int   xg, yg;

  int   xt, yt, d;

  int   sec, min;

  char  s[5];

  double        rad, x, y;

  xg = x0;

  yg = y0 - LLAN;

  xt = XWL + 78;

  yt = YWH + 12;

  sec = min = 0;

  while (1) {

    sec = (sec + 1) % 60;

    if (sec == 0) min++;

    grad = 90 - sec * 6;

    rad = (double)grad * PIG / 180.;

    sem_wait(&mx_mat);

    x = (double)x0 + (double)LLAN * cos(rad);

    y = (double)y0 - (double)LLAN * sin(rad);

    sem_post(&mx_mat);

    sem_wait(&mx_grf);

    grx_line(x0, y0, xg, yg, 0);

    sem_post(&mx_grf);

    xg = x;

    yg = y;

    sem_wait(&mx_grf);

    grx_line(x0, y0, xg, yg, 14);

    sem_post(&mx_grf);

    sem_wait(&mx_grf);

    grx_text("0 :0 ", xt, yt, 14, 0);

    sprintf(s, "%d", min);

    grx_text(s, xt+8, yt, 14, 0);

    sprintf(s, "%d", sec);

    if (sec > 9) d = 24; else d = 32;

    grx_text(s, xt+d, yt, 14, 0);

    sem_post(&mx_grf);

    task_endcycle();

  }

}

/****************************************************************/

/*               PROCESSO DI RIEMPIMENTO                        */

/****************************************************************/

#define CIMA    (YWH+5)         /* fondo del recipiente         */

#define FONDO   (YWH+HW-5)      /* cima  del recipiente         */

#define LREC    (XWM+75)        /* lato sinistro recipiente     */

#define DREC    50              /* diametro del recipiente      */

TASK    tasto()

{

  int   x, y;

  int   x0;                     /* coord. sinistra recipiente   */

  int   col, cliq, bkg;

  int   i;

  int   liv;                    /* livello del liquido          */

  cliq = 9;

  bkg = 14;

  x0 = LREC;

  x = x0 + DREC/2;

  y = CIMA;

  liv = FONDO;

  while (1) {

    col = cliq;

    for (i=0; i<2; i++) {               /* disegna goccia */

      while (y < liv) {

        sem_wait(&mx_grf);

        grx_plot(x,y,col);

        sem_post(&mx_grf);

        y++;

      }

      y = CIMA;

      col = bkg;

    }

    liv--;

    sem_wait(&mx_grf);

    grx_line(x0+1, liv, x0+DREC-1, liv, cliq);

    sem_post(&mx_grf);

    if (liv <= CIMA+1) {                /* swap colors */

      i = bkg; bkg = cliq; cliq = i;

      liv = FONDO;

    }

    task_endcycle();

  }

}

/****************************************************************/

void    kboar()

{

  task_activate(ptas);

}

/****************************************************************/

/*                      PROCESSO PALLA                          */

/****************************************************************/

#define VMIN    11.             /* velocit… minima per suono    */

#define LP      3               /* lato della pallina           */

TASK    palla()

{

  int   ox, oy;                 /* vecchia posizione pallina    */

  int   x0;                     /* posizione iniziale pallina   */

  int   xmin, xmax;

  int   base, top;

  int   xg, yg;                 /* coordinate grafiche pallina  */

  double        x, y;                   /* coordinate pallina   */

  double        G = 9.8;

  double        vx, vy, v0;             /* velocit… della pallina       */

  double        t, tx;                  /* variabile temporale          */

  double        dt;                     /* incremento temporale         */

  double        arg;                    /* variabile di appoggio        */

  xmin = XWR+LP+1;

  xmax = XWR+LW-LP-1;

  base = YWH+HW-LP-1;

  top  = HW-10-LP;

  x = ox = x0 = xmin;

  y = oy = top;

  arg = 2.*G*(double)top;

  vy = v0 = sqrt(arg);

  vx = 15.;

  tx = 0.0;

  t = vy / G;

  dt = .02;

  while (1) {

    x = x0 + vx*tx;

    y = base - vy*t + .5*G*t*t;

    if (y >= base) {

      t = 0.0;

      vy = v0;

      y = base - vy*t + .5*G*t*t;

    }

    if (x >= xmax) {

      tx = 0.0;

      x0 = xmax;

      vx = -vx;

      x = x0 + vx*tx;

    }

    if (x <= xmin) {

      tx = 0.0;

      x0 = xmin;

      vx = -vx;

      x = x0 + vx*tx;

    }

    xg = x; yg = y;

    sem_wait(&mx_grf);

    grx_disc(ox,oy,LP,0);

    grx_disc(xg,yg,LP,10);

    sem_post(&mx_grf);

    oy = yg; ox = xg;

    t += dt;

    tx += dt;

    task_endcycle();

  }

}

/****************************************************************/

/*                      PROCESSO MOSCA                          */

/****************************************************************/

TASK    mosca()

{

  int   x, y, Ax, Ay, h;

  int   x0, y0, tet;

  int   xmax,ymax;

  double        A, B;

  double        r;

  double        rnd;

  xmax = LW/2-1; ymax = HW/2-1;

  x = 0; y = 0; tet = 0;

  x0 = XWL+LW/2; y0 = YWM+HW/2;

  A = 5.; B = 30.;

  while (1) {

    rnd = (rand()%100)/100.;    /* rnd = [0,1] */

    h = (2. * B * rnd) - B;             /*  h = [-B,B] */

    tet = tet + h;

    if (tet > 360) tet = tet - 360;

    if (tet < 0) tet = tet + 360;

    r = tet * PIG / 180.;

    sem_wait(&mx_mat);

    Ax = (double)(A * cos(r));

    Ay = (double)(A * sin(r));

    sem_post(&mx_mat);

    x = x + Ax;

    y = y + Ay;

    if ((x >= xmax) || (x <= -xmax) ||

        (y >= ymax) || (y <= -ymax)) {

      x = x - Ax;

      y = y - Ay;

      tet = tet - 180;

      if (tet > 360) tet = tet - 360;

      if (tet < 0) tet = tet + 360;

      r = tet * PIG / 180.;

      sem_wait(&mx_mat);

      Ax = (double)(A * cos(r));

      Ay = (double)(A * sin(r));

      sem_post(&mx_mat);

      x = x + Ax;

      y = y + Ay;

    }

    sem_wait(&mx_grf);

    grx_plot(x+x0, y+y0, 10);

    sem_post(&mx_grf);

    task_endcycle();

  }

}

/****************************************************************/

/*                      PROCESSO INFORMAZIONI                   */

/****************************************************************/

TASK    infor()

{

  char  s[2];

  int   x, y;

  int   r;

  int   i = 0;

  int   leng;

  int   col = 0;

  r = 0;

  x = XWM + 16;

  y = YWM + 40;

  s[1] = 0;

  leng = 0;

  while (talk[0][leng] != 0) leng++;

  while (1) {

    s[0] = talk[r][i];

    sem_wait(&mx_grf);

    grx_text(s,x+i*8,y+r*8,col+10,1);

    sem_post(&mx_grf);

    i++;

    if (i == leng) {

      i = 0;

      r = (r + 1) % 5;

      if (r == 0) col = (col + 1) % 6;

    }

    task_endcycle();

  }

}

/****************************************************************/

/*                      PROCESSO RUOTA                          */

/****************************************************************/

TASK    ruota()

{

  int   x0 = XWR + LW/2;

  int   y0 = YWM + HW/2;

  int   grad = 90;

  int   xg, yg;

  double        rad, x, y;

  xg = x0;

  yg = y0 + LLAN;

  while (1) {

    rad = (double)grad * PIG / 180.;

    sem_wait(&mx_mat);

    x = (double)x0 + (double)LLAN * cos(rad);

    y = (double)y0 + (double)LLAN * sin(rad);

    sem_post(&mx_mat);

    sem_wait(&mx_grf);

    grx_disc(xg, yg, 4, 0);

    sem_post(&mx_grf);

    xg = x; yg = y;

    sem_wait(&mx_grf);

    grx_disc(xg, yg, 4, 13);

    sem_post(&mx_grf);

    grad = (grad + 1) % 360;

    task_endcycle();

  }

}

/****************************************************************/

/*                      PROCESSO COLORI                         */

/****************************************************************/

TASK    color()

{

  int   xx0 = XWL+5;

  int   yy0 = YWL+5;

  int   n, col;

  int   x, y;

  x = 0; y = 0;

  while (1) {

    n = 19. * ((rand()%100)/100.);

    x = xx0 + n * 10;

    n = 14. * ((rand()%100)/100.);

    y = yy0 + n * 10;

    col = 16. * ((rand()%100)/100.);

    /*          xg = xx0 + x;

                yg = yy0 + y;

                x = (x + 10)%(LW-10);

                y = (y + 10)%(HW-10);

    */

    sem_wait(&mx_grf);

    grx_box(x, y, x+9, y+9, col);

    sem_post(&mx_grf);

    task_endcycle();

  }

}

/****************************************************************/

/*                      PROCESSO PENDOLO                        */

/****************************************************************/

TASK    pendo()

{

  int   x0 = XWM+LW/2;

  int   y0 = YWL+10;

  int   xg, yg;

  int   col = 11;

  double        x, y, teta;

  double        v, a, dt;

  double        g, l;

  g = 9.8;

  l = 80.;

  dt = 0.1;

  teta = 40. * PIG / 180.;

  v = 0.;

  sem_wait(&mx_mat);

  x = l * sin((double)teta);

  y = l * cos((double)teta);

  a = -(g/l) * sin((double)teta);

  sem_post(&mx_mat);

  xg = x0 + x;

  yg = y0 + y;

  while (1) {

    v += a * dt;

    teta += v * dt;

    sem_wait(&mx_mat);

    x = l * sin((double)teta);

    y = l * cos((double)teta);

    a = -(g/l) * sin((double)teta);

    sem_post(&mx_mat);

    sem_wait(&mx_grf);

    grx_line(x0, y0, xg, yg, 0);

    grx_circle(xg, yg, 5, 0);

    grx_disc(xg, yg, 4, 0);

    sem_post(&mx_grf);

    xg = x0+x; yg = y0+y;

    sem_wait(&mx_grf);

    grx_line(x0, y0, xg, yg, col);

    grx_circle(xg, yg, 5, col+2);

    grx_disc(xg, yg, 4, col+1);

    sem_post(&mx_grf);

    task_endcycle();

  }

}

/****************************** gener ******************************/

TASK    gener()

{

  HARD_TASK_MODEL m;

  SOFT_TASK_MODEL am;

  PID   pid;

  //---------------------------------------------

  hard_task_default_model(m);

  hard_task_def_wcet     (m, wcet[1]);

  hard_task_def_mit      (m, period[1]);

  hard_task_def_usemath  (m);

  pid = task_create("watch", watch, &m, NULL);

  task_activate(pid);

  keyb_getch(BLOCK);

  //---------------------------------------------

  soft_task_default_model(am);

  soft_task_def_met      (am, wcet[2]);

  soft_task_def_period   (am, period[2]);

  soft_task_def_aperiodic(am);

  soft_task_def_usemath  (am);

  ptas = task_create("tasto", tasto, &am, NULL);

  task_activate(ptas);

  keyb_getch(BLOCK);

  //---------------------------------------------

  hard_task_default_model(m);

  hard_task_def_wcet     (m, wcet[3]);

  hard_task_def_mit      (m, period[3]);

  hard_task_def_usemath  (m);

  pid = task_create("palla", palla, &m, NULL);

  task_activate(pid);

  keyb_getch(BLOCK);

  //---------------------------------------------

  hard_task_default_model(m);

  hard_task_def_wcet     (m, wcet[4]);

  hard_task_def_mit      (m, period[4]);

  hard_task_def_usemath  (m);

  pid = task_create("mosca", mosca, &m, NULL);

  task_activate(pid);

  keyb_getch(BLOCK);

  //---------------------------------------------

  hard_task_default_model(m);

  hard_task_def_wcet     (m, wcet[5]);

  hard_task_def_mit      (m, period[5]);

  hard_task_def_usemath  (m);

  pid = task_create("infor", infor, &m, NULL);

  task_activate(pid);

  keyb_getch(BLOCK);

  //---------------------------------------------

  hard_task_default_model(m);

  hard_task_def_wcet     (m, wcet[6]);

  hard_task_def_mit      (m, period[6]);

  hard_task_def_usemath  (m);

  pid = task_create("ruota", ruota, &m, NULL);

  task_activate(pid);

  keyb_getch(BLOCK);

  //---------------------------------------------

  hard_task_default_model(m);

  hard_task_def_wcet     (m, wcet[7]);

  hard_task_def_mit      (m, period[7]);

  hard_task_def_usemath  (m);

  pid = task_create("color", color, &m, NULL);

  task_activate(pid);

  keyb_getch(BLOCK);

  //---------------------------------------------

  hard_task_default_model(m);

  hard_task_def_wcet     (m, wcet[8]);

  hard_task_def_mit      (m, period[8]);

  hard_task_def_usemath  (m);

  pid = task_create("pendo", pendo, &m, NULL);

  task_activate(pid);

  //---------------------------------------------

  return NULL;

}

/****************************** MAIN ******************************/

int main()

{

  char  s[20];                  /* carattere letto da tastiera  */

  int   x0, y0;

  int   x, y;

  TIME  t1, count;              /* contatori valutazione carico */

  double        car;                    /* valore del carico corrente   */

  TIME  seme;

  PID   pid;

  NRT_TASK_MODEL m2;

  KEY_EVT       eva, evx, evs;

  set_exchandler_grx();

  sys_atrunlevel(byebye, NULL, RUNLEVEL_BEFORE_EXIT);

  /* set the keyboard handler */

  eva.ascii = 'a';

  eva.scan = KEY_A;

  eva.flag = 0;

  keyb_hook(eva,kboar);

  evx.ascii = 'x';

  evx.scan = KEY_X;

  evx.flag = ALTL_BIT;

  keyb_hook(evx,finish1);

  evs.ascii = ESC;

  evs.scan = KEY_ESC;

  evs.flag = 0;

  keyb_hook(evs,finish2);

  sem_init(&mx_mat,0,1);

  sem_init(&mx_grf,0,1);

  seme = sys_gettime(NULL);

  srand(seme);

  get_par();

  keyb_getch(BLOCK);

  grx_init();

  grx_open(640, 480, 8);

  grx_rect(XWL,YWH,XWL+LW,YWH+HW,14);

  grx_rect(XWM,YWH,XWM+LW,YWH+HW,14);

  grx_rect(XWR,YWH,XWR+LW,YWH+HW,14);

  grx_rect(XWL,YWM,XWL+LW,YWM+HW,14);

  grx_rect(XWM,YWM,XWM+LW,YWM+HW,14);

  grx_rect(XWR,YWM,XWR+LW,YWM+HW,14);

  grx_rect(XWL,YWL,XWL+LW,YWL+HW,14);

  grx_rect(XWM,YWL,XWM+LW,YWL+HW,14);

  grx_rect(XWR,YWL,XWR+LW,YWL+HW,14);

  x0 = XWL + LW/2;

  y0 = YWH + HW/2;

  grx_circle(x0, y0, LLAN+3, 12);

  grx_rect(XWL+74, YWH+7, XWL+120, YWH+22, 12);

  x0 = LREC;

  grx_line(x0, CIMA, x0, FONDO, 15);

  grx_line(x0+DREC, CIMA, x0+DREC, FONDO, 15);

  grx_line(x0, FONDO, x0+DREC, FONDO, 15);

  grx_box(x0+1, CIMA, x0+DREC-1, FONDO-1, 14);

  grx_text("Press A", XWM+16, YWH+48, 10, 0);

  grx_text("to fill", XWM+16, YWH+64, 10, 0);

  grx_text("Press:", XWM+18, YWM+HW-50, 10, 0);

  grx_text("ESC to exit", XWM+18, YWM+HW-40, 10, 0);

  grx_text("SPACE to create", XWM+18, YWM+HW-30, 10, 0);

  x0 = XWR + LW/2;

  y0 = YWM + HW/2;

  grx_circle(x0, y0, LLAN/3, 14);

  grx_disc(x0, y0, LLAN/3-1, 12);

  x0 = XWR+5;

  y0 = YWL+HW-5;

  grx_line(x0, YWL+HLOAD, x0+LW-10, YWL+HLOAD, 12);

  grx_text("SYSTEM WORKLOAD:", x0+5, YWL+HLOAD-10, 10, 0);

  count = 0;

  t1 = sys_gettime(NULL);

  do count++; while (sys_gettime(NULL) < (t1 + DURATA));

  nrt_task_default_model(m2);

  pid = task_create("gener", gener, &m2, NULL);

  task_activate(pid);

  x = 0;

  while (!fine) {

    car = load(count);

    y = (double)LLOAD*car;

    sem_wait(&mx_grf);

    grx_line(x0+x, y0-LLOAD+1, x0+x, y0, 0);

    grx_line(x0+x, y0-y, x0+x, y0, 15);

    grx_text("    ", x0+LW-60, YWL+HLOAD-10, 0, 0);

    sprintf(s, "%.3f", car);

    grx_text(s, x0+LW-50, YWL+HLOAD-10, 15, 0);

    sem_post(&mx_grf);

    x = (x + 1) % (LW-10);

  }

  sys_end();

  return NULL;

}

/****************************************************************/

double  load(long n)

{

  TIME  i, t1;