| Index: third_party/sqlite/src/test/crashtest1.c
|
| diff --git a/third_party/sqlite/src/test/crashtest1.c b/third_party/sqlite/src/test/crashtest1.c
|
| new file mode 100644
|
| index 0000000000000000000000000000000000000000..1f7035d18ea78d137272a6d76edbe1909549c414
|
| --- /dev/null
|
| +++ b/third_party/sqlite/src/test/crashtest1.c
|
| @@ -0,0 +1,96 @@
|
| +/*
|
| +** This program tests the ability of SQLite database to recover from a crash.
|
| +** This program runs under Unix only, but the results are applicable to all
|
| +** systems.
|
| +**
|
| +** The main process first constructs a test database, then starts creating
|
| +** subprocesses that write to that database. Each subprocess is killed off,
|
| +** without a chance to clean up its database connection, after a random
|
| +** delay. This killing of the subprocesses simulates a crash or power
|
| +** failure. The next subprocess to open the database should rollback
|
| +** whatever operation was in process at the time of the simulated crash.
|
| +**
|
| +** If any problems are encountered, an error is reported and the test stops.
|
| +** If no problems are seen after a large number of tests, we assume that
|
| +** the rollback mechanism is working.
|
| +*/
|
| +#include <stdio.h>
|
| +#include <unistd.h>
|
| +#include <sys/types.h>
|
| +#include <sys/wait.h>
|
| +#include <signal.h>
|
| +#include <stdlib.h>
|
| +#include <string.h>
|
| +#include <sched.h>
|
| +#include "sqlite.h"
|
| +
|
| +static void do_some_sql(int parent){
|
| + char *zErr;
|
| + int rc = SQLITE_OK;
|
| + sqlite *db;
|
| + int cnt = 0;
|
| + static char zBig[] =
|
| + "-abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ"
|
| + "-abcdefghijklmnopqrstuvwxyzABCDEFGHIJKLMNOPQRSTUVWXYZ";
|
| +
|
| + if( access("./test.db-journal",0)==0 ){
|
| + /*printf("pid %d: journal exists. rollback will be required\n",getpid());*/ unlink("test.db-saved");
|
| + system("cp test.db test.db-saved");
|
| + unlink("test.db-journal-saved");
|
| + system("cp test.db-journal test.db-journal-saved");
|
| + }
|
| + db = sqlite_open("./test.db", 0, &zErr);
|
| + if( db==0 ){
|
| + printf("ERROR: %s\n", zErr);
|
| + if( strcmp(zErr,"database disk image is malformed")==0 ){
|
| + kill(parent, SIGKILL);
|
| + }
|
| + exit(1);
|
| + }
|
| + srand(getpid());
|
| + while( rc==SQLITE_OK ){
|
| + cnt++;
|
| + rc = sqlite_exec_printf(db,
|
| + "INSERT INTO t1 VALUES(%d,'%d%s')", 0, 0, &zErr,
|
| + rand(), rand(), zBig);
|
| + }
|
| + if( rc!=SQLITE_OK ){
|
| + printf("ERROR #%d: %s\n", rc, zErr);
|
| + if( rc==SQLITE_CORRUPT ){
|
| + kill(parent, SIGKILL);
|
| + }
|
| + }
|
| + printf("pid %d: cnt=%d\n", getpid(), cnt);
|
| +}
|
| +
|
| +
|
| +int main(int argc, char **argv){
|
| + int i;
|
| + sqlite *db;
|
| + char *zErr;
|
| + int status;
|
| + int parent = getpid();
|
| +
|
| + unlink("test.db");
|
| + unlink("test.db-journal");
|
| + db = sqlite_open("test.db", 0, &zErr);
|
| + if( db==0 ){
|
| + printf("Cannot initialize: %s\n", zErr);
|
| + return 1;
|
| + }
|
| + sqlite_exec(db, "CREATE TABLE t1(a,b)", 0, 0, 0);
|
| + sqlite_close(db);
|
| + for(i=0; i<10000; i++){
|
| + int pid = fork();
|
| + if( pid==0 ){
|
| + sched_yield();
|
| + do_some_sql(parent);
|
| + return 0;
|
| + }
|
| + printf("test %d, pid=%d\n", i, pid);
|
| + usleep(rand()%10000 + 1000);
|
| + kill(pid, SIGKILL);
|
| + waitpid(pid, &status, 0);
|
| + }
|
| + return 0;
|
| +}
|
|
|