OLD | NEW |
| (Empty) |
1 # 2014 October 22 | |
2 # | |
3 # The author disclaims copyright to this source code. In place of | |
4 # a legal notice, here is a blessing: | |
5 # | |
6 # May you do good and not evil. | |
7 # May you find forgiveness for yourself and forgive others. | |
8 # May you share freely, never taking more than you give. | |
9 # | |
10 #*********************************************************************** | |
11 # | |
12 | |
13 if {![info exists testdir]} { | |
14 set testdir [file join [file dirname [info script]] .. .. test] | |
15 } | |
16 source $testdir/tester.tcl | |
17 set ::testprefix rbucrash | |
18 | |
19 db close | |
20 forcedelete test.db-oal rbu.db | |
21 sqlite3_shutdown | |
22 sqlite3_config_uri 1 | |
23 reset_db | |
24 | |
25 # Set up a target database and an rbu update database. The target | |
26 # db is the usual "test.db", the rbu db is "test.db2". | |
27 # | |
28 forcedelete test.db2 | |
29 do_execsql_test 1.0 { | |
30 CREATE TABLE t1(a, b, c, PRIMARY KEY(a), UNIQUE(b)); | |
31 INSERT INTO t1 VALUES(1, 2, 3); | |
32 INSERT INTO t1 VALUES(4, 5, 6); | |
33 INSERT INTO t1 VALUES(7, 8, 9); | |
34 | |
35 ATTACH 'test.db2' AS rbu; | |
36 CREATE TABLE rbu.data_t1(a, b, c, rbu_control); | |
37 INSERT INTO data_t1 VALUES(10, 11, 12, 0); | |
38 INSERT INTO data_t1 VALUES(13, 14, 15, 0); | |
39 INSERT INTO data_t1 VALUES(4, NULL, NULL, 1); | |
40 INSERT INTO data_t1 VALUES(1, NULL, 100, '..x'); | |
41 } | |
42 db_save_and_close | |
43 | |
44 | |
45 # Determine the number of steps in applying the rbu update to the test | |
46 # target database created above. Set $::rbu_num_steps accordingly | |
47 # | |
48 # Check that the same number of steps are required to apply the rbu | |
49 # update using many calls to sqlite3rbu_step() on a single rbu handle | |
50 # as required to apply it using a series of rbu handles, on each of | |
51 # which sqlite3rbu_step() is called once. | |
52 # | |
53 do_test 1.1 { | |
54 db_restore | |
55 sqlite3rbu rbu test.db test.db2 | |
56 breakpoint | |
57 set nStep 0 | |
58 while {[rbu step]=="SQLITE_OK"} { incr nStep } | |
59 rbu close | |
60 } {SQLITE_DONE} | |
61 set rbu_num_steps $nStep | |
62 do_test 1.2 { | |
63 db_restore | |
64 set nStep 0 | |
65 while {1} { | |
66 sqlite3rbu rbu test.db test.db2 | |
67 rbu step | |
68 if {[rbu close]=="SQLITE_DONE"} break | |
69 incr nStep | |
70 } | |
71 set nStep | |
72 } $rbu_num_steps | |
73 | |
74 | |
75 # Run one or more tests using the target (test.db) and rbu (test.db2) | |
76 # databases created above. As follows: | |
77 # | |
78 # 1. This process starts the rbu update and calls sqlite3rbu_step() | |
79 # $nPre times. Then closes the rbu update handle. | |
80 # | |
81 # 2. A second process resumes the rbu update and attempts to call | |
82 # sqlite3rbu_step() $nStep times before closing the handle. A | |
83 # crash is simulated during each xSync() of file test.db2. | |
84 # | |
85 # 3. This process attempts to resume the rbu update from whatever | |
86 # state it was left in by step (2). Test that it is successful | |
87 # in doing so and that the final target database is as expected. | |
88 # | |
89 # In total (nSync+1) tests are run, where nSync is the number of times | |
90 # xSync() is called on test.db2. | |
91 # | |
92 proc do_rbu_crash_test {tn nPre nStep} { | |
93 | |
94 set script [subst -nocommands { | |
95 sqlite3rbu rbu test.db file:test.db2?vfs=crash | |
96 set i 0 | |
97 while {[set i] < $nStep} { | |
98 if {[rbu step]!="SQLITE_OK"} break | |
99 incr i | |
100 } | |
101 rbu close | |
102 }] | |
103 | |
104 set bDone 0 | |
105 for {set iDelay 1} {$bDone==0} {incr iDelay} { | |
106 forcedelete test.db2 test.db2-journal test.db test.db-oal test.db-wal | |
107 db_restore | |
108 | |
109 if {$nPre>0} { | |
110 sqlite3rbu rbu test.db file:test.db2 | |
111 set i 0 | |
112 for {set i 0} {$i < $nPre} {incr i} { | |
113 if {[rbu step]!="SQLITE_OK"} break | |
114 } | |
115 rbu close | |
116 } | |
117 | |
118 set res [ | |
119 crashsql -file test.db2 -delay $iDelay -tclbody $script -opendb {} {} | |
120 ] | |
121 | |
122 set bDone 1 | |
123 if {$res == "1 {child process exited abnormally}"} { | |
124 set bDone 0 | |
125 } elseif {$res != "0 {}"} { | |
126 error "unexected catchsql result: $res" | |
127 } | |
128 | |
129 sqlite3rbu rbu test.db test.db2 | |
130 while {[rbu step]=="SQLITE_OK"} {} | |
131 rbu close | |
132 | |
133 sqlite3 db test.db | |
134 do_execsql_test $tn.delay=$iDelay { | |
135 SELECT * FROM t1; | |
136 PRAGMA integrity_check; | |
137 } {1 2 100 7 8 9 10 11 12 13 14 15 ok} | |
138 db close | |
139 } | |
140 } | |
141 | |
142 for {set nPre 0} {$nPre < $rbu_num_steps} {incr nPre} { | |
143 for {set is 1} {$is <= ($rbu_num_steps - $nPre)} {incr is} { | |
144 do_rbu_crash_test 2.pre=$nPre.step=$is $nPre $is | |
145 } | |
146 } | |
147 | |
148 finish_test | |
149 | |
OLD | NEW |