tcutest.c

高性能嵌入式数据库在高并发的环境下使用最好是64位系统比较好

    char buf[RECBUFSIZ];
    int len = sprintf(buf, "%08d", rnd ? myrand(rnum) + 1 : i);
    switch(dmode){
    case -1:
      tctreeputkeep(tree, buf, len, buf, len);
      break;
    case 1:
      tctreeputcat(tree, buf, len, buf, len);
      break;
    case 10:
      tctreeaddint(tree, buf, len, myrand(3));
      break;
    case 11:
      tctreeadddouble(tree, buf, len, myrand(3));
      break;
    default:
      tctreeput(tree, buf, len, buf, len);
      break;
    }
    if(rnum > 250 && i % (rnum / 250) == 0){
      iputchar('.');
      if(i == rnum || i % (rnum / 10) == 0) iprintf(" (%08d)\n", i);
    }
  }
  if(rd){
    double itime = tctime();
    iprintf("time: %.3f\n", itime - stime);
    stime = itime;
    for(int i = 1; i <= rnum; i++){
      char buf[RECBUFSIZ];
      int len = sprintf(buf, "%08d", rnd ? myrand(rnum) + 1 : i);
      tctreeget(tree, buf, len, &len);
      if(rnum > 250 && i % (rnum / 250) == 0){
        iputchar('.');
        if(i == rnum || i % (rnum / 10) == 0) iprintf(" (%08d)\n", i);
      }
    }
  }
  if(tr){
    double itime = tctime();
    iprintf("time: %.3f\n", itime - stime);
    stime = itime;
    tctreeiterinit(tree);
    int ksiz;
    const char *kbuf;
    int inum = 1;
    while((kbuf = tctreeiternext(tree, &ksiz)) != NULL){
      tctreeiterval2(kbuf);
      if(rnum > 250 && inum % (rnum / 250) == 0){
        iputchar('.');
        if(inum == rnum || inum % (rnum / 10) == 0) iprintf(" (%08d)\n", inum);
      }
      inum++;
    }
    if(rnd && rnum > 250) iprintf(" (%08d)\n", inum);
  }
  iprintf("record number: %llu\n", (unsigned long long)tctreernum(tree));
  iprintf("size: %llu\n", (unsigned long long)tctreemsiz(tree));
  tctreedel(tree);
  iprintf("time: %.3f\n", tctime() - stime);
  iprintf("ok\n\n");
  return 0;
}


/* perform mdb command */
static int procmdb(int rnum, int bnum, bool rd, bool tr, bool rnd, int dmode){
  iprintf("<On-memory Hash Database Writing Test>\n  rnum=%d  bnum=%d  rd=%d  tr=%d  rnd=%d"
          "  dmode=%d\n\n", rnum, bnum, rd, tr, rnd, dmode);
  double stime = tctime();
  TCMDB *mdb = (bnum > 0) ? tcmdbnew2(bnum) : tcmdbnew();
  for(int i = 1; i <= rnum; i++){
    char buf[RECBUFSIZ];
    int len = sprintf(buf, "%08d", rnd ? myrand(rnum) + 1 : i);
    switch(dmode){
    case -1:
      tcmdbputkeep(mdb, buf, len, buf, len);
      break;
    case 1:
      tcmdbputcat(mdb, buf, len, buf, len);
      break;
    case 10:
      tcmdbaddint(mdb, buf, len, myrand(3));
      break;
    case 11:
      tcmdbadddouble(mdb, buf, len, myrand(3));
      break;
    default:
      tcmdbput(mdb, buf, len, buf, len);
      break;
    }
    if(rnum > 250 && i % (rnum / 250) == 0){
      iputchar('.');
      if(i == rnum || i % (rnum / 10) == 0) iprintf(" (%08d)\n", i);
    }
  }
  if(rd){
    double itime = tctime();
    iprintf("time: %.3f\n", itime - stime);
    stime = itime;
    for(int i = 1; i <= rnum; i++){
      char buf[RECBUFSIZ];
      int len = sprintf(buf, "%08d", rnd ? myrand(rnum) + 1 : i);
      tcfree(tcmdbget(mdb, buf, len, &len));
      if(rnum > 250 && i % (rnum / 250) == 0){
        iputchar('.');
        if(i == rnum || i % (rnum / 10) == 0) iprintf(" (%08d)\n", i);
      }
    }
  }
  if(tr){
    double itime = tctime();
    iprintf("time: %.3f\n", itime - stime);
    stime = itime;
    tcmdbiterinit(mdb);
    int ksiz;
    char *kbuf;
    int inum = 1;
    while((kbuf = tcmdbiternext(mdb, &ksiz)) != NULL){
      tcfree(kbuf);
      if(rnum > 250 && inum % (rnum / 250) == 0){
        iputchar('.');
        if(inum == rnum || inum % (rnum / 10) == 0) iprintf(" (%08d)\n", inum);
      }
      inum++;
    }
    if(rnd && rnum > 250) iprintf(" (%08d)\n", inum);
  }
  iprintf("record number: %llu\n", (unsigned long long)tcmdbrnum(mdb));
  iprintf("size: %llu\n", (unsigned long long)tcmdbmsiz(mdb));
  tcmdbdel(mdb);
  iprintf("time: %.3f\n", tctime() - stime);
  iprintf("ok\n\n");
  return 0;
}


