diff options
Diffstat (limited to 'src/regress/lib/libc/db/dbtest.c')
-rw-r--r-- | src/regress/lib/libc/db/dbtest.c | 359 |
1 files changed, 217 insertions, 142 deletions
diff --git a/src/regress/lib/libc/db/dbtest.c b/src/regress/lib/libc/db/dbtest.c index 1fcf09af97..8eda40d6b3 100644 --- a/src/regress/lib/libc/db/dbtest.c +++ b/src/regress/lib/libc/db/dbtest.c | |||
@@ -1,7 +1,8 @@ | |||
1 | /* $NetBSD: dbtest.c,v 1.7 1995/04/20 22:39:22 cgd Exp $ */ | 1 | /* $OpenBSD: dbtest.c,v 1.11 2003/07/31 21:48:02 deraadt Exp $ */ |
2 | /* $NetBSD: dbtest.c,v 1.8 1996/05/03 21:57:48 cgd Exp $ */ | ||
2 | 3 | ||
3 | /*- | 4 | /*- |
4 | * Copyright (c) 1992, 1993 | 5 | * Copyright (c) 1992, 1993, 1994 |
5 | * The Regents of the University of California. All rights reserved. | 6 | * The Regents of the University of California. All rights reserved. |
6 | * | 7 | * |
7 | * Redistribution and use in source and binary forms, with or without | 8 | * Redistribution and use in source and binary forms, with or without |
@@ -12,11 +13,7 @@ | |||
12 | * 2. Redistributions in binary form must reproduce the above copyright | 13 | * 2. Redistributions in binary form must reproduce the above copyright |
13 | * notice, this list of conditions and the following disclaimer in the | 14 | * notice, this list of conditions and the following disclaimer in the |
14 | * documentation and/or other materials provided with the distribution. | 15 | * documentation and/or other materials provided with the distribution. |
15 | * 3. All advertising materials mentioning features or use of this software | 16 | * 3. Neither the name of the University nor the names of its contributors |
16 | * must display the following acknowledgement: | ||
17 | * This product includes software developed by the University of | ||
18 | * California, Berkeley and its contributors. | ||
19 | * 4. Neither the name of the University nor the names of its contributors | ||
20 | * may be used to endorse or promote products derived from this software | 17 | * may be used to endorse or promote products derived from this software |
21 | * without specific prior written permission. | 18 | * without specific prior written permission. |
22 | * | 19 | * |
@@ -35,15 +32,15 @@ | |||
35 | 32 | ||
36 | #ifndef lint | 33 | #ifndef lint |
37 | static char copyright[] = | 34 | static char copyright[] = |
38 | "@(#) Copyright (c) 1992, 1993\n\ | 35 | "@(#) Copyright (c) 1992, 1993, 1994\n\ |
39 | The Regents of the University of California. All rights reserved.\n"; | 36 | The Regents of the University of California. All rights reserved.\n"; |
40 | #endif /* not lint */ | 37 | #endif /* not lint */ |
41 | 38 | ||
42 | #ifndef lint | 39 | #ifndef lint |
43 | #if 0 | 40 | #if 0 |
44 | static char sccsid[] = "@(#)dbtest.c 8.8 (Berkeley) 2/21/94"; | 41 | static char sccsid[] = "@(#)dbtest.c 8.17 (Berkeley) 9/1/94"; |
45 | #else | 42 | #else |
46 | static char rcsid[] = "$NetBSD: dbtest.c,v 1.7 1995/04/20 22:39:22 cgd Exp $"; | 43 | static char rcsid[] = "$OpenBSD: dbtest.c,v 1.11 2003/07/31 21:48:02 deraadt Exp $"; |
47 | #endif | 44 | #endif |
48 | #endif /* not lint */ | 45 | #endif /* not lint */ |
49 | 46 | ||
@@ -57,39 +54,41 @@ static char rcsid[] = "$NetBSD: dbtest.c,v 1.7 1995/04/20 22:39:22 cgd Exp $"; | |||
57 | #include <stdio.h> | 54 | #include <stdio.h> |
58 | #include <stdlib.h> | 55 | #include <stdlib.h> |
59 | #include <string.h> | 56 | #include <string.h> |
57 | #include <stdarg.h> | ||
60 | #include <unistd.h> | 58 | #include <unistd.h> |
61 | 59 | ||
62 | #include <db.h> | 60 | #include <db.h> |
63 | 61 | ||
64 | enum S { COMMAND, COMPARE, GET, PUT, REMOVE, SEQ, SEQFLAG, KEY, DATA }; | 62 | enum S { COMMAND, COMPARE, GET, PUT, REMOVE, SEQ, SEQFLAG, KEY, DATA }; |
65 | 63 | ||
66 | void compare __P((DBT *, DBT *)); | 64 | void compare(DBT *, DBT *); |
67 | DBTYPE dbtype __P((char *)); | 65 | DBTYPE dbtype(char *); |
68 | void dump __P((DB *, int)); | 66 | void dump(DB *, int); |
69 | void err __P((const char *, ...)); | 67 | void dberr(const char *, ...); |
70 | void get __P((DB *, DBT *)); | 68 | void get(DB *, DBT *); |
71 | void getdata __P((DB *, DBT *, DBT *)); | 69 | void getdata(DB *, DBT *, DBT *); |
72 | void put __P((DB *, DBT *, DBT *)); | 70 | void put(DB *, DBT *, DBT *); |
73 | void rem __P((DB *, DBT *)); | 71 | void rem(DB *, DBT *); |
74 | void *rfile __P((char *, size_t *)); | 72 | char *sflags(int); |
75 | void seq __P((DB *, DBT *)); | 73 | void synk(DB *); |
76 | u_int setflags __P((char *)); | 74 | void *rfile(char *, size_t *); |
77 | void *setinfo __P((DBTYPE, char *)); | 75 | void seq(DB *, DBT *); |
78 | void usage __P((void)); | 76 | u_int setflags(char *); |
79 | void *xmalloc __P((char *, size_t)); | 77 | void *setinfo(DBTYPE, char *); |
80 | 78 | void usage(void); | |
81 | DBTYPE type; | 79 | void *xmalloc(char *, size_t); |
82 | void *infop; | 80 | |
83 | u_long lineno; | 81 | DBTYPE type; /* Database type. */ |
84 | u_int flags; | 82 | void *infop; /* Iflags. */ |
85 | int ofd = STDOUT_FILENO; | 83 | u_long lineno; /* Current line in test script. */ |
84 | u_int flags; /* Current DB flags. */ | ||
85 | int ofd = STDOUT_FILENO; /* Standard output fd. */ | ||
86 | 86 | ||
87 | DB *XXdbp; /* Global for gdb. */ | 87 | DB *XXdbp; /* Global for gdb. */ |
88 | int XXlineno; /* Fast breakpoint for gdb. */ | ||
88 | 89 | ||
89 | int | 90 | int |
90 | main(argc, argv) | 91 | main(int argc, char *argv[]) |
91 | int argc; | ||
92 | char *argv[]; | ||
93 | { | 92 | { |
94 | extern int optind; | 93 | extern int optind; |
95 | extern char *optarg; | 94 | extern char *optarg; |
@@ -97,14 +96,15 @@ main(argc, argv) | |||
97 | DB *dbp; | 96 | DB *dbp; |
98 | DBT data, key, keydata; | 97 | DBT data, key, keydata; |
99 | size_t len; | 98 | size_t len; |
100 | int ch, oflags; | 99 | int ch, oflags, sflag; |
101 | char *fname, *infoarg, *p, buf[8 * 1024]; | 100 | char *fname, *infoarg, *p, *t, buf[8 * 1024]; |
102 | 101 | ||
103 | infoarg = NULL; | 102 | infoarg = NULL; |
104 | fname = NULL; | 103 | fname = NULL; |
105 | oflags = O_CREAT | O_RDWR; | 104 | oflags = O_CREAT | O_RDWR; |
106 | while ((ch = getopt(argc, argv, "f:i:lo:")) != EOF) | 105 | sflag = 0; |
107 | switch(ch) { | 106 | while ((ch = getopt(argc, argv, "f:i:lo:s")) != -1) |
107 | switch (ch) { | ||
108 | case 'f': | 108 | case 'f': |
109 | fname = optarg; | 109 | fname = optarg; |
110 | break; | 110 | break; |
@@ -117,7 +117,10 @@ main(argc, argv) | |||
117 | case 'o': | 117 | case 'o': |
118 | if ((ofd = open(optarg, | 118 | if ((ofd = open(optarg, |
119 | O_WRONLY|O_CREAT|O_TRUNC, 0666)) < 0) | 119 | O_WRONLY|O_CREAT|O_TRUNC, 0666)) < 0) |
120 | err("%s: %s", optarg, strerror(errno)); | 120 | dberr("%s: %s", optarg, strerror(errno)); |
121 | break; | ||
122 | case 's': | ||
123 | sflag = 1; | ||
121 | break; | 124 | break; |
122 | case '?': | 125 | case '?': |
123 | default: | 126 | default: |
@@ -133,8 +136,8 @@ main(argc, argv) | |||
133 | type = dbtype(*argv++); | 136 | type = dbtype(*argv++); |
134 | 137 | ||
135 | /* Open the descriptor file. */ | 138 | /* Open the descriptor file. */ |
136 | if (freopen(*argv, "r", stdin) == NULL) | 139 | if (strcmp(*argv, "-") && freopen(*argv, "r", stdin) == NULL) |
137 | err("%s: %s", *argv, strerror(errno)); | 140 | dberr("%s: %s", *argv, strerror(errno)); |
138 | 141 | ||
139 | /* Set up the db structure as necessary. */ | 142 | /* Set up the db structure as necessary. */ |
140 | if (infoarg == NULL) | 143 | if (infoarg == NULL) |
@@ -145,61 +148,93 @@ main(argc, argv) | |||
145 | if (*p != '\0') | 148 | if (*p != '\0') |
146 | infop = setinfo(type, p); | 149 | infop = setinfo(type, p); |
147 | 150 | ||
148 | /* Open the DB. */ | 151 | /* |
152 | * Open the DB. Delete any preexisting copy, you almost never | ||
153 | * want it around, and it often screws up tests. | ||
154 | */ | ||
149 | if (fname == NULL) { | 155 | if (fname == NULL) { |
150 | p = getenv("TMPDIR"); | 156 | p = getenv("TMPDIR"); |
151 | if (p == NULL) | 157 | if (p == NULL) |
152 | p = "/var/tmp"; | 158 | p = "/var/tmp"; |
153 | (void)sprintf(buf, "%s/__dbtest", p); | 159 | (void)snprintf(buf, sizeof buf, "%s/__dbtest", p); |
154 | fname = buf; | 160 | fname = buf; |
155 | (void)unlink(buf); | 161 | (void)unlink(buf); |
156 | } | 162 | } else if (!sflag) |
163 | (void)unlink(fname); | ||
164 | |||
157 | if ((dbp = dbopen(fname, | 165 | if ((dbp = dbopen(fname, |
158 | oflags, S_IRUSR | S_IWUSR, type, infop)) == NULL) | 166 | oflags, S_IRUSR | S_IWUSR, type, infop)) == NULL) |
159 | err("dbopen: %s", strerror(errno)); | 167 | dberr("dbopen: %s", strerror(errno)); |
160 | XXdbp = dbp; | 168 | XXdbp = dbp; |
161 | 169 | ||
162 | state = COMMAND; | 170 | state = COMMAND; |
163 | for (lineno = 1; | 171 | for (lineno = 1; |
164 | (p = fgets(buf, sizeof(buf), stdin)) != NULL; ++lineno) { | 172 | (p = fgets(buf, sizeof(buf), stdin)) != NULL; ++lineno) { |
165 | len = strlen(buf); | 173 | /* Delete the newline, displaying the key/data is easier. */ |
166 | switch(*p) { | 174 | if (ofd == STDOUT_FILENO && (t = strchr(p, '\n')) != NULL) |
175 | *t = '\0'; | ||
176 | if ((len = strlen(buf)) == 0 || isspace(*p) || *p == '#') | ||
177 | continue; | ||
178 | |||
179 | /* Convenient gdb break point. */ | ||
180 | if (XXlineno == lineno) | ||
181 | XXlineno = 1; | ||
182 | switch (*p) { | ||
167 | case 'c': /* compare */ | 183 | case 'c': /* compare */ |
168 | if (state != COMMAND) | 184 | if (state != COMMAND) |
169 | err("line %lu: not expecting command", lineno); | 185 | dberr("line %lu: not expecting command", |
186 | lineno); | ||
170 | state = KEY; | 187 | state = KEY; |
171 | command = COMPARE; | 188 | command = COMPARE; |
172 | break; | 189 | break; |
173 | case 'e': /* echo */ | 190 | case 'e': /* echo */ |
174 | if (state != COMMAND) | 191 | if (state != COMMAND) |
175 | err("line %lu: not expecting command", lineno); | 192 | dberr("line %lu: not expecting command", |
193 | lineno); | ||
176 | /* Don't display the newline, if CR at EOL. */ | 194 | /* Don't display the newline, if CR at EOL. */ |
177 | if (p[len - 2] == '\r') | 195 | if (p[len - 2] == '\r') |
178 | --len; | 196 | --len; |
179 | if (write(ofd, p + 1, len - 1) != len - 1) | 197 | if (write(ofd, p + 1, len - 1) != len - 1 || |
180 | err("write: %s", strerror(errno)); | 198 | write(ofd, "\n", 1) != 1) |
199 | dberr("write: %s", strerror(errno)); | ||
181 | break; | 200 | break; |
182 | case 'g': /* get */ | 201 | case 'g': /* get */ |
183 | if (state != COMMAND) | 202 | if (state != COMMAND) |
184 | err("line %lu: not expecting command", lineno); | 203 | dberr("line %lu: not expecting command", |
204 | lineno); | ||
185 | state = KEY; | 205 | state = KEY; |
186 | command = GET; | 206 | command = GET; |
187 | break; | 207 | break; |
188 | case 'p': /* put */ | 208 | case 'p': /* put */ |
189 | if (state != COMMAND) | 209 | if (state != COMMAND) |
190 | err("line %lu: not expecting command", lineno); | 210 | dberr("line %lu: not expecting command", |
211 | lineno); | ||
191 | state = KEY; | 212 | state = KEY; |
192 | command = PUT; | 213 | command = PUT; |
193 | break; | 214 | break; |
194 | case 'r': /* remove */ | 215 | case 'r': /* remove */ |
195 | if (state != COMMAND) | 216 | if (state != COMMAND) |
196 | err("line %lu: not expecting command", lineno); | 217 | dberr("line %lu: not expecting command", |
197 | state = KEY; | 218 | lineno); |
198 | command = REMOVE; | 219 | if (flags == R_CURSOR) { |
220 | rem(dbp, &key); | ||
221 | state = COMMAND; | ||
222 | } else { | ||
223 | state = KEY; | ||
224 | command = REMOVE; | ||
225 | } | ||
226 | break; | ||
227 | case 'S': /* sync */ | ||
228 | if (state != COMMAND) | ||
229 | dberr("line %lu: not expecting command", | ||
230 | lineno); | ||
231 | synk(dbp); | ||
232 | state = COMMAND; | ||
199 | break; | 233 | break; |
200 | case 's': /* seq */ | 234 | case 's': /* seq */ |
201 | if (state != COMMAND) | 235 | if (state != COMMAND) |
202 | err("line %lu: not expecting command", lineno); | 236 | dberr("line %lu: not expecting command", |
237 | lineno); | ||
203 | if (flags == R_CURSOR) { | 238 | if (flags == R_CURSOR) { |
204 | state = KEY; | 239 | state = KEY; |
205 | command = SEQ; | 240 | command = SEQ; |
@@ -211,15 +246,15 @@ main(argc, argv) | |||
211 | break; | 246 | break; |
212 | case 'D': /* data file */ | 247 | case 'D': /* data file */ |
213 | if (state != DATA) | 248 | if (state != DATA) |
214 | err("line %lu: not expecting data", lineno); | 249 | dberr("line %lu: not expecting data", lineno); |
215 | data.data = rfile(p + 1, &data.size); | 250 | data.data = rfile(p + 1, &data.size); |
216 | goto ldata; | 251 | goto ldata; |
217 | case 'd': /* data */ | 252 | case 'd': /* data */ |
218 | if (state != DATA) | 253 | if (state != DATA) |
219 | err("line %lu: not expecting data", lineno); | 254 | dberr("line %lu: not expecting data", lineno); |
220 | data.data = xmalloc(p + 1, len - 1); | 255 | data.data = xmalloc(p + 1, len - 1); |
221 | data.size = len - 1; | 256 | data.size = len - 1; |
222 | ldata: switch(command) { | 257 | ldata: switch (command) { |
223 | case COMPARE: | 258 | case COMPARE: |
224 | compare(&keydata, &data); | 259 | compare(&keydata, &data); |
225 | break; | 260 | break; |
@@ -227,7 +262,7 @@ ldata: switch(command) { | |||
227 | put(dbp, &key, &data); | 262 | put(dbp, &key, &data); |
228 | break; | 263 | break; |
229 | default: | 264 | default: |
230 | err("line %lu: command doesn't take data", | 265 | dberr("line %lu: command doesn't take data", |
231 | lineno); | 266 | lineno); |
232 | } | 267 | } |
233 | if (type != DB_RECNO) | 268 | if (type != DB_RECNO) |
@@ -237,15 +272,15 @@ ldata: switch(command) { | |||
237 | break; | 272 | break; |
238 | case 'K': /* key file */ | 273 | case 'K': /* key file */ |
239 | if (state != KEY) | 274 | if (state != KEY) |
240 | err("line %lu: not expecting a key", lineno); | 275 | dberr("line %lu: not expecting a key", lineno); |
241 | if (type == DB_RECNO) | 276 | if (type == DB_RECNO) |
242 | err("line %lu: 'K' not available for recno", | 277 | dberr("line %lu: 'K' not available for recno", |
243 | lineno); | 278 | lineno); |
244 | key.data = rfile(p + 1, &key.size); | 279 | key.data = rfile(p + 1, &key.size); |
245 | goto lkey; | 280 | goto lkey; |
246 | case 'k': /* key */ | 281 | case 'k': /* key */ |
247 | if (state != KEY) | 282 | if (state != KEY) |
248 | err("line %lu: not expecting a key", lineno); | 283 | dberr("line %lu: not expecting a key", lineno); |
249 | if (type == DB_RECNO) { | 284 | if (type == DB_RECNO) { |
250 | static recno_t recno; | 285 | static recno_t recno; |
251 | recno = atoi(p + 1); | 286 | recno = atoi(p + 1); |
@@ -255,7 +290,7 @@ ldata: switch(command) { | |||
255 | key.data = xmalloc(p + 1, len - 1); | 290 | key.data = xmalloc(p + 1, len - 1); |
256 | key.size = len - 1; | 291 | key.size = len - 1; |
257 | } | 292 | } |
258 | lkey: switch(command) { | 293 | lkey: switch (command) { |
259 | case COMPARE: | 294 | case COMPARE: |
260 | getdata(dbp, &key, &keydata); | 295 | getdata(dbp, &key, &keydata); |
261 | state = DATA; | 296 | state = DATA; |
@@ -271,18 +306,18 @@ lkey: switch(command) { | |||
271 | break; | 306 | break; |
272 | case REMOVE: | 307 | case REMOVE: |
273 | rem(dbp, &key); | 308 | rem(dbp, &key); |
274 | if (type != DB_RECNO) | 309 | if ((type != DB_RECNO) && (flags != R_CURSOR)) |
275 | free(key.data); | 310 | free(key.data); |
276 | state = COMMAND; | 311 | state = COMMAND; |
277 | break; | 312 | break; |
278 | case SEQ: | 313 | case SEQ: |
279 | seq(dbp, &key); | 314 | seq(dbp, &key); |
280 | if (type != DB_RECNO) | 315 | if ((type != DB_RECNO) && (flags != R_CURSOR)) |
281 | free(key.data); | 316 | free(key.data); |
282 | state = COMMAND; | 317 | state = COMMAND; |
283 | break; | 318 | break; |
284 | default: | 319 | default: |
285 | err("line %lu: command doesn't take a key", | 320 | dberr("line %lu: command doesn't take a key", |
286 | lineno); | 321 | lineno); |
287 | } | 322 | } |
288 | break; | 323 | break; |
@@ -290,22 +325,25 @@ lkey: switch(command) { | |||
290 | dump(dbp, p[1] == 'r'); | 325 | dump(dbp, p[1] == 'r'); |
291 | break; | 326 | break; |
292 | default: | 327 | default: |
293 | err("line %lu: %s: unknown command character", | 328 | dberr("line %lu: %s: unknown command character", |
294 | p, lineno); | 329 | lineno, p); |
295 | } | 330 | } |
296 | } | 331 | } |
297 | #ifdef STATISTICS | 332 | #ifdef STATISTICS |
298 | if (type == DB_BTREE) | 333 | /* |
334 | * -l must be used (DB_LOCK must be set) for this to be | ||
335 | * used, otherwise a page will be locked and it will fail. | ||
336 | */ | ||
337 | if (type == DB_BTREE && oflags & DB_LOCK) | ||
299 | __bt_stat(dbp); | 338 | __bt_stat(dbp); |
300 | #endif | 339 | #endif |
301 | if (dbp->close(dbp)) | 340 | if (dbp->close(dbp)) |
302 | err("db->close: %s", strerror(errno)); | 341 | dberr("db->close: %s", strerror(errno)); |
303 | (void)close(ofd); | 342 | (void)close(ofd); |
304 | exit(0); | 343 | exit(0); |
305 | } | 344 | } |
306 | 345 | ||
307 | #define NOOVERWRITE "put failed, would overwrite key\n" | 346 | #define NOOVERWRITE "put failed, would overwrite key\n" |
308 | #define NOSUCHKEY "get failed, no such key\n" | ||
309 | 347 | ||
310 | void | 348 | void |
311 | compare(db1, db2) | 349 | compare(db1, db2) |
@@ -334,17 +372,23 @@ get(dbp, kp) | |||
334 | { | 372 | { |
335 | DBT data; | 373 | DBT data; |
336 | 374 | ||
337 | switch(dbp->get(dbp, kp, &data, flags)) { | 375 | switch (dbp->get(dbp, kp, &data, flags)) { |
338 | case 0: | 376 | case 0: |
339 | (void)write(ofd, data.data, data.size); | 377 | (void)write(ofd, data.data, data.size); |
378 | if (ofd == STDOUT_FILENO) | ||
379 | (void)write(ofd, "\n", 1); | ||
340 | break; | 380 | break; |
341 | case -1: | 381 | case -1: |
342 | err("line %lu: get: %s", lineno, strerror(errno)); | 382 | dberr("line %lu: get: %s", lineno, strerror(errno)); |
343 | /* NOTREACHED */ | 383 | /* NOTREACHED */ |
344 | case 1: | 384 | case 1: |
345 | (void)write(ofd, NOSUCHKEY, sizeof(NOSUCHKEY) - 1); | 385 | #define NOSUCHKEY "get failed, no such key\n" |
346 | (void)fprintf(stderr, "%d: %.*s: %s\n", | 386 | if (ofd != STDOUT_FILENO) |
347 | lineno, kp->size, kp->data, NOSUCHKEY); | 387 | (void)write(ofd, NOSUCHKEY, sizeof(NOSUCHKEY) - 1); |
388 | else | ||
389 | (void)fprintf(stderr, "%d: %.*s: %s", | ||
390 | lineno, MIN(kp->size, 20), kp->data, NOSUCHKEY); | ||
391 | #undef NOSUCHKEY | ||
348 | break; | 392 | break; |
349 | } | 393 | } |
350 | } | 394 | } |
@@ -354,14 +398,14 @@ getdata(dbp, kp, dp) | |||
354 | DB *dbp; | 398 | DB *dbp; |
355 | DBT *kp, *dp; | 399 | DBT *kp, *dp; |
356 | { | 400 | { |
357 | switch(dbp->get(dbp, kp, dp, flags)) { | 401 | switch (dbp->get(dbp, kp, dp, flags)) { |
358 | case 0: | 402 | case 0: |
359 | return; | 403 | return; |
360 | case -1: | 404 | case -1: |
361 | err("line %lu: getdata: %s", lineno, strerror(errno)); | 405 | dberr("line %lu: getdata: %s", lineno, strerror(errno)); |
362 | /* NOTREACHED */ | 406 | /* NOTREACHED */ |
363 | case 1: | 407 | case 1: |
364 | err("line %lu: get failed, no such key", lineno); | 408 | dberr("line %lu: getdata failed, no such key", lineno); |
365 | /* NOTREACHED */ | 409 | /* NOTREACHED */ |
366 | } | 410 | } |
367 | } | 411 | } |
@@ -371,11 +415,11 @@ put(dbp, kp, dp) | |||
371 | DB *dbp; | 415 | DB *dbp; |
372 | DBT *kp, *dp; | 416 | DBT *kp, *dp; |
373 | { | 417 | { |
374 | switch(dbp->put(dbp, kp, dp, flags)) { | 418 | switch (dbp->put(dbp, kp, dp, flags)) { |
375 | case 0: | 419 | case 0: |
376 | break; | 420 | break; |
377 | case -1: | 421 | case -1: |
378 | err("line %lu: put: %s", lineno, strerror(errno)); | 422 | dberr("line %lu: put: %s", lineno, strerror(errno)); |
379 | /* NOTREACHED */ | 423 | /* NOTREACHED */ |
380 | case 1: | 424 | case 1: |
381 | (void)write(ofd, NOOVERWRITE, sizeof(NOOVERWRITE) - 1); | 425 | (void)write(ofd, NOOVERWRITE, sizeof(NOOVERWRITE) - 1); |
@@ -388,34 +432,67 @@ rem(dbp, kp) | |||
388 | DB *dbp; | 432 | DB *dbp; |
389 | DBT *kp; | 433 | DBT *kp; |
390 | { | 434 | { |
391 | switch(dbp->del(dbp, kp, flags)) { | 435 | switch (dbp->del(dbp, kp, flags)) { |
392 | case 0: | 436 | case 0: |
393 | break; | 437 | break; |
394 | case -1: | 438 | case -1: |
395 | err("line %lu: get: %s", lineno, strerror(errno)); | 439 | dberr("line %lu: rem: %s", lineno, strerror(errno)); |
396 | /* NOTREACHED */ | 440 | /* NOTREACHED */ |
397 | case 1: | 441 | case 1: |
398 | (void)write(ofd, NOSUCHKEY, sizeof(NOSUCHKEY) - 1); | 442 | #define NOSUCHKEY "rem failed, no such key\n" |
443 | if (ofd != STDOUT_FILENO) | ||
444 | (void)write(ofd, NOSUCHKEY, sizeof(NOSUCHKEY) - 1); | ||
445 | else if (flags != R_CURSOR) | ||
446 | (void)fprintf(stderr, "%d: %.*s: %s", | ||
447 | lineno, MIN(kp->size, 20), kp->data, NOSUCHKEY); | ||
448 | else | ||
449 | (void)fprintf(stderr, | ||
450 | "%d: rem of cursor failed\n", lineno); | ||
451 | #undef NOSUCHKEY | ||
399 | break; | 452 | break; |
400 | } | 453 | } |
401 | } | 454 | } |
402 | 455 | ||
403 | void | 456 | void |
457 | synk(dbp) | ||
458 | DB *dbp; | ||
459 | { | ||
460 | switch (dbp->sync(dbp, flags)) { | ||
461 | case 0: | ||
462 | break; | ||
463 | case -1: | ||
464 | dberr("line %lu: synk: %s", lineno, strerror(errno)); | ||
465 | /* NOTREACHED */ | ||
466 | } | ||
467 | } | ||
468 | |||
469 | void | ||
404 | seq(dbp, kp) | 470 | seq(dbp, kp) |
405 | DB *dbp; | 471 | DB *dbp; |
406 | DBT *kp; | 472 | DBT *kp; |
407 | { | 473 | { |
408 | DBT data; | 474 | DBT data; |
409 | 475 | ||
410 | switch(dbp->seq(dbp, kp, &data, flags)) { | 476 | switch (dbp->seq(dbp, kp, &data, flags)) { |
411 | case 0: | 477 | case 0: |
412 | (void)write(ofd, data.data, data.size); | 478 | (void)write(ofd, data.data, data.size); |
479 | if (ofd == STDOUT_FILENO) | ||
480 | (void)write(ofd, "\n", 1); | ||
413 | break; | 481 | break; |
414 | case -1: | 482 | case -1: |
415 | err("line %lu: seq: %s", lineno, strerror(errno)); | 483 | dberr("line %lu: seq: %s", lineno, strerror(errno)); |
416 | /* NOTREACHED */ | 484 | /* NOTREACHED */ |
417 | case 1: | 485 | case 1: |
418 | (void)write(ofd, NOSUCHKEY, sizeof(NOSUCHKEY) - 1); | 486 | #define NOSUCHKEY "seq failed, no such key\n" |
487 | if (ofd != STDOUT_FILENO) | ||
488 | (void)write(ofd, NOSUCHKEY, sizeof(NOSUCHKEY) - 1); | ||
489 | else if (flags == R_CURSOR) | ||
490 | (void)fprintf(stderr, "%d: %.*s: %s", | ||
491 | lineno, MIN(kp->size, 20), kp->data, NOSUCHKEY); | ||
492 | else | ||
493 | (void)fprintf(stderr, | ||
494 | "%d: seq (%s) failed\n", lineno, sflags(flags)); | ||
495 | #undef NOSUCHKEY | ||
419 | break; | 496 | break; |
420 | } | 497 | } |
421 | } | 498 | } |
@@ -436,14 +513,16 @@ dump(dbp, rev) | |||
436 | nflags = R_NEXT; | 513 | nflags = R_NEXT; |
437 | } | 514 | } |
438 | for (;; flags = nflags) | 515 | for (;; flags = nflags) |
439 | switch(dbp->seq(dbp, &key, &data, flags)) { | 516 | switch (dbp->seq(dbp, &key, &data, flags)) { |
440 | case 0: | 517 | case 0: |
441 | (void)write(ofd, data.data, data.size); | 518 | (void)write(ofd, data.data, data.size); |
519 | if (ofd == STDOUT_FILENO) | ||
520 | (void)write(ofd, "\n", 1); | ||
442 | break; | 521 | break; |
443 | case 1: | 522 | case 1: |
444 | goto done; | 523 | goto done; |
445 | case -1: | 524 | case -1: |
446 | err("line %lu: (dump) seq: %s", | 525 | dberr("line %lu: (dump) seq: %s", |
447 | lineno, strerror(errno)); | 526 | lineno, strerror(errno)); |
448 | /* NOTREACHED */ | 527 | /* NOTREACHED */ |
449 | } | 528 | } |
@@ -454,34 +533,45 @@ u_int | |||
454 | setflags(s) | 533 | setflags(s) |
455 | char *s; | 534 | char *s; |
456 | { | 535 | { |
457 | char *p, *index(); | 536 | char *p; |
458 | 537 | ||
459 | for (; isspace(*s); ++s); | 538 | for (; isspace(*s); ++s); |
460 | if (*s == '\n') | 539 | if (*s == '\n' || *s == '\0') |
461 | return (0); | 540 | return (0); |
462 | if ((p = index(s, '\n')) != NULL) | 541 | if ((p = strchr(s, '\n')) != NULL) |
463 | *p = '\0'; | 542 | *p = '\0'; |
464 | if (!strcmp(s, "R_CURSOR")) | 543 | if (!strcmp(s, "R_CURSOR")) return (R_CURSOR); |
465 | return (R_CURSOR); | 544 | if (!strcmp(s, "R_FIRST")) return (R_FIRST); |
466 | if (!strcmp(s, "R_FIRST")) | 545 | if (!strcmp(s, "R_IAFTER")) return (R_IAFTER); |
467 | return (R_FIRST); | 546 | if (!strcmp(s, "R_IBEFORE")) return (R_IBEFORE); |
468 | if (!strcmp(s, "R_IAFTER")) | 547 | if (!strcmp(s, "R_LAST")) return (R_LAST); |
469 | return (R_IAFTER); | 548 | if (!strcmp(s, "R_NEXT")) return (R_NEXT); |
470 | if (!strcmp(s, "R_IBEFORE")) | 549 | if (!strcmp(s, "R_NOOVERWRITE")) return (R_NOOVERWRITE); |
471 | return (R_IBEFORE); | 550 | if (!strcmp(s, "R_PREV")) return (R_PREV); |
472 | if (!strcmp(s, "R_LAST")) | 551 | if (!strcmp(s, "R_SETCURSOR")) return (R_SETCURSOR); |
473 | return (R_LAST); | 552 | |
474 | if (!strcmp(s, "R_NEXT")) | 553 | dberr("line %lu: %s: unknown flag", lineno, s); |
475 | return (R_NEXT); | ||
476 | if (!strcmp(s, "R_NOOVERWRITE")) | ||
477 | return (R_NOOVERWRITE); | ||
478 | if (!strcmp(s, "R_PREV")) | ||
479 | return (R_PREV); | ||
480 | if (!strcmp(s, "R_SETCURSOR")) | ||
481 | return (R_SETCURSOR); | ||
482 | err("line %lu: %s: unknown flag", lineno, s); | ||
483 | /* NOTREACHED */ | 554 | /* NOTREACHED */ |
484 | } | 555 | } |
556 | |||
557 | char * | ||
558 | sflags(flags) | ||
559 | int flags; | ||
560 | { | ||
561 | switch (flags) { | ||
562 | case R_CURSOR: return ("R_CURSOR"); | ||
563 | case R_FIRST: return ("R_FIRST"); | ||
564 | case R_IAFTER: return ("R_IAFTER"); | ||
565 | case R_IBEFORE: return ("R_IBEFORE"); | ||
566 | case R_LAST: return ("R_LAST"); | ||
567 | case R_NEXT: return ("R_NEXT"); | ||
568 | case R_NOOVERWRITE: return ("R_NOOVERWRITE"); | ||
569 | case R_PREV: return ("R_PREV"); | ||
570 | case R_SETCURSOR: return ("R_SETCURSOR"); | ||
571 | } | ||
572 | |||
573 | return ("UNKNOWN!"); | ||
574 | } | ||
485 | 575 | ||
486 | DBTYPE | 576 | DBTYPE |
487 | dbtype(s) | 577 | dbtype(s) |
@@ -493,7 +583,7 @@ dbtype(s) | |||
493 | return (DB_HASH); | 583 | return (DB_HASH); |
494 | if (!strcmp(s, "recno")) | 584 | if (!strcmp(s, "recno")) |
495 | return (DB_RECNO); | 585 | return (DB_RECNO); |
496 | err("%s: unknown type (use btree, hash or recno)", s); | 586 | dberr("%s: unknown type (use btree, hash or recno)", s); |
497 | /* NOTREACHED */ | 587 | /* NOTREACHED */ |
498 | } | 588 | } |
499 | 589 | ||
@@ -505,15 +595,15 @@ setinfo(type, s) | |||
505 | static BTREEINFO ib; | 595 | static BTREEINFO ib; |
506 | static HASHINFO ih; | 596 | static HASHINFO ih; |
507 | static RECNOINFO rh; | 597 | static RECNOINFO rh; |
508 | char *eq, *index(); | 598 | char *eq; |
509 | 599 | ||
510 | if ((eq = index(s, '=')) == NULL) | 600 | if ((eq = strchr(s, '=')) == NULL) |
511 | err("%s: illegal structure set statement", s); | 601 | dberr("%s: illegal structure set statement", s); |
512 | *eq++ = '\0'; | 602 | *eq++ = '\0'; |
513 | if (!isdigit(*eq)) | 603 | if (!isdigit(*eq)) |
514 | err("%s: structure set statement must be a number", s); | 604 | dberr("%s: structure set statement must be a number", s); |
515 | 605 | ||
516 | switch(type) { | 606 | switch (type) { |
517 | case DB_BTREE: | 607 | case DB_BTREE: |
518 | if (!strcmp("flags", s)) { | 608 | if (!strcmp("flags", s)) { |
519 | ib.flags = atoi(eq); | 609 | ib.flags = atoi(eq); |
@@ -589,7 +679,7 @@ setinfo(type, s) | |||
589 | } | 679 | } |
590 | break; | 680 | break; |
591 | } | 681 | } |
592 | err("%s: unknown structure value", s); | 682 | dberr("%s: unknown structure value", s); |
593 | /* NOTREACHED */ | 683 | /* NOTREACHED */ |
594 | } | 684 | } |
595 | 685 | ||
@@ -601,20 +691,20 @@ rfile(name, lenp) | |||
601 | struct stat sb; | 691 | struct stat sb; |
602 | void *p; | 692 | void *p; |
603 | int fd; | 693 | int fd; |
604 | char *np, *index(); | 694 | char *np; |
605 | 695 | ||
606 | for (; isspace(*name); ++name); | 696 | for (; isspace(*name); ++name); |
607 | if ((np = index(name, '\n')) != NULL) | 697 | if ((np = strchr(name, '\n')) != NULL) |
608 | *np = '\0'; | 698 | *np = '\0'; |
609 | if ((fd = open(name, O_RDONLY, 0)) < 0 || | 699 | if ((fd = open(name, O_RDONLY, 0)) < 0 || |
610 | fstat(fd, &sb)) | 700 | fstat(fd, &sb)) |
611 | err("%s: %s\n", name, strerror(errno)); | 701 | dberr("%s: %s\n", name, strerror(errno)); |
612 | #ifdef NOT_PORTABLE | 702 | #ifdef NOT_PORTABLE |
613 | if (sb.st_size > (off_t)SIZE_T_MAX) | 703 | if (sb.st_size > (off_t)SIZE_T_MAX) |
614 | err("%s: %s\n", name, strerror(E2BIG)); | 704 | dberr("%s: %s\n", name, strerror(E2BIG)); |
615 | #endif | 705 | #endif |
616 | if ((p = (void *)malloc((u_int)sb.st_size)) == NULL) | 706 | if ((p = (void *)malloc((u_int)sb.st_size)) == NULL) |
617 | err("%s", strerror(errno)); | 707 | dberr("%s", strerror(errno)); |
618 | (void)read(fd, p, (int)sb.st_size); | 708 | (void)read(fd, p, (int)sb.st_size); |
619 | *lenp = sb.st_size; | 709 | *lenp = sb.st_size; |
620 | (void)close(fd); | 710 | (void)close(fd); |
@@ -629,7 +719,7 @@ xmalloc(text, len) | |||
629 | void *p; | 719 | void *p; |
630 | 720 | ||
631 | if ((p = (void *)malloc(len)) == NULL) | 721 | if ((p = (void *)malloc(len)) == NULL) |
632 | err("%s", strerror(errno)); | 722 | dberr("%s", strerror(errno)); |
633 | memmove(p, text, len); | 723 | memmove(p, text, len); |
634 | return (p); | 724 | return (p); |
635 | } | 725 | } |
@@ -642,27 +732,12 @@ usage() | |||
642 | exit(1); | 732 | exit(1); |
643 | } | 733 | } |
644 | 734 | ||
645 | #if __STDC__ | ||
646 | #include <stdarg.h> | ||
647 | #else | ||
648 | #include <varargs.h> | ||
649 | #endif | ||
650 | |||
651 | void | 735 | void |
652 | #if __STDC__ | 736 | dberr(const char *fmt, ...) |
653 | err(const char *fmt, ...) | ||
654 | #else | ||
655 | err(fmt, va_alist) | ||
656 | char *fmt; | ||
657 | va_dcl | ||
658 | #endif | ||
659 | { | 737 | { |
660 | va_list ap; | 738 | va_list ap; |
661 | #if __STDC__ | 739 | |
662 | va_start(ap, fmt); | 740 | va_start(ap, fmt); |
663 | #else | ||
664 | va_start(ap); | ||
665 | #endif | ||
666 | (void)fprintf(stderr, "dbtest: "); | 741 | (void)fprintf(stderr, "dbtest: "); |
667 | (void)vfprintf(stderr, fmt, ap); | 742 | (void)vfprintf(stderr, fmt, ap); |
668 | va_end(ap); | 743 | va_end(ap); |