开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 数据库系统 > MySQL数据库 > 查看源码
test3.c
资源名称：mysql-4.1.16-win-src.zip　[点击查看]
上传用户：romrleung
上传日期：2022-05-23
资源大小：18897k
文件大小：11k
源码类别：

MySQL数据库

开发平台：

Visual C++

test3.c：源码内容
  1. /* Copyright (C) 2000 MySQL AB & MySQL Finland AB & TCX DataKonsult AB
  3.    This program is free software; you can redistribute it and/or modify
  4.    it under the terms of the GNU General Public License as published by
  5.    the Free Software Foundation; either version 2 of the License, or
  6.    (at your option) any later version.
  8.    This program is distributed in the hope that it will be useful,
  9.    but WITHOUT ANY WARRANTY; without even the implied warranty of
  10.    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
  11.    GNU General Public License for more details.
  13.    You should have received a copy of the GNU General Public License
  14.    along with this program; if not, write to the Free Software
  15.    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA */
  17. /* Test av locking */
  19. #ifndef __NETWARE__
  21. #include "nisam.h"
  22. #include <sys/types.h>
  23. #include <keycache.h>
  24. #ifdef HAVE_SYS_WAIT_H
  25. # include <sys/wait.h>
  26. #endif
  27. #ifndef WEXITSTATUS
  28. # define WEXITSTATUS(stat_val) ((unsigned)(stat_val) >> 8)
  29. #endif
  30. #ifndef WIFEXITED
  31. # define WIFEXITED(stat_val) (((stat_val) & 255) == 0)
  32. #endif
  35. #if defined(HAVE_LRAND48)
  36. #define rnd(X) (lrand48() % X)
  37. #define rnd_init(X) srand48(X)
  38. #else
  39. #define rnd(X) (random() % X)
  40. #define rnd_init(X) srandom(X)
  41. #endif
  44. const char *filename= "test3.ISM";
  45. uint tests=10,forks=10,key_cacheing=0,use_log=0;
  47. static void get_options(int argc, char *argv[]);
  48. void start_test(int id);
  49. int test_read(N_INFO *,int),test_write(N_INFO *,int,int),
  50.     test_update(N_INFO *,int,int),test_rrnd(N_INFO *,int);
  52. struct record {
  53.   char id[8];
  54.   uint32 nr;
  55.   char text[10];
  56. } record;
  59. int main(int argc,char **argv)
  60. {
  61.   int status,wait_ret;
  62.   uint i;
  63.   N_KEYDEF keyinfo[10];
  64.   N_RECINFO recinfo[10];
  65.   MY_INIT(argv[0]);
  67.   get_options(argc,argv);
  69.   keyinfo[0].seg[0].base.start=0;
  70.   keyinfo[0].seg[0].base.length=8;
  71.   keyinfo[0].seg[0].base.type=HA_KEYTYPE_TEXT;
  72.   keyinfo[0].seg[0].base.flag=HA_SPACE_PACK;
  73.   keyinfo[0].seg[1].base.type=0;
  74.   keyinfo[0].base.flag = (uint8) HA_PACK_KEY;
  75.   keyinfo[1].seg[0].base.start=8;
  76.   keyinfo[1].seg[0].base.length=sizeof(uint32);
  77.   keyinfo[1].seg[0].base.type=HA_KEYTYPE_LONG_INT;
  78.   keyinfo[1].seg[0].base.flag=0;
  79.   keyinfo[1].seg[1].base.type=0;
  80.   keyinfo[1].base.flag =HA_NOSAME;
  82.   recinfo[0].base.type=0;
  83.   recinfo[0].base.length=sizeof(record.id);
  84.   recinfo[1].base.type=0;
  85.   recinfo[1].base.length=sizeof(record.nr);
  86.   recinfo[2].base.type=0;
  87.   recinfo[2].base.length=sizeof(record.text);
  88.   recinfo[3].base.type=FIELD_LAST;
  90.   puts("- Creating isam-file");
  91.   my_delete(filename,MYF(0)); /* Remove old locks under gdb */
  92.   if (nisam_create(filename,2,&keyinfo[0],&recinfo[0],10000,0,0,0,0L))
  93.     exit(1);
  95.   rnd_init(0);
  96.   printf("- Starting %d processesn",forks); fflush(stdout);
  97.   for (i=0 ; i < forks; i++)
  98.   {
  99.     if (!fork())
  100.     {
  101.       start_test(i+1);
  102.       sleep(1);
  103.       return 0;
  104.     }
  105.     VOID(rnd(1));
  106.   }
  108.   for (i=0 ; i < forks ; i++)
  109.     while ((wait_ret=wait(&status)) && wait_ret == -1);
  110.   return 0;
  111. }
  114. static void get_options(argc,argv)
  115. int argc;
  116. char *argv[];
  117. {
  118.   char *pos,*progname;
  119.   DEBUGGER_OFF;
  121.   progname= argv[0];
  123.   while (--argc >0 && *(pos = *(++argv)) == '-' ) {
  124.     switch(*++pos) {
  125.     case 'l':
  126.       use_log=1;
  127.       break;
  128.     case 'f':
  129.       forks=atoi(++pos);
  130.       break;
  131.     case 't':
  132.       tests=atoi(++pos);
  133.       break;
  134.     case 'K': /* Use key cacheing */
  135.       key_cacheing=1;
  136.       break;
  137.     case 'A': /* All flags */
  138.       use_log=key_cacheing=1;
  139.       break;
  140.    case '?':
  141.     case 'I':
  142.     case 'V':
  143.       printf("%s  Ver 1.0 for %s at %sn",progname,SYSTEM_TYPE,MACHINE_TYPE);
  144.       puts("TCX Datakonsult AB, by Monty, for your professional usen");
  145.       puts("Test av locking with threadsn");
  146.       printf("Usage: %s [-?lKA] [-f#] [-t#]n",progname);
  147.       exit(0);
  148.     case '#':
  149.       DEBUGGER_ON;
  150.       DBUG_PUSH (++pos);
  151.       break;
  152.     default:
  153.       printf("Illegal option: '%c'n",*pos);
  154.       break;
  155.     }
  156.   }
  157.   return;
  158. }
  161. void start_test(int id)
  162. {
  163.   uint i;
  164.   int error,lock_type;
  165.   N_ISAMINFO isam_info;
  166.   N_INFO *file,*file1,*file2,*lock;
  168.   if (use_log)
  169.     nisam_log(1);
  170.   if (!(file1=nisam_open(filename,O_RDWR,HA_OPEN_WAIT_IF_LOCKED)) ||
  171.       !(file2=nisam_open(filename,O_RDWR,HA_OPEN_WAIT_IF_LOCKED)))
  172.   {
  173.     fprintf(stderr,"Can't open isam-file: %sn",filename);
  174.     exit(1);
  175.   }
  176.   if (key_cacheing && rnd(2) == 0)
  177.     init_key_cache(dflt_key_cache,512,65536L,0,0);
  178.   printf("Process %d, pid: %dn",id,(int) getpid()); fflush(stdout);
  180.   for (error=i=0 ; i < tests && !error; i++)
  181.   {
  182.     file= (rnd(2) == 1) ? file1 : file2;
  183.     lock=0 ; lock_type=0;
  184.     if (rnd(10) == 0)
  185.     {
  186.       if (nisam_lock_database(lock=(rnd(2) ? file1 : file2),
  187.    lock_type=(rnd(2) == 0 ? F_RDLCK : F_WRLCK)))
  188.       {
  189. fprintf(stderr,"%2d: start: Can't lock table %dn",id,my_errno);
  190. error=1;
  191. break;
  192.       }
  193.     }
  194.     switch (rnd(4)) {
  195.     case 0: error=test_read(file,id); break;
  196.     case 1: error=test_rrnd(file,id); break;
  197.     case 2: error=test_write(file,id,lock_type); break;
  198.     case 3: error=test_update(file,id,lock_type); break;
  199.     }
  200.     if (lock)
  201.       nisam_lock_database(lock,F_UNLCK);
  202.   }
  203.   if (!error)
  204.   {
  205.     nisam_info(file1,&isam_info,0);
  206.     printf("%2d: End of test.  Records:  %ld  Deleted:  %ldn",
  207.    id,isam_info.records,isam_info.deleted);
  208.     fflush(stdout);
  209.   }
  211.   nisam_close(file1);
  212.   nisam_close(file2);
  213.   if (use_log)
  214.     nisam_log(0);
  215.   if (error)
  216.   {
  217.     printf("%2d: Abortedn",id); fflush(stdout);
  218.     exit(1);
  219.   }
  220. }
  223. int test_read(N_INFO *file,int id)
  224. {
  225.   uint i,lock,found,next,prev;
  226.   ulong find;
  228.   lock=0;
  229.   if (rnd(2) == 0)
  230.   {
  231.     lock=1;
  232.     if (nisam_lock_database(file,F_RDLCK))
  233.     {
  234.       fprintf(stderr,"%2d: Can't lock table %dn",id,my_errno);
  235.       return 1;
  236.     }
  237.   }
  239.   found=next=prev=0;
  240.   for (i=0 ; i < 100 ; i++)
  241.   {
  242.     find=rnd(100000);
  243.     if (!nisam_rkey(file,record.id,1,(byte*) &find,
  244.  sizeof(find),HA_READ_KEY_EXACT))
  245.       found++;
  246.     else
  247.     {
  248.       if (my_errno != HA_ERR_KEY_NOT_FOUND)
  249.       {
  250. fprintf(stderr,"%2d: Got error %d from read in readn",id,my_errno);
  251. return 1;
  252.       }
  253.       else if (!nisam_rnext(file,record.id,1))
  254. next++;
  255.       else
  256.       {
  257. if (my_errno != HA_ERR_END_OF_FILE)
  258. {
  259.   fprintf(stderr,"%2d: Got error %d from rnext in readn",id,my_errno);
  260.   return 1;
  261. }
  262. else if (!nisam_rprev(file,record.id,1))
  263.   prev++;
  264. else
  265. {
  266.   if (my_errno != HA_ERR_END_OF_FILE)
  267.   {
  268.     fprintf(stderr,"%2d: Got error %d from rnext in readn",
  269.     id,my_errno);
  270.     return 1;
  271.   }
  272. }
  273.       }
  274.     }
  275.   }
  276.   if (lock)
  277.   {
  278.     if (nisam_lock_database(file,F_UNLCK))
  279.     {
  280.       fprintf(stderr,"%2d: Can't unlock tablen",id);
  281.       return 1;
  282.     }
  283.   }
  284.   printf("%2d: read:   found: %5d  next: %5d   prev: %5dn",
  285.  id,found,next,prev);
  286.   fflush(stdout);
  287.   return 0;
  288. }
  291. int test_rrnd(N_INFO *file,int id)
  292. {
  293.   uint count,lock;
  295.   lock=0;
  296.   if (rnd(2) == 0)
  297.   {
  298.     lock=1;
  299.     if (nisam_lock_database(file,F_RDLCK))
  300.     {
  301.       fprintf(stderr,"%2d: Can't lock table (%d)n",id,my_errno);
  302.       nisam_close(file);
  303.       return 1;
  304.     }
  305.     if (rnd(2) == 0)
  306.       nisam_extra(file,HA_EXTRA_CACHE);
  307.   }
  309.   count=0;
  310.   if (nisam_rrnd(file,record.id,0L))
  311.   {
  312.     if (my_errno == HA_ERR_END_OF_FILE)
  313.       goto end;
  314.     fprintf(stderr,"%2d: Can't read first record (%d)n",id,my_errno);
  315.     return 1;
  316.   }
  317.   for (count=1 ; !nisam_rrnd(file,record.id,NI_POS_ERROR) ;count++) ;
  318.   if (my_errno != HA_ERR_END_OF_FILE)
  319.   {
  320.     fprintf(stderr,"%2d: Got error %d from rrndn",id,my_errno);
  321.     return 1;
  322.   }
  324. end:
  325.   if (lock)
  326.   {
  327.     nisam_extra(file,HA_EXTRA_NO_CACHE);
  328.     if (nisam_lock_database(file,F_UNLCK))
  329.     {
  330.       fprintf(stderr,"%2d: Can't unlock tablen",id);
  331.       exit(0);
  332.     }
  333.   }
  334.   printf("%2d: rrnd:   %5dn",id,count); fflush(stdout);
  335.   return 0;
  336. }
  339. int test_write(N_INFO *file,int id,int lock_type)
  340. {
  341.   uint i,tries,count,lock;
  343.   lock=0;
  344.   if (rnd(2) == 0 || lock_type == F_RDLCK)
  345.   {
  346.     lock=1;
  347.     if (nisam_lock_database(file,F_WRLCK))
  348.     {
  349.       if (lock_type == F_RDLCK && my_errno == EDEADLK)
  350.       {
  351. printf("%2d: write:  deadlockn",id); fflush(stdout);
  352. return 0;
  353.       }
  354.       fprintf(stderr,"%2d: Can't lock table (%d)n",id,my_errno);
  355.       nisam_close(file);
  356.       return 1;
  357.     }
  358.     if (rnd(2) == 0)
  359.       nisam_extra(file,HA_EXTRA_WRITE_CACHE);
  360.   }
  362.   sprintf(record.id,"%7d",(int) getpid());
  363.   strmov(record.text,"Testing...");
  365.   tries=(uint) rnd(100)+10;
  366.   for (i=count=0 ; i < tries ; i++)
  367.   {
  368.     record.nr=rnd(80000)+20000;
  369.     if (!nisam_write(file,record.id))
  370.       count++;
  371.     else
  372.     {
  373.       if (my_errno != HA_ERR_FOUND_DUPP_KEY)
  374.       {
  375. fprintf(stderr,"%2d: Got error %d (errno %d) from writen",id,my_errno,
  376. errno);
  377. return 1;
  378.       }
  379.     }
  380.   }
  381.   if (lock)
  382.   {
  383.     nisam_extra(file,HA_EXTRA_NO_CACHE);
  384.     if (nisam_lock_database(file,F_UNLCK))
  385.     {
  386.       fprintf(stderr,"%2d: Can't unlock tablen",id);
  387.       exit(0);
  388.     }
  389.   }
  390.   printf("%2d: write:  %5dn",id,count); fflush(stdout);
  391.   return 0;
  392. }
  395. int test_update(N_INFO *file,int id,int lock_type)
  396. {
  397.   uint i,lock,found,next,prev,update;
  398.   ulong find;
  399.   struct record new_record;
  401.   lock=0;
  402.   if (rnd(2) == 0 || lock_type == F_RDLCK)
  403.   {
  404.     lock=1;
  405.     if (nisam_lock_database(file,F_WRLCK))
  406.     {
  407.       if (lock_type == F_RDLCK && my_errno == EDEADLK)
  408.       {
  409. printf("%2d: write:  deadlockn",id); fflush(stdout);
  410. return 0;
  411.       }
  412.       fprintf(stderr,"%2d: Can't lock table (%d)n",id,my_errno);
  413.       return 1;
  414.     }
  415.   }
  416.   bzero((char*) &new_record,sizeof(new_record));
  417.   strmov(new_record.text,"Updated");
  419.   found=next=prev=update=0;
  420.   for (i=0 ; i < 100 ; i++)
  421.   {
  422.     find=rnd(100000);
  423.     if (!nisam_rkey(file,record.id,1,(byte*) &find,
  424.  sizeof(find),HA_READ_KEY_EXACT))
  425.       found++;
  426.     else
  427.     {
  428.       if (my_errno != HA_ERR_KEY_NOT_FOUND)
  429.       {
  430. fprintf(stderr,"%2d: Got error %d from read in updaten",id,my_errno);
  431. return 1;
  432.       }
  433.       else if (!nisam_rnext(file,record.id,1))
  434. next++;
  435.       else
  436.       {
  437. if (my_errno != HA_ERR_END_OF_FILE)
  438. {
  439.   fprintf(stderr,"%2d: Got error %d from rnext in updaten",
  440.   id,my_errno);
  441.   return 1;
  442. }
  443. else if (!nisam_rprev(file,record.id,1))
  444.   prev++;
  445. else
  446. {
  447.   if (my_errno != HA_ERR_END_OF_FILE)
  448.   {
  449.     fprintf(stderr,"%2d: Got error %d from rnext in updaten",
  450.     id,my_errno);
  451.     return 1;
  452.   }
  453.   continue;
  454. }
  455.       }
  456.     }
  457.     memcpy_fixed(new_record.id,record.id,sizeof(record.id));
  458.     new_record.nr=rnd(20000)+40000;
  459.     if (!nisam_update(file,record.id,new_record.id))
  460.       update++;
  461.     else
  462.     {
  463.       if (my_errno != HA_ERR_RECORD_CHANGED &&
  464.   my_errno != HA_ERR_RECORD_DELETED &&
  465.   my_errno != HA_ERR_FOUND_DUPP_KEY)
  466.       {
  467. fprintf(stderr,"%2d: Got error %d from updaten",id,my_errno);
  468. return 1;
  469.       }
  470.     }
  471.   }
  472.   if (lock)
  473.   {
  474.     if (nisam_lock_database(file,F_UNLCK))
  475.     {
  476.       fprintf(stderr,"Can't unlock table,id, error%dn",my_errno);
  477.       return 1;
  478.     }
  479.   }
  480.   printf("%2d: update: %5dn",id,update); fflush(stdout);
  481.   return 0;
  482. }
  484. #else /* __NETWARE__ */
  486. #include <stdio.h>
  488. main()
  489. {
  490. fprintf(stderr,"this test has not been ported to NetWaren");
  491. return 0;
  492. }
  494. #endif /* __NETWARE__ */