/* perform ndb command */
static int procndb(int rnum, bool rd, bool tr, bool rnd, int dmode){
  iprintf("<On-memory Tree Database Writing Test>\n  rnum=%d  rd=%d  tr=%d  rnd=%d  dmode=%d\n\n",
          rnum, rd, tr, rnd, dmode);
  double stime = tctime();
  TCNDB *ndb = tcndbnew();
  for(int i = 1; i <= rnum; i++){
    char buf[RECBUFSIZ];
    int len = sprintf(buf, "%08d", rnd ? myrand(rnum) + 1 : i);
    switch(dmode){
    case -1:
      tcndbputkeep(ndb, buf, len, buf, len);
      break;
    case 1:
      tcndbputcat(ndb, buf, len, buf, len);
      break;
    case 10:
      tcndbaddint(ndb, buf, len, myrand(3));
      break;
    case 11:
      tcndbadddouble(ndb, buf, len, myrand(3));
      break;
    default:
      tcndbput(ndb, buf, len, buf, len);
      break;
    }
    if(rnum > 250 && i % (rnum / 250) == 0){
      iputchar('.');
      if(i == rnum || i % (rnum / 10) == 0) iprintf(" (%08d)\n", i);
    }
  }
  if(rd){
    double itime = tctime();
    iprintf("time: %.3f\n", itime - stime);
    stime = itime;
    for(int i = 1; i <= rnum; i++){
      char buf[RECBUFSIZ];
      int len = sprintf(buf, "%08d", rnd ? myrand(rnum) + 1 : i);
      tcfree(tcndbget(ndb, buf, len, &len));
      if(rnum > 250 && i % (rnum / 250) == 0){
        iputchar('.');
        if(i == rnum || i % (rnum / 10) == 0) iprintf(" (%08d)\n", i);
      }
    }
  }
  if(tr){
    double itime = tctime();
    iprintf("time: %.3f\n", itime - stime);
    stime = itime;
    tcndbiterinit(ndb);
    int ksiz;
    char *kbuf;
    int inum = 1;
    while((kbuf = tcndbiternext(ndb, &ksiz)) != NULL){
      tcfree(kbuf);
      if(rnum > 250 && inum % (rnum / 250) == 0){
        iputchar('.');
        if(inum == rnum || inum % (rnum / 10) == 0) iprintf(" (%08d)\n", inum);
      }
      inum++;
    }
    if(rnd && rnum > 250) iprintf(" (%08d)\n", inum);
  }
  iprintf("record number: %llu\n", (unsigned long long)tcndbrnum(ndb));
  iprintf("size: %llu\n", (unsigned long long)tcndbmsiz(ndb));
  tcndbdel(ndb);
  iprintf("time: %.3f\n", tctime() - stime);
  iprintf("ok\n\n");
  return 0;
}


