home *** CD-ROM | disk | FTP | other *** search
/ OS/2 Shareware BBS: 8 Other / 08-Other.zip / fsb.zip / fsbench.c next >
C/C++ Source or Header  |  1996-09-19  |  11KB  |  349 lines
  1. /********************************************************/
  2. /*                                                      */
  3. /*   F I L E - S Y S T E M     B E N C H M A R K S      */
  4. /*                                                      */
  5. /*        Radim Kolar , 2:423/66.111@FidoNet            */
  6. /*       radim_kolar@p111.f66.n423.z2.fido.cz           */
  7. /*           F R E E W A R E                            */
  8. /*                                                      */
  9. /*            version 0.22                              */
  10. /*                                                      */
  11. /* History:                                             */
  12. /* 0.01 - 28/02/1996 - Project started...               */
  13. /* 0.10 - 03/03/1996 - Fully functional FSB kernel      */
  14. /* 0.20 - 09/03/1996 - Config parsing + display         */
  15. /* 0.21 - 21/04/1996 - Emergency exit on SIGINT         */
  16. /* 0.22 - 13/06/1996 - DosForceDelete on Emergency exit */
  17. /*                     updated comments in config file  */
  18. /*                     corrected bug in emergency exit  */
  19. /*                      sometimes fsb don't exit        */
  20. /********************************************************/
  21.  
  22. #define FSBENCH_V "0.22"
  23.  
  24. #define INCL_DOSMISC
  25. #define INCL_DOSFILEMGR
  26. #define INCL_BASE
  27. #include <os2.h>
  28. #include <malloc.h>
  29. #include <ctype.h>
  30. #include <string.h>
  31. #include <stdio.h>
  32. #include <sys/time.h>
  33. #include <stdlib.h>
  34. #include <io.h>
  35. #include <signal.h>
  36.  
  37. /* Global vars. */
  38. #define TEST_FILENAME "test.tmp"
  39. #define TEST_FILESIZE 1024*1024*4
  40. HFILE h=0; /* handle prave otevreneho souboru */
  41. char *fn=NULL;  /* jmeno prave otevreneho souboru */
  42.  
  43.  
  44.  
  45. /* Vytvori testovaci soubor fn o velikosti fs bajtu */
  46. int CreateTestFile(char *fn,unsigned long fs)
  47. {
  48.  APIRET rc;
  49.  HFILE hnd;
  50.  ULONG act;
  51.  void *blok;
  52.  int i;
  53.  blok=malloc(512);
  54.  rc=DosOpen(fn,&hnd,&act,fs,FILE_NORMAL,OPEN_ACTION_CREATE_IF_NEW|
  55.             OPEN_ACTION_REPLACE_IF_EXISTS,OPEN_SHARE_DENYREADWRITE|
  56.             OPEN_ACCESS_READWRITE,NULL);
  57.  h=hnd;           
  58.  for(i=0;i<fs/512;i++)
  59.    DosWrite(hnd,blok,512,&act);
  60.  /* dodatek */
  61.  DosWrite(hnd,blok,fs-(fs/512)*512,&act);
  62.  DosClose(hnd);
  63.  h=0;
  64.  return rc;
  65. }
  66.  
  67. /* smaze testovaci soubor */
  68. int DeleteTestFile(char *fn)
  69. {
  70.  APIRET rc;
  71.  rc=DosForceDelete(fn);
  72.  return rc;
  73. } 
  74.  
  75. void sync(void)
  76. {
  77.  DosShutdown(1L);
  78.  DosSleep(5000);
  79. }
  80.  
  81. /* File-System testing Engine */
  82.  
  83. /* Cache flagy */
  84. #define C_NONE 1
  85. #define C_THR  2
  86. #define C_FULL 3
  87. /* seq. flagy */
  88. #define S_RND 1
  89. #define S_FOR 2
  90. #define S_BACK 3
  91. /* access flagy */
  92. #define A_READ 1
  93. #define A_WRITE 2
  94. #define A_REWRITE 3
  95.  
  96. int OpenTF(HFILE *hnd,char *fn,int cache,int seq,int acc)
  97. {
  98.  APIRET rc;
  99.  ULONG act;
  100.  ULONG omode;
  101.  /* acc flahy */
  102.  if (acc==A_READ) omode=OPEN_ACCESS_READONLY;
  103.           else    omode=OPEN_ACCESS_READWRITE;
  104.  /* cache flagy */
  105.  if (cache==C_THR) omode=omode|OPEN_FLAGS_WRITE_THROUGH;
  106.  if (cache==C_NONE) omode=omode|OPEN_FLAGS_NO_CACHE;
  107.  /* seq. flagy */
  108.  if (seq==S_RND) omode=omode|OPEN_FLAGS_RANDOM;
  109.  if (seq==S_FOR) omode=omode|OPEN_FLAGS_SEQUENTIAL;
  110.  if (seq==S_BACK) omode=omode|OPEN_FLAGS_RANDOMSEQUENTIAL;
  111.  
  112.  rc=DosOpen(fn,hnd,&act,0,FILE_NORMAL,OPEN_ACTION_FAIL_IF_NEW|
  113.     OPEN_ACTION_OPEN_IF_EXISTS,omode|OPEN_FLAGS_FAIL_ON_ERROR|
  114.     OPEN_SHARE_DENYREADWRITE,NULL);
  115.  return rc;       
  116. }            
  117.  
  118. int EngineFT(char *fn, unsigned long fs,unsigned long blocksize,
  119.            unsigned long times,int cache, int seq,int acc,double *etime)
  120. {
  121.  APIRET rc;
  122.  unsigned long loop;
  123.  void *buff;
  124.  ULONG bread;
  125. /* unsigned long times2;*/
  126.  double t1,t2;
  127.  struct timeval tv;
  128. /* times2=times;*/
  129.  if((rc=OpenTF(&h,fn,cache,seq,acc))) return 1;
  130. /* printf("File handle je %ld\n",h);*/
  131. /* printf("%ld Blocks/loop\n",fs/blocksize);*/
  132. /*printf("Blocksize: %ld\n",blocksize);*/
  133.  buff=malloc(blocksize);
  134.  if(!buff) return 5;
  135.  srand(1);
  136.  if(gettimeofday(&tv,NULL)) return 6;
  137.  t1=tv.tv_sec+tv.tv_usec/1000000.0;
  138. /* printf("Start: %f\n",t1);*/
  139.  while (times>0)
  140.  {
  141.   loop=fs/blocksize;
  142. /*  printf("%ld blocks to go\n",times);*/
  143.   if(seq==S_FOR) if(DosSetFilePtr(h,0,FILE_BEGIN,&bread)) { DosClose(h);h=0;free(buff);return 2;}
  144.   if(seq==S_BACK) if(DosSetFilePtr(h,-blocksize,FILE_END,&bread)) { DosClose(h);h=0;free(buff);return 2;}
  145.  
  146.   while ((times>0)&&(loop>0))
  147.   {
  148.    if (acc==A_READ) if(DosRead(h,buff,blocksize,&bread)) { DosClose(h);h=0;free(buff);return 3;}
  149.    if (acc==A_WRITE) if(DosWrite(h,buff,blocksize,&bread)) { DosClose(h);h=0;free(buff);return 3;}
  150.    if (acc==A_REWRITE)
  151.           {
  152.            if(DosRead(h,buff,blocksize,&bread)) { DosClose(h);h=0;free(buff);return 3;}
  153.            if(DosSetFilePtr(h,-blocksize,FILE_CURRENT,&bread)) { DosClose(h);h=0;free(buff);return 2;}
  154.            if(DosWrite(h,buff,blocksize,&bread)) { DosClose(h);h=0;free(buff);return 3;}
  155.           }
  156.    if(bread<blocksize-2) { DosClose(h);h=0;free(buff);return 4;}
  157. /* printf("%ld.",bread);*/
  158.    loop--;
  159.    times--;
  160.    if(seq==S_BACK) if(DosSetFilePtr(h,-blocksize*2,FILE_CURRENT,&bread)) { DosClose(h);free(buff);return 2;};
  161.    if(seq==S_RND) { 
  162.                    if(DosSetFilePtr(h,blocksize*(rand()/(1+(RAND_MAX/(fs/blocksize)))),FILE_BEGIN,&bread)) 
  163.                      { DosClose(h);h=0;free(buff);return 2;}
  164. /*                 printf("NP: %ld",bread);*/
  165.                   }
  166.   };
  167.  };  
  168.  if(gettimeofday(&tv,NULL)) return 6; 
  169.  t2=tv.tv_sec+tv.tv_usec/1000000.0;
  170. /* printf("Stop : %f\n",t2);*/
  171.  *etime=t2-t1;
  172. /*printf("  time %.2fs - ",t2-t1);*/
  173. /* printf("Precteno %ld K bajtu\n",times2*blocksize/1024L);*/
  174. /* printf("Transfer speed %.1f KB/s\n",((blocksize*times2)/1024L)/(t2-t1));*/
  175.  DosClose(h);
  176.  h=0;
  177.  free(buff);
  178.  return rc;
  179. } 
  180.  
  181. unsigned long pnumb(const char *n)
  182. {
  183.  int i;
  184.  unsigned long res;
  185.  res=0;
  186.  for (i=0;i<strlen(n);i++)
  187.    {
  188.    if (isdigit(n[i])) {
  189.                         res=res*10+((n[i])-'0');
  190.                         continue;
  191.                       }
  192.    if (toupper(n[i])=='K')
  193.                       {
  194.                        res=res*1024;
  195.                        continue;
  196.                       }
  197.                       
  198.    if (toupper(n[i])=='M')
  199.                       {
  200.                        res=res*1024*1024;
  201.                        continue;
  202.                       }
  203.                                         
  204.    }                       
  205.    return res;
  206. } 
  207. int config(void)
  208. {
  209.   FILE *c;
  210.   char *line;
  211.   char *keyw;
  212.   char *ar,*tmp;
  213.   unsigned long fs;
  214.   int i,j,n,p;
  215.   double etime,timer;
  216.   unsigned long blocksize;
  217.   unsigned long times;
  218.   int cache, seq, acc;
  219.  
  220.   c=fopen("fsbench.cnf","rt");
  221.   if (c==NULL) return 1;
  222.   if(DosQuerySysInfo(QSV_TIMER_INTERVAL,QSV_TIMER_INTERVAL,×,4)) return 2;
  223.   timer=(times/10.0)/1000.0;
  224. /*  printf("Timer=%f\n",timer);*/
  225.   line=malloc(2048);
  226.   ar  =malloc(2048);
  227.   keyw=malloc(2048);
  228.   fn=malloc(256);
  229.   tmp=malloc(2048);
  230.   if((!line)||(!ar)||(!keyw)||(!fn)||(!tmp)) { free(line);free(ar);free(keyw);free(fn);
  231.                                 free(tmp);
  232.                                 fclose(c); return 2;}
  233.   printf("\nAction  Direction   cache    times    blocksize   time   Filesystem speed\n");
  234.   printf("-------------------------------------------------------------------------------\n");
  235.   strcpy(fn,"fsbench.tmp");
  236.   fs=8*1024*1024;
  237.   while ((EOF!=fscanf(c,"%[^\n]%*[\n]",line)))
  238.     {
  239.     if (line[0]==';') continue;
  240. /*    printf("!%s\n",line);*/
  241.     /* predej param */
  242.     strcpy(keyw,"");
  243.     strcpy(ar,"");
  244.     sscanf(line,"%s %[^\n]",keyw,ar);
  245. /*  printf("KW: %s\nARG: %s\n",keyw,ar);*/
  246.     if (!stricmp(keyw,"SIZE")) fs=pnumb(ar);
  247.     if (!stricmp(keyw,"NAME")) strcpy(fn,ar);
  248.     if (!stricmp(keyw,"CREATE")) CreateTestFile(fn,fs);
  249.     if (!stricmp(keyw,"DELETE")) DeleteTestFile(fn);
  250.     if (!stricmp(keyw,"SAY")) printf("\n%s\n",ar);
  251.     if (!stricmp(keyw,"TEST"))
  252.     { 
  253.       j=0;n=1;acc=0;seq=0;cache=0;p=0;
  254.       times=0;blocksize=0;
  255.       /* pridam mezeru na konec */
  256.       ar[strlen(ar)+1]='\0';
  257.       ar[strlen(ar)]=' ';
  258.       for(i=0;i<strlen(ar);i++)
  259.         {  
  260.           if (ar[i]!=' ') {tmp[j++]=ar[i];p=0;continue;}
  261.           if (p==1) continue;
  262.           tmp[j]='\0';j=0;
  263.           /* ted'ka to zpracuju */
  264.           switch(n)
  265.           {
  266.            case 1: blocksize=pnumb(tmp);break;
  267.            case 2: times=pnumb(tmp);break;
  268.            case 3: if (tmp[0]=='R') acc=A_READ;
  269.                    if (tmp[0]=='W') acc=A_WRITE;
  270.                    if (tmp[0]=='E') acc=A_REWRITE;
  271.                    break;
  272.            case 4: if (tmp[0]=='F') seq=S_FOR;
  273.                    if (tmp[0]=='B') seq=S_BACK;
  274.                    if (tmp[0]=='R') seq=S_RND;
  275.                    break;
  276.            case 5: if (tmp[0]=='F') cache=C_FULL;
  277.                    if (tmp[0]=='N') cache=C_NONE;
  278.                    if (tmp[0]=='W') cache=C_THR;
  279.                    break;
  280.           }
  281.           n++;p=1;
  282.         }  
  283.        if ((!acc)||(!seq)||(!cache)||(!blocksize)||(!times)) continue;
  284.        sync();
  285.        /* vytiskni co delas */
  286.        switch(acc)
  287.        {
  288.        case A_READ   : printf("Read     ");break;
  289.        case A_WRITE  : printf("Write    ");break;
  290.        case A_REWRITE: printf("Rewrite  ");
  291.        }
  292.        switch(seq)
  293.        {
  294.        case S_FOR : printf("Forward  ");break;
  295.        case S_BACK: printf("Backward ");break;
  296.        case S_RND:  printf("Random   ");
  297.        }
  298.        switch(cache)
  299.        {
  300.        case C_FULL:  printf("use cache ");break;
  301.        case C_NONE:  printf("no cache  ");break;
  302.        case C_THR:   printf("w through ");
  303.        }
  304.        printf("%6ldx ",times);
  305.        printf("%5ld bytes ",blocksize);
  306.        j=EngineFT(fn,fs,blocksize,times,cache,seq,acc,&etime);
  307.        if(j) printf ("ERROR(%d)\n",j);
  308.         else
  309.         { 
  310.          printf("%6.2fs ",etime);
  311.          printf("(%6.0f ",(blocksize*times/1024)/etime);
  312.          /* pocitani chyby mereni v KB */
  313.          printf("+/- %5.1f) KB/s\n",(((blocksize*times/1024)/(etime-timer))-
  314.                 ((blocksize*times/1024)/(etime+timer)))/2);
  315.         } 
  316.     }
  317.     if(EOF==(i=getc(c))) break;
  318.                   else 
  319.                     ungetc(i,c);
  320.  
  321.     
  322. /*  if (eof(c)) break;*/
  323.     }
  324. /*printf("FSIZE=%ld\n",fs);  */
  325.   free(line);free(ar);free(keyw);free(fn);free(tmp);
  326.   fclose(c);
  327.   return 0;
  328. }
  329.  
  330. void Uklid(int i)
  331. {
  332.  printf("\nEmergency exit..\n");
  333.  if (h) { DosClose(h);}
  334.  DosForceDelete(fn);
  335.  exit(255);
  336. /* signal(i,SIG_ACK);*/
  337. }
  338.  
  339. void main(void)
  340. {
  341.  if(DosSetPriority(PRTYS_PROCESS,PRTYC_FOREGROUNDSERVER,PRTYD_MAXIMUM,0)) 
  342.   printf("Error setting priority\n");
  343.  if(SIG_ERR==signal(SIGINT,Uklid)) printf("Error catching signal SIGINT\n"); 
  344.  printf("File system benchmark program, version "FSBENCH_V"\n");
  345.  printf("Compiled "__DATE__" using GCC "__VERSION__"\n");
  346.  config();
  347.  return;
  348. }
  349.