| # 2020 May 06 |
| # |
| # The author disclaims copyright to this source code. In place of |
| # a legal notice, here is a blessing: |
| # |
| # May you do good and not evil. |
| # May you find forgiveness for yourself and forgive others. |
| # May you share freely, never taking more than you give. |
| # |
| #*********************************************************************** |
| # |
| # TESTRUNNER: slow |
| # |
| |
| set testdir [file dirname $argv0] |
| source $testdir/tester.tcl |
| source $testdir/lock_common.tcl |
| set testprefix walsetlk3 |
| |
| ifcapable !wal {finish_test ; return } |
| ifcapable !setlk_timeout {finish_test ; return } |
| |
| do_execsql_test 1.0 { |
| CREATE TABLE t1(x, y); |
| PRAGMA journal_mode = wal; |
| INSERT INTO t1 VALUES(1, 2); |
| INSERT INTO t1 VALUES(3, 4); |
| } {wal} |
| |
| db close |
| |
| proc sql_block_on_close {sql} { |
| testfixture_nb done [string map [list %SQL% $sql] { |
| testvfs tvfs |
| tvfs script xWrite |
| tvfs filter xWrite |
| |
| set ::delay_done 0 |
| proc xWrite {method fname args} { |
| if {[file tail $fname]=="test.db" && $::delay_done==0} { |
| after 3000 |
| set ::delay_done 1 |
| } |
| return 0 |
| } |
| |
| sqlite3 db test.db -vfs tvfs |
| db eval {%SQL%} |
| db close |
| }] |
| } |
| |
| # Start a second process that writes to the db, then blocks within the |
| # [db close] holding an EXCLUSIVE on the db in order to checkpoint and |
| # delete the wal file. Then try to read the db. |
| # |
| # Without the SQLITE_SETLK_BLOCK_ON_CONNECT flag, this should fail with |
| # SQLITE_BUSY. |
| # |
| sql_block_on_close { |
| INSERT INTO t1 VALUES(5, 6); |
| INSERT INTO t1 VALUES(7, 8); |
| } |
| after 500 {set ok 1} |
| vwait ok |
| sqlite3 db test.db |
| sqlite3_setlk_timeout db 2000 |
| do_catchsql_test 1.1 { |
| SELECT * FROM t1 |
| } {1 {database is locked}} |
| |
| vwait ::done |
| |
| # But with SQLITE_SETLK_BLOCK_ON_CONNECT flag, it should succeed. |
| # |
| sql_block_on_close { |
| INSERT INTO t1 VALUES(9, 10); |
| INSERT INTO t1 VALUES(11, 12); |
| } |
| after 500 {set ok 1} |
| vwait ok |
| sqlite3 db test.db |
| sqlite3_setlk_timeout -block db 2000 |
| do_catchsql_test 1.2 { |
| SELECT * FROM t1 |
| } {0 {1 2 3 4 5 6 7 8 9 10 11 12}} |
| |
| vwait ::done |
| |
| #------------------------------------------------------------------------- |
| # Check that the SQLITE_SETLK_BLOCK_ON_CONNECT does not cause connections |
| # to block when taking a SHARED lock on a rollback mode database. |
| # |
| reset_db |
| do_execsql_test 2.1 { |
| CREATE TABLE x1(a); |
| INSERT INTO x1 VALUES(1), (2), (3); |
| } |
| |
| proc sql_block_on_write {sql} { |
| testfixture_nb done [string map [list %SQL% $sql] { |
| sqlite3 db test.db |
| db eval "BEGIN EXCLUSIVE" |
| db eval {%SQL%} |
| after 3000 |
| db eval COMMIT |
| db close |
| }] |
| } |
| |
| db close |
| sql_block_on_write { |
| INSERT INTO x1 VALUES(4); |
| } |
| |
| after 500 {set ok 1} |
| vwait ok |
| |
| sqlite3 db test.db |
| sqlite3_setlk_timeout -block db 2000 |
| |
| do_catchsql_test 2.2 { |
| SELECT * FROM x1 |
| } {1 {database is locked}} |
| |
| vwait ::done |
| after 500 {set ok 1} |
| vwait ok |
| |
| do_catchsql_test 2.3 { |
| SELECT * FROM x1 |
| } {0 {1 2 3 4}} |
| |
| finish_test |
| |