Index: third_party/sqlite/sqlite-src-3080704/test/crashtest1.c |
diff --git a/third_party/sqlite/sqlite-src-3080704/test/crashtest1.c b/third_party/sqlite/sqlite-src-3080704/test/crashtest1.c |
new file mode 100644 |
index 0000000000000000000000000000000000000000..1f7035d18ea78d137272a6d76edbe1909549c414 |
--- /dev/null |
+++ b/third_party/sqlite/sqlite-src-3080704/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; |
+} |