Annotation of embedaddon/sqlite3/test/thread003.test, revision 1.1
1.1 ! misho 1: # 2007 September 10
! 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: # This file contains tests that attempt to break the pcache module
! 13: # by bombarding it with simultaneous requests from multiple threads.
! 14: #
! 15: # $Id: thread003.test,v 1.8 2009/03/26 14:48:07 danielk1977 Exp $
! 16:
! 17: set testdir [file dirname $argv0]
! 18:
! 19: source $testdir/tester.tcl
! 20: if {[run_thread_tests]==0} { finish_test ; return }
! 21:
! 22: # Set up a couple of different databases full of pseudo-randomly
! 23: # generated data.
! 24: #
! 25: do_test thread003.1.1 {
! 26: execsql {
! 27: BEGIN;
! 28: CREATE TABLE t1(a, b, c);
! 29: }
! 30: for {set ii 0} {$ii < 5000} {incr ii} {
! 31: execsql {INSERT INTO t1 VALUES($ii, randomblob(200), randomblob(200))}
! 32: }
! 33: execsql {
! 34: CREATE INDEX i1 ON t1(a, b);
! 35: COMMIT;
! 36: }
! 37: } {}
! 38: do_test thread003.1.2 {
! 39: expr {([file size test.db] / 1024) > 2000}
! 40: } {1}
! 41: do_test thread003.1.3 {
! 42: db close
! 43: forcedelete test2.db
! 44: sqlite3 db test2.db
! 45: } {}
! 46: do_test thread003.1.4 {
! 47: execsql {
! 48: BEGIN;
! 49: CREATE TABLE t1(a, b, c);
! 50: }
! 51: for {set ii 0} {$ii < 5000} {incr ii} {
! 52: execsql {INSERT INTO t1 VALUES($ii, randomblob(200), randomblob(200))}
! 53: }
! 54: execsql {
! 55: CREATE INDEX i1 ON t1(a, b);
! 56: COMMIT;
! 57: }
! 58: } {}
! 59: do_test thread003.1.5 {
! 60: expr {([file size test.db] / 1024) > 2000}
! 61: } {1}
! 62: do_test thread003.1.6 {
! 63: db close
! 64: } {}
! 65:
! 66:
! 67: # This test opens a connection on each of the large (>2MB) database files
! 68: # created by the previous block. The connections do not share a cache.
! 69: # Both "cache_size" parameters are set to 15, so there is a maximum of
! 70: # 30 pages available globally.
! 71: #
! 72: # Then, in separate threads, the databases are randomly queried over and
! 73: # over again. This will force the connections to recycle clean pages from
! 74: # each other. If there is a thread-safety problem, a segfault or assertion
! 75: # failure may eventually occur.
! 76: #
! 77: set nSecond 30
! 78: puts "Starting thread003.2 (should run for ~$nSecond seconds)"
! 79: do_test thread003.2 {
! 80: foreach zFile {test.db test2.db} {
! 81: set SCRIPT [format {
! 82: set iEnd [expr {[clock_seconds] + %d}]
! 83: set ::DB [sqlthread open %s xyzzy]
! 84:
! 85: # Set the cache size to 15 pages per cache. 30 available globally.
! 86: execsql { PRAGMA cache_size = 15 }
! 87:
! 88: while {[clock_seconds] < $iEnd} {
! 89: set iQuery [expr {int(rand()*5000)}]
! 90: execsql " SELECT * FROM t1 WHERE a = $iQuery "
! 91: }
! 92:
! 93: sqlite3_close $::DB
! 94: expr 1
! 95: } $nSecond $zFile]
! 96:
! 97: unset -nocomplain finished($zFile)
! 98: thread_spawn finished($zFile) $thread_procs $SCRIPT
! 99: }
! 100: foreach zFile {test.db test2.db} {
! 101: if {![info exists finished($zFile)]} {
! 102: vwait finished($zFile)
! 103: }
! 104: }
! 105: expr 0
! 106: } {0}
! 107:
! 108: # This test is the same as the test above, except that each thread also
! 109: # writes to the database. This causes pages to be moved back and forth
! 110: # between the caches internal dirty and clean lists, which is another
! 111: # opportunity for a thread-related bug to present itself.
! 112: #
! 113: set nSecond 30
! 114: puts "Starting thread003.3 (should run for ~$nSecond seconds)"
! 115: do_test thread003.3 {
! 116: foreach zFile {test.db test2.db} {
! 117: set SCRIPT [format {
! 118: set iStart [clock_seconds]
! 119: set iEnd [expr {[clock_seconds] + %d}]
! 120: set ::DB [sqlthread open %s xyzzy]
! 121:
! 122: # Set the cache size to 15 pages per cache. 30 available globally.
! 123: execsql { PRAGMA cache_size = 15 }
! 124:
! 125: while {[clock_seconds] < $iEnd} {
! 126: set iQuery [expr {int(rand()*5000)}]
! 127: execsql "SELECT * FROM t1 WHERE a = $iQuery"
! 128: execsql "UPDATE t1 SET b = randomblob(200)
! 129: WHERE a < $iQuery AND a > $iQuery + 20
! 130: "
! 131: }
! 132:
! 133: sqlite3_close $::DB
! 134: expr 1
! 135: } $nSecond $zFile]
! 136:
! 137: unset -nocomplain finished($zFile)
! 138: thread_spawn finished($zFile) $thread_procs $SCRIPT
! 139: }
! 140: foreach zFile {test.db test2.db} {
! 141: if {![info exists finished($zFile)]} {
! 142: vwait finished($zFile)
! 143: }
! 144: }
! 145: expr 0
! 146: } {0}
! 147:
! 148: # In this test case, one thread is continually querying the database.
! 149: # The other thread does not have a database connection, but calls
! 150: # sqlite3_release_memory() over and over again.
! 151: #
! 152: set nSecond 30
! 153: puts "Starting thread003.4 (should run for ~$nSecond seconds)"
! 154: unset -nocomplain finished(1)
! 155: unset -nocomplain finished(2)
! 156: do_test thread003.4 {
! 157: thread_spawn finished(1) $thread_procs [format {
! 158: set iEnd [expr {[clock_seconds] + %d}]
! 159: set ::DB [sqlthread open test.db xyzzy]
! 160:
! 161: # Set the cache size to 15 pages per cache. 30 available globally.
! 162: execsql { PRAGMA cache_size = 15 }
! 163:
! 164: while {[clock_seconds] < $iEnd} {
! 165: set iQuery [expr {int(rand()*5000)}]
! 166: execsql "SELECT * FROM t1 WHERE a = $iQuery"
! 167: }
! 168:
! 169: sqlite3_close $::DB
! 170: expr 1
! 171: } $nSecond]
! 172: thread_spawn finished(2) [format {
! 173: set iEnd [expr {[clock_seconds] + %d}]
! 174:
! 175: while {[clock_seconds] < $iEnd} {
! 176: sqlite3_release_memory 1000
! 177: }
! 178: } $nSecond]
! 179:
! 180: foreach ii {1 2} {
! 181: if {![info exists finished($ii)]} {
! 182: vwait finished($ii)
! 183: }
! 184: }
! 185: expr 0
! 186: } {0}
! 187:
! 188: set sqlite_open_file_count 0
! 189: finish_test
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to thread003.test CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / sqlite3 / test