summaryrefslogtreecommitdiff
path: root/qdbm/crtest.c
diff options
context:
space:
mode:
Diffstat (limited to 'qdbm/crtest.c')
-rw-r--r--qdbm/crtest.c873
1 files changed, 873 insertions, 0 deletions
diff --git a/qdbm/crtest.c b/qdbm/crtest.c
new file mode 100644
index 00000000..6239841b
--- /dev/null
+++ b/qdbm/crtest.c
@@ -0,0 +1,873 @@
+/*************************************************************************************************
+ * Test cases of Curia
+ * Copyright (C) 2000-2007 Mikio Hirabayashi
+ * This file is part of QDBM, Quick Database Manager.
+ * QDBM is free software; you can redistribute it and/or modify it under the terms of the GNU
+ * Lesser General Public License as published by the Free Software Foundation; either version
+ * 2.1 of the License or any later version. QDBM is distributed in the hope that it will be
+ * useful, but WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
+ * FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more
+ * details.
+ * You should have received a copy of the GNU Lesser General Public License along with QDBM; if
+ * not, write to the Free Software Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA
+ * 02111-1307 USA.
+ *************************************************************************************************/
+
+
+#include <depot.h>
+#include <curia.h>
+#include <cabin.h>
+#include <stdlib.h>
+#include <stdio.h>
+#include <string.h>
+#include <stdarg.h>
+#include <limits.h>
+#include <time.h>
+
+#undef TRUE
+#define TRUE 1 /* boolean true */
+#undef FALSE
+#define FALSE 0 /* boolean false */
+
+#define RECBUFSIZ 32 /* buffer for records */
+
+
+/* for RISC OS */
+#if defined(__riscos__) || defined(__riscos)
+#include <unixlib/local.h>
+int __riscosify_control = __RISCOSIFY_NO_PROCESS;
+#endif
+
+
+/* global variables */
+const char *progname; /* program name */
+
+
+/* function prototypes */
+int main(int argc, char **argv);
+void usage(void);
+int runwrite(int argc, char **argv);
+int runread(int argc, char **argv);
+int runrcat(int argc, char **argv);
+int runcombo(int argc, char **argv);
+int runwicked(int argc, char **argv);
+int printfflush(const char *format, ...);
+void pdperror(const char *name);
+int myrand(void);
+int dowrite(const char *name, int rnum, int bnum, int dnum, int sparse, int lob);
+int doread(const char *name, int wb, int lob);
+int dorcat(const char *name, int rnum, int bnum, int dnum, int pnum,
+ int align, int fbpsiz, int cb);
+int docombo(const char *name);
+int dowicked(const char *name, int rnum, int cb);
+
+
+/* main routine */
+int main(int argc, char **argv){
+ char *env;
+ int rv;
+ cbstdiobin();
+ if((env = getenv("QDBMDBGFD")) != NULL) dpdbgfd = atoi(env);
+ progname = argv[0];
+ if(argc < 2) usage();
+ rv = 0;
+ if(!strcmp(argv[1], "write")){
+ rv = runwrite(argc, argv);
+ } else if(!strcmp(argv[1], "read")){
+ rv = runread(argc, argv);
+ } else if(!strcmp(argv[1], "rcat")){
+ rv = runrcat(argc, argv);
+ } else if(!strcmp(argv[1], "combo")){
+ rv = runcombo(argc, argv);
+ } else if(!strcmp(argv[1], "wicked")){
+ rv = runwicked(argc, argv);
+ } else {
+ usage();
+ }
+ return rv;
+}
+
+
+/* print the usage and exit */
+void usage(void){
+ fprintf(stderr, "%s: test cases for Curia\n", progname);
+ fprintf(stderr, "\n");
+ fprintf(stderr, "usage:\n");
+ fprintf(stderr, " %s write [-s] [-lob] name rnum bnum dnum\n", progname);
+ fprintf(stderr, " %s read [-wb] [-lob] name\n", progname);
+ fprintf(stderr, " %s rcat [-c] name rnum bnum dnum pnum align fbpsiz\n", progname);
+ fprintf(stderr, " %s combo name\n", progname);
+ fprintf(stderr, " %s wicked [-c] name rnum\n", progname);
+ fprintf(stderr, "\n");
+ exit(1);
+}
+
+
+/* parse arguments of write command */
+int runwrite(int argc, char **argv){
+ char *name, *rstr, *bstr, *dstr;
+ int i, rnum, bnum, dnum, sb, lob, rv;
+ name = NULL;
+ rstr = NULL;
+ bstr = NULL;
+ dstr = NULL;
+ rnum = 0;
+ bnum = 0;
+ dnum = 0;
+ sb = FALSE;
+ lob = FALSE;
+ for(i = 2; i < argc; i++){
+ if(!name && argv[i][0] == '-'){
+ if(!strcmp(argv[i], "-s")){
+ sb = TRUE;
+ } else if(!strcmp(argv[i], "-lob")){
+ lob = TRUE;
+ } else {
+ usage();
+ }
+ } else if(!name){
+ name = argv[i];
+ } else if(!rstr){
+ rstr = argv[i];
+ } else if(!bstr){
+ bstr = argv[i];
+ } else if(!dstr){
+ dstr = argv[i];
+ } else {
+ usage();
+ }
+ }
+ if(!name || !rstr || !bstr || !dstr) usage();
+ rnum = atoi(rstr);
+ bnum = atoi(bstr);
+ dnum = atoi(dstr);
+ if(rnum < 1 || bnum < 1 || dnum < 1) usage();
+ rv = dowrite(name, rnum, bnum, dnum, sb, lob);
+ return rv;
+}
+
+
+/* parse arguments of read command */
+int runread(int argc, char **argv){
+ char *name;
+ int i, wb, lob, rv;
+ name = NULL;
+ wb = FALSE;
+ lob = FALSE;
+ for(i = 2; i < argc; i++){
+ if(!name && argv[i][0] == '-'){
+ if(!strcmp(argv[i], "-wb")){
+ wb = TRUE;
+ } else if(!strcmp(argv[i], "-lob")){
+ lob = TRUE;
+ } else {
+ usage();
+ }
+ } else if(!name){
+ name = argv[i];
+ } else {
+ usage();
+ }
+ }
+ if(!name) usage();
+ rv = doread(name, wb, lob);
+ return rv;
+}
+
+
+/* parse arguments of rcat command */
+int runrcat(int argc, char **argv){
+ char *name, *rstr, *bstr, *dstr, *pstr, *astr, *fstr;
+ int i, rnum, bnum, dnum, pnum, align, fbpsiz, cb, rv;
+ name = NULL;
+ rstr = NULL;
+ bstr = NULL;
+ dstr = NULL;
+ pstr = NULL;
+ astr = NULL;
+ fstr = NULL;
+ rnum = 0;
+ bnum = 0;
+ pnum = 0;
+ align = 0;
+ fbpsiz = 0;
+ cb = FALSE;
+ for(i = 2; i < argc; i++){
+ if(!name && argv[i][0] == '-'){
+ if(!strcmp(argv[i], "-c")){
+ cb = TRUE;
+ } else {
+ usage();
+ }
+ } else if(!name){
+ name = argv[i];
+ } else if(!rstr){
+ rstr = argv[i];
+ } else if(!bstr){
+ bstr = argv[i];
+ } else if(!dstr){
+ dstr = argv[i];
+ } else if(!pstr){
+ pstr = argv[i];
+ } else if(!astr){
+ astr = argv[i];
+ } else if(!fstr){
+ fstr = argv[i];
+ } else {
+ usage();
+ }
+ }
+ if(!name || !rstr || !bstr || !dstr || !pstr || !astr || !fstr) usage();
+ rnum = atoi(rstr);
+ bnum = atoi(bstr);
+ dnum = atoi(dstr);
+ pnum = atoi(pstr);
+ align = atoi(astr);
+ fbpsiz = atoi(fstr);
+ if(rnum < 1 || bnum < 1 || dnum < 1 || pnum < 1 || fbpsiz < 0) usage();
+ rv = dorcat(name, rnum, bnum, dnum, pnum, align, fbpsiz, cb);
+ return rv;
+}
+
+
+/* parse arguments of combo command */
+int runcombo(int argc, char **argv){
+ char *name;
+ int i, rv;
+ name = NULL;
+ for(i = 2; i < argc; i++){
+ if(!name && argv[i][0] == '-'){
+ usage();
+ } else if(!name){
+ name = argv[i];
+ } else {
+ usage();
+ }
+ }
+ if(!name) usage();
+ rv = docombo(name);
+ return rv;
+}
+
+
+/* parse arguments of wicked command */
+int runwicked(int argc, char **argv){
+ char *name, *rstr;
+ int i, rnum, cb, rv;
+ name = NULL;
+ rstr = NULL;
+ rnum = 0;
+ cb = FALSE;
+ for(i = 2; i < argc; i++){
+ if(!name && argv[i][0] == '-'){
+ if(!strcmp(argv[i], "-c")){
+ cb = TRUE;
+ } else {
+ usage();
+ }
+ } else if(!name){
+ name = argv[i];
+ } else if(!rstr){
+ rstr = argv[i];
+ } else {
+ usage();
+ }
+ }
+ if(!name || !rstr) usage();
+ rnum = atoi(rstr);
+ if(rnum < 1) usage();
+ rv = dowicked(name, rnum, cb);
+ return rv;
+}
+
+
+/* print formatted string and flush the buffer */
+int printfflush(const char *format, ...){
+ va_list ap;
+ int rv;
+ va_start(ap, format);
+ rv = vprintf(format, ap);
+ if(fflush(stdout) == EOF) rv = -1;
+ va_end(ap);
+ return rv;
+}
+
+
+/* print an error message */
+void pdperror(const char *name){
+ fprintf(stderr, "%s: %s: %s\n", progname, name, dperrmsg(dpecode));
+}
+
+
+/* pseudo random number generator */
+int myrand(void){
+ static int cnt = 0;
+ if(cnt == 0) srand(time(NULL));
+ return (rand() * rand() + (rand() >> (sizeof(int) * 4)) + (cnt++)) & INT_MAX;
+}
+
+
+/* perform write command */
+int dowrite(const char *name, int rnum, int bnum, int dnum, int sparse, int lob){
+ CURIA *curia;
+ int i, omode, err, len;
+ char buf[RECBUFSIZ];
+ printfflush("<Writing Test>\n name=%s rnum=%d bnum=%d dnum=%d s=%d lob=%d\n\n",
+ name, rnum, bnum, dnum, sparse, lob);
+ /* open a database */
+ omode = CR_OWRITER | CR_OCREAT | CR_OTRUNC | (sparse ? CR_OSPARSE : 0);
+ if(!(curia = cropen(name, omode, bnum, dnum))){
+ pdperror(name);
+ return 1;
+ }
+ err = FALSE;
+ /* loop for each record */
+ for(i = 1; i <= rnum; i++){
+ /* store a record */
+ len = sprintf(buf, "%08d", i);
+ if(lob){
+ if(!crputlob(curia, buf, len, buf, len, CR_DOVER)){
+ pdperror(name);
+ err = TRUE;
+ break;
+ }
+ } else {
+ if(!crput(curia, buf, len, buf, len, CR_DOVER)){
+ pdperror(name);
+ err = TRUE;
+ break;
+ }
+ }
+ /* print progression */
+ if(rnum > 250 && i % (rnum / 250) == 0){
+ putchar('.');
+ fflush(stdout);
+ if(i == rnum || i % (rnum / 10) == 0){
+ printfflush(" (%08d)\n", i);
+ }
+ }
+ }
+ /* close the database */
+ if(!crclose(curia)){
+ pdperror(name);
+ return 1;
+ }
+ if(!err) printfflush("ok\n\n");
+ return err ? 1 : 0;
+}
+
+
+/* perform read command */
+int doread(const char *name, int wb, int lob){
+ CURIA *curia;
+ int i, rnum, err, len;
+ char buf[RECBUFSIZ], vbuf[RECBUFSIZ], *val;
+ printfflush("<Reading Test>\n name=%s wb=%d lob=%d\n\n", name, wb, lob);
+ /* open a database */
+ if(!(curia = cropen(name, CR_OREADER, -1, -1))){
+ pdperror(name);
+ return 1;
+ }
+ /* get the number of records */
+ if(lob){
+ rnum = crrnumlob(curia);
+ } else {
+ rnum = crrnum(curia);
+ }
+ err = FALSE;
+ /* loop for each record */
+ for(i = 1; i <= rnum; i++){
+ /* retrieve a record */
+ len = sprintf(buf, "%08d", i);
+ if(lob){
+ if(!(val = crgetlob(curia, buf, len, 0, -1, NULL))){
+ pdperror(name);
+ err = TRUE;
+ break;
+ }
+ free(val);
+ } else if(wb){
+ if(crgetwb(curia, buf, len, 0, RECBUFSIZ, vbuf) == -1){
+ pdperror(name);
+ err = TRUE;
+ break;
+ }
+ } else {
+ if(!(val = crget(curia, buf, len, 0, -1, NULL))){
+ pdperror(name);
+ err = TRUE;
+ break;
+ }
+ free(val);
+ }
+ /* print progression */
+ if(rnum > 250 && i % (rnum / 250) == 0){
+ putchar('.');
+ fflush(stdout);
+ if(i == rnum || i % (rnum / 10) == 0){
+ printfflush(" (%08d)\n", i);
+ }
+ }
+ }
+ /* close the database */
+ if(!crclose(curia)){
+ pdperror(name);
+ return 1;
+ }
+ if(!err) printfflush("ok\n\n");
+ return err ? 1 : 0;
+}
+
+
+/* perform rcat command */
+int dorcat(const char *name, int rnum, int bnum, int dnum, int pnum,
+ int align, int fbpsiz, int cb){
+ CURIA *curia;
+ CBMAP *map;
+ int i, err, len, ksiz, vsiz, rsiz;
+ const char *kbuf, *vbuf;
+ char buf[RECBUFSIZ], *rbuf;
+ printfflush("<Random Writing Test>\n name=%s rnum=%d bnum=%d dnum=%d pnum=%d"
+ " align=%d fbpsiz=%d c=%d\n\n", name, rnum, bnum, dnum, pnum, align, fbpsiz, cb);
+ if(!(curia = cropen(name, CR_OWRITER | CR_OCREAT | CR_OTRUNC, bnum, dnum))){
+ pdperror(name);
+ return 1;
+ }
+ if(!crsetalign(curia, align) || !crsetfbpsiz(curia, fbpsiz)){
+ pdperror(name);
+ crclose(curia);
+ return 1;
+ }
+ map = NULL;
+ if(cb) map = cbmapopen();
+ err = FALSE;
+ for(i = 1; i <= rnum; i++){
+ len = sprintf(buf, "%08d", myrand() % pnum + 1);
+ if(!crput(curia, buf, len, buf, len, CR_DCAT)){
+ pdperror(name);
+ err = TRUE;
+ break;
+ }
+ if(rnum > 250 && i % (rnum / 250) == 0){
+ putchar('.');
+ fflush(stdout);
+ if(i == rnum || i % (rnum / 10) == 0){
+ printfflush(" (%08d: fsiz=%d rnum=%d)\n", i, crfsiz(curia), crrnum(curia));
+ }
+ }
+ }
+ if(map){
+ printfflush("Matching records ... ");
+ cbmapiterinit(map);
+ while((kbuf = cbmapiternext(map, &ksiz)) != NULL){
+ vbuf = cbmapget(map, kbuf, ksiz, &vsiz);
+ if(!(rbuf = crget(curia, kbuf, ksiz, 0, -1, &rsiz))){
+ pdperror(name);
+ err = TRUE;
+ break;
+ }
+ if(rsiz != vsiz || memcmp(rbuf, vbuf, rsiz)){
+ fprintf(stderr, "%s: %s: unmatched record\n", progname, name);
+ free(rbuf);
+ err = TRUE;
+ break;
+ }
+ free(rbuf);
+ }
+ cbmapclose(map);
+ if(!err) printfflush("ok\n");
+ }
+ if(!crclose(curia)){
+ pdperror(name);
+ return 1;
+ }
+ if(!err) printfflush("ok\n\n");
+ return err ? 1 : 0;
+}
+
+
+/* perform combo command */
+int docombo(const char *name){
+ CURIA *curia;
+ char buf[RECBUFSIZ], wbuf[RECBUFSIZ], *vbuf;
+ int i, len, wlen, vsiz;
+ printfflush("<Combination Test>\n name=%s\n\n", name);
+ printfflush("Creating a database with bnum 3 ... ");
+ if(!(curia = cropen(name, CR_OWRITER | CR_OCREAT | CR_OTRUNC, 3, 3))){
+ pdperror(name);
+ return 1;
+ }
+ printfflush("ok\n");
+ printfflush("Setting alignment as 16 ... ");
+ if(!crsetalign(curia, 16)){
+ pdperror(name);
+ crclose(curia);
+ return 1;
+ }
+ printfflush("ok\n");
+ printfflush("Adding 20 records ... ");
+ for(i = 1; i <= 20; i++){
+ len = sprintf(buf, "%08d", i);
+ if(!crput(curia, buf, len, buf, len, CR_DOVER)){
+ pdperror(name);
+ crclose(curia);
+ return 1;
+ }
+ }
+ printfflush("ok\n");
+ printfflush("Checking records ... ");
+ for(i = 1; i <= 20; i++){
+ len = sprintf(buf, "%08d", i);
+ if(!(vbuf = crget(curia, buf, len, 0, -1, &vsiz))){
+ pdperror(name);
+ crclose(curia);
+ return 1;
+ }
+ free(vbuf);
+ if(vsiz != crvsiz(curia, buf, len)){
+ fprintf(stderr, "%s: %s: invalid vsiz\n", progname, name);
+ crclose(curia);
+ return 1;
+ }
+ }
+ printfflush("ok\n");
+ printfflush("Overwriting top 10 records without moving rooms ... ");
+ for(i = 1; i <= 10; i++){
+ len = sprintf(buf, "%08d", i);
+ if(!crput(curia, buf, len, buf, len, CR_DOVER)){
+ pdperror(name);
+ crclose(curia);
+ return 1;
+ }
+ }
+ printfflush("ok\n");
+ printfflush("Overwriting top 5 records with moving rooms ... ");
+ for(i = 1; i <= 5; i++){
+ len = sprintf(buf, "%08d", i);
+ wlen = sprintf(wbuf, "%024d", i);
+ if(!crput(curia, buf, len, wbuf, wlen, CR_DOVER)){
+ pdperror(name);
+ crclose(curia);
+ return 1;
+ }
+ }
+ printfflush("ok\n");
+ printfflush("Overwriting top 15 records in concatenation with moving rooms ... ");
+ for(i = 1; i <= 15; i++){
+ len = sprintf(buf, "%08d", i);
+ wlen = sprintf(wbuf, "========================");
+ if(!crput(curia, buf, len, wbuf, wlen, CR_DCAT)){
+ pdperror(name);
+ crclose(curia);
+ return 1;
+ }
+ }
+ printfflush("ok\n");
+ printfflush("Checking records ... ");
+ for(i = 1; i <= 20; i++){
+ len = sprintf(buf, "%08d", i);
+ if(!(vbuf = crget(curia, buf, len, 0, -1, &vsiz))){
+ pdperror(name);
+ crclose(curia);
+ return 1;
+ }
+ free(vbuf);
+ if(vsiz != crvsiz(curia, buf, len)){
+ fprintf(stderr, "%s: %s: invalid vsiz\n", progname, name);
+ crclose(curia);
+ return 1;
+ }
+ }
+ printfflush("ok\n");
+ printfflush("Deleting top 10 records ... ");
+ for(i = 1; i <= 10; i++){
+ len = sprintf(buf, "%08d", i);
+ if(!crout(curia, buf, len)){
+ pdperror(name);
+ crclose(curia);
+ return 1;
+ }
+ }
+ printfflush("ok\n");
+ printfflush("Checking deleted records ... ");
+ for(i = 1; i <= 10; i++){
+ len = sprintf(buf, "%08d", i);
+ vbuf = crget(curia, buf, len, 0, -1, &vsiz);
+ free(vbuf);
+ if(vbuf || dpecode != DP_ENOITEM){
+ fprintf(stderr, "%s: %s: deleting failed\n", progname, name);
+ crclose(curia);
+ return 1;
+ }
+ }
+ printfflush("ok\n");
+ printfflush("Overwriting top 15 records in concatenation with moving rooms ... ");
+ for(i = 1; i <= 15; i++){
+ len = sprintf(buf, "%08d", i);
+ wlen = sprintf(wbuf, "========================");
+ if(!crput(curia, buf, len, wbuf, wlen, CR_DCAT)){
+ pdperror(name);
+ crclose(curia);
+ return 1;
+ }
+ }
+ printfflush("ok\n");
+ printfflush("Checking records ... ");
+ for(i = 1; i <= 20; i++){
+ len = sprintf(buf, "%08d", i);
+ if(!(vbuf = crget(curia, buf, len, 0, -1, &vsiz))){
+ pdperror(name);
+ crclose(curia);
+ return 1;
+ }
+ free(vbuf);
+ if(vsiz != crvsiz(curia, buf, len)){
+ fprintf(stderr, "%s: %s: invalid vsiz\n", progname, name);
+ crclose(curia);
+ return 1;
+ }
+ }
+ printfflush("ok\n");
+ printfflush("Optimizing the database ... ");
+ if(!croptimize(curia, -1)){
+ pdperror(name);
+ crclose(curia);
+ return 1;
+ }
+ printfflush("ok\n");
+ printfflush("Checking records ... ");
+ for(i = 1; i <= 20; i++){
+ len = sprintf(buf, "%08d", i);
+ if(!(vbuf = crget(curia, buf, len, 0, -1, &vsiz))){
+ pdperror(name);
+ crclose(curia);
+ return 1;
+ }
+ free(vbuf);
+ if(vsiz != crvsiz(curia, buf, len)){
+ fprintf(stderr, "%s: %s: invalid vsiz\n", progname, name);
+ crclose(curia);
+ return 1;
+ }
+ }
+ printfflush("ok\n");
+ printfflush("Closing database ... ");
+ if(!crclose(curia)){
+ pdperror(name);
+ return 1;
+ }
+ printfflush("ok\n");
+ printfflush("Creating a database with bnum 1000000 ... ");
+ if(!(curia = cropen(name, DP_OWRITER | DP_OCREAT | DP_OTRUNC, 1000000, -1))){
+ pdperror(name);
+ return 1;
+ }
+ printfflush("ok\n");
+ printfflush("Adding 1000 records ... ");
+ for(i = 1; i <= 1000; i++){
+ len = sprintf(buf, "%08d", i);
+ if(!crput(curia, buf, len, buf, len, DP_DOVER)){
+ pdperror(name);
+ crclose(curia);
+ return 1;
+ }
+ }
+ printfflush("ok\n");
+ printfflush("Adding 64 records ... ");
+ for(i = 1; i <= 64; i++){
+ len = sprintf(buf, "%o", i);
+ if(!crput(curia, buf, len, buf, len, DP_DOVER)){
+ pdperror(name);
+ crclose(curia);
+ return 1;
+ }
+ }
+ printfflush("ok\n");
+ printfflush("Syncing the database ... ");
+ if(!crsync(curia)){
+ pdperror(name);
+ crclose(curia);
+ return 1;
+ }
+ printfflush("ok\n");
+ printfflush("Retrieving records directly ... ");
+ for(i = 1; i <= 64; i++){
+ len = sprintf(buf, "%o", i);
+ if(!(vbuf = crsnaffle(name, buf, len, &vsiz))){
+ pdperror(name);
+ crclose(curia);
+ return 1;
+ }
+ if(strcmp(vbuf, buf)){
+ fprintf(stderr, "%s: %s: invalid content\n", progname, name);
+ free(vbuf);
+ crclose(curia);
+ return 1;
+ }
+ free(vbuf);
+ if(vsiz != crvsiz(curia, buf, len)){
+ fprintf(stderr, "%s: %s: invalid vsiz\n", progname, name);
+ crclose(curia);
+ return 1;
+ }
+ }
+ printfflush("ok\n");
+ printfflush("Optimizing the database ... ");
+ if(!croptimize(curia, -1)){
+ pdperror(name);
+ crclose(curia);
+ return 1;
+ }
+ printfflush("ok\n");
+ printfflush("Closing the database ... ");
+ if(!crclose(curia)){
+ pdperror(name);
+ return 1;
+ }
+ printfflush("ok\n");
+ printfflush("all ok\n\n");
+ return 0;
+}
+
+
+/* perform wicked command */
+int dowicked(const char *name, int rnum, int cb){
+ CURIA *curia;
+ CBMAP *map;
+ int i, len, err, align, mksiz, mvsiz, rsiz;
+ const char *mkbuf, *mvbuf;
+ char buf[RECBUFSIZ], vbuf[RECBUFSIZ], *val;
+ printfflush("<Wicked Writing Test>\n name=%s rnum=%d\n\n", name, rnum);
+ err = FALSE;
+ if(!(curia = cropen(name, CR_OWRITER | CR_OCREAT | CR_OTRUNC, rnum / 10, 5))){
+ pdperror(name);
+ return 1;
+ }
+ if(!crsetalign(curia, 16) || !crsetfbpsiz(curia, 256)){
+ pdperror(name);
+ err = TRUE;
+ }
+ map = NULL;
+ if(cb) map = cbmapopen();
+ for(i = 1; i <= rnum; i++){
+ len = sprintf(buf, "%08d", myrand() % rnum + 1);
+ switch(myrand() % 16){
+ case 0:
+ putchar('O');
+ if(!crput(curia, buf, len, buf, len, CR_DOVER)) err = TRUE;
+ if(map) cbmapput(map, buf, len, buf, len, TRUE);
+ break;
+ case 1:
+ putchar('K');
+ if(!crput(curia, buf, len, buf, len, CR_DKEEP) && dpecode != DP_EKEEP) err = TRUE;
+ if(map) cbmapput(map, buf, len, buf, len, FALSE);
+ break;
+ case 2:
+ putchar('D');
+ if(!crout(curia, buf, len) && dpecode != DP_ENOITEM) err = TRUE;
+ if(map) cbmapout(map, buf, len);
+ break;
+ case 3:
+ putchar('G');
+ if(crgetwb(curia, buf, len, 2, RECBUFSIZ, vbuf) == -1 && dpecode != DP_ENOITEM) err = TRUE;
+ break;
+ case 4:
+ putchar('V');
+ if(crvsiz(curia, buf, len) == -1 && dpecode != DP_ENOITEM) err = TRUE;
+ break;
+ default:
+ putchar('C');
+ if(!crput(curia, buf, len, buf, len, CR_DCAT)) err = TRUE;
+ if(map) cbmapputcat(map, buf, len, buf, len);
+ break;
+ }
+ if(i % 50 == 0) printfflush(" (%08d)\n", i);
+ if(!err && rnum > 100 && myrand() % (rnum / 100) == 0){
+ if(myrand() % 10 == 0){
+ align = (myrand() % 4 + 1) * -1;
+ } else {
+ align = myrand() % 32;
+ }
+ if(!crsetalign(curia, align)) err = TRUE;
+ }
+ if(err){
+ pdperror(name);
+ break;
+ }
+ }
+ if(!croptimize(curia, -1)){
+ pdperror(name);
+ err = TRUE;
+ }
+ for(i = 1; i <= rnum; i++){
+ len = sprintf(buf, "%08d", i);
+ if(!crput(curia, buf, len, ":", -1, CR_DCAT)){
+ pdperror(name);
+ err = TRUE;
+ break;
+ }
+ if(map) cbmapputcat(map, buf, len, ":", -1);
+ putchar(':');
+ if(i % 50 == 0) printfflush(" (%08d)\n", i);
+ }
+ if(!croptimize(curia, -1)){
+ pdperror(name);
+ err = TRUE;
+ }
+ for(i = 1; i <= rnum; i++){
+ len = sprintf(buf, "%08d", i);
+ if(!(val = crget(curia, buf, len, 0, -1, NULL))){
+ pdperror(name);
+ err = TRUE;
+ break;
+ }
+ free(val);
+ putchar('=');
+ if(i % 50 == 0) printfflush(" (%08d)\n", i);
+ }
+ if(!criterinit(curia)){
+ pdperror(name);
+ err = TRUE;
+ }
+ for(i = 1; i <= rnum; i++){
+ if(!(val = criternext(curia, NULL))){
+ pdperror(name);
+ err = TRUE;
+ break;
+ }
+ free(val);
+ putchar('@');
+ if(i % 50 == 0) printfflush(" (%08d)\n", i);
+ }
+ if(map){
+ printfflush("Matching records ... ");
+ cbmapiterinit(map);
+ while((mkbuf = cbmapiternext(map, &mksiz)) != NULL){
+ mvbuf = cbmapget(map, mkbuf, mksiz, &mvsiz);
+ if(!(val = crget(curia, mkbuf, mksiz, 0, -1, &rsiz))){
+ pdperror(name);
+ err = TRUE;
+ break;
+ }
+ if(rsiz != mvsiz || memcmp(val, mvbuf, rsiz)){
+ fprintf(stderr, "%s: %s: unmatched record\n", progname, name);
+ free(val);
+ err = TRUE;
+ break;
+ }
+ free(val);
+ }
+ cbmapclose(map);
+ if(!err) printfflush("ok\n");
+ }
+ if(!crclose(curia)){
+ pdperror(name);
+ return 1;
+ }
+ if(!err) printfflush("ok\n\n");
+ return err ? 1 : 0;
+}
+
+
+
+/* END OF FILE */
generated by cgit v1.2.3 (git 2.25.1) at 2024-04-20 01:36:28 +0000