?? tcbtest.c
字號:
} iprintf("writing:\n"); for(int i = 1; i <= rnum; i++){ char kbuf[RECBUFSIZ]; int ksiz = sprintf(kbuf, "[%d]", i); char vbuf[RECBUFSIZ]; int vsiz = i % RECBUFSIZ; memset(vbuf, '*', vsiz); if(!tcbdbputkeep(bdb, kbuf, ksiz, vbuf, vsiz)){ eprint(bdb, "tcbdbputkeep"); err = true; break; } if(vsiz < 1){ char tbuf[PATH_MAX]; for(int j = 0; j < PATH_MAX; j++){ tbuf[j] = myrand(0x100); } if(!tcbdbput(bdb, kbuf, ksiz, tbuf, PATH_MAX)){ eprint(bdb, "tcbdbput"); err = true; break; } } if(rnum > 250 && i % (rnum / 250) == 0){ iputchar('.'); if(i == rnum || i % (rnum / 10) == 0) iprintf(" (%08d)\n", i); } } iprintf("erasing:\n"); for(int i = 1; i <= rnum; i++){ if(i % 2 == 1){ char kbuf[RECBUFSIZ]; int ksiz = sprintf(kbuf, "[%d]", i); if(!tcbdbout(bdb, kbuf, ksiz)){ eprint(bdb, "tcbdbout"); err = true; break; } if(tcbdbout(bdb, kbuf, ksiz) || tcbdbecode(bdb) != TCENOREC){ eprint(bdb, "tcbdbout"); err = true; break; } } if(rnum > 250 && i % (rnum / 250) == 0){ iputchar('.'); if(i == rnum || i % (rnum / 10) == 0) iprintf(" (%08d)\n", i); } } iprintf("random writing and reopening:\n"); for(int i = 1; i <= rnum; i++){ if(myrand(10) == 0){ int ksiz, vsiz; char *kbuf, *vbuf; ksiz = (myrand(5) == 0) ? myrand(UINT16_MAX) : myrand(RECBUFSIZ); kbuf = tcmalloc(ksiz + 1); for(int j = 0; j < ksiz; j++){ kbuf[j] = 128 + myrand(128); } vsiz = (myrand(5) == 0) ? myrand(UINT16_MAX) : myrand(RECBUFSIZ); vbuf = tcmalloc(vsiz + 1); for(int j = 0; j < vsiz; j++){ vbuf[j] = myrand(256); } switch(myrand(5)){ case 0: if(!tcbdbput(bdb, kbuf, ksiz, vbuf, vsiz)){ eprint(bdb, "tcbdbput"); err = true; } break; case 1: if(!tcbdbputcat(bdb, kbuf, ksiz, vbuf, vsiz)){ eprint(bdb, "tcbdbputcat"); err = true; } break; case 2: if(!tcbdbputdup(bdb, kbuf, ksiz, vbuf, vsiz)){ eprint(bdb, "tcbdbputdup"); err = true; } break; case 3: if(!tcbdbputdupback(bdb, kbuf, ksiz, vbuf, vsiz)){ eprint(bdb, "tcbdbputdupback"); err = true; } break; default: if(!tcbdbout(bdb, kbuf, ksiz) && tcbdbecode(bdb) != TCENOREC){ eprint(bdb, "tcbdbout"); err = true; } break; } tcfree(vbuf); tcfree(kbuf); } else { char kbuf[RECBUFSIZ]; int ksiz = myrand(RECBUFSIZ); memset(kbuf, '@', ksiz); char vbuf[RECBUFSIZ]; int vsiz = myrand(RECBUFSIZ); memset(vbuf, '@', vsiz); if(!tcbdbput(bdb, kbuf, ksiz, vbuf, vsiz)){ eprint(bdb, "tcbdbputcat"); err = true; break; } } if(rnum > 250 && i % (rnum / 250) == 0){ iputchar('.'); if(i == rnum || i % (rnum / 10) == 0) iprintf(" (%08d)\n", i); } } if(!tcbdbclose(bdb)){ eprint(bdb, "tcbdbclose"); err = true; } if(!tcbdbopen(bdb, path, BDBOWRITER | omode)){ eprint(bdb, "tcbdbopen"); err = true; } iprintf("checking:\n"); for(int i = 1; i <= rnum; i++){ char kbuf[RECBUFSIZ]; int ksiz = sprintf(kbuf, "[%d]", i); int vsiz; char *vbuf = tcbdbget(bdb, kbuf, ksiz, &vsiz); if(i % 2 == 0){ if(!vbuf){ eprint(bdb, "tcbdbget"); err = true; break; } if(vsiz != i % RECBUFSIZ && vsiz != PATH_MAX){ eprint(bdb, "(validation)"); err = true; tcfree(vbuf); break; } } else { if(vbuf || tcbdbecode(bdb) != TCENOREC){ eprint(bdb, "(validation)"); err = true; tcfree(vbuf); break; } } tcfree(vbuf); if(rnum > 250 && i % (rnum / 250) == 0){ iputchar('.'); if(i == rnum || i % (rnum / 10) == 0) iprintf(" (%08d)\n", i); } } iprintf("writing:\n"); for(int i = 1; i <= rnum; i++){ char buf[RECBUFSIZ]; int len = sprintf(buf, "%08d", i); if(!tcbdbput(bdb, buf, len, buf, len)){ eprint(bdb, "tcbdbput"); err = true; break; } if(i % 10 == 0){ TCLIST *vals = tclistnew(); for(int j = myrand(5) + 1; j >= 0; j--){ tclistpush(vals, buf, len); } if(!tcbdbputdup3(bdb, buf, len, vals)){ eprint(bdb, "tcbdbput3"); err = true; break; } tclistdel(vals); } if(rnum > 250 && i % (rnum / 250) == 0){ iputchar('.'); if(i == rnum || i % (rnum / 10) == 0) iprintf(" (%08d)\n", i); } } iprintf("reading:\n"); for(int i = 1; i <= rnum; i++){ char kbuf[RECBUFSIZ]; int ksiz = sprintf(kbuf, "%08d", i); int vsiz; char *vbuf = tcbdbget(bdb, kbuf, ksiz, &vsiz); if(!vbuf){ eprint(bdb, "tcbdbget"); err = true; break; } else if(vsiz != ksiz || memcmp(vbuf, kbuf, vsiz)){ eprint(bdb, "(validation)"); err = true; tcfree(vbuf); break; } tcfree(vbuf); if(rnum > 250 && i % (rnum / 250) == 0){ iputchar('.'); if(i == rnum || i % (rnum / 10) == 0) iprintf(" (%08d)\n", i); } } iprintf("checking words:\n"); for(int i = 0; words[i] != NULL; i += 2){ const char *kbuf = words[i]; int ksiz = strlen(kbuf); const char *vbuf = words[i+1]; int vsiz = strlen(vbuf); int rsiz; char *rbuf = tcbdbget(bdb, kbuf, ksiz, &rsiz); if(!rbuf){ eprint(bdb, "tcbdbget"); err = true; break; } else if(rsiz != vsiz || memcmp(rbuf, vbuf, rsiz)){ eprint(bdb, "(validation)"); err = true; tcfree(rbuf); break; } tcfree(rbuf); if(rnum > 250) iputchar('.'); } if(rnum > 250) iprintf(" (%08d)\n", sizeof(words) / sizeof(*words)); iprintf("checking cursor:\n"); BDBCUR *cur = tcbdbcurnew(bdb); if(!tcbdbcurfirst(cur)){ eprint(bdb, "tcbdbcurfirst"); err = true; } char *kbuf; int ksiz; int inum = 0; for(int i = 1; (kbuf = tcbdbcurkey(cur, &ksiz)) != NULL; i++, inum++){ int vsiz; char *vbuf = tcbdbget(bdb, kbuf, ksiz, &vsiz); if(!vbuf){ eprint(bdb, "tcbdbget"); err = true; tcfree(kbuf); break; } tcfree(vbuf); tcfree(kbuf); tcbdbcurnext(cur); if(rnum > 250 && i % (rnum / 250) == 0){ iputchar('.'); if(i == rnum || i % (rnum / 10) == 0) iprintf(" (%08d)\n", i); } } if(tcbdbecode(bdb) != TCENOREC || inum != tcbdbrnum(bdb)){ eprint(bdb, "(validation)"); err = true; } iprintf("cursor updating:\n"); if(!tcbdbcurfirst(cur)){ eprint(bdb, "tcbdbcurfirst"); err = true; } inum = 0; for(int i = 1; !err && (kbuf = tcbdbcurkey(cur, &ksiz)) != NULL; i++, inum++){ switch(myrand(6)){ case 0: if(!tcbdbputdup(bdb, kbuf, ksiz, "0123456789", 10)){ eprint(bdb, "tcbdbputcat"); err = true; } break; case 1: if(!tcbdbout(bdb, kbuf, ksiz)){ eprint(bdb, "tcbdbout"); err = true; } break; case 2: if(!tcbdbcurput(cur, kbuf, ksiz, BDBCPCURRENT)){ eprint(bdb, "tcbdbcurput"); err = true; } break; case 3: if(!tcbdbcurput(cur, kbuf, ksiz, BDBCPBEFORE)){ eprint(bdb, "tcbdbcurput"); err = true; } break; case 4: if(!tcbdbcurput(cur, kbuf, ksiz, BDBCPAFTER)){ eprint(bdb, "tcbdbcurput"); err = true; } break; default: if(!tcbdbcurout(cur) && tcbdbecode(bdb) != TCENOREC){ eprint(bdb, "tcbdbcurout"); err = true; } break; } tcfree(kbuf); tcbdbcurnext(cur); if(rnum > 250 && i % (rnum / 250) == 0){ iputchar('.'); if(i == rnum || i % (rnum / 10) == 0) iprintf(" (%08d)\n", i); } } if(rnum > 250) iprintf(" (%08d)\n", inum); if(tcbdbecode(bdb) != TCENOREC){ eprint(bdb, "(validation)"); err = true; } if(!tcbdbsync(bdb)){ eprint(bdb, "tcbdbsync"); err = true; } iprintf("cursor updating from empty:\n"); tcbdbcurfirst(cur); inum = 0; for(int i = 1; (kbuf = tcbdbcurkey(cur, &ksiz)) != NULL; i++, inum++){ tcfree(kbuf); if(!tcbdbcurout(cur) && tcbdbecode(bdb) != TCENOREC){ eprint(bdb, "tcbdbcurout"); err = true; } if(rnum > 250 && i % (rnum / 250) == 0){ iputchar('.'); if(i == rnum || i % (rnum / 10) == 0) iprintf(" (%08d)\n", i); } } if(rnum > 250) iprintf(" (%08d)\n", inum); if(tcbdbrnum(bdb) != 0){ eprint(bdb, "(validation)"); err = true; } if(!tcbdbput2(bdb, "one", "first")){ eprint(bdb, "tcbdbput"); err = true; } if(!tcbdbcurlast(cur)){ eprint(bdb, "tcbdbcurlast"); err = true; } if(!tcbdbcurput2(cur, "second", BDBCPCURRENT) || !tcbdbcurput2(cur, "first", BDBCPBEFORE) || !tcbdbcurput2(cur, "zero", BDBCPBEFORE) || !tcbdbcurput2(cur, "top", BDBCPBEFORE)){ eprint(bdb, "tcbdbcurput2"); err = true; } if(!tcbdbcurlast(cur)){ eprint(bdb, "tcbdbcurlast"); err = true; } if(!tcbdbcurput2(cur, "third", BDBCPAFTER) || !tcbdbcurput2(cur, "fourth", BDBCPAFTER) || !tcbdbcurput2(cur, "end", BDBCPCURRENT) || !tcbdbcurput2(cur, "bottom", BDBCPAFTER)){ eprint(bdb, "tcbdbcurput2"); err = true; } iprintf("checking transaction commit:\n"); if(!tcbdbtranbegin(bdb)){ eprint(bdb, "tcbdbtranbegin"); err = true; } for(int i = 1; i <= rnum; i++){ char kbuf[RECBUFSIZ]; int ksiz = sprintf(kbuf, "%d", myrand(rnum)); if(!tcbdbputdup(bdb, kbuf, ksiz, kbuf, ksiz)){ eprint(bdb, "tcbdbputdup"); err = true; break; } if(rnum > 250 && i % (rnum / 250) == 0){ iputchar('.'); if(i == rnum || i % (rnum / 10) == 0) iprintf(" (%08d)\n", i); } } if(!tcbdbtrancommit(bdb)){ eprint(bdb, "tcbdbtrancommit"); err = true; } iprintf("checking transaction abort:\n"); uint64_t ornum = tcbdbrnum(bdb); if(!tcbdbtranbegin(bdb)){ eprint(bdb, "tcbdbtranbegin"); err = true; } for(int i = 1; i <= rnum; i++){ char kbuf[RECBUFSIZ]; int ksiz = sprintf(kbuf, "%d", myrand(rnum)); if(!tcbdbout(bdb, kbuf, ksiz) && tcbdbecode(bdb) != TCENOREC){ eprint(bdb, "tcbdbout"); err = true; break; } if(rnum > 250 && i % (rnum / 250) == 0){ iputchar('.'); if(i == rnum || i % (rnum / 10) == 0) iprintf(" (%08d)\n", i); } } if(!tcbdbtranabort(bdb)){ eprint(bdb, "tcbdbtranabort"); err = true; } if(tcbdbrnum(bdb) != ornum){ eprint(bdb, "(validation)"); err = true; } if(ornum > 1000){ if(!tcbdbcurfirst(cur)){ eprint(bdb, "tcbdbcurfirst"); err = true; } for(int i = 1; i < 500 && !err && (kbuf = tcbdbcurkey(cur, &ksiz)) != NULL; i++){ int vsiz; if(myrand(20) == 0){ if(!tcbdbget3(bdb, kbuf, ksiz, &vsiz)){ eprint(bdb, "tcbdbget3"); err = true; } if(myrand(2) == 0 && !tcbdbout(bdb, kbuf, ksiz)){ eprint(bdb, "tcbdbget3"); err = true; } if(myrand(2) == 0 && !tcbdbputdup(bdb, kbuf, ksiz, kbuf, ksiz)){ eprint(bdb, "tcbdbput"); err = true; } } else { if(!tcbdbcurout(cur)){
?? 快捷鍵說明
復制代碼
Ctrl + C
搜索代碼
Ctrl + F
全屏模式
F11
切換主題
Ctrl + Shift + D
顯示快捷鍵
?
增大字號
Ctrl + =
減小字號
Ctrl + -