xref: /sqlite-3.40.0/test/walprotocol.test (revision dfe4e6bb) 
1# 2016 February 4
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# This file implements regression tests for SQLite library.  The
12# focus of this file is testing the operation of the library in
13# "PRAGMA journal_mode=WAL" mode.
14#
15# More specifically, it tests "locking protocol" errors - errors that
16# may be caused if one or more SQLite clients does not follow the expected
17# locking protocol when accessing a wal-mode database. These tests take
18# quite a while to run.
19#
20
21set testdir [file dirname $argv0]
22source $testdir/tester.tcl
23source $testdir/lock_common.tcl
24source $testdir/wal_common.tcl
25ifcapable !wal {finish_test ; return }
26
27set testprefix walprotocol
28
29#-------------------------------------------------------------------------
30# When recovering the contents of a WAL file, a process obtains the WRITER
31# lock, then locks all other bytes before commencing recovery. If it fails
32# to lock all other bytes (because some other process is holding a read
33# lock) it should retry up to 100 times. Then return SQLITE_PROTOCOL to the
34# caller. Test this (test case 1.3).
35#
36# Also test the effect of hitting an SQLITE_BUSY while attempting to obtain
37# the WRITER lock (should be the same). Test case 1.4.
38#
39do_execsql_test 1.0 {
40  PRAGMA journal_mode = wal;
41  CREATE TABLE x(y);
42  INSERT INTO x VALUES('z');
43} {wal}
44
45proc lock_callback {method filename handle lock} {
46  lappend ::locks $lock
47}
48do_test 1.1 {
49  testvfs T
50  T filter xShmLock
51  T script lock_callback
52  set ::locks [list]
53  sqlite3 db test.db -vfs T
54  execsql { SELECT * FROM x }
55  lrange $::locks 0 3
56} [list {0 1 lock exclusive} {1 7 lock exclusive}      \
57        {1 7 unlock exclusive} {0 1 unlock exclusive}  \
58]
59do_test 1.2 {
60  db close
61  set ::locks [list]
62  sqlite3 db test.db -vfs T
63  execsql { SELECT * FROM x }
64  lrange $::locks 0 3
65} [list {0 1 lock exclusive} {1 7 lock exclusive}      \
66        {1 7 unlock exclusive} {0 1 unlock exclusive}  \
67]
68proc lock_callback {method filename handle lock} {
69  if {$lock == "1 7 lock exclusive"} { return SQLITE_BUSY }
70  return SQLITE_OK
71}
72puts "# Warning: This next test case causes SQLite to call xSleep(1) 100 times."
73puts "# Normally this equates to a delay of roughly 10 seconds, but if SQLite"
74puts "# is built on unix without HAVE_USLEEP defined, it may be much longer."
75do_test 1.3 {
76  db close
77  set ::locks [list]
78  sqlite3 db test.db -vfs T
79  catchsql { SELECT * FROM x }
80} {1 {locking protocol}}
81
82puts "# Warning: Same again!"
83proc lock_callback {method filename handle lock} {
84  if {$lock == "0 1 lock exclusive"} { return SQLITE_BUSY }
85  return SQLITE_OK
86}
87do_test 1.4 {
88  db close
89  set ::locks [list]
90  sqlite3 db test.db -vfs T
91  catchsql { SELECT * FROM x }
92} {1 {locking protocol}}
93db close
94T delete
95
96#-------------------------------------------------------------------------
97#
98do_test 2.1 {
99  forcedelete test.db test.db-journal test.db wal
100  sqlite3 db test.db
101  sqlite3 db2 test.db
102  execsql {
103    PRAGMA auto_vacuum = off;
104    PRAGMA journal_mode = WAL;
105    CREATE TABLE b(c);
106    INSERT INTO b VALUES('Tehran');
107    INSERT INTO b VALUES('Qom');
108    INSERT INTO b VALUES('Markazi');
109    PRAGMA wal_checkpoint;
110  }
111} {wal 0 5 5}
112do_test 2.2 {
113  execsql { SELECT * FROM b }
114} {Tehran Qom Markazi}
115do_test 2.3 {
116  db eval { SELECT * FROM b } {
117    db eval { INSERT INTO b VALUES('Qazvin') }
118    set r [db2 eval { SELECT * FROM b }]
119    break
120  }
121  set r
122} {Tehran Qom Markazi Qazvin}
123do_test 2.4 {
124  execsql {
125    INSERT INTO b VALUES('Gilan');
126    INSERT INTO b VALUES('Ardabil');
127  }
128} {}
129db2 close
130
131faultsim_save_and_close
132testvfs T -default 1
133faultsim_restore_and_reopen
134T filter xShmLock
135T script lock_callback
136
137proc lock_callback {method file handle spec} {
138  if {$spec == "1 7 unlock exclusive"} {
139    T filter {}
140    set ::r [catchsql { SELECT * FROM b } db2]
141  }
142}
143sqlite3 db test.db
144sqlite3 db2 test.db
145do_test 2.5 {
146  execsql { SELECT * FROM b }
147} {Tehran Qom Markazi Qazvin Gilan Ardabil}
148do_test 2.6 {
149  set ::r
150} {1 {locking protocol}}
151
152db close
153db2 close
154
155faultsim_restore_and_reopen
156sqlite3 db2 test.db
157T filter xShmLock
158T script lock_callback
159proc lock_callback {method file handle spec} {
160  if {$spec == "1 7 unlock exclusive"} {
161    T filter {}
162    set ::r [catchsql { SELECT * FROM b } db2]
163  }
164}
165unset ::r
166do_test 2.7 {
167  execsql { SELECT * FROM b }
168} {Tehran Qom Markazi Qazvin Gilan Ardabil}
169do_test 2.8 {
170  set ::r
171} {1 {locking protocol}}
172
173db close
174db2 close
175T delete
176
177finish_test
178