/* perform misc command */
static int procmisc(int rnum){
  iprintf("<Miscellaneous Test>\n  rnum=%d\n\n", rnum);
  double stime = tctime();
  bool err = false;
  for(int i = 1; i <= rnum && !err; i++){
    const char *str = "5%2+3-1=4 \"Yes/No\" <a&b>";
    int slen = strlen(str);
    char *buf, *dec;
    int bsiz, dsiz, jl;
    time_t date, ddate;
    TCXSTR *xstr;
    TCLIST *list;
    TCMAP *map;
    TCTREE *tree;
    TCPTRLIST *ptrlist;
    buf = tcmemdup(str, slen);
    xstr = tcxstrfrommalloc(buf, slen);
    buf = tcxstrtomalloc(xstr);
    if(strcmp(buf, str)) err = true;
    tcfree(buf);
    if(tclmax(1, 2) != 2) err = true;
    if(tclmin(1, 2) != 1) err = true;
    tclrand();
    if(tcdrand() >= 1.0) err = true;
    tcdrandnd(50, 10);
    if(tcstricmp("abc", "ABC") != 0) err = true;
    if(!tcstrfwm("abc", "ab") || !tcstrifwm("abc", "AB")) err = true;
    if(!tcstrbwm("abc", "bc") || !tcstribwm("abc", "BC")) err = true;
    if(tcstrdist("abcde", "abdfgh") != 4 || tcstrdist("abdfgh", "abcde") != 4) err = true;
    if(tcstrdistutf("abcde", "abdfgh") != 4 || tcstrdistutf("abdfgh", "abcde") != 4) err = true;
    buf = tcmemdup("abcde", 5);
    tcstrtoupper(buf);
    if(strcmp(buf, "ABCDE")) err = true;
    tcstrtolower(buf);
    if(strcmp(buf, "abcde")) err = true;
    tcfree(buf);
    buf = tcmemdup("  ab  cd  ", 10);
    tcstrtrim(buf);
    if(strcmp(buf, "ab  cd")) err = true;
    tcstrsqzspc(buf);
    if(strcmp(buf, "ab cd")) err = true;
    tcstrsubchr(buf, "cd", "C");
    if(strcmp(buf, "ab C")) err = true;
    if(tcstrcntutf(buf) != 4) err = true;
    tcstrcututf(buf, 2);
    if(strcmp(buf, "ab")) err = true;
    tcfree(buf);
    if(i % 10 == 1){
      int anum = myrand(30);
      uint16_t ary[anum+1];
      for(int j = 0; j < anum; j++){
        ary[j] = myrand(65535) + 1;
      }
      char ustr[anum*3+1];
      tcstrucstoutf(ary, anum, ustr);
      uint16_t dary[anum+1];
      int danum;
      tcstrutftoucs(ustr, dary, &danum);
      if(danum != anum){
        err = true;
      } else {
        for(int j = 0; j < danum; j++){
          if(dary[j] != dary[j]) err = true;
        }
      }
      list = tcstrsplit(",a,b..c,d,", ",.");
      if(tclistnum(list) != 7) err = true;
      buf = tcstrjoin(list, ':');
      if(strcmp(buf, ":a:b::c:d:")) err = true;
      tcfree(buf);
      tclistdel(list);
      if(!tcregexmatch("ABCDEFGHI", "*(b)c[d-f]*g(h)")) err = true;
      buf = tcregexreplace("ABCDEFGHI", "*(b)c[d-f]*g(h)", "[\\1][\\2][&]");
      if(strcmp(buf, "A[B][H][BCDEFGH]I")) err = true;
      tcfree(buf);
      buf = tcmalloc(48);
      for(int i = 0; i < 10; i++){
        char kbuf[RECBUFSIZ];
        int ksiz = sprintf(kbuf, "%d", myrand(1000000));
        tcmd5hash(kbuf, ksiz, buf);
      }
      tcfree(buf);
      TCCHIDX *chidx = tcchidxnew(5);
      for(int i = 0; i < 10; i++){
        char kbuf[RECBUFSIZ];
        int ksiz = sprintf(kbuf, "%d", myrand(1000000));
        tcchidxhash(chidx, kbuf, ksiz);
      }
      tcchidxdel(chidx);
      buf = tczeromap(myrand(1024*256) + 1);
      tczerounmap(buf);
    }
    buf = tcmalloc(48);
    date = myrand(INT_MAX - 1000000);
    jl = 3600 * (myrand(23) - 11);
    tcdatestrwww(date, jl, buf);
    ddate = tcstrmktime(buf);
    if(ddate != date) err = true;
    tcdatestrhttp(date, jl, buf);
    ddate = tcstrmktime(buf);
    if(ddate != date) err = true;
    tcfree(buf);
    if(i % 100 == 1){
      map = myrand(2) == 0 ? tcmapnew() : tcmapnew2(myrand(10));
      tree = tctreenew();
      for(int j = 0; j < 10; j++){
        char kbuf[RECBUFSIZ];
        int ksiz = sprintf(kbuf, "%d", myrand(10));
        tcmapaddint(map, kbuf, ksiz, 1);
        const char *vbuf = tcmapget2(map, kbuf);
        if(*(int *)vbuf < 1) err = true;
        tctreeaddint(tree, kbuf, ksiz, 1);
        vbuf = tctreeget2(tree, kbuf);
        if(*(int *)vbuf < 1) err = true;
      }
      tcmapclear(map);
      tctreeclear(tree);
      for(int j = 0; j < 10; j++){
        char kbuf[RECBUFSIZ];
        int ksiz = sprintf(kbuf, "%d", myrand(10));
        tcmapadddouble(map, kbuf, ksiz, 1.0);
        const char *vbuf = tcmapget2(map, kbuf);
        if(*(double *)vbuf < 1.0) err = true;
        tctreeadddouble(tree, kbuf, ksiz, 1.0);
        vbuf = tctreeget2(tree, kbuf);
        if(*(double *)vbuf < 1.0) err = true;
      }
      tctreedel(tree);
      tcmapdel(map);
    }
    if(i % 100 == 1){
      ptrlist = myrand(2) == 0 ? tcptrlistnew() : tcptrlistnew2(myrand(10));
      for(int j = 0; j < 10; j++){
        tcptrlistpush(ptrlist, tcsprintf("%d", j));
        tcptrlistunshift(ptrlist, tcsprintf("::%d", j));
      }
      for(int j = 0; j < 5; j++){
        tcfree(tcptrlistpop(ptrlist));
        tcfree(tcptrlistshift(ptrlist));
      }
      for(int j = 0; j < tcptrlistnum(ptrlist); j++){
        tcfree(tcptrlistval(ptrlist, j));
      }
      tcptrlistdel(ptrlist);
    }
    buf = tcurlencode(str, slen);
    if(strcmp(buf, "5%252%2B3-1%3D4%20%22Yes%2FNo%22%20%3Ca%26b%3E")) err = true;
    dec = tcurldecode(buf, &dsiz);
    if(dsiz != slen || strcmp(dec, str)) err = true;
    tcfree(dec);
    tcfree(buf);
    if(i % 10 == 1){
      map = tcurlbreak("http://mikio:[e-mail]:1978/foo/bar/baz.cgi?ab=cd&ef=jkl#quux");
      const char *elem;
      if(!(elem = tcmapget2(map, "self")) ||
         strcmp(elem, "http://mikio:[e-mail]:1978/foo/bar/baz.cgi?ab=cd&ef=jkl#quux"))
        err = true;
      if(!(elem = tcmapget2(map, "scheme")) || strcmp(elem, "http")) err = true;
      if(!(elem = tcmapget2(map, "host")) || strcmp(elem, "estraier.net")) err = true;
      if(!(elem = tcmapget2(map, "port")) || strcmp(elem, "1978")) err = true;
      if(!(elem = tcmapget2(map, "authority")) || strcmp(elem, "mikio:oikim")) err = true;
      if(!(elem = tcmapget2(map, "path")) || strcmp(elem, "/foo/bar/baz.cgi")) err = true;
      if(!(elem = tcmapget2(map, "file")) || strcmp(elem, "baz.cgi")) err = true;
      if(!(elem = tcmapget2(map, "query")) || strcmp(elem, "ab=cd&ef=jkl")) err = true;
      if(!(elem = tcmapget2(map, "fragment")) || strcmp(elem, "quux")) err = true;
      tcmapdel(map);
      buf = tcurlresolve("http://a:b@c.d:1/e/f/g.h?i=j#k", "http://A:B@C.D:1/E/F/G.H?I=J#K");
      if(strcmp(buf, "http://A:B@c.d:1/E/F/G.H?I=J#K")) err = true;
      tcfree(buf);
      buf = tcurlresolve("http://a:b@c.d:1/e/f/g.h?i=j#k", "/E/F/G.H?I=J#K");
      if(strcmp(buf, "http://a:b@c.d:1/E/F/G.H?I=J#K")) err = true;
      tcfree(buf);
      buf = tcurlresolve("http://a:b@c.d:1/e/f/g.h?i=j#k", "G.H?I=J#K");
      if(strcmp(buf, "http://a:b@c.d:1/e/f/G.H?I=J#K")) err = true;
      tcfree(buf);
      buf = tcurlresolve("http://a:b@c.d:1/e/f/g.h?i=j#k", "?I=J#K");
      if(strcmp(buf, "http://a:b@c.d:1/e/f/g.h?I=J#K")) err = true;
      tcfree(buf);
      buf = tcurlresolve("http://a:b@c.d:1/e/f/g.h?i=j#k", "#K");
      if(strcmp(buf, "http://a:b@c.d:1/e/f/g.h?i=j#K")) err = true;
      tcfree(buf);
    }
    buf = tcbaseencode(str, slen);
    if(strcmp(buf, "NSUyKzMtMT00ICJZZXMvTm8iIDxhJmI+")) err = true;
    dec = tcbasedecode(buf, &dsiz);
    if(dsiz != slen || strcmp(dec, str)) err = true;
    tcfree(dec);
    tcfree(buf);
    buf = tcquoteencode(str, slen);
    if(strcmp(buf, "5%2+3-1=3D4 \"Yes/No\" <a&b>")) err = true;
    dec = tcquotedecode(buf, &dsiz);
    if(dsiz != slen || strcmp(dec, str)) err = true;
    tcfree(dec);
    tcfree(buf);
    buf = tcmimeencode(str, "UTF-8", true);
    if(strcmp(buf, "=?UTF-8?B?NSUyKzMtMT00ICJZZXMvTm8iIDxhJmI+?=")) err = true;
    char encname[32];
    dec = tcmimedecode(buf, encname);
    if(strcmp(dec, str) || strcmp(encname, "UTF-8")) err = true;
    tcfree(dec);
    tcfree(buf);
    if(i % 10 == 1){
      const char *mstr = "Subject: Hello\r\nContent-Type: multipart/mixed; boundary=____\r\n\r\n"
        "\r\n--____\r\nThis is a pen.\r\n--____\r\nIs this your bag?\r\n--____--\r\n";
      map = tcmapnew2(10);
      char *buf = tcmimebreak(mstr, strlen(mstr), map, &bsiz);
      const char *boundary = tcmapget2(map, "BOUNDARY");
      if(boundary){
        list = tcmimeparts(buf, bsiz, boundary);
        if(tclistnum(list) == 2){
          if(strcmp(tclistval2(list, 0), "This is a pen.")) err = true;
          if(strcmp(tclistval2(list, 1), "Is this your bag?")) err = true;
        } else {
          err = true;
        }
        tclistdel(list);
      } else {
        err = true;
      }
      tcfree(buf);
      tcmapdel(map);
    }
    buf = tcpackencode(str, slen, &bsiz);
    dec = tcpackdecode(buf, bsiz, &dsiz);
    if(dsiz != slen || strcmp(dec, str)) err = true;
    tcfree(dec);
    tcfree(buf);
    buf = tcbsencode(str, slen, &bsiz);
    dec = tcbsdecode(buf, bsiz, &dsiz);
    if(dsiz != slen || strcmp(dec, str)) err = true;
    tcfree(dec);
    tcfree(buf);
    int idx;
    buf = tcbwtencode(str, slen, &idx);
    if(memcmp(buf, "4\"o 5a23s-%+=> 1b/\"<&YNe", slen) || idx != 13) err = true;
    dec = tcbwtdecode(buf, slen, idx);
    if(memcmp(dec, str, slen)) err = true;
    tcfree(dec);
    tcfree(buf);
    if(_tc_deflate){
      if((buf = tcdeflate(str, slen, &bsiz)) != NULL){
        if((dec = tcinflate(buf, bsiz, &dsiz)) != NULL){
          if(slen != dsiz || memcmp(str, dec, dsiz)) err = true;
          tcfree(dec);
        } else {
          err = true;
        }
        tcfree(buf);
      } else {
        err = true;
      }
      if((buf = tcgzipencode(str, slen, &bsiz)) != NULL){
        if((dec = tcgzipdecode(buf, bsiz, &dsiz)) != NULL){
          if(slen != dsiz || memcmp(str, dec, dsiz)) err = true;
          tcfree(dec);
        } else {
          err = true;
        }
        tcfree(buf);
      } else {
        err = true;
      }
      if(tcgetcrc("hoge", 4) % 10000 != 7034) err = true;
    }
    if(_tc_bzcompress){
      if((buf = tcbzipencode(str, slen, &bsiz)) != NULL){
        if((dec = tcbzipdecode(buf, bsiz, &dsiz)) != NULL){
          if(slen != dsiz || memcmp(str, dec, dsiz)) err = true;
          tcfree(dec);
        } else {
          err = true;
        }
        tcfree(buf);
      } else {
        err = true;
      }
    }
    int anum = myrand(50)+1;
    unsigned int ary[anum];
    for(int j = 0; j < anum; j++){
      ary[j] = myrand(INT_MAX);
    }
    buf = tcberencode(ary, anum, &bsiz);
    int dnum;
    unsigned int *dary = tcberdecode(buf, bsiz, &dnum);
    if(anum != dnum || memcmp(ary, dary, sizeof(*dary) * dnum)) err = true;
    tcfree(dary);
    tcfree(buf);
    buf = tcxmlescape(str);
    if(strcmp(buf, "5%2+3-1=4 &quot;Yes/No&quot; &lt;a&amp;b&gt;")) err = true;
    dec = tcxmlunescape(buf);
    if(strcmp(dec, str)) err = true;
    tcfree(dec);
    tcfree(buf);
    if(i % 10 == 1){
      list = tcxmlbreak("<abc de=\"foo&amp;\" gh='&lt;bar&gt;'>xyz<br>\na<!--<mikio>--></abc>");
      for(int j = 0; j < tclistnum(list); j++){
        const char *elem = tclistval2(list, j);
        TCMAP *attrs = tcxmlattrs(elem);
        tcmapdel(attrs);
      }
      tclistdel(list);
    }