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: step2b.c,v 1.1 2004-07-05 14:17:15 pj Exp $

 File:        $File$

 Revision:    $Revision: 1.1 $

 Last update: $Date: 2004-07-05 14:17:15 $

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

**/

/*

 * 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 "string.h"

#include "ll/i386/x-dos.h"

#include "modules/rr.h"

#include "modules/dummy.h"

#include "modules/edf.h"

#include "modules/sem.h"

#include "modules/hartport.h"

#include "drivers/keyb.h"

#include "ctype.h"

#include "tune.h"

int ending=0;

// Patterns

#define MAX_PATTERN 10000

int max_pattern = 0;

TIME pattern_t[MAX_PATTERN];

TIME pattern_period[MAX_PATTERN];

TIME pattern_wcet[MAX_PATTERN];

TIME pattern_iter[MAX_PATTERN];

void record_pattern(TIME t, TIME period, TIME wcet)

{

  pattern_t[max_pattern] = t;

  pattern_period[max_pattern] = period;

  pattern_wcet[max_pattern] = wcet;

  max_pattern++;

}

#define WCET_SLACK 500

void tune_pattern(void)

{

  int i,w;

  for (i=0; i<max_pattern; i++) {

    w = (pattern_wcet[i]*80)/100-WCET_SLACK;

    // if (w>pattern_wcet[i]-WCET_SLACK) w=pattern_wcet[i]-WCET_SLACK;

    if (w<0) w=WCET_SLACK/2;

    pattern_iter[i] = tune_CPU_speed(w);

  }

}

// Shape modification

#define DEFAULT_SHIFT 1000000

#define MAX_SHAPE 1000

bandwidth_t shape=0; // current shape threshold

int current_shape = 0;

bandwidth_t shape_B[MAX_SHAPE];

TIME shape_T[MAX_SHAPE];

int max_shape;

void shape_event(void *arg)

{

  shape = shape_B[0];

}

void end_event(void *arg)

{

  ending = 1;

}

void start_shape(void)

{

  struct timespec t;

  NULL_TIMESPEC(&t);

  kern_cli();

  kern_event_post(&t,shape_event,NULL);

  ADDUSEC2TIMESPEC(DEFAULT_SHIFT,&t);

  kern_event_post(&t,end_event,NULL);

  kern_sti();

}

// Hard task

#define ASTER_LIM 80

void *hard_task(void *arg)

{

  int j, x, y;

  char s[2];

  struct timespec t;

  int b;

  NULL_TIMESPEC(&t);

  ADDUSEC2TIMESPEC((DEFAULT_SHIFT*2)/3,&t);

  b = TIMESPEC_A_LT_B(&proc_table[exec_shadow].request_time,&t);

  do {

    x = 0;

    y = rand() % 6 + 3;

    s[0] = '*'; s[1] = 0;

    while (x < ASTER_LIM) {

      for (j=0; j<50; j++) {

        s[0] = '*' + rand() % 100;

        puts_xy(x,y,rand()%15+1,s);

      }

      task_endcycle();

      puts_xy(x,y,WHITE," ");

      x++;

    }

  } while (b && !ending);

  return (void *)0;

}

#define MAX_PERIOD 100

// Load creation

void *create_load(void *arg)

{

    PID p;

    HARD_TASK_MODEL m;

    TIME period = 0;

    TIME wcet = 0;

    int x; // adaptive bandwidth...

    int counter=0;

    char buf[100];

    hard_task_default_model(m);

    x = MAX_PERIOD/3;

    place(0,11);

    // waiting for the start time :-)

    while (sys_gettime(NULL)<DEFAULT_SHIFT/2);

    while (1) {

      sprintf(buf,"Shape: %5.3f Band: %5.3f period: %10ld wcet: %10ld Time: %d",

              (double)shape/(double)MAX_BANDWIDTH,

              (double)EDF_usedbandwidth(0)/(double)MAX_BANDWIDTH,

              period, wcet, sys_gettime(NULL)/1000000);

      puts_xy(0,10,WHITE,buf);

      period = (x+rand() % (MAX_PERIOD-x+1))*1000;

      wcet = rand()%1000 * (period/1500);

      if ((MAX_BANDWIDTH/period)*wcet > shape - EDF_usedbandwidth(0))

        wcet = (shape - EDF_usedbandwidth(0))/period;

      if (wcet < period/40) wcet=period/40;

      if (wcet < 500) wcet=500;

      if (EDF_usedbandwidth(0) + (MAX_BANDWIDTH/period)*wcet < shape) {

        hard_task_def_mit(m, period);

        hard_task_def_wcet(m, wcet);

        p = task_create("hard_task",hard_task,&m,NULL);

        if (p == -1) {

          x += rand()%10-4;

        }

        else {

          record_pattern(sys_gettime(NULL),period,wcet);

          cprintf("%d ",++counter);

          task_activate(p);

          x *= 3;

          x /= 4;

        }

        if (x<MAX_PERIOD/3) x = MAX_PERIOD/3;

        if (x > MAX_PERIOD) x = MAX_PERIOD;

      }

      if (ending) return (void *)0;

    }

}

// Read/Write part

#define FILEBUF_DIM 10000

/* This is the buffer used by read_myfile */

char myfilebuf[FILEBUF_DIM];

/* This is the number of bytes read by read_myfile */

