Subversion Repositories shark

/*
 *
 *
 *
 */

#include <kernel/func.h>
#include <kernel/model.h>

#include <sys/types.h>
#include <sys/stat.h>
#include <sys/mount.h>
#include <dirent.h>
#include <fcntl.h>
#include <unistd.h>
#include <errno.h>
#include <string.h>
#include <stdlib.h>
#include <semaphore.h>
#include <stdio.h>

#include "common.h"

#define NOSHOW
#undef NOSHOW

#define sem_signal sem_post

int noscroll=0;
sem_t console;

#define MPROC    ((50<(MAX_PROC-10))?50:MAX_PROC-10)
//#define MWCET    1000l
//#define MPERIOD  (MWCET*(MPROC+10))

TASK viewdir(void *prof);
sem_t actmutex,actsync;
char *globpathname;
PID globpid;
int counter=0,actcounter=0;

void activate_task(int prof, char *pathname)
{
  char tname[32];
  NRT_TASK_MODEL m;
  PID pid;

REPEAT:
  sem_wait(&actmutex);

  if (actcounter>=MPROC) {
    sem_signal(&actmutex);
    task_delay(10000);
    goto REPEAT;
  }
 
  globpathname=pathname;
  counter++;
  sprintf(tname,"tsk%i",counter);

  /*
  printd("Û");
  sem_wait(&console);
  printd("Ü");
  cprintf("%03i has called for ##%s##\n",prof,pathname);
  sem_signal(&console);
  */
 
  nrt_task_default_model(m);
  //soft_task_def_met(m,MWCET);
  //soft_task_def_wcet(m,MWCET);
  //soft_task_def_periodic(m);
  nrt_task_def_arg(m,(void*)counter);
  //soft_task_def_period(m,MPERIOD);
 
  globpid=pid=task_create(tname,viewdir,&m,NULL);
  if (pid==-1) {
    sem_wait(&console);
    cprintf("can't create '%s'\n",tname);
    perror("can't create task");
    sem_signal(&console);
    sys_end();
    return;
  }
  task_activate(pid);
  sem_wait(&actsync);
  actcounter++;

  /*
  printd("Û");
  sem_wait(&console);
  printd("Ü");
  if (noscroll) place(0,9);
  cprintf("task running: %5i/%5i --- task started: %5i\n",
          actcounter,MAX_PROC,counter);
  sem_signal(&console);
  */
 
  sem_signal(&actmutex);
}

/*
 *
 */

int filecounter=0;

TASK viewdir(void *pointer)
{
  struct dirent *den;
  struct stat st;
  char *str;
  DIR *d;
  int res;
  int x;
  char pathname[1024];
  PID mypid;
  int prof=(int)pointer;

  strcpy(pathname,globpathname);
  mypid=globpid;
  sem_signal(&actsync);  

  //sem_wait(&console);
  //cprintf("%03i on <%s>\n",prof,pathname);
  //sem_signal(&console);
 
  str=pathname+(x=strlen(pathname));
  d=opendir(pathname);
 
  if (d==NULL) {
    sem_wait(&console);
    cprintf("%03i ERR: can't open dir %s\n",prof,pathname);
    cprintf("errno: %i '%s'\n",errno,strerror(errno));
    sem_signal(&console);

    sys_end();
    l1_exit(0);
   
    goto END;
  }

  while ((den=readdir(d))!=NULL) {

    if (x==1&&*pathname=='/')
      strcat(pathname,den->d_name);
    else
      strcat(strcat(pathname,"/"),den->d_name);

    sem_wait(&console);
#ifndef NOSHOW
    if (noscroll) {
      place(0,10);
      cprintf("                                                           ");
      place(0,10);
    }
    //cprintf("%03i(0_%03i) %s\n",prof,(int)mypid,pathname);
    cprintf("t%03i %s\n",prof,pathname);
#endif
    filecounter++;
    sem_signal(&console);
   
    //if (*den->d_name=='.') {
      //  sem_wait(console,BLOCK);
      //  cprintf("%03i HAS FOUND <%s>\n",prof,den->d_name);
      //  sem_signal(console);
      //}
   
    if (!strcmp(den->d_name,".")) {
      //sem_wait(console,BLOCK);
      //cprintf("%03i skip for .\n",prof);
      //sem_signal(console);
      goto SKIP;
    }
    if (!strcmp(den->d_name,"..")) {
      //sem_wait(console,BLOCK);
      //cprintf("%03i skip for ..\n",prof);
      //sem_signal(console);
      goto SKIP;
    }

    res=stat(pathname,&st);
    if (res!=0) {
      sem_wait(&console);
      cprintf("t%03i can't stat %s\n",prof,pathname);
      cprintf("errno: %i '%s'\n",errno,strerror(errno));
      sem_signal(&console);

      sys_end();
      l1_exit(0);
     
      closedir(d);
      goto END;
    } else {          
      if (S_ISDIR(st.st_mode)) {
        sem_wait(&console);
        //if (den->d_name[0]=='.')
          //  cprintf("%03i called for <%s>\n",prof,den->d_name);
        sem_signal(&console);
        activate_task(prof,pathname);
      }
     
    }

  SKIP:
    *str='\0';
  }

  closedir(d);

END:
  sem_wait(&actmutex);
  actcounter--;
  sem_signal(&actmutex);

  return 0;
}

int main(int argc,char *argv[])
{
  extern void dump_sem_table(void);
  TIME stime,etime;
  //  int res;

  /*
  temp_device=bdev_scan_devices(choose_temp_callback);
  if (temp_device<0) {
    cprintf("can't find a filesystem to mount on /TEMP!!!\n");
    return -1;
  }
  */
 
  /* mounting 2nd msdos partition on /TEMP */
  /*
  res=mount(temp_device,FS_MSDOS,"/TEMP",NULL);
  if (res!=0) {
    cprintf("can't mount XXX on /TEMP\n");
    cprintf("errno: %i '%s'\n",errno,strerror(errno));
    return -1;
  }
  */
 
  /* clear screen */
  //clear();

  showmessage("This test show all filenames of a directory of an hardisk\n"
              "recursively using a soft task for every directory.\n");

  stime=sys_gettime(NULL);
 
  sem_init(&console,0,1);
  sem_init(&actmutex,0,1);
  sem_init(&actsync,0,0);

  //dump_sem_table();

  //keyb_getchar();
 
  activate_task(-1,"/TEMP");

  for(;;) {
    sem_wait(&actmutex);
    if (actcounter==0) break;
    sem_signal(&actmutex);
  }

  etime=sys_gettime(NULL);
 
  cprintf("\nfiles: %i\n",filecounter);
  cprintf("time   : %li\n",etime-stime);
 
  waitend();
 
  return 0;
}