Artifact
141b4e4668844fdca2b01a5656a2d7fa9f25a87d:
0000: 3b 3b 20 43 6f 70 79 72 69 67 68 74 20 32 30 30 ;; Copyright 200
0010: 36 2d 32 30 31 33 2c 20 4d 61 74 74 68 65 77 20 6-2013, Matthew
0020: 57 65 6c 6c 61 6e 64 2e 0a 3b 3b 20 0a 3b 3b 20 Welland..;; .;;
0030: 20 54 68 69 73 20 70 72 6f 67 72 61 6d 20 69 73 This program is
0040: 20 6d 61 64 65 20 61 76 61 69 6c 61 62 6c 65 20 made available
0050: 75 6e 64 65 72 20 74 68 65 20 47 4e 55 20 47 50 under the GNU GP
0060: 4c 20 76 65 72 73 69 6f 6e 20 32 2e 30 20 6f 72 L version 2.0 or
0070: 0a 3b 3b 20 20 67 72 65 61 74 65 72 2e 20 53 65 .;; greater. Se
0080: 65 20 74 68 65 20 61 63 63 6f 6d 70 61 6e 79 69 e the accompanyi
0090: 6e 67 20 66 69 6c 65 20 43 4f 50 59 49 4e 47 20 ng file COPYING
00a0: 66 6f 72 20 64 65 74 61 69 6c 73 2e 0a 3b 3b 20 for details..;;
00b0: 0a 3b 3b 20 20 54 68 69 73 20 70 72 6f 67 72 61 .;; This progra
00c0: 6d 20 69 73 20 64 69 73 74 72 69 62 75 74 65 64 m is distributed
00d0: 20 57 49 54 48 4f 55 54 20 41 4e 59 20 57 41 52 WITHOUT ANY WAR
00e0: 52 41 4e 54 59 3b 20 77 69 74 68 6f 75 74 20 65 RANTY; without e
00f0: 76 65 6e 20 74 68 65 0a 3b 3b 20 20 69 6d 70 6c ven the.;; impl
0100: 69 65 64 20 77 61 72 72 61 6e 74 79 20 6f 66 20 ied warranty of
0110: 4d 45 52 43 48 41 4e 54 41 42 49 4c 49 54 59 20 MERCHANTABILITY
0120: 6f 72 20 46 49 54 4e 45 53 53 20 46 4f 52 20 41 or FITNESS FOR A
0130: 20 50 41 52 54 49 43 55 4c 41 52 0a 3b 3b 20 20 PARTICULAR.;;
0140: 50 55 52 50 4f 53 45 2e 0a 0a 28 75 73 65 20 73 PURPOSE...(use s
0150: 71 6c 69 74 65 33 20 73 72 66 69 2d 31 38 29 0a qlite3 srfi-18).
0160: 28 69 6d 70 6f 72 74 20 28 70 72 65 66 69 78 20 (import (prefix
0170: 73 71 6c 69 74 65 33 20 73 71 6c 69 74 65 33 3a sqlite3 sqlite3:
0180: 29 29 0a 0a 28 64 65 63 6c 61 72 65 20 28 75 6e ))..(declare (un
0190: 69 74 20 6c 6f 63 6b 2d 71 75 65 75 65 29 29 0a it lock-queue)).
01a0: 28 64 65 63 6c 61 72 65 20 28 75 73 65 73 20 63 (declare (uses c
01b0: 6f 6d 6d 6f 6e 29 29 0a 28 64 65 63 6c 61 72 65 ommon)).(declare
01c0: 20 28 75 73 65 73 20 74 61 73 6b 73 29 29 0a 0a (uses tasks))..
01d0: 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ;;==============
01e0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
01f0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0200: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0210: 3d 3d 3d 3d 3d 3d 3d 3d 0a 3b 3b 20 61 74 74 65 ========.;; atte
0220: 6d 70 74 20 74 6f 20 70 72 65 76 65 6e 74 20 6f mpt to prevent o
0230: 76 65 72 6c 61 70 70 69 6e 67 20 75 70 64 61 74 verlapping updat
0240: 65 73 20 6f 66 20 72 6f 6c 6c 75 70 20 66 69 6c es of rollup fil
0250: 65 73 20 62 79 20 71 75 65 75 65 69 6e 67 0a 3b es by queueing.;
0260: 3b 20 75 70 64 61 74 65 20 72 65 71 75 65 73 74 ; update request
0270: 73 20 69 6e 20 61 6e 20 73 71 6c 69 74 65 20 64 s in an sqlite d
0280: 62 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d b.;;============
0290: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
02a0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
02b0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
02c0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a 0a 3b 3b 3d 3d ==========..;;==
02d0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
02e0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
02f0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0300: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0310: 3d 3d 3d 3d 0a 3b 3b 20 64 62 20 72 65 63 6f 72 ====.;; db recor
0320: 64 2c 20 3c 76 65 63 74 6f 72 20 64 62 20 70 61 d, <vector db pa
0330: 74 68 2d 74 6f 2d 64 62 3e 0a 3b 3b 3d 3d 3d 3d th-to-db>.;;====
0340: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0350: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0360: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0370: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0380: 3d 3d 0a 0a 28 64 65 66 69 6e 65 20 28 6d 61 6b ==..(define (mak
0390: 65 2d 6c 6f 63 6b 2d 71 75 65 75 65 3a 64 62 2d e-lock-queue:db-
03a0: 64 61 74 29 28 6d 61 6b 65 2d 76 65 63 74 6f 72 dat)(make-vector
03b0: 20 33 29 29 0a 28 64 65 66 69 6e 65 2d 69 6e 6c 3)).(define-inl
03c0: 69 6e 65 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a ine (lock-queue:
03d0: 64 62 2d 64 61 74 2d 67 65 74 2d 64 62 20 20 20 db-dat-get-db
03e0: 20 20 20 20 20 76 65 63 29 20 20 20 20 28 76 65 vec) (ve
03f0: 63 74 6f 72 2d 72 65 66 20 20 76 65 63 20 30 29 ctor-ref vec 0)
0400: 29 0a 28 64 65 66 69 6e 65 2d 69 6e 6c 69 6e 65 ).(define-inline
0410: 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 64 62 2d (lock-queue:db-
0420: 64 61 74 2d 67 65 74 2d 70 61 74 68 20 20 20 20 dat-get-path
0430: 20 20 76 65 63 29 20 20 20 20 28 76 65 63 74 6f vec) (vecto
0440: 72 2d 72 65 66 20 20 76 65 63 20 31 29 29 0a 28 r-ref vec 1)).(
0450: 64 65 66 69 6e 65 2d 69 6e 6c 69 6e 65 20 28 6c define-inline (l
0460: 6f 63 6b 2d 71 75 65 75 65 3a 64 62 2d 64 61 74 ock-queue:db-dat
0470: 2d 73 65 74 2d 64 62 21 20 20 20 20 20 20 20 76 -set-db! v
0480: 65 63 20 76 61 6c 29 28 76 65 63 74 6f 72 2d 73 ec val)(vector-s
0490: 65 74 21 20 76 65 63 20 30 20 76 61 6c 29 29 0a et! vec 0 val)).
04a0: 28 64 65 66 69 6e 65 2d 69 6e 6c 69 6e 65 20 28 (define-inline (
04b0: 6c 6f 63 6b 2d 71 75 65 75 65 3a 64 62 2d 64 61 lock-queue:db-da
04c0: 74 2d 73 65 74 2d 70 61 74 68 21 20 20 20 20 20 t-set-path!
04d0: 76 65 63 20 76 61 6c 29 28 76 65 63 74 6f 72 2d vec val)(vector-
04e0: 73 65 74 21 20 76 65 63 20 31 20 76 61 6c 29 29 set! vec 1 val))
04f0: 0a 0a 28 64 65 66 69 6e 65 20 28 6c 6f 63 6b 2d ..(define (lock-
0500: 71 75 65 75 65 3a 6f 70 65 6e 2d 64 62 20 66 6e queue:open-db fn
0510: 61 6d 65 20 23 21 6b 65 79 20 28 63 6f 75 6e 74 ame #!key (count
0520: 20 31 30 29 29 0a 20 20 28 6c 65 74 2a 20 28 28 10)). (let* ((
0530: 61 63 74 75 61 6c 66 6e 61 6d 65 20 28 63 6f 6e actualfname (con
0540: 63 20 66 6e 61 6d 65 20 22 2e 6c 6f 63 6b 64 62 c fname ".lockdb
0550: 22 29 29 0a 09 20 28 64 62 65 78 69 73 74 73 20 ")).. (dbexists
0560: 28 66 69 6c 65 2d 65 78 69 73 74 73 3f 20 61 63 (file-exists? ac
0570: 74 75 61 6c 66 6e 61 6d 65 29 29 0a 09 20 28 64 tualfname)).. (d
0580: 62 20 20 20 20 20 20 20 28 73 71 6c 69 74 65 33 b (sqlite3
0590: 3a 6f 70 65 6e 2d 64 61 74 61 62 61 73 65 20 61 :open-database a
05a0: 63 74 75 61 6c 66 6e 61 6d 65 29 29 0a 09 20 28 ctualfname)).. (
05b0: 68 61 6e 64 6c 65 72 20 20 28 6d 61 6b 65 2d 62 handler (make-b
05c0: 75 73 79 2d 74 69 6d 65 6f 75 74 20 31 33 36 30 usy-timeout 1360
05d0: 30 30 29 29 29 0a 20 20 20 20 28 69 66 20 64 62 00))). (if db
05e0: 65 78 69 73 74 73 0a 09 28 76 65 63 74 6f 72 20 exists..(vector
05f0: 64 62 20 61 63 74 75 61 6c 66 6e 61 6d 65 29 0a db actualfname).
0600: 09 28 62 65 67 69 6e 0a 09 20 20 28 68 61 6e 64 .(begin.. (hand
0610: 6c 65 2d 65 78 63 65 70 74 69 6f 6e 73 0a 09 20 le-exceptions..
0620: 20 20 65 78 6e 0a 09 20 20 20 28 62 65 67 69 6e exn.. (begin
0630: 0a 09 20 20 20 20 20 28 74 68 72 65 61 64 2d 73 .. (thread-s
0640: 6c 65 65 70 21 20 31 30 29 0a 09 20 20 20 20 20 leep! 10)..
0650: 28 69 66 20 28 3e 20 63 6f 75 6e 74 20 30 29 0a (if (> count 0).
0660: 09 09 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 6f .. (lock-queue:o
0670: 70 65 6e 2d 64 62 20 66 6e 61 6d 65 20 63 6f 75 pen-db fname cou
0680: 6e 74 3a 20 28 2d 20 63 6f 75 6e 74 20 31 29 29 nt: (- count 1))
0690: 0a 09 09 20 28 76 65 63 74 6f 72 20 64 62 20 61 ... (vector db a
06a0: 63 74 75 61 6c 66 6e 61 6d 65 29 29 29 0a 09 20 ctualfname)))..
06b0: 20 20 28 73 71 6c 69 74 65 33 3a 77 69 74 68 2d (sqlite3:with-
06c0: 74 72 61 6e 73 61 63 74 69 6f 6e 0a 09 20 20 20 transaction..
06d0: 20 64 62 0a 09 20 20 20 20 28 6c 61 6d 62 64 61 db.. (lambda
06e0: 20 28 29 0a 09 20 20 20 20 20 20 28 73 71 6c 69 ().. (sqli
06f0: 74 65 33 3a 65 78 65 63 75 74 65 20 0a 09 20 20 te3:execute ..
0700: 20 20 20 20 20 64 62 0a 09 20 20 20 20 20 20 20 db..
0710: 22 43 52 45 41 54 45 20 54 41 42 4c 45 20 49 46 "CREATE TABLE IF
0720: 20 4e 4f 54 20 45 58 49 53 54 53 20 71 75 65 75 NOT EXISTS queu
0730: 65 20 28 0a 20 20 20 20 20 09 20 20 20 20 20 20 e (. .
0740: 20 20 20 69 64 20 20 20 20 20 20 20 20 20 49 4e id IN
0750: 54 45 47 45 52 20 50 52 49 4d 41 52 59 20 4b 45 TEGER PRIMARY KE
0760: 59 2c 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 Y,.
0770: 20 20 20 20 74 65 73 74 5f 69 64 20 20 20 20 49 test_id I
0780: 4e 54 45 47 45 52 2c 0a 20 20 20 20 20 20 20 20 NTEGER,.
0790: 20 20 20 20 20 20 20 20 20 73 74 61 72 74 5f 74 start_t
07a0: 69 6d 65 20 49 4e 54 45 47 45 52 2c 0a 20 20 20 ime INTEGER,.
07b0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 73 74 st
07c0: 61 74 65 20 20 20 20 20 20 54 45 58 54 2c 0a 20 ate TEXT,.
07d0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
07e0: 43 4f 4e 53 54 52 41 49 4e 54 20 71 75 65 75 65 CONSTRAINT queue
07f0: 5f 63 6f 6e 73 74 72 61 69 6e 74 20 55 4e 49 51 _constraint UNIQ
0800: 55 45 20 28 74 65 73 74 5f 69 64 29 29 3b 22 29 UE (test_id));")
0810: 0a 09 20 20 20 20 20 20 28 73 71 6c 69 74 65 33 .. (sqlite3
0820: 3a 65 78 65 63 75 74 65 0a 09 20 20 20 20 20 20 :execute..
0830: 20 64 62 0a 09 20 20 20 20 20 20 20 22 43 52 45 db.. "CRE
0840: 41 54 45 20 54 41 42 4c 45 20 49 46 20 4e 4f 54 ATE TABLE IF NOT
0850: 20 45 58 49 53 54 53 20 72 75 6e 6c 6f 63 6b 73 EXISTS runlocks
0860: 20 28 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 (.
0870: 20 20 20 20 69 64 20 20 20 20 20 20 20 20 20 49 id I
0880: 4e 54 45 47 45 52 20 50 52 49 4d 41 52 59 20 4b NTEGER PRIMARY K
0890: 45 59 2c 0a 20 20 20 20 20 20 20 20 20 20 20 20 EY,.
08a0: 20 20 20 20 20 74 65 73 74 5f 69 64 20 20 20 20 test_id
08b0: 49 4e 54 45 47 45 52 2c 0a 20 20 20 20 20 20 20 INTEGER,.
08c0: 20 20 20 20 20 20 20 20 20 20 72 75 6e 5f 6c 6f run_lo
08d0: 63 6b 20 20 20 54 45 58 54 2c 0a 20 20 20 20 20 ck TEXT,.
08e0: 20 20 20 20 20 20 20 20 20 20 20 20 43 4f 4e 53 CONS
08f0: 54 52 41 49 4e 54 20 72 75 6e 6c 6f 63 6b 5f 63 TRAINT runlock_c
0900: 6f 6e 73 74 72 61 69 6e 74 20 55 4e 49 51 55 45 onstraint UNIQUE
0910: 20 28 72 75 6e 5f 6c 6f 63 6b 29 29 3b 22 29 29 (run_lock));"))
0920: 29 29 29 29 0a 20 20 20 20 28 73 71 6c 69 74 65 )))). (sqlite
0930: 33 3a 73 65 74 2d 62 75 73 79 2d 68 61 6e 64 6c 3:set-busy-handl
0940: 65 72 21 20 64 62 20 68 61 6e 64 6c 65 72 29 0a er! db handler).
0950: 20 20 20 20 28 76 65 63 74 6f 72 20 64 62 20 61 (vector db a
0960: 63 74 75 61 6c 66 6e 61 6d 65 29 29 29 0a 0a 28 ctualfname)))..(
0970: 64 65 66 69 6e 65 20 28 6c 6f 63 6b 2d 71 75 65 define (lock-que
0980: 75 65 3a 73 65 74 2d 73 74 61 74 65 20 64 62 64 ue:set-state dbd
0990: 61 74 20 74 65 73 74 2d 69 64 20 6e 65 77 73 74 at test-id newst
09a0: 61 74 65 20 23 21 6b 65 79 20 28 72 65 6d 74 72 ate #!key (remtr
09b0: 69 65 73 20 31 30 29 29 0a 20 20 28 74 61 73 6b ies 10)). (task
09c0: 73 3a 77 61 69 74 2d 6f 6e 2d 6a 6f 75 72 6e 61 s:wait-on-journa
09d0: 6c 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 64 62 l (lock-queue:db
09e0: 2d 64 61 74 2d 67 65 74 2d 70 61 74 68 20 64 62 -dat-get-path db
09f0: 64 61 74 29 20 31 32 30 30 29 0a 20 20 28 68 61 dat) 1200). (ha
0a00: 6e 64 6c 65 2d 65 78 63 65 70 74 69 6f 6e 73 0a ndle-exceptions.
0a10: 20 20 20 65 78 6e 0a 20 20 20 28 69 66 20 28 3e exn. (if (>
0a20: 20 72 65 6d 74 72 69 65 73 20 30 29 0a 20 20 20 remtries 0).
0a30: 20 20 20 20 28 62 65 67 69 6e 0a 09 20 28 64 65 (begin.. (de
0a40: 62 75 67 3a 70 72 69 6e 74 20 30 20 22 57 41 52 bug:print 0 "WAR
0a50: 4e 49 4e 47 3a 20 65 78 63 65 70 74 69 6f 6e 20 NING: exception
0a60: 6f 6e 20 6c 6f 63 6b 2d 71 75 65 75 65 3a 73 65 on lock-queue:se
0a70: 74 2d 73 74 61 74 65 2e 20 54 72 79 69 6e 67 20 t-state. Trying
0a80: 61 67 61 69 6e 20 69 6e 20 33 30 20 73 65 63 6f again in 30 seco
0a90: 6e 64 73 2e 22 29 0a 09 20 28 64 65 62 75 67 3a nds.").. (debug:
0aa0: 70 72 69 6e 74 20 30 20 22 20 6d 65 73 73 61 67 print 0 " messag
0ab0: 65 3a 20 22 20 28 28 63 6f 6e 64 69 74 69 6f 6e e: " ((condition
0ac0: 2d 70 72 6f 70 65 72 74 79 2d 61 63 63 65 73 73 -property-access
0ad0: 6f 72 20 27 65 78 6e 20 27 6d 65 73 73 61 67 65 or 'exn 'message
0ae0: 29 20 65 78 6e 29 29 0a 09 20 28 74 68 72 65 61 ) exn)).. (threa
0af0: 64 2d 73 6c 65 65 70 21 20 33 30 29 0a 09 20 28 d-sleep! 30).. (
0b00: 6c 6f 63 6b 2d 71 75 65 75 65 3a 73 65 74 2d 73 lock-queue:set-s
0b10: 74 61 74 65 20 64 62 64 61 74 20 74 65 73 74 2d tate dbdat test-
0b20: 69 64 20 6e 65 77 73 74 61 74 65 20 72 65 6d 74 id newstate remt
0b30: 72 69 65 73 3a 20 28 2d 20 72 65 6d 74 72 69 65 ries: (- remtrie
0b40: 73 20 31 29 29 29 0a 20 20 20 20 20 20 20 28 62 s 1))). (b
0b50: 65 67 69 6e 0a 09 20 28 64 65 62 75 67 3a 70 72 egin.. (debug:pr
0b60: 69 6e 74 20 30 20 22 45 52 52 4f 52 3a 20 20 46 int 0 "ERROR: F
0b70: 61 69 6c 65 64 20 74 6f 20 73 65 74 20 6c 6f 63 ailed to set loc
0b80: 6b 20 73 74 61 74 65 20 66 6f 72 20 74 65 73 74 k state for test
0b90: 20 77 69 74 68 20 69 64 20 22 20 74 65 73 74 2d with id " test-
0ba0: 69 64 20 22 2c 20 65 72 72 6f 72 3a 20 22 20 28 id ", error: " (
0bb0: 28 63 6f 6e 64 69 74 69 6f 6e 2d 70 72 6f 70 65 (condition-prope
0bc0: 72 74 79 2d 61 63 63 65 73 73 6f 72 20 27 65 78 rty-accessor 'ex
0bd0: 6e 20 27 6d 65 73 73 61 67 65 29 20 65 78 6e 29 n 'message) exn)
0be0: 20 22 2c 20 67 69 76 69 6e 67 20 75 70 2e 22 29 ", giving up.")
0bf0: 0a 09 20 23 66 29 29 0a 20 20 20 28 73 71 6c 69 .. #f)). (sqli
0c00: 74 65 33 3a 65 78 65 63 75 74 65 20 28 6c 6f 63 te3:execute (loc
0c10: 6b 2d 71 75 65 75 65 3a 64 62 2d 64 61 74 2d 67 k-queue:db-dat-g
0c20: 65 74 2d 64 62 20 64 62 64 61 74 29 20 22 55 50 et-db dbdat) "UP
0c30: 44 41 54 45 20 71 75 65 75 65 20 53 45 54 20 73 DATE queue SET s
0c40: 74 61 74 65 3d 3f 20 57 48 45 52 45 20 74 65 73 tate=? WHERE tes
0c50: 74 5f 69 64 3d 3f 3b 22 0a 09 09 20 20 20 20 6e t_id=?;"... n
0c60: 65 77 73 74 61 74 65 0a 09 09 20 20 20 20 74 65 ewstate... te
0c70: 73 74 2d 69 64 29 29 29 0a 0a 28 64 65 66 69 6e st-id)))..(defin
0c80: 65 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 61 6e e (lock-queue:an
0c90: 79 2d 79 6f 75 6e 67 65 72 3f 20 64 62 64 61 74 y-younger? dbdat
0ca0: 20 6d 79 73 74 61 72 74 20 74 65 73 74 2d 69 64 mystart test-id
0cb0: 20 23 21 6b 65 79 20 28 72 65 6d 74 72 69 65 73 #!key (remtries
0cc0: 20 31 30 29 29 0a 20 20 28 74 61 73 6b 73 3a 77 10)). (tasks:w
0cd0: 61 69 74 2d 6f 6e 2d 6a 6f 75 72 6e 61 6c 20 28 ait-on-journal (
0ce0: 6c 6f 63 6b 2d 71 75 65 75 65 3a 64 62 2d 64 61 lock-queue:db-da
0cf0: 74 2d 67 65 74 2d 70 61 74 68 20 64 62 64 61 74 t-get-path dbdat
0d00: 29 20 31 32 30 30 29 0a 20 20 28 68 61 6e 64 6c ) 1200). (handl
0d10: 65 2d 65 78 63 65 70 74 69 6f 6e 73 0a 20 20 20 e-exceptions.
0d20: 65 78 6e 0a 20 20 20 28 69 66 20 28 3e 20 72 65 exn. (if (> re
0d30: 6d 74 72 69 65 73 20 30 29 0a 20 20 20 20 20 20 mtries 0).
0d40: 20 28 62 65 67 69 6e 0a 09 20 28 64 65 62 75 67 (begin.. (debug
0d50: 3a 70 72 69 6e 74 20 30 20 22 57 41 52 4e 49 4e :print 0 "WARNIN
0d60: 47 3a 20 65 78 63 65 70 74 69 6f 6e 20 6f 6e 20 G: exception on
0d70: 6c 6f 63 6b 2d 71 75 65 75 65 3a 61 6e 79 2d 79 lock-queue:any-y
0d80: 6f 75 6e 67 65 72 2e 20 54 72 79 69 6e 67 20 61 ounger. Trying a
0d90: 67 61 69 6e 20 69 6e 20 33 30 20 73 65 63 6f 6e gain in 30 secon
0da0: 64 73 2e 22 29 0a 09 20 28 64 65 62 75 67 3a 70 ds.").. (debug:p
0db0: 72 69 6e 74 20 30 20 22 20 6d 65 73 73 61 67 65 rint 0 " message
0dc0: 3a 20 22 20 28 28 63 6f 6e 64 69 74 69 6f 6e 2d : " ((condition-
0dd0: 70 72 6f 70 65 72 74 79 2d 61 63 63 65 73 73 6f property-accesso
0de0: 72 20 27 65 78 6e 20 27 6d 65 73 73 61 67 65 29 r 'exn 'message)
0df0: 20 65 78 6e 29 29 0a 09 20 28 74 68 72 65 61 64 exn)).. (thread
0e00: 2d 73 6c 65 65 70 21 20 33 30 29 0a 09 20 28 6c -sleep! 30).. (l
0e10: 6f 63 6b 2d 71 75 65 75 65 3a 61 6e 79 2d 79 6f ock-queue:any-yo
0e20: 75 6e 67 65 72 3f 20 64 62 64 61 74 20 6d 79 73 unger? dbdat mys
0e30: 74 61 72 74 20 74 65 73 74 2d 69 64 20 72 65 6d tart test-id rem
0e40: 74 72 69 65 73 3a 20 28 2d 20 72 65 6d 74 72 69 tries: (- remtri
0e50: 65 73 20 31 29 29 29 0a 20 20 20 20 20 20 20 28 es 1))). (
0e60: 62 65 67 69 6e 0a 09 20 28 64 65 62 75 67 3a 70 begin.. (debug:p
0e70: 72 69 6e 74 20 30 20 22 45 52 52 4f 52 3a 20 20 rint 0 "ERROR:
0e80: 46 61 69 6c 65 64 20 74 6f 20 66 69 6e 64 20 79 Failed to find y
0e90: 6f 75 6e 67 65 72 20 6c 6f 63 6b 73 20 66 6f 72 ounger locks for
0ea0: 20 74 65 73 74 20 77 69 74 68 20 69 64 20 22 20 test with id "
0eb0: 74 65 73 74 2d 69 64 20 22 2c 20 65 72 72 6f 72 test-id ", error
0ec0: 3a 20 22 20 28 28 63 6f 6e 64 69 74 69 6f 6e 2d : " ((condition-
0ed0: 70 72 6f 70 65 72 74 79 2d 61 63 63 65 73 73 6f property-accesso
0ee0: 72 20 27 65 78 6e 20 27 6d 65 73 73 61 67 65 29 r 'exn 'message)
0ef0: 20 65 78 6e 29 20 22 2c 20 67 69 76 69 6e 67 20 exn) ", giving
0f00: 75 70 2e 22 29 0a 09 20 23 66 29 29 0a 20 20 20 up.").. #f)).
0f10: 28 6c 65 74 20 28 28 72 65 73 20 23 66 29 29 0a (let ((res #f)).
0f20: 20 20 20 20 20 28 73 71 6c 69 74 65 33 3a 66 6f (sqlite3:fo
0f30: 72 2d 65 61 63 68 2d 72 6f 77 0a 20 20 20 20 20 r-each-row.
0f40: 20 28 6c 61 6d 62 64 61 20 28 74 69 64 29 0a 09 (lambda (tid)..
0f50: 3b 3b 20 41 63 74 75 61 6c 6c 79 20 74 68 69 73 ;; Actually this
0f60: 20 73 68 6f 75 6c 64 20 6e 6f 74 20 62 65 20 6e should not be n
0f70: 65 65 64 65 64 20 61 73 20 6d 79 73 74 61 72 74 eeded as mystart
0f80: 20 63 61 6e 6e 6f 74 20 62 65 20 73 69 6d 75 6c cannot be simul
0f90: 74 61 6e 65 6f 75 73 6c 79 20 6c 65 73 73 20 74 taneously less t
0fa0: 68 61 6e 20 61 6e 64 20 74 65 73 74 2d 69 64 20 han and test-id
0fb0: 73 61 6d 65 20 61 73 20 0a 09 28 69 66 20 28 6e same as ..(if (n
0fc0: 6f 74 20 28 65 71 75 61 6c 3f 20 74 69 64 20 74 ot (equal? tid t
0fd0: 65 73 74 2d 69 64 29 29 20 0a 09 20 20 20 20 28 est-id)) .. (
0fe0: 73 65 74 21 20 72 65 73 20 74 69 64 29 29 29 0a set! res tid))).
0ff0: 20 20 20 20 20 20 28 6c 6f 63 6b 2d 71 75 65 75 (lock-queu
1000: 65 3a 64 62 2d 64 61 74 2d 67 65 74 2d 64 62 20 e:db-dat-get-db
1010: 64 62 64 61 74 29 0a 20 20 20 20 20 20 22 53 45 dbdat). "SE
1020: 4c 45 43 54 20 74 65 73 74 5f 69 64 20 46 52 4f LECT test_id FRO
1030: 4d 20 71 75 65 75 65 20 57 48 45 52 45 20 73 74 M queue WHERE st
1040: 61 72 74 5f 74 69 6d 65 20 3e 20 3f 3b 22 20 6d art_time > ?;" m
1050: 79 73 74 61 72 74 29 0a 20 20 20 20 20 72 65 73 ystart). res
1060: 29 29 29 0a 0a 28 64 65 66 69 6e 65 20 28 6c 6f )))..(define (lo
1070: 63 6b 2d 71 75 65 75 65 3a 67 65 74 2d 6c 6f 63 ck-queue:get-loc
1080: 6b 20 64 62 64 61 74 20 74 65 73 74 2d 69 64 20 k dbdat test-id
1090: 23 21 6b 65 79 20 28 63 6f 75 6e 74 20 31 30 29 #!key (count 10)
10a0: 28 77 61 69 74 69 6e 67 2d 6d 73 67 20 23 66 29 (waiting-msg #f)
10b0: 29 0a 20 20 28 74 61 73 6b 73 3a 77 61 69 74 2d ). (tasks:wait-
10c0: 6f 6e 2d 6a 6f 75 72 6e 61 6c 20 28 6c 6f 63 6b on-journal (lock
10d0: 2d 71 75 65 75 65 3a 64 62 2d 64 61 74 2d 67 65 -queue:db-dat-ge
10e0: 74 2d 70 61 74 68 20 64 62 64 61 74 29 20 31 32 t-path dbdat) 12
10f0: 30 30 20 72 65 6d 6f 76 65 3a 20 23 74 20 77 61 00 remove: #t wa
1100: 69 74 69 6e 67 2d 6d 73 67 3a 20 22 6c 6f 63 6b iting-msg: "lock
1110: 2d 71 75 65 75 65 3a 67 65 74 2d 6c 6f 63 6b 2c -queue:get-lock,
1120: 20 77 61 69 74 69 6e 67 20 6f 6e 20 6a 6f 75 72 waiting on jour
1130: 6e 61 6c 22 29 0a 20 20 28 6c 65 74 2a 20 28 28 nal"). (let* ((
1140: 72 65 73 20 20 20 20 20 20 20 23 66 29 0a 09 20 res #f)..
1150: 28 64 62 20 20 20 20 20 20 20 20 28 6c 6f 63 6b (db (lock
1160: 2d 71 75 65 75 65 3a 64 62 2d 64 61 74 2d 67 65 -queue:db-dat-ge
1170: 74 2d 64 62 20 64 62 64 61 74 29 29 0a 09 20 28 t-db dbdat)).. (
1180: 6c 63 6b 71 72 79 20 20 20 20 28 73 71 6c 69 74 lckqry (sqlit
1190: 65 33 3a 70 72 65 70 61 72 65 20 64 62 20 22 53 e3:prepare db "S
11a0: 45 4c 45 43 54 20 74 65 73 74 5f 69 64 2c 72 75 ELECT test_id,ru
11b0: 6e 5f 6c 6f 63 6b 20 46 52 4f 4d 20 72 75 6e 6c n_lock FROM runl
11c0: 6f 63 6b 73 20 57 48 45 52 45 20 72 75 6e 5f 6c ocks WHERE run_l
11d0: 6f 63 6b 3d 27 6c 6f 63 6b 65 64 27 3b 22 29 29 ock='locked';"))
11e0: 0a 09 20 28 6d 6b 6c 63 6b 71 72 79 20 20 28 73 .. (mklckqry (s
11f0: 71 6c 69 74 65 33 3a 70 72 65 70 61 72 65 20 64 qlite3:prepare d
1200: 62 20 22 49 4e 53 45 52 54 20 49 4e 54 4f 20 72 b "INSERT INTO r
1210: 75 6e 6c 6f 63 6b 73 20 28 74 65 73 74 5f 69 64 unlocks (test_id
1220: 2c 72 75 6e 5f 6c 6f 63 6b 29 20 56 41 4c 55 45 ,run_lock) VALUE
1230: 53 20 28 3f 2c 27 6c 6f 63 6b 65 64 27 29 3b 22 S (?,'locked');"
1240: 29 29 29 0a 20 20 20 20 28 6c 65 74 20 28 28 72 ))). (let ((r
1250: 65 73 75 6c 74 20 0a 09 20 20 20 28 68 61 6e 64 esult .. (hand
1260: 6c 65 2d 65 78 63 65 70 74 69 6f 6e 73 0a 09 20 le-exceptions..
1270: 20 20 20 65 78 6e 0a 09 20 20 20 20 28 62 65 67 exn.. (beg
1280: 69 6e 0a 09 20 20 20 20 20 20 28 64 65 62 75 67 in.. (debug
1290: 3a 70 72 69 6e 74 20 30 20 22 57 41 52 4e 49 4e :print 0 "WARNIN
12a0: 47 3a 20 66 61 69 6c 65 64 20 74 6f 20 67 65 74 G: failed to get
12b0: 20 71 75 65 75 65 20 6c 6f 63 6b 2e 20 57 69 6c queue lock. Wil
12c0: 6c 20 74 72 79 20 61 67 61 69 6e 20 69 6e 20 61 l try again in a
12d0: 20 66 65 77 20 73 65 63 6f 6e 64 73 22 29 0a 09 few seconds")..
12e0: 20 20 20 20 20 20 28 64 65 62 75 67 3a 70 72 69 (debug:pri
12f0: 6e 74 20 30 20 22 20 6d 65 73 73 61 67 65 3a 20 nt 0 " message:
1300: 22 20 28 28 63 6f 6e 64 69 74 69 6f 6e 2d 70 72 " ((condition-pr
1310: 6f 70 65 72 74 79 2d 61 63 63 65 73 73 6f 72 20 operty-accessor
1320: 27 65 78 6e 20 27 6d 65 73 73 61 67 65 29 20 65 'exn 'message) e
1330: 78 6e 29 29 0a 09 20 20 20 20 20 20 28 74 68 72 xn)).. (thr
1340: 65 61 64 2d 73 6c 65 65 70 21 20 31 30 29 0a 09 ead-sleep! 10)..
1350: 20 20 20 20 20 20 28 69 66 20 28 3e 20 63 6f 75 (if (> cou
1360: 6e 74 20 30 29 0a 09 09 20 20 28 6c 6f 63 6b 2d nt 0)... (lock-
1370: 71 75 65 75 65 3a 67 65 74 2d 6c 6f 63 6b 20 64 queue:get-lock d
1380: 62 64 61 74 20 74 65 73 74 2d 69 64 20 63 6f 75 bdat test-id cou
1390: 6e 74 3a 20 28 2d 20 63 6f 75 6e 74 20 31 29 29 nt: (- count 1))
13a0: 29 0a 09 20 20 20 20 20 20 23 66 29 0a 09 20 20 ).. #f)..
13b0: 20 20 28 73 71 6c 69 74 65 33 3a 77 69 74 68 2d (sqlite3:with-
13c0: 74 72 61 6e 73 61 63 74 69 6f 6e 0a 09 20 20 20 transaction..
13d0: 20 20 64 62 0a 09 20 20 20 20 20 28 6c 61 6d 62 db.. (lamb
13e0: 64 61 20 28 29 0a 09 20 20 20 20 20 20 20 28 73 da ().. (s
13f0: 71 6c 69 74 65 33 3a 66 6f 72 2d 65 61 63 68 2d qlite3:for-each-
1400: 72 6f 77 20 28 6c 61 6d 62 64 61 20 28 74 69 64 row (lambda (tid
1410: 20 6c 6f 63 6b 73 74 61 74 65 29 0a 09 09 09 09 lockstate).....
1420: 20 20 20 20 20 20 20 28 73 65 74 21 20 72 65 73 (set! res
1430: 20 28 6c 69 73 74 20 74 69 64 20 6c 6f 63 6b 73 (list tid locks
1440: 74 61 74 65 29 29 29 0a 09 09 09 09 20 20 20 20 tate))).....
1450: 20 6c 63 6b 71 72 79 29 0a 09 20 20 20 20 20 20 lckqry)..
1460: 20 28 69 66 20 72 65 73 0a 09 09 20 20 20 28 69 (if res... (i
1470: 66 20 28 65 71 75 61 6c 3f 20 28 63 61 72 20 72 f (equal? (car r
1480: 65 73 29 20 74 65 73 74 2d 69 64 29 0a 09 09 20 es) test-id)...
1490: 20 20 20 20 20 20 23 74 20 3b 3b 20 61 6c 72 65 #t ;; alre
14a0: 61 64 79 20 68 61 76 65 20 74 68 65 20 6c 6f 63 ady have the loc
14b0: 6b 0a 09 09 20 20 20 20 20 20 20 23 66 29 0a 09 k... #f)..
14c0: 09 20 20 20 28 62 65 67 69 6e 0a 09 09 20 20 20 . (begin...
14d0: 20 20 28 73 71 6c 69 74 65 33 3a 65 78 65 63 75 (sqlite3:execu
14e0: 74 65 20 6d 6b 6c 63 6b 71 72 79 20 74 65 73 74 te mklckqry test
14f0: 2d 69 64 29 0a 09 09 20 20 20 20 20 3b 3b 20 69 -id)... ;; i
1500: 66 20 6e 6f 20 65 72 72 6f 72 20 68 61 6e 64 6c f no error handl
1510: 65 64 20 74 68 65 6e 20 72 65 74 75 72 6e 20 23 ed then return #
1520: 74 20 66 6f 72 20 67 6f 74 20 74 68 65 20 6c 6f t for got the lo
1530: 63 6b 0a 09 09 20 20 20 20 20 23 74 29 29 29 29 ck... #t))))
1540: 29 29 29 0a 20 20 20 20 20 20 28 73 71 6c 69 74 ))). (sqlit
1550: 65 33 3a 66 69 6e 61 6c 69 7a 65 21 20 6c 63 6b e3:finalize! lck
1560: 71 72 79 29 0a 20 20 20 20 20 20 28 73 71 6c 69 qry). (sqli
1570: 74 65 33 3a 66 69 6e 61 6c 69 7a 65 21 20 6d 6b te3:finalize! mk
1580: 6c 63 6b 71 72 79 29 0a 20 20 20 20 20 20 72 65 lckqry). re
1590: 73 75 6c 74 29 29 29 0a 0a 28 64 65 66 69 6e 65 sult)))..(define
15a0: 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 72 65 6c (lock-queue:rel
15b0: 65 61 73 65 2d 6c 6f 63 6b 20 66 6e 61 6d 65 20 ease-lock fname
15c0: 74 65 73 74 2d 69 64 20 23 21 6b 65 79 20 28 63 test-id #!key (c
15d0: 6f 75 6e 74 20 31 30 29 29 0a 20 20 28 6c 65 74 ount 10)). (let
15e0: 2a 20 28 28 64 62 64 61 74 20 28 6c 6f 63 6b 2d * ((dbdat (lock-
15f0: 71 75 65 75 65 3a 6f 70 65 6e 2d 64 62 20 66 6e queue:open-db fn
1600: 61 6d 65 29 29 29 0a 20 20 20 20 28 68 61 6e 64 ame))). (hand
1610: 6c 65 2d 65 78 63 65 70 74 69 6f 6e 73 0a 20 20 le-exceptions.
1620: 20 20 20 65 78 6e 0a 20 20 20 20 20 28 62 65 67 exn. (beg
1630: 69 6e 0a 20 20 20 20 20 20 20 28 64 65 62 75 67 in. (debug
1640: 3a 70 72 69 6e 74 20 30 20 22 57 41 52 4e 49 4e :print 0 "WARNIN
1650: 47 3a 20 46 61 69 6c 65 64 20 74 6f 20 72 65 6c G: Failed to rel
1660: 65 61 73 65 20 71 75 65 75 65 20 6c 6f 63 6b 2e ease queue lock.
1670: 20 57 69 6c 6c 20 74 72 79 20 61 67 61 69 6e 20 Will try again
1680: 69 6e 20 66 65 77 20 73 65 63 6f 6e 64 73 22 29 in few seconds")
1690: 0a 20 20 20 20 20 20 20 28 64 65 62 75 67 3a 70 . (debug:p
16a0: 72 69 6e 74 20 30 20 22 20 6d 65 73 73 61 67 65 rint 0 " message
16b0: 3a 20 22 20 28 28 63 6f 6e 64 69 74 69 6f 6e 2d : " ((condition-
16c0: 70 72 6f 70 65 72 74 79 2d 61 63 63 65 73 73 6f property-accesso
16d0: 72 20 27 65 78 6e 20 27 6d 65 73 73 61 67 65 29 r 'exn 'message)
16e0: 20 65 78 6e 29 29 0a 20 20 20 20 20 20 20 28 74 exn)). (t
16f0: 68 72 65 61 64 2d 73 6c 65 65 70 21 20 28 2f 20 hread-sleep! (/
1700: 63 6f 75 6e 74 20 31 30 29 29 0a 20 20 20 20 20 count 10)).
1710: 20 20 28 69 66 20 28 3e 20 63 6f 75 6e 74 20 30 (if (> count 0
1720: 29 0a 09 20 20 20 28 62 65 67 69 6e 0a 09 20 20 ).. (begin..
1730: 20 20 20 28 73 71 6c 69 74 65 33 3a 66 69 6e 61 (sqlite3:fina
1740: 6c 69 7a 65 21 20 28 6c 6f 63 6b 2d 71 75 65 75 lize! (lock-queu
1750: 65 3a 64 62 2d 64 61 74 2d 67 65 74 2d 64 62 20 e:db-dat-get-db
1760: 64 62 64 61 74 29 29 0a 09 20 20 20 20 20 28 6c dbdat)).. (l
1770: 6f 63 6b 2d 71 75 65 75 65 3a 72 65 6c 65 61 73 ock-queue:releas
1780: 65 2d 6c 6f 63 6b 20 66 6e 61 6d 65 20 74 65 73 e-lock fname tes
1790: 74 2d 69 64 20 63 6f 75 6e 74 3a 20 28 2d 20 63 t-id count: (- c
17a0: 6f 75 6e 74 20 31 29 29 29 0a 09 20 20 20 28 6c ount 1))).. (l
17b0: 65 74 20 28 28 6a 6f 75 72 6e 61 6c 20 28 63 6f et ((journal (co
17c0: 6e 63 20 66 6e 61 6d 65 20 22 2d 6a 6f 75 72 6e nc fname "-journ
17d0: 61 6c 22 29 29 29 0a 09 20 20 20 20 20 3b 3b 20 al"))).. ;;
17e0: 49 66 20 77 65 27 76 65 20 74 72 69 65 64 20 74 If we've tried t
17f0: 65 6e 20 74 69 6d 65 73 20 61 6e 64 20 66 61 69 en times and fai
1800: 6c 65 64 20 74 68 65 72 65 20 69 73 20 61 20 73 led there is a s
1810: 65 72 69 6f 75 73 20 70 72 6f 62 6c 65 6d 0a 09 erious problem..
1820: 20 20 20 20 20 3b 3b 20 74 72 79 20 74 6f 20 72 ;; try to r
1830: 65 6d 6f 76 65 20 74 68 65 20 6c 6f 63 6b 20 64 emove the lock d
1840: 62 20 61 6e 64 20 61 6c 6c 6f 77 20 69 74 20 74 b and allow it t
1850: 6f 20 62 65 20 72 65 63 72 65 61 74 65 64 0a 09 o be recreated..
1860: 20 20 20 20 20 28 68 61 6e 64 6c 65 2d 65 78 63 (handle-exc
1870: 65 70 74 69 6f 6e 73 0a 09 20 20 20 20 20 20 65 eptions.. e
1880: 78 6e 0a 09 20 20 20 20 20 20 23 66 0a 09 20 20 xn.. #f..
1890: 20 20 20 20 28 69 66 20 28 66 69 6c 65 2d 65 78 (if (file-ex
18a0: 69 73 74 73 3f 20 6a 6f 75 72 6e 61 6c 29 28 64 ists? journal)(d
18b0: 65 6c 65 74 65 2d 66 69 6c 65 20 6a 6f 75 72 6e elete-file journ
18c0: 61 6c 29 29 0a 09 20 20 20 20 20 20 28 69 66 20 al)).. (if
18d0: 28 66 69 6c 65 2d 65 78 69 73 74 73 3f 20 66 6e (file-exists? fn
18e0: 61 6d 65 29 20 20 28 64 65 6c 65 74 65 2d 66 69 ame) (delete-fi
18f0: 6c 65 20 66 6e 61 6d 65 29 29 0a 09 20 20 20 20 le fname))..
1900: 20 20 23 66 29 29 29 29 0a 20 20 20 20 20 28 73 #f)))). (s
1910: 71 6c 69 74 65 33 3a 65 78 65 63 75 74 65 20 28 qlite3:execute (
1920: 6c 6f 63 6b 2d 71 75 65 75 65 3a 64 62 2d 64 61 lock-queue:db-da
1930: 74 2d 67 65 74 2d 64 62 20 64 62 64 61 74 29 20 t-get-db dbdat)
1940: 22 44 45 4c 45 54 45 20 46 52 4f 4d 20 72 75 6e "DELETE FROM run
1950: 6c 6f 63 6b 73 20 57 48 45 52 45 20 74 65 73 74 locks WHERE test
1960: 5f 69 64 3d 3f 3b 22 20 74 65 73 74 2d 69 64 29 _id=?;" test-id)
1970: 0a 20 20 20 20 20 28 73 71 6c 69 74 65 33 3a 66 . (sqlite3:f
1980: 69 6e 61 6c 69 7a 65 21 20 28 6c 6f 63 6b 2d 71 inalize! (lock-q
1990: 75 65 75 65 3a 64 62 2d 64 61 74 2d 67 65 74 2d ueue:db-dat-get-
19a0: 64 62 20 64 62 64 61 74 29 29 29 29 29 0a 0a 28 db dbdat)))))..(
19b0: 64 65 66 69 6e 65 20 28 6c 6f 63 6b 2d 71 75 65 define (lock-que
19c0: 75 65 3a 73 74 65 61 6c 2d 6c 6f 63 6b 20 64 62 ue:steal-lock db
19d0: 64 61 74 20 74 65 73 74 2d 69 64 20 23 21 6b 65 dat test-id #!ke
19e0: 79 20 28 63 6f 75 6e 74 20 31 30 29 29 0a 20 20 y (count 10)).
19f0: 28 64 65 62 75 67 3a 70 72 69 6e 74 2d 69 6e 66 (debug:print-inf
1a00: 6f 20 30 20 22 41 74 74 65 6d 70 74 69 6e 67 20 o 0 "Attempting
1a10: 74 6f 20 73 74 65 61 6c 20 6c 6f 63 6b 20 61 74 to steal lock at
1a20: 20 22 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 64 " (lock-queue:d
1a30: 62 2d 64 61 74 2d 67 65 74 2d 70 61 74 68 20 64 b-dat-get-path d
1a40: 62 64 61 74 29 29 0a 20 20 28 74 61 73 6b 73 3a bdat)). (tasks:
1a50: 77 61 69 74 2d 6f 6e 2d 6a 6f 75 72 6e 61 6c 20 wait-on-journal
1a60: 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 64 62 2d 64 (lock-queue:db-d
1a70: 61 74 2d 67 65 74 2d 70 61 74 68 20 64 62 64 61 at-get-path dbda
1a80: 74 29 20 31 32 30 30 20 22 6c 6f 63 6b 2d 71 75 t) 1200 "lock-qu
1a90: 65 75 65 3a 73 74 65 61 6c 2d 6c 6f 63 6b 3b 20 eue:steal-lock;
1aa0: 77 61 69 74 69 6e 67 20 6f 6e 20 6a 6f 75 72 6e waiting on journ
1ab0: 61 6c 22 29 0a 20 20 28 68 61 6e 64 6c 65 2d 65 al"). (handle-e
1ac0: 78 63 65 70 74 69 6f 6e 73 0a 20 20 20 65 78 6e xceptions. exn
1ad0: 0a 20 20 20 28 62 65 67 69 6e 0a 20 20 20 20 20 . (begin.
1ae0: 28 64 65 62 75 67 3a 70 72 69 6e 74 20 30 20 22 (debug:print 0 "
1af0: 57 41 52 4e 49 4e 47 3a 20 46 61 69 6c 65 64 20 WARNING: Failed
1b00: 74 6f 20 73 74 65 61 6c 20 71 75 65 75 65 20 6c to steal queue l
1b10: 6f 63 6b 2e 20 57 69 6c 6c 20 74 72 79 20 61 67 ock. Will try ag
1b20: 61 69 6e 20 69 6e 20 66 65 77 20 73 65 63 6f 6e ain in few secon
1b30: 64 73 22 29 0a 20 20 20 20 20 28 64 65 62 75 67 ds"). (debug
1b40: 3a 70 72 69 6e 74 20 30 20 22 20 6d 65 73 73 61 :print 0 " messa
1b50: 67 65 3a 20 22 20 28 28 63 6f 6e 64 69 74 69 6f ge: " ((conditio
1b60: 6e 2d 70 72 6f 70 65 72 74 79 2d 61 63 63 65 73 n-property-acces
1b70: 73 6f 72 20 27 65 78 6e 20 27 6d 65 73 73 61 67 sor 'exn 'messag
1b80: 65 29 20 65 78 6e 29 29 0a 20 20 20 20 20 28 74 e) exn)). (t
1b90: 68 72 65 61 64 2d 73 6c 65 65 70 21 20 31 30 29 hread-sleep! 10)
1ba0: 0a 20 20 20 20 20 28 69 66 20 28 3e 20 63 6f 75 . (if (> cou
1bb0: 6e 74 20 30 29 0a 09 20 28 6c 6f 63 6b 2d 71 75 nt 0).. (lock-qu
1bc0: 65 75 65 3a 73 74 65 61 6c 2d 6c 6f 63 6b 20 64 eue:steal-lock d
1bd0: 62 64 61 74 20 74 65 73 74 2d 69 64 20 63 6f 75 bdat test-id cou
1be0: 6e 74 3a 20 28 2d 20 63 6f 75 6e 74 20 31 29 29 nt: (- count 1))
1bf0: 0a 09 20 23 66 29 29 0a 20 20 20 28 73 71 6c 69 .. #f)). (sqli
1c00: 74 65 33 3a 65 78 65 63 75 74 65 20 28 6c 6f 63 te3:execute (loc
1c10: 6b 2d 71 75 65 75 65 3a 64 62 2d 64 61 74 2d 67 k-queue:db-dat-g
1c20: 65 74 2d 64 62 20 64 62 64 61 74 29 20 22 44 45 et-db dbdat) "DE
1c30: 4c 45 54 45 20 46 52 4f 4d 20 72 75 6e 6c 6f 63 LETE FROM runloc
1c40: 6b 73 20 57 48 45 52 45 20 72 75 6e 5f 6c 6f 63 ks WHERE run_loc
1c50: 6b 3d 27 6c 6f 63 6b 65 64 27 3b 22 29 29 0a 20 k='locked';")).
1c60: 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 67 65 74 (lock-queue:get
1c70: 2d 6c 6f 63 6b 20 64 62 64 61 74 20 74 65 73 74 -lock dbdat test
1c80: 2d 69 74 29 29 0a 0a 3b 3b 20 72 65 74 75 72 6e -it))..;; return
1c90: 73 20 23 66 20 69 66 20 6f 6b 20 74 6f 20 73 6b s #f if ok to sk
1ca0: 69 70 20 74 68 65 20 74 61 73 6b 0a 3b 3b 20 72 ip the task.;; r
1cb0: 65 74 75 72 6e 73 20 23 74 20 69 66 20 6f 6b 20 eturns #t if ok
1cc0: 74 6f 20 70 72 6f 63 65 65 64 20 77 69 74 68 20 to proceed with
1cd0: 74 61 73 6b 0a 3b 3b 20 6f 74 68 65 72 77 69 73 task.;; otherwis
1ce0: 65 20 77 61 69 74 73 0a 3b 3b 0a 28 64 65 66 69 e waits.;;.(defi
1cf0: 6e 65 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 77 ne (lock-queue:w
1d00: 61 69 74 2d 74 75 72 6e 20 66 6e 61 6d 65 20 74 ait-turn fname t
1d10: 65 73 74 2d 69 64 20 23 21 6b 65 79 20 28 63 6f est-id #!key (co
1d20: 75 6e 74 20 31 30 29 28 77 61 69 74 69 6e 67 2d unt 10)(waiting-
1d30: 6d 73 67 20 23 66 29 29 0a 20 20 28 6c 65 74 2a msg #f)). (let*
1d40: 20 28 28 64 62 64 61 74 20 20 20 28 6c 6f 63 6b ((dbdat (lock
1d50: 2d 71 75 65 75 65 3a 6f 70 65 6e 2d 64 62 20 66 -queue:open-db f
1d60: 6e 61 6d 65 29 29 0a 09 20 28 6d 79 73 74 61 72 name)).. (mystar
1d70: 74 20 28 63 75 72 72 65 6e 74 2d 73 65 63 6f 6e t (current-secon
1d80: 64 73 29 29 0a 09 20 28 64 62 20 20 20 20 20 20 ds)).. (db
1d90: 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 64 62 2d 64 (lock-queue:db-d
1da0: 61 74 2d 67 65 74 2d 64 62 20 64 62 64 61 74 29 at-get-db dbdat)
1db0: 29 29 0a 20 20 20 20 28 68 61 6e 64 6c 65 2d 65 )). (handle-e
1dc0: 78 63 65 70 74 69 6f 6e 73 0a 20 20 20 20 20 65 xceptions. e
1dd0: 78 6e 0a 20 20 20 20 20 28 62 65 67 69 6e 0a 20 xn. (begin.
1de0: 20 20 20 20 20 20 28 64 65 62 75 67 3a 70 72 69 (debug:pri
1df0: 6e 74 20 30 20 22 57 41 52 4e 49 4e 47 3a 20 46 nt 0 "WARNING: F
1e00: 61 69 6c 65 64 20 74 6f 20 66 69 6e 64 20 6f 75 ailed to find ou
1e10: 74 20 69 66 20 69 74 20 69 73 20 6f 6b 20 74 6f t if it is ok to
1e20: 20 73 6b 69 70 20 74 68 65 20 77 61 69 74 20 71 skip the wait q
1e30: 75 65 75 65 2e 20 57 69 6c 6c 20 74 72 79 20 61 ueue. Will try a
1e40: 67 61 69 6e 20 69 6e 20 66 65 77 20 73 65 63 6f gain in few seco
1e50: 6e 64 73 22 29 0a 20 20 20 20 20 20 20 28 64 65 nds"). (de
1e60: 62 75 67 3a 70 72 69 6e 74 20 30 20 22 20 6d 65 bug:print 0 " me
1e70: 73 73 61 67 65 3a 20 22 20 28 28 63 6f 6e 64 69 ssage: " ((condi
1e80: 74 69 6f 6e 2d 70 72 6f 70 65 72 74 79 2d 61 63 tion-property-ac
1e90: 63 65 73 73 6f 72 20 27 65 78 6e 20 27 6d 65 73 cessor 'exn 'mes
1ea0: 73 61 67 65 29 20 65 78 6e 29 29 0a 20 20 20 20 sage) exn)).
1eb0: 20 20 20 28 70 72 69 6e 74 2d 63 61 6c 6c 2d 63 (print-call-c
1ec0: 68 61 69 6e 29 0a 20 20 20 20 20 20 20 28 74 68 hain). (th
1ed0: 72 65 61 64 2d 73 6c 65 65 70 21 20 31 30 29 0a read-sleep! 10).
1ee0: 20 20 20 20 20 20 20 28 69 66 20 28 3e 20 63 6f (if (> co
1ef0: 75 6e 74 20 30 29 0a 09 20 20 20 28 62 65 67 69 unt 0).. (begi
1f00: 6e 0a 09 20 20 20 20 20 28 73 71 6c 69 74 65 33 n.. (sqlite3
1f10: 3a 66 69 6e 61 6c 69 7a 65 21 20 64 62 29 0a 09 :finalize! db)..
1f20: 20 20 20 20 20 28 6c 6f 63 6b 2d 71 75 65 75 65 (lock-queue
1f30: 3a 77 61 69 74 2d 74 75 72 6e 20 66 6e 61 6d 65 :wait-turn fname
1f40: 20 74 65 73 74 2d 69 64 20 63 6f 75 6e 74 3a 20 test-id count:
1f50: 28 2d 20 63 6f 75 6e 74 20 31 29 29 29 0a 09 20 (- count 1)))..
1f60: 20 20 28 62 65 67 69 6e 0a 09 20 20 20 20 20 28 (begin.. (
1f70: 64 65 62 75 67 3a 70 72 69 6e 74 20 30 20 22 47 debug:print 0 "G
1f80: 69 76 69 6e 67 20 75 70 20 63 61 6c 6c 73 20 74 iving up calls t
1f90: 6f 20 6c 6f 63 6b 2d 71 75 65 75 65 3a 77 61 69 o lock-queue:wai
1fa0: 74 2d 74 75 72 6e 20 66 6f 72 20 74 65 73 74 2d t-turn for test-
1fb0: 69 64 20 22 20 74 65 73 74 2d 69 64 20 22 20 61 id " test-id " a
1fc0: 74 20 70 61 74 68 20 22 20 66 6e 61 6d 65 20 22 t path " fname "
1fd0: 2c 20 70 72 69 6e 74 69 6e 67 20 63 61 6c 6c 20 , printing call
1fe0: 63 68 61 69 6e 22 29 0a 09 20 20 20 20 20 28 70 chain").. (p
1ff0: 72 69 6e 74 2d 63 61 6c 6c 2d 63 68 61 69 6e 29 rint-call-chain)
2000: 0a 09 20 20 20 20 20 23 66 29 29 29 0a 20 20 20 .. #f))).
2010: 20 20 28 74 61 73 6b 73 3a 77 61 69 74 2d 6f 6e (tasks:wait-on
2020: 2d 6a 6f 75 72 6e 61 6c 20 28 6c 6f 63 6b 2d 71 -journal (lock-q
2030: 75 65 75 65 3a 64 62 2d 64 61 74 2d 67 65 74 2d ueue:db-dat-get-
2040: 70 61 74 68 20 64 62 64 61 74 29 20 31 32 30 30 path dbdat) 1200
2050: 20 77 61 69 74 69 6e 67 2d 6d 73 67 3a 20 22 6c waiting-msg: "l
2060: 6f 63 6b 2d 71 75 65 75 65 3a 77 61 69 74 2d 74 ock-queue:wait-t
2070: 75 72 6e 3b 20 77 61 69 74 69 6e 67 20 6f 6e 20 urn; waiting on
2080: 6a 6f 75 72 6e 61 6c 20 66 69 6c 65 22 29 0a 20 journal file").
2090: 20 20 20 20 28 73 71 6c 69 74 65 33 3a 65 78 65 (sqlite3:exe
20a0: 63 75 74 65 0a 20 20 20 20 20 20 64 62 0a 20 20 cute. db.
20b0: 20 20 20 20 22 49 4e 53 45 52 54 20 4f 52 20 52 "INSERT OR R
20c0: 45 50 4c 41 43 45 20 49 4e 54 4f 20 71 75 65 75 EPLACE INTO queu
20d0: 65 20 28 74 65 73 74 5f 69 64 2c 73 74 61 72 74 e (test_id,start
20e0: 5f 74 69 6d 65 2c 73 74 61 74 65 29 20 56 41 4c _time,state) VAL
20f0: 55 45 53 20 28 3f 2c 3f 2c 27 77 61 69 74 69 6e UES (?,?,'waitin
2100: 67 27 29 3b 22 0a 20 20 20 20 20 20 74 65 73 74 g');". test
2110: 2d 69 64 20 6d 79 73 74 61 72 74 29 0a 20 20 20 -id mystart).
2120: 20 20 28 74 68 72 65 61 64 2d 73 6c 65 65 70 21 (thread-sleep!
2130: 20 31 29 20 3b 3b 20 67 69 76 65 20 6f 74 68 65 1) ;; give othe
2140: 72 20 74 65 73 74 73 20 61 20 63 68 61 6e 63 65 r tests a chance
2150: 20 74 6f 20 72 65 67 69 73 74 65 72 0a 20 20 20 to register.
2160: 20 20 28 6c 65 74 20 28 28 72 65 73 75 6c 74 20 (let ((result
2170: 0a 09 20 20 20 20 28 6c 65 74 20 6c 6f 6f 70 20 .. (let loop
2180: 28 28 79 6f 75 6e 67 65 72 2d 77 61 69 74 69 6e ((younger-waitin
2190: 67 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 61 6e g (lock-queue:an
21a0: 79 2d 79 6f 75 6e 67 65 72 3f 20 64 62 64 61 74 y-younger? dbdat
21b0: 20 6d 79 73 74 61 72 74 20 74 65 73 74 2d 69 64 mystart test-id
21c0: 29 29 29 0a 09 20 20 20 20 20 20 28 69 66 20 79 ))).. (if y
21d0: 6f 75 6e 67 65 72 2d 77 61 69 74 69 6e 67 0a 09 ounger-waiting..
21e0: 09 20 20 28 62 65 67 69 6e 0a 09 09 20 20 20 20 . (begin...
21f0: 3b 3b 20 6e 6f 20 6e 65 65 64 20 66 6f 72 20 75 ;; no need for u
2200: 73 20 74 6f 20 77 61 69 74 2e 20 6d 61 72 6b 20 s to wait. mark
2210: 69 6e 20 74 68 65 20 6c 6f 63 6b 20 71 75 65 75 in the lock queu
2220: 65 20 64 62 20 61 73 20 73 6b 69 70 70 69 6e 67 e db as skipping
2230: 0a 09 09 20 20 20 20 28 6c 6f 63 6b 2d 71 75 65 ... (lock-que
2240: 75 65 3a 73 65 74 2d 73 74 61 74 65 20 64 62 64 ue:set-state dbd
2250: 61 74 20 74 65 73 74 2d 69 64 20 22 73 6b 69 70 at test-id "skip
2260: 70 69 6e 67 22 29 0a 09 09 20 20 20 20 23 66 29 ping")... #f)
2270: 20 3b 3b 20 6c 65 74 20 74 68 65 20 63 61 6c 6c ;; let the call
2280: 69 6e 67 20 70 72 6f 63 65 73 73 20 6b 6e 6f 77 ing process know
2290: 20 74 68 61 74 20 6e 6f 74 68 69 6e 67 20 6e 65 that nothing ne
22a0: 65 64 73 20 74 6f 20 62 65 20 64 6f 6e 65 0a 09 eds to be done..
22b0: 09 20 20 28 69 66 20 28 6c 6f 63 6b 2d 71 75 65 . (if (lock-que
22c0: 75 65 3a 67 65 74 2d 6c 6f 63 6b 20 64 62 64 61 ue:get-lock dbda
22d0: 74 20 74 65 73 74 2d 69 64 29 0a 09 09 20 20 20 t test-id)...
22e0: 20 20 20 23 74 0a 09 09 20 20 20 20 20 20 28 69 #t... (i
22f0: 66 20 28 3e 20 28 2d 20 28 63 75 72 72 65 6e 74 f (> (- (current
2300: 2d 73 65 63 6f 6e 64 73 29 20 6d 79 73 74 61 72 -seconds) mystar
2310: 74 29 20 33 36 30 30 30 29 20 3b 3b 20 77 61 69 t) 36000) ;; wai
2320: 74 65 64 20 74 6f 6f 20 6c 6f 6e 67 2c 20 73 74 ted too long, st
2330: 65 61 6c 20 74 68 65 20 6c 6f 63 6b 0a 09 09 09 eal the lock....
2340: 20 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 73 74 (lock-queue:st
2350: 65 61 6c 2d 6c 6f 63 6b 20 64 62 64 61 74 20 74 eal-lock dbdat t
2360: 65 73 74 2d 69 64 29 0a 09 09 09 20 20 28 62 65 est-id).... (be
2370: 67 69 6e 0a 09 09 09 20 20 20 20 28 74 68 72 65 gin.... (thre
2380: 61 64 2d 73 6c 65 65 70 21 20 31 29 0a 09 09 09 ad-sleep! 1)....
2390: 20 20 20 20 28 6c 6f 6f 70 20 28 6c 6f 63 6b 2d (loop (lock-
23a0: 71 75 65 75 65 3a 61 6e 79 2d 79 6f 75 6e 67 65 queue:any-younge
23b0: 72 3f 20 64 62 64 61 74 20 6d 79 73 74 61 72 74 r? dbdat mystart
23c0: 20 74 65 73 74 2d 69 64 29 29 29 29 29 29 29 29 test-id))))))))
23d0: 29 0a 20 20 20 20 20 20 20 28 73 71 6c 69 74 65 ). (sqlite
23e0: 33 3a 66 69 6e 61 6c 69 7a 65 21 20 64 62 29 0a 3:finalize! db).
23f0: 20 20 20 20 20 20 20 72 65 73 75 6c 74 29 29 29 result)))
2400: 29 0a 09 20 20 0a 20 20 20 20 20 20 20 20 20 20 ).. .
2410: 20 20 0a 3b 3b 20 28 75 73 65 20 74 72 61 63 65 .;; (use trace
2420: 29 0a 3b 3b 20 28 74 72 61 63 65 20 6c 6f 63 6b ).;; (trace lock
2430: 2d 71 75 65 75 65 3a 67 65 74 2d 6c 6f 63 6b 20 -queue:get-lock
2440: 6c 6f 63 6b 2d 71 75 65 75 65 3a 72 65 6c 65 61 lock-queue:relea
2450: 73 65 2d 6c 6f 63 6b 20 6c 6f 63 6b 2d 71 75 65 se-lock lock-que
2460: 75 65 3a 77 61 69 74 2d 74 75 72 6e 20 6c 6f 63 ue:wait-turn loc
2470: 6b 2d 71 75 65 75 65 3a 61 6e 79 2d 79 6f 75 6e k-queue:any-youn
2480: 67 65 72 3f 20 6c 6f 63 6b 2d 71 75 65 75 65 3a ger? lock-queue:
2490: 73 65 74 2d 73 74 61 74 65 29 set-state)