int myfilebuf_length;

/* the buffer b is scannedc to search for numbers

   at the first non-number the function stops */

int geti(char *b, int *pos, int maxpos)

{

  int res = 0;

  // skip first chars

  while (!isdigit(b[*pos])) {

    (*pos)++;

    if (*pos == maxpos) return -1;  // Error!!!

  }

  // read the numbers

  do {

    res = (res * 10) + b[*pos] - '0';

    (*pos)++;

  } while (isdigit(b[*pos]));

  return res;

}

void parse_shape(void)

{

  int curr_filepos = 0;

  int i = 0;

  // read the number of tasks into the data file

  max_shape = geti(myfilebuf, &curr_filepos, myfilebuf_length);

  if (max_shape == -1) {

    cprintf("Error parsing shape.dat file...\n");

    sys_end();

  }

  for (i=0; i<max_shape; i++) {

      // read the seven datas

      shape_T[i]      = geti(myfilebuf, &curr_filepos, myfilebuf_length);

      shape_B[i]      = geti(myfilebuf, &curr_filepos, myfilebuf_length);

      // check the last one for an error

      if (shape_B[i] == -1) {

        cprintf("Error parsing shape %d...\n",i);

        sys_end();

      }

  }

}

void read_shapes(void)

{

  char name[]="shape.dat";

  /* DOS file descriptor */

  DOS_FILE *f;

  /* Error code */

  int err;

  /* open the DOS file for reading  (you can specify only "r" or "w") */

  f = DOS_fopen(name,"r");

  /* check for open errors */

  if (!f) {

    /* error!! */

    err = DOS_error();

    /* note that if you call DOS_error() here, it return 0!!! */

    cprintf("Error %d opening %s...\n", err, name);

    myfilebuf_length = 0;

    return;

  }

  /* read up to 1000 chars */

  myfilebuf_length = DOS_fread(&myfilebuf,1,FILEBUF_DIM,f);

  /* check for errors */

  err = DOS_error();

  cprintf("Read %d bytes from %s...\n", myfilebuf_length, name);

  if (err) {

    cprintf("Error %d reading %s...\n", err, name);

    myfilebuf_length = 0;

   /* there is not return because I want to close the file! */

  }

  /* Close the file */

  DOS_fclose(f);

}

/* This function write myfile.out (up to 30 chars) */

void write_hpattern(void *arg)

{

  DOS_FILE *f;  /* DOS file descriptor */

  int err=0;  /* Error code */

  int writtenbytes = 0;  /* number of files written */

  char buf[100];

  int i;

  /* open the DOS file for writing  (you can specify only "r" or "w") */

  f = DOS_fopen("hpattern.dat","w");

  /* check for open errors */

  if (!f) {

    /* error!! */

    err = DOS_error();

    /* note that if you call DOS_error() here, it return 0!!! */

    cprintf("Error %d opening hpattern.dat...\n", err);

    return;

  }

  sprintf(buf,"%d\r\n",max_pattern);

  writtenbytes += DOS_fwrite(buf,1,strlen(buf),f);

  for (i=0; i<max_pattern; i++) {

    sprintf(buf,"%ld %ld %ld %ld\r\n", pattern_t[i], pattern_period[i],

                            pattern_wcet[i], pattern_iter[i]);

    writtenbytes += DOS_fwrite(buf,1,strlen(buf),f);

    /* check for errors */

    err = DOS_error();

    if (err) break;

  }

  cprintf("Written %d bytes into hpattern.dat...\n", writtenbytes);

  if (err) {

    cprintf("Error %d writing hpattern.dat...\n", err);

    /* there is not return because I want to close the file! */

  }

  /* Close the file */

  DOS_fclose(f);

}

/*+ sysyem tick in us +*/

#define TICK 0

/*+ RR tick in us +*/

#define RRTICK 10000

void read_myfile(void);

TIME __kernel_register_levels__(void *arg)

{

  struct multiboot_info *mb = (struct multiboot_info *)arg;

  EDF_register_level(EDF_ENABLE_ALL);

  RR_register_level(RRTICK, RR_MAIN_NO, mb);

  RR_register_level(RRTICK, RR_MAIN_YES, mb);

  dummy_register_level();

  SEM_register_module();

  read_shapes();

  return TICK;

}

NRT_TASK_MODEL keyb_model;

TASK __init__(void *arg)

{

  NRT_TASK_MODEL nrt;

  KEYB_PARMS kparms = BASE_KEYB;

  HARTPORT_init();

  nrt_task_default_model(keyb_model);

  nrt_task_def_system(keyb_model);

  nrt_task_def_nokill(keyb_model);

  keyb_def_task(kparms,(TASK_MODEL *)&keyb_model);

  KEYB_init(&kparms);

  set_exchandler_grx();

  nrt_task_default_model(nrt);

  srand(sys_gettime(NULL));

  clear();

  sys_atrunlevel(write_hpattern, NULL, RUNLEVEL_AFTER_EXIT);

  parse_shape();

  start_shape();

  task_activate(task_create("create_load",create_load,&nrt,NULL));

  cputs("\nWaiting the end of the periodic tasks...\n");

  while (task_counter != 1);

  // the task create_load preempt __init__ until all is finished!

  tune_pattern();

  return (void *)0;

}

// never called!!!

int main()

{

  return 0;

}