Artifact
95a058169470401121d65066d175c525fb2eebf7:
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 28 69 6e 63 6c 75 64 65 20 22 2f 6e 66 )).(include "/nf
0190: 73 2f 73 69 74 65 2f 64 69 73 6b 73 2f 69 63 66 s/site/disks/icf
01a0: 5f 66 64 6b 5f 63 77 5f 67 77 61 30 30 32 2f 73 _fdk_cw_gwa002/s
01b0: 72 65 68 6d 61 6e 2f 66 6f 73 73 69 6c 2f 64 62 rehman/fossil/db
01c0: 69 2f 64 62 69 2e 73 63 6d 22 29 0a 28 69 6d 70 i/dbi.scm").(imp
01d0: 6f 72 74 20 28 70 72 65 66 69 78 20 64 62 69 20 ort (prefix dbi
01e0: 64 62 69 3a 29 29 0a 0a 28 64 65 63 6c 61 72 65 dbi:))..(declare
01f0: 20 28 75 6e 69 74 20 6c 6f 63 6b 2d 71 75 65 75 (unit lock-queu
0200: 65 29 29 0a 28 64 65 63 6c 61 72 65 20 28 75 73 e)).(declare (us
0210: 65 73 20 63 6f 6d 6d 6f 6e 29 29 0a 28 64 65 63 es common)).(dec
0220: 6c 61 72 65 20 28 75 73 65 73 20 74 61 73 6b 73 lare (uses tasks
0230: 29 29 0a 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ))..;;==========
0240: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0250: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0260: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0270: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a 3b 3b 20 ============.;;
0280: 61 74 74 65 6d 70 74 20 74 6f 20 70 72 65 76 65 attempt to preve
0290: 6e 74 20 6f 76 65 72 6c 61 70 70 69 6e 67 20 75 nt overlapping u
02a0: 70 64 61 74 65 73 20 6f 66 20 72 6f 6c 6c 75 70 pdates of rollup
02b0: 20 66 69 6c 65 73 20 62 79 20 71 75 65 75 65 69 files by queuei
02c0: 6e 67 0a 3b 3b 20 75 70 64 61 74 65 20 72 65 71 ng.;; update req
02d0: 75 65 73 74 73 20 69 6e 20 61 6e 20 73 71 6c 69 uests in an sqli
02e0: 74 65 20 64 62 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d te db.;;========
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 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0320: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a 0a ==============..
0330: 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ;;==============
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 0a 3b 3b 20 64 62 20 72 ========.;; db r
0380: 65 63 6f 72 64 2c 20 3c 76 65 63 74 6f 72 20 64 ecord, <vector d
0390: 62 20 70 61 74 68 2d 74 6f 2d 64 62 3e 0a 3b 3b b path-to-db>.;;
03a0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
03b0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
03c0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
03d0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
03e0: 3d 3d 3d 3d 3d 3d 0a 0a 28 64 65 66 69 6e 65 20 ======..(define
03f0: 28 6d 61 6b 65 2d 6c 6f 63 6b 2d 71 75 65 75 65 (make-lock-queue
0400: 3a 64 62 2d 64 61 74 29 28 6d 61 6b 65 2d 76 65 :db-dat)(make-ve
0410: 63 74 6f 72 20 33 29 29 0a 28 64 65 66 69 6e 65 ctor 3)).(define
0420: 2d 69 6e 6c 69 6e 65 20 28 6c 6f 63 6b 2d 71 75 -inline (lock-qu
0430: 65 75 65 3a 64 62 2d 64 61 74 2d 67 65 74 2d 64 eue:db-dat-get-d
0440: 62 20 20 20 20 20 20 20 20 76 65 63 29 20 20 20 b vec)
0450: 20 28 76 65 63 74 6f 72 2d 72 65 66 20 20 76 65 (vector-ref ve
0460: 63 20 30 29 29 0a 28 64 65 66 69 6e 65 2d 69 6e c 0)).(define-in
0470: 6c 69 6e 65 20 28 6c 6f 63 6b 2d 71 75 65 75 65 line (lock-queue
0480: 3a 64 62 2d 64 61 74 2d 67 65 74 2d 70 61 74 68 :db-dat-get-path
0490: 20 20 20 20 20 20 76 65 63 29 20 20 20 20 28 76 vec) (v
04a0: 65 63 74 6f 72 2d 72 65 66 20 20 76 65 63 20 31 ector-ref vec 1
04b0: 29 29 0a 28 64 65 66 69 6e 65 2d 69 6e 6c 69 6e )).(define-inlin
04c0: 65 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 64 62 e (lock-queue:db
04d0: 2d 64 61 74 2d 73 65 74 2d 64 62 21 20 20 20 20 -dat-set-db!
04e0: 20 20 20 76 65 63 20 76 61 6c 29 28 76 65 63 74 vec val)(vect
04f0: 6f 72 2d 73 65 74 21 20 76 65 63 20 30 20 76 61 or-set! vec 0 va
0500: 6c 29 29 0a 28 64 65 66 69 6e 65 2d 69 6e 6c 69 l)).(define-inli
0510: 6e 65 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 64 ne (lock-queue:d
0520: 62 2d 64 61 74 2d 73 65 74 2d 70 61 74 68 21 20 b-dat-set-path!
0530: 20 20 20 20 76 65 63 20 76 61 6c 29 28 76 65 63 vec val)(vec
0540: 74 6f 72 2d 73 65 74 21 20 76 65 63 20 31 20 76 tor-set! vec 1 v
0550: 61 6c 29 29 0a 0a 28 64 65 66 69 6e 65 20 28 6c al))..(define (l
0560: 6f 63 6b 2d 71 75 65 75 65 3a 64 65 6c 65 74 65 ock-queue:delete
0570: 2d 6c 6f 63 6b 2d 64 62 20 64 62 64 61 74 29 0a -lock-db dbdat).
0580: 20 20 28 6c 65 74 20 28 28 66 6e 61 6d 65 20 28 (let ((fname (
0590: 6c 6f 63 6b 2d 71 75 65 75 65 3a 64 62 2d 64 61 lock-queue:db-da
05a0: 74 2d 67 65 74 2d 70 61 74 68 20 64 62 64 61 74 t-get-path dbdat
05b0: 29 29 29 0a 20 20 20 20 28 73 79 73 74 65 6d 20 ))). (system
05c0: 28 63 6f 6e 63 20 22 72 6d 20 2d 66 20 22 20 66 (conc "rm -f " f
05d0: 6e 61 6d 65 20 22 2a 22 29 29 29 29 0a 0a 28 64 name "*"))))..(d
05e0: 65 66 69 6e 65 20 28 6c 6f 63 6b 2d 71 75 65 75 efine (lock-queu
05f0: 65 3a 6f 70 65 6e 2d 64 62 20 66 6e 61 6d 65 20 e:open-db fname
0600: 23 21 6b 65 79 20 28 63 6f 75 6e 74 20 31 30 29 #!key (count 10)
0610: 29 0a 20 20 28 6c 65 74 2a 20 28 28 61 63 74 75 ). (let* ((actu
0620: 61 6c 66 6e 61 6d 65 20 28 63 6f 6e 63 20 66 6e alfname (conc fn
0630: 61 6d 65 20 22 2e 6c 6f 63 6b 64 62 22 29 29 0a ame ".lockdb")).
0640: 09 20 28 64 62 65 78 69 73 74 73 20 28 66 69 6c . (dbexists (fil
0650: 65 2d 65 78 69 73 74 73 3f 20 61 63 74 75 61 6c e-exists? actual
0660: 66 6e 61 6d 65 29 29 0a 09 20 28 64 62 20 20 20 fname)).. (db
0670: 20 20 20 20 28 64 62 69 3a 6f 70 65 6e 20 27 73 (dbi:open 's
0680: 71 6c 69 74 65 33 20 28 63 6f 6e 73 20 28 63 6f qlite3 (cons (co
0690: 6e 73 20 28 27 64 62 6e 61 6d 65 20 61 63 74 75 ns ('dbname actu
06a0: 61 6c 66 6e 61 6d 65 29 20 27 28 29 29 29 29 29 alfname) '()))))
06b0: 29 0a 09 20 3b 3b 28 68 61 6e 64 6c 65 72 20 20 ).. ;;(handler
06c0: 28 6d 61 6b 65 2d 62 75 73 79 2d 74 69 6d 65 6f (make-busy-timeo
06d0: 75 74 20 31 33 36 30 30 30 29 29 29 0a 20 20 20 ut 136000))).
06e0: 20 28 69 66 20 64 62 65 78 69 73 74 73 0a 09 28 (if dbexists..(
06f0: 76 65 63 74 6f 72 20 64 62 20 61 63 74 75 61 6c vector db actual
0700: 66 6e 61 6d 65 29 0a 09 28 62 65 67 69 6e 0a 09 fname)..(begin..
0710: 20 20 28 68 61 6e 64 6c 65 2d 65 78 63 65 70 74 (handle-except
0720: 69 6f 6e 73 0a 09 20 20 20 65 78 6e 0a 09 20 20 ions.. exn..
0730: 20 28 62 65 67 69 6e 0a 09 20 20 20 20 20 28 74 (begin.. (t
0740: 68 72 65 61 64 2d 73 6c 65 65 70 21 20 31 30 29 hread-sleep! 10)
0750: 0a 09 20 20 20 20 20 28 69 66 20 28 3e 20 63 6f .. (if (> co
0760: 75 6e 74 20 30 29 0a 09 09 20 28 6c 6f 63 6b 2d unt 0)... (lock-
0770: 71 75 65 75 65 3a 6f 70 65 6e 2d 64 62 20 66 6e queue:open-db fn
0780: 61 6d 65 20 63 6f 75 6e 74 3a 20 28 2d 20 63 6f ame count: (- co
0790: 75 6e 74 20 31 29 29 0a 09 09 20 28 76 65 63 74 unt 1))... (vect
07a0: 6f 72 20 64 62 20 61 63 74 75 61 6c 66 6e 61 6d or db actualfnam
07b0: 65 29 29 29 0a 09 20 20 20 28 64 62 69 3a 77 69 e))).. (dbi:wi
07c0: 74 68 2d 74 72 61 6e 73 61 63 74 69 6f 6e 0a 09 th-transaction..
07d0: 20 20 20 20 64 62 0a 09 20 20 20 20 28 6c 61 6d db.. (lam
07e0: 62 64 61 20 28 29 0a 09 20 20 20 20 20 20 28 64 bda ().. (d
07f0: 62 69 3a 65 78 65 63 20 0a 09 20 20 20 20 20 20 bi:exec ..
0800: 20 64 62 0a 09 20 20 20 20 20 20 20 22 43 52 45 db.. "CRE
0810: 41 54 45 20 54 41 42 4c 45 20 49 46 20 4e 4f 54 ATE TABLE IF NOT
0820: 20 45 58 49 53 54 53 20 71 75 65 75 65 20 28 0a EXISTS queue (.
0830: 20 20 20 20 20 09 20 20 20 20 20 20 20 20 20 69 . i
0840: 64 20 20 20 20 20 20 20 20 20 49 4e 54 45 47 45 d INTEGE
0850: 52 20 50 52 49 4d 41 52 59 20 4b 45 59 2c 0a 20 R PRIMARY KEY,.
0860: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
0870: 74 65 73 74 5f 69 64 20 20 20 20 49 4e 54 45 47 test_id INTEG
0880: 45 52 2c 0a 20 20 20 20 20 20 20 20 20 20 20 20 ER,.
0890: 20 20 20 20 20 73 74 61 72 74 5f 74 69 6d 65 20 start_time
08a0: 49 4e 54 45 47 45 52 2c 0a 20 20 20 20 20 20 20 INTEGER,.
08b0: 20 20 20 20 20 20 20 20 20 20 73 74 61 74 65 20 state
08c0: 20 20 20 20 20 54 45 58 54 2c 0a 20 20 20 20 20 TEXT,.
08d0: 20 20 20 20 20 20 20 20 20 20 20 20 43 4f 4e 53 CONS
08e0: 54 52 41 49 4e 54 20 71 75 65 75 65 5f 63 6f 6e TRAINT queue_con
08f0: 73 74 72 61 69 6e 74 20 55 4e 49 51 55 45 20 28 straint UNIQUE (
0900: 74 65 73 74 5f 69 64 29 29 3b 22 29 0a 09 20 20 test_id));")..
0910: 20 20 20 20 28 64 62 69 3a 65 78 65 63 0a 09 20 (dbi:exec..
0920: 20 20 20 20 20 20 64 62 0a 09 20 20 20 20 20 20 db..
0930: 20 22 43 52 45 41 54 45 20 54 41 42 4c 45 20 49 "CREATE TABLE I
0940: 46 20 4e 4f 54 20 45 58 49 53 54 53 20 72 75 6e F NOT EXISTS run
0950: 6c 6f 63 6b 73 20 28 0a 20 20 20 20 20 20 20 20 locks (.
0960: 20 20 20 20 20 20 20 20 20 69 64 20 20 20 20 20 id
0970: 20 20 20 20 49 4e 54 45 47 45 52 20 50 52 49 4d INTEGER PRIM
0980: 41 52 59 20 4b 45 59 2c 0a 20 20 20 20 20 20 20 ARY KEY,.
0990: 20 20 20 20 20 20 20 20 20 20 74 65 73 74 5f 69 test_i
09a0: 64 20 20 20 20 49 4e 54 45 47 45 52 2c 0a 20 20 d INTEGER,.
09b0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 72 r
09c0: 75 6e 5f 6c 6f 63 6b 20 20 20 54 45 58 54 2c 0a un_lock TEXT,.
09d0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
09e0: 20 43 4f 4e 53 54 52 41 49 4e 54 20 72 75 6e 6c CONSTRAINT runl
09f0: 6f 63 6b 5f 63 6f 6e 73 74 72 61 69 6e 74 20 55 ock_constraint U
0a00: 4e 49 51 55 45 20 28 72 75 6e 5f 6c 6f 63 6b 29 NIQUE (run_lock)
0a10: 29 3b 22 29 29 29 29 29 29 0a 20 20 20 20 3b 3b );")))))). ;;
0a20: 28 73 71 6c 69 74 65 33 3a 73 65 74 2d 62 75 73 (sqlite3:set-bus
0a30: 79 2d 68 61 6e 64 6c 65 72 21 20 64 62 20 68 61 y-handler! db ha
0a40: 6e 64 6c 65 72 29 0a 20 20 20 20 28 76 65 63 74 ndler). (vect
0a50: 6f 72 20 64 62 20 61 63 74 75 61 6c 66 6e 61 6d or db actualfnam
0a60: 65 29 29 29 0a 0a 28 64 65 66 69 6e 65 20 28 6c e)))..(define (l
0a70: 6f 63 6b 2d 71 75 65 75 65 3a 73 65 74 2d 73 74 ock-queue:set-st
0a80: 61 74 65 20 64 62 64 61 74 20 74 65 73 74 2d 69 ate dbdat test-i
0a90: 64 20 6e 65 77 73 74 61 74 65 20 23 21 6b 65 79 d newstate #!key
0aa0: 20 28 72 65 6d 74 72 69 65 73 20 31 30 29 29 0a (remtries 10)).
0ab0: 20 20 28 74 61 73 6b 73 3a 77 61 69 74 2d 6f 6e (tasks:wait-on
0ac0: 2d 6a 6f 75 72 6e 61 6c 20 28 6c 6f 63 6b 2d 71 -journal (lock-q
0ad0: 75 65 75 65 3a 64 62 2d 64 61 74 2d 67 65 74 2d ueue:db-dat-get-
0ae0: 70 61 74 68 20 64 62 64 61 74 29 20 31 32 30 30 path dbdat) 1200
0af0: 29 0a 20 20 28 68 61 6e 64 6c 65 2d 65 78 63 65 ). (handle-exce
0b00: 70 74 69 6f 6e 73 0a 20 20 20 65 78 6e 0a 20 20 ptions. exn.
0b10: 20 28 69 66 20 28 3e 20 72 65 6d 74 72 69 65 73 (if (> remtries
0b20: 20 30 29 0a 20 20 20 20 20 20 20 28 62 65 67 69 0). (begi
0b30: 6e 0a 09 20 28 64 65 62 75 67 3a 70 72 69 6e 74 n.. (debug:print
0b40: 20 30 20 2a 64 65 66 61 75 6c 74 2d 6c 6f 67 2d 0 *default-log-
0b50: 70 6f 72 74 2a 20 22 57 41 52 4e 49 4e 47 3a 20 port* "WARNING:
0b60: 65 78 63 65 70 74 69 6f 6e 20 6f 6e 20 6c 6f 63 exception on loc
0b70: 6b 2d 71 75 65 75 65 3a 73 65 74 2d 73 74 61 74 k-queue:set-stat
0b80: 65 2e 20 54 72 79 69 6e 67 20 61 67 61 69 6e 20 e. Trying again
0b90: 69 6e 20 33 30 20 73 65 63 6f 6e 64 73 2e 22 29 in 30 seconds.")
0ba0: 0a 09 20 28 64 65 62 75 67 3a 70 72 69 6e 74 20 .. (debug:print
0bb0: 30 20 2a 64 65 66 61 75 6c 74 2d 6c 6f 67 2d 70 0 *default-log-p
0bc0: 6f 72 74 2a 20 22 20 6d 65 73 73 61 67 65 3a 20 ort* " message:
0bd0: 22 20 28 28 63 6f 6e 64 69 74 69 6f 6e 2d 70 72 " ((condition-pr
0be0: 6f 70 65 72 74 79 2d 61 63 63 65 73 73 6f 72 20 operty-accessor
0bf0: 27 65 78 6e 20 27 6d 65 73 73 61 67 65 29 20 65 'exn 'message) e
0c00: 78 6e 29 29 0a 09 20 28 74 68 72 65 61 64 2d 73 xn)).. (thread-s
0c10: 6c 65 65 70 21 20 33 30 29 0a 09 20 28 6c 6f 63 leep! 30).. (loc
0c20: 6b 2d 71 75 65 75 65 3a 73 65 74 2d 73 74 61 74 k-queue:set-stat
0c30: 65 20 64 62 64 61 74 20 74 65 73 74 2d 69 64 20 e dbdat test-id
0c40: 6e 65 77 73 74 61 74 65 20 72 65 6d 74 72 69 65 newstate remtrie
0c50: 73 3a 20 28 2d 20 72 65 6d 74 72 69 65 73 20 31 s: (- remtries 1
0c60: 29 29 29 0a 20 20 20 20 20 20 20 28 62 65 67 69 ))). (begi
0c70: 6e 0a 09 20 28 64 65 62 75 67 3a 70 72 69 6e 74 n.. (debug:print
0c80: 2d 65 72 72 6f 72 20 30 20 2a 64 65 66 61 75 6c -error 0 *defaul
0c90: 74 2d 6c 6f 67 2d 70 6f 72 74 2a 20 22 20 46 61 t-log-port* " Fa
0ca0: 69 6c 65 64 20 74 6f 20 73 65 74 20 6c 6f 63 6b iled to set lock
0cb0: 20 73 74 61 74 65 20 66 6f 72 20 74 65 73 74 20 state for test
0cc0: 77 69 74 68 20 69 64 20 22 20 74 65 73 74 2d 69 with id " test-i
0cd0: 64 20 22 2c 20 65 72 72 6f 72 3a 20 22 20 28 28 d ", error: " ((
0ce0: 63 6f 6e 64 69 74 69 6f 6e 2d 70 72 6f 70 65 72 condition-proper
0cf0: 74 79 2d 61 63 63 65 73 73 6f 72 20 27 65 78 6e ty-accessor 'exn
0d00: 20 27 6d 65 73 73 61 67 65 29 20 65 78 6e 29 20 'message) exn)
0d10: 22 2c 20 67 69 76 69 6e 67 20 75 70 2e 22 29 0a ", giving up.").
0d20: 09 20 23 66 29 29 0a 20 20 20 28 64 62 69 3a 65 . #f)). (dbi:e
0d30: 78 65 63 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a xec (lock-queue:
0d40: 64 62 2d 64 61 74 2d 67 65 74 2d 64 62 20 64 62 db-dat-get-db db
0d50: 64 61 74 29 20 22 55 50 44 41 54 45 20 71 75 65 dat) "UPDATE que
0d60: 75 65 20 53 45 54 20 73 74 61 74 65 3d 3f 20 57 ue SET state=? W
0d70: 48 45 52 45 20 74 65 73 74 5f 69 64 3d 3f 3b 22 HERE test_id=?;"
0d80: 0a 09 09 20 20 20 20 6e 65 77 73 74 61 74 65 0a ... newstate.
0d90: 09 09 20 20 20 20 74 65 73 74 2d 69 64 29 29 29 .. test-id)))
0da0: 0a 0a 28 64 65 66 69 6e 65 20 28 6c 6f 63 6b 2d ..(define (lock-
0db0: 71 75 65 75 65 3a 61 6e 79 2d 79 6f 75 6e 67 65 queue:any-younge
0dc0: 72 3f 20 64 62 64 61 74 20 6d 79 73 74 61 72 74 r? dbdat mystart
0dd0: 20 74 65 73 74 2d 69 64 20 23 21 6b 65 79 20 28 test-id #!key (
0de0: 72 65 6d 74 72 69 65 73 20 31 30 29 29 0a 20 20 remtries 10)).
0df0: 3b 3b 20 6e 6f 20 6e 65 65 64 20 74 6f 20 77 61 ;; no need to wa
0e00: 69 74 20 6f 6e 20 6a 6f 75 72 6e 61 6c 20 6f 6e it on journal on
0e10: 20 72 65 61 64 20 6f 6e 6c 79 20 71 75 65 72 69 read only queri
0e20: 65 73 0a 20 20 3b 3b 20 28 74 61 73 6b 73 3a 77 es. ;; (tasks:w
0e30: 61 69 74 2d 6f 6e 2d 6a 6f 75 72 6e 61 6c 20 28 ait-on-journal (
0e40: 6c 6f 63 6b 2d 71 75 65 75 65 3a 64 62 2d 64 61 lock-queue:db-da
0e50: 74 2d 67 65 74 2d 70 61 74 68 20 64 62 64 61 74 t-get-path dbdat
0e60: 29 20 31 32 30 30 29 0a 20 20 28 68 61 6e 64 6c ) 1200). (handl
0e70: 65 2d 65 78 63 65 70 74 69 6f 6e 73 0a 20 20 20 e-exceptions.
0e80: 65 78 6e 0a 20 20 20 28 69 66 20 28 3e 20 72 65 exn. (if (> re
0e90: 6d 74 72 69 65 73 20 30 29 0a 20 20 20 20 20 20 mtries 0).
0ea0: 20 28 62 65 67 69 6e 0a 09 20 28 64 65 62 75 67 (begin.. (debug
0eb0: 3a 70 72 69 6e 74 20 30 20 2a 64 65 66 61 75 6c :print 0 *defaul
0ec0: 74 2d 6c 6f 67 2d 70 6f 72 74 2a 20 22 57 41 52 t-log-port* "WAR
0ed0: 4e 49 4e 47 3a 20 65 78 63 65 70 74 69 6f 6e 20 NING: exception
0ee0: 6f 6e 20 6c 6f 63 6b 2d 71 75 65 75 65 3a 61 6e on lock-queue:an
0ef0: 79 2d 79 6f 75 6e 67 65 72 2e 20 52 65 6d 6f 76 y-younger. Remov
0f00: 69 6e 67 20 6c 6f 63 6b 64 62 20 61 6e 64 20 74 ing lockdb and t
0f10: 72 79 69 6e 67 20 61 67 61 69 6e 20 69 6e 20 35 rying again in 5
0f20: 20 73 65 63 6f 6e 64 73 2e 22 29 0a 09 20 28 64 seconds.").. (d
0f30: 65 62 75 67 3a 70 72 69 6e 74 20 30 20 2a 64 65 ebug:print 0 *de
0f40: 66 61 75 6c 74 2d 6c 6f 67 2d 70 6f 72 74 2a 20 fault-log-port*
0f50: 22 20 6d 65 73 73 61 67 65 3a 20 22 20 28 28 63 " message: " ((c
0f60: 6f 6e 64 69 74 69 6f 6e 2d 70 72 6f 70 65 72 74 ondition-propert
0f70: 79 2d 61 63 63 65 73 73 6f 72 20 27 65 78 6e 20 y-accessor 'exn
0f80: 27 6d 65 73 73 61 67 65 29 20 65 78 6e 29 29 0a 'message) exn)).
0f90: 09 20 28 74 68 72 65 61 64 2d 73 6c 65 65 70 21 . (thread-sleep!
0fa0: 20 35 29 0a 20 20 20 20 20 20 20 20 20 28 6c 6f 5). (lo
0fb0: 63 6b 2d 71 75 65 75 65 3a 64 65 6c 65 74 65 2d ck-queue:delete-
0fc0: 6c 6f 63 6b 2d 64 62 20 64 62 64 61 74 29 0a 09 lock-db dbdat)..
0fd0: 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 61 6e 79 (lock-queue:any
0fe0: 2d 79 6f 75 6e 67 65 72 3f 20 64 62 64 61 74 20 -younger? dbdat
0ff0: 6d 79 73 74 61 72 74 20 74 65 73 74 2d 69 64 20 mystart test-id
1000: 72 65 6d 74 72 69 65 73 3a 20 28 2d 20 72 65 6d remtries: (- rem
1010: 74 72 69 65 73 20 31 29 29 29 0a 20 20 20 20 20 tries 1))).
1020: 20 20 28 62 65 67 69 6e 0a 09 20 28 64 65 62 75 (begin.. (debu
1030: 67 3a 70 72 69 6e 74 2d 65 72 72 6f 72 20 30 20 g:print-error 0
1040: 2a 64 65 66 61 75 6c 74 2d 6c 6f 67 2d 70 6f 72 *default-log-por
1050: 74 2a 20 22 20 46 61 69 6c 65 64 20 74 6f 20 66 t* " Failed to f
1060: 69 6e 64 20 79 6f 75 6e 67 65 72 20 6c 6f 63 6b ind younger lock
1070: 73 20 66 6f 72 20 74 65 73 74 20 77 69 74 68 20 s for test with
1080: 69 64 20 22 20 74 65 73 74 2d 69 64 20 22 2c 20 id " test-id ",
1090: 65 72 72 6f 72 3a 20 22 20 28 28 63 6f 6e 64 69 error: " ((condi
10a0: 74 69 6f 6e 2d 70 72 6f 70 65 72 74 79 2d 61 63 tion-property-ac
10b0: 63 65 73 73 6f 72 20 27 65 78 6e 20 27 6d 65 73 cessor 'exn 'mes
10c0: 73 61 67 65 29 20 65 78 6e 29 20 22 2c 20 67 69 sage) exn) ", gi
10d0: 76 69 6e 67 20 75 70 2e 22 29 0a 09 20 23 66 29 ving up.").. #f)
10e0: 29 0a 20 20 20 28 6c 65 74 20 28 28 72 65 73 20 ). (let ((res
10f0: 23 66 29 29 0a 20 20 20 20 20 28 64 62 69 3a 66 #f)). (dbi:f
1100: 6f 72 2d 65 61 63 68 2d 72 6f 77 0a 20 20 20 20 or-each-row.
1110: 20 20 28 6c 61 6d 62 64 61 20 28 74 69 64 29 0a (lambda (tid).
1120: 09 3b 3b 20 41 63 74 75 61 6c 6c 79 20 74 68 69 .;; Actually thi
1130: 73 20 73 68 6f 75 6c 64 20 6e 6f 74 20 62 65 20 s should not be
1140: 6e 65 65 64 65 64 20 61 73 20 6d 79 73 74 61 72 needed as mystar
1150: 74 20 63 61 6e 6e 6f 74 20 62 65 20 73 69 6d 75 t cannot be simu
1160: 6c 74 61 6e 65 6f 75 73 6c 79 20 6c 65 73 73 20 ltaneously less
1170: 74 68 61 6e 20 61 6e 64 20 74 65 73 74 2d 69 64 than and test-id
1180: 20 73 61 6d 65 20 61 73 20 0a 09 28 69 66 20 28 same as ..(if (
1190: 6e 6f 74 20 28 65 71 75 61 6c 3f 20 74 69 64 20 not (equal? tid
11a0: 74 65 73 74 2d 69 64 29 29 20 0a 09 20 20 20 20 test-id)) ..
11b0: 28 73 65 74 21 20 72 65 73 20 74 69 64 29 29 29 (set! res tid)))
11c0: 0a 20 20 20 20 20 20 28 6c 6f 63 6b 2d 71 75 65 . (lock-que
11d0: 75 65 3a 64 62 2d 64 61 74 2d 67 65 74 2d 64 62 ue:db-dat-get-db
11e0: 20 64 62 64 61 74 29 0a 20 20 20 20 20 20 22 53 dbdat). "S
11f0: 45 4c 45 43 54 20 74 65 73 74 5f 69 64 20 46 52 ELECT test_id FR
1200: 4f 4d 20 71 75 65 75 65 20 57 48 45 52 45 20 73 OM queue WHERE s
1210: 74 61 72 74 5f 74 69 6d 65 20 3e 20 3f 3b 22 20 tart_time > ?;"
1220: 6d 79 73 74 61 72 74 29 0a 20 20 20 20 20 72 65 mystart). re
1230: 73 29 29 29 0a 0a 28 64 65 66 69 6e 65 20 28 6c s)))..(define (l
1240: 6f 63 6b 2d 71 75 65 75 65 3a 67 65 74 2d 6c 6f ock-queue:get-lo
1250: 63 6b 20 64 62 64 61 74 20 74 65 73 74 2d 69 64 ck dbdat test-id
1260: 20 23 21 6b 65 79 20 28 63 6f 75 6e 74 20 31 30 #!key (count 10
1270: 29 28 77 61 69 74 69 6e 67 2d 6d 73 67 20 23 66 )(waiting-msg #f
1280: 29 29 0a 20 20 28 74 61 73 6b 73 3a 77 61 69 74 )). (tasks:wait
1290: 2d 6f 6e 2d 6a 6f 75 72 6e 61 6c 20 28 6c 6f 63 -on-journal (loc
12a0: 6b 2d 71 75 65 75 65 3a 64 62 2d 64 61 74 2d 67 k-queue:db-dat-g
12b0: 65 74 2d 70 61 74 68 20 64 62 64 61 74 29 20 31 et-path dbdat) 1
12c0: 32 30 30 20 72 65 6d 6f 76 65 3a 20 23 74 20 77 200 remove: #t w
12d0: 61 69 74 69 6e 67 2d 6d 73 67 3a 20 22 6c 6f 63 aiting-msg: "loc
12e0: 6b 2d 71 75 65 75 65 3a 67 65 74 2d 6c 6f 63 6b k-queue:get-lock
12f0: 2c 20 77 61 69 74 69 6e 67 20 6f 6e 20 6a 6f 75 , waiting on jou
1300: 72 6e 61 6c 22 29 0a 20 20 28 6c 65 74 2a 20 28 rnal"). (let* (
1310: 28 72 65 73 20 20 20 20 20 20 20 23 66 29 0a 09 (res #f)..
1320: 20 28 64 62 20 20 20 20 20 20 20 20 28 6c 6f 63 (db (loc
1330: 6b 2d 71 75 65 75 65 3a 64 62 2d 64 61 74 2d 67 k-queue:db-dat-g
1340: 65 74 2d 64 62 20 64 62 64 61 74 29 29 0a 09 20 et-db dbdat))..
1350: 28 6c 63 6b 71 72 79 20 20 20 20 28 73 71 6c 69 (lckqry (sqli
1360: 74 65 33 3a 70 72 65 70 61 72 65 20 64 62 20 22 te3:prepare db "
1370: 53 45 4c 45 43 54 20 74 65 73 74 5f 69 64 2c 72 SELECT test_id,r
1380: 75 6e 5f 6c 6f 63 6b 20 46 52 4f 4d 20 72 75 6e un_lock FROM run
1390: 6c 6f 63 6b 73 20 57 48 45 52 45 20 72 75 6e 5f locks WHERE run_
13a0: 6c 6f 63 6b 3d 27 6c 6f 63 6b 65 64 27 3b 22 29 lock='locked';")
13b0: 29 0a 09 20 28 6d 6b 6c 63 6b 71 72 79 20 20 28 ).. (mklckqry (
13c0: 73 71 6c 69 74 65 33 3a 70 72 65 70 61 72 65 20 sqlite3:prepare
13d0: 64 62 20 22 49 4e 53 45 52 54 20 49 4e 54 4f 20 db "INSERT INTO
13e0: 72 75 6e 6c 6f 63 6b 73 20 28 74 65 73 74 5f 69 runlocks (test_i
13f0: 64 2c 72 75 6e 5f 6c 6f 63 6b 29 20 56 41 4c 55 d,run_lock) VALU
1400: 45 53 20 28 3f 2c 27 6c 6f 63 6b 65 64 27 29 3b ES (?,'locked');
1410: 22 29 29 29 0a 20 20 20 20 28 6c 65 74 20 28 28 "))). (let ((
1420: 72 65 73 75 6c 74 20 0a 09 20 20 20 28 68 61 6e result .. (han
1430: 64 6c 65 2d 65 78 63 65 70 74 69 6f 6e 73 0a 09 dle-exceptions..
1440: 20 20 20 20 65 78 6e 0a 09 20 20 20 20 28 62 65 exn.. (be
1450: 67 69 6e 0a 09 20 20 20 20 20 20 28 64 65 62 75 gin.. (debu
1460: 67 3a 70 72 69 6e 74 20 30 20 2a 64 65 66 61 75 g:print 0 *defau
1470: 6c 74 2d 6c 6f 67 2d 70 6f 72 74 2a 20 22 57 41 lt-log-port* "WA
1480: 52 4e 49 4e 47 3a 20 66 61 69 6c 65 64 20 74 6f RNING: failed to
1490: 20 67 65 74 20 71 75 65 75 65 20 6c 6f 63 6b 2e get queue lock.
14a0: 20 52 65 6d 6f 76 69 6e 67 20 6c 6f 63 6b 20 64 Removing lock d
14b0: 62 20 61 6e 64 20 72 65 74 75 72 6e 69 6e 67 20 b and returning
14c0: 66 61 69 6c 22 29 20 3b 3b 20 57 69 6c 6c 20 74 fail") ;; Will t
14d0: 72 79 20 61 67 61 69 6e 20 69 6e 20 61 20 66 65 ry again in a fe
14e0: 77 20 73 65 63 6f 6e 64 73 22 29 0a 09 20 20 20 w seconds")..
14f0: 20 20 20 28 64 65 62 75 67 3a 70 72 69 6e 74 20 (debug:print
1500: 30 20 2a 64 65 66 61 75 6c 74 2d 6c 6f 67 2d 70 0 *default-log-p
1510: 6f 72 74 2a 20 22 20 6d 65 73 73 61 67 65 3a 20 ort* " message:
1520: 22 20 28 28 63 6f 6e 64 69 74 69 6f 6e 2d 70 72 " ((condition-pr
1530: 6f 70 65 72 74 79 2d 61 63 63 65 73 73 6f 72 20 operty-accessor
1540: 27 65 78 6e 20 27 6d 65 73 73 61 67 65 29 20 65 'exn 'message) e
1550: 78 6e 29 29 0a 09 20 20 20 20 20 20 28 74 68 72 xn)).. (thr
1560: 65 61 64 2d 73 6c 65 65 70 21 20 31 30 29 0a 09 ead-sleep! 10)..
1570: 20 20 20 20 20 20 3b 3b 20 28 69 66 20 28 3e 20 ;; (if (>
1580: 63 6f 75 6e 74 20 30 29 09 0a 09 20 20 20 20 20 count 0)...
1590: 20 3b 3b 20 20 23 66 20 3b 3b 20 28 6c 6f 63 6b ;; #f ;; (lock
15a0: 2d 71 75 65 75 65 3a 67 65 74 2d 6c 6f 63 6b 20 -queue:get-lock
15b0: 64 62 64 61 74 20 74 65 73 74 2d 69 64 20 63 6f dbdat test-id co
15c0: 75 6e 74 3a 20 28 2d 20 63 6f 75 6e 74 20 31 29 unt: (- count 1)
15d0: 29 20 2d 20 67 69 76 65 20 75 70 20 6f 6e 20 72 ) - give up on r
15e0: 65 74 72 69 65 73 20 0a 09 20 20 20 20 20 20 3b etries .. ;
15f0: 3b 20 28 62 65 67 69 6e 20 3b 3b 20 6e 65 76 65 ; (begin ;; neve
1600: 72 20 72 65 63 6f 76 65 72 65 64 2c 20 72 65 6d r recovered, rem
1610: 6f 74 65 20 74 68 65 20 6c 6f 63 6b 20 66 69 6c ote the lock fil
1620: 65 20 61 6e 64 20 72 65 74 75 72 6e 20 23 66 2c e and return #f,
1630: 20 6e 6f 20 6c 6f 63 6b 20 6f 62 74 61 69 6e 65 no lock obtaine
1640: 64 0a 09 20 20 20 20 20 20 28 6c 6f 63 6b 2d 71 d.. (lock-q
1650: 75 65 75 65 3a 64 65 6c 65 74 65 2d 6c 6f 63 6b ueue:delete-lock
1660: 2d 64 62 20 64 62 64 61 74 29 0a 09 20 20 20 20 -db dbdat)..
1670: 20 20 23 66 29 0a 09 20 20 20 20 28 64 62 69 3a #f).. (dbi:
1680: 77 69 74 68 2d 74 72 61 6e 73 61 63 74 69 6f 6e with-transaction
1690: 0a 09 20 20 20 20 20 64 62 0a 09 20 20 20 20 20 .. db..
16a0: 28 6c 61 6d 62 64 61 20 28 29 0a 09 20 20 20 20 (lambda ()..
16b0: 20 20 20 28 64 62 69 3a 66 6f 72 2d 65 61 63 68 (dbi:for-each
16c0: 2d 72 6f 77 20 28 6c 61 6d 62 64 61 20 28 74 69 -row (lambda (ti
16d0: 64 20 6c 6f 63 6b 73 74 61 74 65 29 0a 09 09 09 d lockstate)....
16e0: 09 20 20 20 20 20 20 20 28 73 65 74 21 20 72 65 . (set! re
16f0: 73 20 28 6c 69 73 74 20 74 69 64 20 6c 6f 63 6b s (list tid lock
1700: 73 74 61 74 65 29 29 29 0a 09 09 09 09 20 20 20 state))).....
1710: 20 20 6c 63 6b 71 72 79 29 0a 09 20 20 20 20 20 lckqry)..
1720: 20 20 28 69 66 20 72 65 73 0a 09 09 20 20 20 28 (if res... (
1730: 69 66 20 28 65 71 75 61 6c 3f 20 28 63 61 72 20 if (equal? (car
1740: 72 65 73 29 20 74 65 73 74 2d 69 64 29 0a 09 09 res) test-id)...
1750: 20 20 20 20 20 20 20 23 74 20 3b 3b 20 61 6c 72 #t ;; alr
1760: 65 61 64 79 20 68 61 76 65 20 74 68 65 20 6c 6f eady have the lo
1770: 63 6b 0a 09 09 20 20 20 20 20 20 20 23 66 29 0a ck... #f).
1780: 09 09 20 20 20 28 62 65 67 69 6e 0a 09 09 20 20 .. (begin...
1790: 20 20 20 28 64 62 69 3a 65 78 65 63 20 6d 6b 6c (dbi:exec mkl
17a0: 63 6b 71 72 79 20 74 65 73 74 2d 69 64 29 0a 09 ckqry test-id)..
17b0: 09 20 20 20 20 20 3b 3b 20 69 66 20 6e 6f 20 65 . ;; if no e
17c0: 72 72 6f 72 20 68 61 6e 64 6c 65 64 20 74 68 65 rror handled the
17d0: 6e 20 72 65 74 75 72 6e 20 23 74 20 66 6f 72 20 n return #t for
17e0: 67 6f 74 20 74 68 65 20 6c 6f 63 6b 0a 09 09 20 got the lock...
17f0: 20 20 20 20 23 74 29 29 29 29 29 29 29 0a 20 20 #t))))))).
1800: 20 20 20 20 28 64 62 69 3a 63 6c 6f 73 65 20 6c (dbi:close l
1810: 63 6b 71 72 79 29 0a 20 20 20 20 20 20 28 64 62 ckqry). (db
1820: 69 3a 63 6c 6f 73 65 20 6d 6b 6c 63 6b 71 72 79 i:close mklckqry
1830: 29 0a 20 20 20 20 20 20 72 65 73 75 6c 74 29 29 ). result))
1840: 29 0a 0a 28 64 65 66 69 6e 65 20 28 6c 6f 63 6b )..(define (lock
1850: 2d 71 75 65 75 65 3a 72 65 6c 65 61 73 65 2d 6c -queue:release-l
1860: 6f 63 6b 20 66 6e 61 6d 65 20 74 65 73 74 2d 69 ock fname test-i
1870: 64 20 23 21 6b 65 79 20 28 63 6f 75 6e 74 20 31 d #!key (count 1
1880: 30 29 29 0a 20 20 28 6c 65 74 2a 20 28 28 64 62 0)). (let* ((db
1890: 64 61 74 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a dat (lock-queue:
18a0: 6f 70 65 6e 2d 64 62 20 66 6e 61 6d 65 29 29 29 open-db fname)))
18b0: 0a 20 20 20 20 28 74 61 73 6b 73 3a 77 61 69 74 . (tasks:wait
18c0: 2d 6f 6e 2d 6a 6f 75 72 6e 61 6c 20 28 6c 6f 63 -on-journal (loc
18d0: 6b 2d 71 75 65 75 65 3a 64 62 2d 64 61 74 2d 67 k-queue:db-dat-g
18e0: 65 74 2d 70 61 74 68 20 64 62 64 61 74 29 20 31 et-path dbdat) 1
18f0: 32 30 30 20 22 6c 6f 63 6b 2d 71 75 65 75 65 3a 200 "lock-queue:
1900: 72 65 6c 65 61 73 65 2d 6c 6f 63 6b 3b 20 77 61 release-lock; wa
1910: 69 74 69 6e 67 20 6f 6e 20 6a 6f 75 72 6e 61 6c iting on journal
1920: 22 29 0a 20 20 20 20 28 68 61 6e 64 6c 65 2d 65 "). (handle-e
1930: 78 63 65 70 74 69 6f 6e 73 0a 20 20 20 20 20 65 xceptions. e
1940: 78 6e 0a 20 20 20 20 20 28 62 65 67 69 6e 0a 20 xn. (begin.
1950: 20 20 20 20 20 20 28 64 65 62 75 67 3a 70 72 69 (debug:pri
1960: 6e 74 20 30 20 2a 64 65 66 61 75 6c 74 2d 6c 6f nt 0 *default-lo
1970: 67 2d 70 6f 72 74 2a 20 22 57 41 52 4e 49 4e 47 g-port* "WARNING
1980: 3a 20 46 61 69 6c 65 64 20 74 6f 20 72 65 6c 65 : Failed to rele
1990: 61 73 65 20 71 75 65 75 65 20 6c 6f 63 6b 2e 20 ase queue lock.
19a0: 57 69 6c 6c 20 74 72 79 20 61 67 61 69 6e 20 69 Will try again i
19b0: 6e 20 66 65 77 20 73 65 63 6f 6e 64 73 22 29 0a n few seconds").
19c0: 20 20 20 20 20 20 20 28 64 65 62 75 67 3a 70 72 (debug:pr
19d0: 69 6e 74 20 30 20 2a 64 65 66 61 75 6c 74 2d 6c int 0 *default-l
19e0: 6f 67 2d 70 6f 72 74 2a 20 22 20 6d 65 73 73 61 og-port* " messa
19f0: 67 65 3a 20 22 20 28 28 63 6f 6e 64 69 74 69 6f ge: " ((conditio
1a00: 6e 2d 70 72 6f 70 65 72 74 79 2d 61 63 63 65 73 n-property-acces
1a10: 73 6f 72 20 27 65 78 6e 20 27 6d 65 73 73 61 67 sor 'exn 'messag
1a20: 65 29 20 65 78 6e 29 29 0a 20 20 20 20 20 20 20 e) exn)).
1a30: 28 74 68 72 65 61 64 2d 73 6c 65 65 70 21 20 28 (thread-sleep! (
1a40: 2f 20 63 6f 75 6e 74 20 31 30 29 29 0a 20 20 20 / count 10)).
1a50: 20 20 20 20 28 69 66 20 28 3e 20 63 6f 75 6e 74 (if (> count
1a60: 20 30 29 0a 09 20 20 20 28 62 65 67 69 6e 0a 09 0).. (begin..
1a70: 20 20 20 20 20 28 64 62 69 3a 63 6c 6f 73 65 20 (dbi:close
1a80: 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 64 62 2d 64 (lock-queue:db-d
1a90: 61 74 2d 67 65 74 2d 64 62 20 64 62 64 61 74 29 at-get-db dbdat)
1aa0: 29 0a 09 20 20 20 20 20 28 6c 6f 63 6b 2d 71 75 ).. (lock-qu
1ab0: 65 75 65 3a 72 65 6c 65 61 73 65 2d 6c 6f 63 6b eue:release-lock
1ac0: 20 66 6e 61 6d 65 20 74 65 73 74 2d 69 64 20 63 fname test-id c
1ad0: 6f 75 6e 74 3a 20 28 2d 20 63 6f 75 6e 74 20 31 ount: (- count 1
1ae0: 29 29 29 0a 09 20 20 20 28 6c 65 74 20 28 28 6a ))).. (let ((j
1af0: 6f 75 72 6e 61 6c 20 28 63 6f 6e 63 20 66 6e 61 ournal (conc fna
1b00: 6d 65 20 22 2d 6a 6f 75 72 6e 61 6c 22 29 29 29 me "-journal")))
1b10: 0a 09 20 20 20 20 20 3b 3b 20 49 66 20 77 65 27 .. ;; If we'
1b20: 76 65 20 74 72 69 65 64 20 74 65 6e 20 74 69 6d ve tried ten tim
1b30: 65 73 20 61 6e 64 20 66 61 69 6c 65 64 20 74 68 es and failed th
1b40: 65 72 65 20 69 73 20 61 20 73 65 72 69 6f 75 73 ere is a serious
1b50: 20 70 72 6f 62 6c 65 6d 0a 09 20 20 20 20 20 3b problem.. ;
1b60: 3b 20 74 72 79 20 74 6f 20 72 65 6d 6f 76 65 20 ; try to remove
1b70: 74 68 65 20 6c 6f 63 6b 20 64 62 20 61 6e 64 20 the lock db and
1b80: 61 6c 6c 6f 77 20 69 74 20 74 6f 20 62 65 20 72 allow it to be r
1b90: 65 63 72 65 61 74 65 64 0a 09 20 20 20 20 20 28 ecreated.. (
1ba0: 68 61 6e 64 6c 65 2d 65 78 63 65 70 74 69 6f 6e handle-exception
1bb0: 73 0a 09 20 20 20 20 20 20 65 78 6e 0a 09 20 20 s.. exn..
1bc0: 20 20 20 20 23 66 0a 09 20 20 20 20 20 20 28 69 #f.. (i
1bd0: 66 20 28 66 69 6c 65 2d 65 78 69 73 74 73 3f 20 f (file-exists?
1be0: 6a 6f 75 72 6e 61 6c 29 28 64 65 6c 65 74 65 2d journal)(delete-
1bf0: 66 69 6c 65 20 6a 6f 75 72 6e 61 6c 29 29 0a 09 file journal))..
1c00: 20 20 20 20 20 20 28 69 66 20 28 66 69 6c 65 2d (if (file-
1c10: 65 78 69 73 74 73 3f 20 66 6e 61 6d 65 29 20 20 exists? fname)
1c20: 28 64 65 6c 65 74 65 2d 66 69 6c 65 20 66 6e 61 (delete-file fna
1c30: 6d 65 29 29 0a 09 20 20 20 20 20 20 23 66 29 29 me)).. #f))
1c40: 29 29 0a 20 20 20 20 20 28 64 62 69 3a 65 78 65 )). (dbi:exe
1c50: 63 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 64 62 c (lock-queue:db
1c60: 2d 64 61 74 2d 67 65 74 2d 64 62 20 64 62 64 61 -dat-get-db dbda
1c70: 74 29 20 22 44 45 4c 45 54 45 20 46 52 4f 4d 20 t) "DELETE FROM
1c80: 72 75 6e 6c 6f 63 6b 73 20 57 48 45 52 45 20 74 runlocks WHERE t
1c90: 65 73 74 5f 69 64 3d 3f 3b 22 20 74 65 73 74 2d est_id=?;" test-
1ca0: 69 64 29 0a 20 20 20 20 20 28 64 62 69 3a 63 6c id). (dbi:cl
1cb0: 6f 73 65 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a ose (lock-queue:
1cc0: 64 62 2d 64 61 74 2d 67 65 74 2d 64 62 20 64 62 db-dat-get-db db
1cd0: 64 61 74 29 29 29 29 29 0a 0a 28 64 65 66 69 6e dat)))))..(defin
1ce0: 65 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 73 74 e (lock-queue:st
1cf0: 65 61 6c 2d 6c 6f 63 6b 20 64 62 64 61 74 20 74 eal-lock dbdat t
1d00: 65 73 74 2d 69 64 20 23 21 6b 65 79 20 28 63 6f est-id #!key (co
1d10: 75 6e 74 20 31 30 29 29 0a 20 20 28 64 65 62 75 unt 10)). (debu
1d20: 67 3a 70 72 69 6e 74 2d 69 6e 66 6f 20 30 20 2a g:print-info 0 *
1d30: 64 65 66 61 75 6c 74 2d 6c 6f 67 2d 70 6f 72 74 default-log-port
1d40: 2a 20 22 41 74 74 65 6d 70 74 69 6e 67 20 74 6f * "Attempting to
1d50: 20 73 74 65 61 6c 20 6c 6f 63 6b 20 61 74 20 22 steal lock at "
1d60: 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 64 62 2d (lock-queue:db-
1d70: 64 61 74 2d 67 65 74 2d 70 61 74 68 20 64 62 64 dat-get-path dbd
1d80: 61 74 29 29 0a 20 20 28 74 61 73 6b 73 3a 77 61 at)). (tasks:wa
1d90: 69 74 2d 6f 6e 2d 6a 6f 75 72 6e 61 6c 20 28 6c it-on-journal (l
1da0: 6f 63 6b 2d 71 75 65 75 65 3a 64 62 2d 64 61 74 ock-queue:db-dat
1db0: 2d 67 65 74 2d 70 61 74 68 20 64 62 64 61 74 29 -get-path dbdat)
1dc0: 20 31 32 30 30 20 22 6c 6f 63 6b 2d 71 75 65 75 1200 "lock-queu
1dd0: 65 3a 73 74 65 61 6c 2d 6c 6f 63 6b 3b 20 77 61 e:steal-lock; wa
1de0: 69 74 69 6e 67 20 6f 6e 20 6a 6f 75 72 6e 61 6c iting on journal
1df0: 22 29 0a 20 20 28 68 61 6e 64 6c 65 2d 65 78 63 "). (handle-exc
1e00: 65 70 74 69 6f 6e 73 0a 20 20 20 65 78 6e 0a 20 eptions. exn.
1e10: 20 20 28 62 65 67 69 6e 0a 20 20 20 20 20 28 64 (begin. (d
1e20: 65 62 75 67 3a 70 72 69 6e 74 20 30 20 2a 64 65 ebug:print 0 *de
1e30: 66 61 75 6c 74 2d 6c 6f 67 2d 70 6f 72 74 2a 20 fault-log-port*
1e40: 22 57 41 52 4e 49 4e 47 3a 20 46 61 69 6c 65 64 "WARNING: Failed
1e50: 20 74 6f 20 73 74 65 61 6c 20 71 75 65 75 65 20 to steal queue
1e60: 6c 6f 63 6b 2e 20 57 69 6c 6c 20 74 72 79 20 61 lock. Will try a
1e70: 67 61 69 6e 20 69 6e 20 66 65 77 20 73 65 63 6f gain in few seco
1e80: 6e 64 73 22 29 0a 20 20 20 20 20 28 64 65 62 75 nds"). (debu
1e90: 67 3a 70 72 69 6e 74 20 30 20 2a 64 65 66 61 75 g:print 0 *defau
1ea0: 6c 74 2d 6c 6f 67 2d 70 6f 72 74 2a 20 22 20 6d lt-log-port* " m
1eb0: 65 73 73 61 67 65 3a 20 22 20 28 28 63 6f 6e 64 essage: " ((cond
1ec0: 69 74 69 6f 6e 2d 70 72 6f 70 65 72 74 79 2d 61 ition-property-a
1ed0: 63 63 65 73 73 6f 72 20 27 65 78 6e 20 27 6d 65 ccessor 'exn 'me
1ee0: 73 73 61 67 65 29 20 65 78 6e 29 29 0a 20 20 20 ssage) exn)).
1ef0: 20 20 28 74 68 72 65 61 64 2d 73 6c 65 65 70 21 (thread-sleep!
1f00: 20 31 30 29 0a 20 20 20 20 20 28 69 66 20 28 3e 10). (if (>
1f10: 20 63 6f 75 6e 74 20 30 29 0a 09 20 28 6c 6f 63 count 0).. (loc
1f20: 6b 2d 71 75 65 75 65 3a 73 74 65 61 6c 2d 6c 6f k-queue:steal-lo
1f30: 63 6b 20 64 62 64 61 74 20 74 65 73 74 2d 69 64 ck dbdat test-id
1f40: 20 63 6f 75 6e 74 3a 20 28 2d 20 63 6f 75 6e 74 count: (- count
1f50: 20 31 29 29 0a 09 20 23 66 29 29 0a 20 20 20 28 1)).. #f)). (
1f60: 64 62 69 3a 65 78 65 63 20 28 6c 6f 63 6b 2d 71 dbi:exec (lock-q
1f70: 75 65 75 65 3a 64 62 2d 64 61 74 2d 67 65 74 2d ueue:db-dat-get-
1f80: 64 62 20 64 62 64 61 74 29 20 22 44 45 4c 45 54 db dbdat) "DELET
1f90: 45 20 46 52 4f 4d 20 72 75 6e 6c 6f 63 6b 73 20 E FROM runlocks
1fa0: 57 48 45 52 45 20 72 75 6e 5f 6c 6f 63 6b 3d 27 WHERE run_lock='
1fb0: 6c 6f 63 6b 65 64 27 3b 22 29 29 0a 20 20 28 6c locked';")). (l
1fc0: 6f 63 6b 2d 71 75 65 75 65 3a 67 65 74 2d 6c 6f ock-queue:get-lo
1fd0: 63 6b 20 64 62 64 61 74 20 74 65 73 74 2d 69 74 ck dbdat test-it
1fe0: 29 29 0a 0a 3b 3b 20 72 65 74 75 72 6e 73 20 23 ))..;; returns #
1ff0: 66 20 69 66 20 6f 6b 20 74 6f 20 73 6b 69 70 20 f if ok to skip
2000: 74 68 65 20 74 61 73 6b 0a 3b 3b 20 72 65 74 75 the task.;; retu
2010: 72 6e 73 20 23 74 20 69 66 20 6f 6b 20 74 6f 20 rns #t if ok to
2020: 70 72 6f 63 65 65 64 20 77 69 74 68 20 74 61 73 proceed with tas
2030: 6b 0a 3b 3b 20 6f 74 68 65 72 77 69 73 65 20 77 k.;; otherwise w
2040: 61 69 74 73 0a 3b 3b 0a 28 64 65 66 69 6e 65 20 aits.;;.(define
2050: 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 77 61 69 74 (lock-queue:wait
2060: 2d 74 75 72 6e 20 66 6e 61 6d 65 20 74 65 73 74 -turn fname test
2070: 2d 69 64 20 23 21 6b 65 79 20 28 63 6f 75 6e 74 -id #!key (count
2080: 20 31 30 29 28 77 61 69 74 69 6e 67 2d 6d 73 67 10)(waiting-msg
2090: 20 23 66 29 29 0a 20 20 28 6c 65 74 2a 20 28 28 #f)). (let* ((
20a0: 64 62 64 61 74 20 20 20 28 6c 6f 63 6b 2d 71 75 dbdat (lock-qu
20b0: 65 75 65 3a 6f 70 65 6e 2d 64 62 20 66 6e 61 6d eue:open-db fnam
20c0: 65 29 29 0a 09 20 28 6d 79 73 74 61 72 74 20 28 e)).. (mystart (
20d0: 63 75 72 72 65 6e 74 2d 73 65 63 6f 6e 64 73 29 current-seconds)
20e0: 29 0a 09 20 28 64 62 20 20 20 20 20 20 28 6c 6f ).. (db (lo
20f0: 63 6b 2d 71 75 65 75 65 3a 64 62 2d 64 61 74 2d ck-queue:db-dat-
2100: 67 65 74 2d 64 62 20 64 62 64 61 74 29 29 29 0a get-db dbdat))).
2110: 20 20 20 20 3b 3b 20 28 74 61 73 6b 73 3a 77 61 ;; (tasks:wa
2120: 69 74 2d 6f 6e 2d 6a 6f 75 72 6e 61 6c 20 28 6c it-on-journal (l
2130: 6f 63 6b 2d 71 75 65 75 65 3a 64 62 2d 64 61 74 ock-queue:db-dat
2140: 2d 67 65 74 2d 70 61 74 68 20 64 62 64 61 74 29 -get-path dbdat)
2150: 20 31 32 30 30 20 77 61 69 74 69 6e 67 2d 6d 73 1200 waiting-ms
2160: 67 3a 20 22 6c 6f 63 6b 2d 71 75 65 75 65 3a 77 g: "lock-queue:w
2170: 61 69 74 2d 74 75 72 6e 3b 20 77 61 69 74 69 6e ait-turn; waitin
2180: 67 20 6f 6e 20 6a 6f 75 72 6e 61 6c 20 66 69 6c g on journal fil
2190: 65 22 29 0a 20 20 20 20 28 68 61 6e 64 6c 65 2d e"). (handle-
21a0: 65 78 63 65 70 74 69 6f 6e 73 0a 20 20 20 20 20 exceptions.
21b0: 65 78 6e 0a 20 20 20 20 20 28 62 65 67 69 6e 0a exn. (begin.
21c0: 20 20 20 20 20 20 20 28 64 65 62 75 67 3a 70 72 (debug:pr
21d0: 69 6e 74 20 30 20 2a 64 65 66 61 75 6c 74 2d 6c int 0 *default-l
21e0: 6f 67 2d 70 6f 72 74 2a 20 22 57 41 52 4e 49 4e og-port* "WARNIN
21f0: 47 3a 20 46 61 69 6c 65 64 20 74 6f 20 66 69 6e G: Failed to fin
2200: 64 20 6f 75 74 20 69 66 20 69 74 20 69 73 20 6f d out if it is o
2210: 6b 20 74 6f 20 73 6b 69 70 20 74 68 65 20 77 61 k to skip the wa
2220: 69 74 20 71 75 65 75 65 2e 20 57 69 6c 6c 20 74 it queue. Will t
2230: 72 79 20 61 67 61 69 6e 20 69 6e 20 66 65 77 20 ry again in few
2240: 73 65 63 6f 6e 64 73 22 29 0a 20 20 20 20 20 20 seconds").
2250: 20 28 64 65 62 75 67 3a 70 72 69 6e 74 20 30 20 (debug:print 0
2260: 2a 64 65 66 61 75 6c 74 2d 6c 6f 67 2d 70 6f 72 *default-log-por
2270: 74 2a 20 22 20 6d 65 73 73 61 67 65 3a 20 22 20 t* " message: "
2280: 28 28 63 6f 6e 64 69 74 69 6f 6e 2d 70 72 6f 70 ((condition-prop
2290: 65 72 74 79 2d 61 63 63 65 73 73 6f 72 20 27 65 erty-accessor 'e
22a0: 78 6e 20 27 6d 65 73 73 61 67 65 29 20 65 78 6e xn 'message) exn
22b0: 29 29 0a 20 20 20 20 20 20 20 28 70 72 69 6e 74 )). (print
22c0: 2d 63 61 6c 6c 2d 63 68 61 69 6e 20 28 63 75 72 -call-chain (cur
22d0: 72 65 6e 74 2d 65 72 72 6f 72 2d 70 6f 72 74 29 rent-error-port)
22e0: 29 0a 20 20 20 20 20 20 20 28 74 68 72 65 61 64 ). (thread
22f0: 2d 73 6c 65 65 70 21 20 31 30 29 0a 20 20 20 20 -sleep! 10).
2300: 20 20 20 28 69 66 20 28 3e 20 63 6f 75 6e 74 20 (if (> count
2310: 30 29 0a 09 20 20 20 28 62 65 67 69 6e 0a 09 20 0).. (begin..
2320: 20 20 20 20 28 64 62 69 3a 63 6c 6f 73 65 20 64 (dbi:close d
2330: 62 29 0a 09 20 20 20 20 20 28 6c 6f 63 6b 2d 71 b).. (lock-q
2340: 75 65 75 65 3a 77 61 69 74 2d 74 75 72 6e 20 66 ueue:wait-turn f
2350: 6e 61 6d 65 20 74 65 73 74 2d 69 64 20 63 6f 75 name test-id cou
2360: 6e 74 3a 20 28 2d 20 63 6f 75 6e 74 20 31 29 29 nt: (- count 1))
2370: 29 0a 09 20 20 20 28 62 65 67 69 6e 0a 09 20 20 ).. (begin..
2380: 20 20 20 28 64 65 62 75 67 3a 70 72 69 6e 74 20 (debug:print
2390: 30 20 2a 64 65 66 61 75 6c 74 2d 6c 6f 67 2d 70 0 *default-log-p
23a0: 6f 72 74 2a 20 22 47 69 76 69 6e 67 20 75 70 20 ort* "Giving up
23b0: 63 61 6c 6c 73 20 74 6f 20 6c 6f 63 6b 2d 71 75 calls to lock-qu
23c0: 65 75 65 3a 77 61 69 74 2d 74 75 72 6e 20 66 6f eue:wait-turn fo
23d0: 72 20 74 65 73 74 2d 69 64 20 22 20 74 65 73 74 r test-id " test
23e0: 2d 69 64 20 22 20 61 74 20 70 61 74 68 20 22 20 -id " at path "
23f0: 66 6e 61 6d 65 20 22 2c 20 70 72 69 6e 74 69 6e fname ", printin
2400: 67 20 63 61 6c 6c 20 63 68 61 69 6e 22 29 0a 09 g call chain")..
2410: 20 20 20 20 20 28 70 72 69 6e 74 2d 63 61 6c 6c (print-call
2420: 2d 63 68 61 69 6e 20 28 63 75 72 72 65 6e 74 2d -chain (current-
2430: 65 72 72 6f 72 2d 70 6f 72 74 29 29 0a 09 20 20 error-port))..
2440: 20 20 20 23 66 29 29 29 0a 20 20 20 20 20 3b 3b #f))). ;;
2450: 20 77 61 69 74 20 31 30 20 73 65 63 6f 6e 64 73 wait 10 seconds
2460: 20 61 6e 64 20 74 68 65 6e 20 63 68 65 63 6b 20 and then check
2470: 74 6f 20 73 65 65 20 69 66 20 73 6f 6d 65 6f 6e to see if someon
2480: 65 20 69 73 20 61 6c 72 65 61 64 79 20 75 70 64 e is already upd
2490: 61 74 69 6e 67 20 74 68 65 20 68 74 6d 6c 0a 20 ating the html.
24a0: 20 20 20 20 28 74 68 72 65 61 64 2d 73 6c 65 65 (thread-slee
24b0: 70 21 20 31 30 29 0a 20 20 20 20 20 28 69 66 20 p! 10). (if
24c0: 28 6e 6f 74 20 28 6c 6f 63 6b 2d 71 75 65 75 65 (not (lock-queue
24d0: 3a 61 6e 79 2d 79 6f 75 6e 67 65 72 3f 20 64 62 :any-younger? db
24e0: 64 61 74 20 6d 79 73 74 61 72 74 20 74 65 73 74 dat mystart test
24f0: 2d 69 64 29 29 20 3b 3b 20 6e 6f 20 70 72 6f 63 -id)) ;; no proc
2500: 65 73 73 69 6e 67 20 69 6e 20 66 6c 69 67 68 74 essing in flight
2510: 2c 20 6d 75 73 74 20 74 72 79 20 74 6f 20 73 74 , must try to st
2520: 61 72 74 20 70 72 6f 63 65 73 73 69 6e 67 0a 09 art processing..
2530: 20 28 62 65 67 69 6e 0a 09 20 20 20 28 74 61 73 (begin.. (tas
2540: 6b 73 3a 77 61 69 74 2d 6f 6e 2d 6a 6f 75 72 6e ks:wait-on-journ
2550: 61 6c 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 64 al (lock-queue:d
2560: 62 2d 64 61 74 2d 67 65 74 2d 70 61 74 68 20 64 b-dat-get-path d
2570: 62 64 61 74 29 20 31 32 30 30 20 77 61 69 74 69 bdat) 1200 waiti
2580: 6e 67 2d 6d 73 67 3a 20 22 6c 6f 63 6b 2d 71 75 ng-msg: "lock-qu
2590: 65 75 65 3a 77 61 69 74 2d 74 75 72 6e 3b 20 77 eue:wait-turn; w
25a0: 61 69 74 69 6e 67 20 6f 6e 20 6a 6f 75 72 6e 61 aiting on journa
25b0: 6c 20 66 69 6c 65 22 29 0a 09 20 20 20 28 64 62 l file").. (db
25c0: 69 3a 65 78 65 63 0a 09 20 20 20 20 64 62 0a 09 i:exec.. db..
25d0: 20 20 20 20 22 49 4e 53 45 52 54 20 4f 52 20 52 "INSERT OR R
25e0: 45 50 4c 41 43 45 20 49 4e 54 4f 20 71 75 65 75 EPLACE INTO queu
25f0: 65 20 28 74 65 73 74 5f 69 64 2c 73 74 61 72 74 e (test_id,start
2600: 5f 74 69 6d 65 2c 73 74 61 74 65 29 20 56 41 4c _time,state) VAL
2610: 55 45 53 20 28 3f 2c 3f 2c 27 77 61 69 74 69 6e UES (?,?,'waitin
2620: 67 27 29 3b 22 0a 09 20 20 20 20 74 65 73 74 2d g');".. test-
2630: 69 64 20 6d 79 73 74 61 72 74 29 0a 09 20 20 20 id mystart)..
2640: 3b 3b 20 28 74 68 72 65 61 64 2d 73 6c 65 65 70 ;; (thread-sleep
2650: 21 20 31 29 20 3b 3b 20 67 69 76 65 20 6f 74 68 ! 1) ;; give oth
2660: 65 72 20 74 65 73 74 73 20 61 20 63 68 61 6e 63 er tests a chanc
2670: 65 20 74 6f 20 72 65 67 69 73 74 65 72 0a 09 20 e to register..
2680: 20 20 28 6c 65 74 20 28 28 72 65 73 75 6c 74 20 (let ((result
2690: 0a 09 09 20 20 28 6c 65 74 20 6c 6f 6f 70 20 28 ... (let loop (
26a0: 28 79 6f 75 6e 67 65 72 2d 77 61 69 74 69 6e 67 (younger-waiting
26b0: 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 61 6e 79 (lock-queue:any
26c0: 2d 79 6f 75 6e 67 65 72 3f 20 64 62 64 61 74 20 -younger? dbdat
26d0: 6d 79 73 74 61 72 74 20 74 65 73 74 2d 69 64 29 mystart test-id)
26e0: 29 29 0a 09 09 20 20 20 20 28 69 66 20 79 6f 75 ))... (if you
26f0: 6e 67 65 72 2d 77 61 69 74 69 6e 67 0a 09 09 09 nger-waiting....
2700: 28 62 65 67 69 6e 0a 09 09 09 20 20 3b 3b 20 6e (begin.... ;; n
2710: 6f 20 6e 65 65 64 20 66 6f 72 20 75 73 20 74 6f o need for us to
2720: 20 77 61 69 74 2e 20 6d 61 72 6b 20 69 6e 20 74 wait. mark in t
2730: 68 65 20 6c 6f 63 6b 20 71 75 65 75 65 20 64 62 he lock queue db
2740: 20 61 73 20 73 6b 69 70 70 69 6e 67 0a 09 09 09 as skipping....
2750: 20 20 3b 3b 20 6e 6f 20 70 6f 69 6e 74 20 69 6e ;; no point in
2760: 20 6d 61 72 6b 69 6e 67 20 61 6e 79 74 68 69 6e marking anythin
2770: 67 20 69 6e 20 74 68 65 20 71 75 65 75 65 20 2d g in the queue -
2780: 20 73 69 6d 70 6c 79 20 6e 65 76 65 72 20 72 65 simply never re
2790: 67 69 73 74 65 72 20 74 68 69 73 0a 09 09 09 20 gister this....
27a0: 20 3b 3b 20 74 65 73 74 20 61 73 20 69 74 20 69 ;; test as it i
27b0: 73 20 2a 63 6f 76 65 72 65 64 2a 20 62 79 20 61 s *covered* by a
27c0: 20 70 72 65 76 69 6f 75 73 6c 79 20 73 74 61 72 previously star
27d0: 74 65 64 20 75 70 64 61 74 65 20 74 6f 20 74 68 ted update to th
27e0: 65 20 68 74 6d 6c 20 66 69 6c 65 0a 09 09 09 20 e html file....
27f0: 20 3b 3b 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a ;; (lock-queue:
2800: 73 65 74 2d 73 74 61 74 65 20 64 62 64 61 74 20 set-state dbdat
2810: 74 65 73 74 2d 69 64 20 22 73 6b 69 70 70 69 6e test-id "skippin
2820: 67 22 29 0a 09 09 09 20 20 23 66 29 20 3b 3b 20 g").... #f) ;;
2830: 6c 65 74 20 74 68 65 20 63 61 6c 6c 69 6e 67 20 let the calling
2840: 70 72 6f 63 65 73 73 20 6b 6e 6f 77 20 74 68 61 process know tha
2850: 74 20 6e 6f 74 68 69 6e 67 20 6e 65 65 64 73 20 t nothing needs
2860: 74 6f 20 62 65 20 64 6f 6e 65 0a 09 09 09 28 69 to be done....(i
2870: 66 20 28 6c 6f 63 6b 2d 71 75 65 75 65 3a 67 65 f (lock-queue:ge
2880: 74 2d 6c 6f 63 6b 20 64 62 64 61 74 20 74 65 73 t-lock dbdat tes
2890: 74 2d 69 64 29 0a 09 09 09 20 20 20 20 23 74 0a t-id).... #t.
28a0: 09 09 09 20 20 20 20 28 69 66 20 28 3e 20 28 2d ... (if (> (-
28b0: 20 28 63 75 72 72 65 6e 74 2d 73 65 63 6f 6e 64 (current-second
28c0: 73 29 20 6d 79 73 74 61 72 74 29 20 33 36 30 30 s) mystart) 3600
28d0: 30 29 20 3b 3b 20 77 61 69 74 65 64 20 74 6f 6f 0) ;; waited too
28e0: 20 6c 6f 6e 67 2c 20 73 74 65 61 6c 20 74 68 65 long, steal the
28f0: 20 6c 6f 63 6b 0a 09 09 09 09 28 6c 6f 63 6b 2d lock.....(lock-
2900: 71 75 65 75 65 3a 73 74 65 61 6c 2d 6c 6f 63 6b queue:steal-lock
2910: 20 64 62 64 61 74 20 74 65 73 74 2d 69 64 29 0a dbdat test-id).
2920: 09 09 09 09 28 62 65 67 69 6e 0a 09 09 09 09 20 ....(begin.....
2930: 20 28 74 68 72 65 61 64 2d 73 6c 65 65 70 21 20 (thread-sleep!
2940: 31 29 0a 09 09 09 09 20 20 28 6c 6f 6f 70 20 28 1)..... (loop (
2950: 6c 6f 63 6b 2d 71 75 65 75 65 3a 61 6e 79 2d 79 lock-queue:any-y
2960: 6f 75 6e 67 65 72 3f 20 64 62 64 61 74 20 6d 79 ounger? dbdat my
2970: 73 74 61 72 74 20 74 65 73 74 2d 69 64 29 29 29 start test-id)))
2980: 29 29 29 29 29 29 0a 09 20 20 20 20 20 28 64 62 )))))).. (db
2990: 69 3a 63 6c 6f 73 65 20 64 62 29 0a 09 20 20 20 i:close db)..
29a0: 20 20 72 65 73 75 6c 74 29 29 29 29 29 29 0a 09 result))))))..
29b0: 20 20 0a 20 20 20 20 20 20 20 20 20 20 20 20 0a . .
29c0: 3b 3b 20 28 75 73 65 20 74 72 61 63 65 29 0a 3b ;; (use trace).;
29d0: 3b 20 28 74 72 61 63 65 20 6c 6f 63 6b 2d 71 75 ; (trace lock-qu
29e0: 65 75 65 3a 67 65 74 2d 6c 6f 63 6b 20 6c 6f 63 eue:get-lock loc
29f0: 6b 2d 71 75 65 75 65 3a 72 65 6c 65 61 73 65 2d k-queue:release-
2a00: 6c 6f 63 6b 20 6c 6f 63 6b 2d 71 75 65 75 65 3a lock lock-queue:
2a10: 77 61 69 74 2d 74 75 72 6e 20 6c 6f 63 6b 2d 71 wait-turn lock-q
2a20: 75 65 75 65 3a 61 6e 79 2d 79 6f 75 6e 67 65 72 ueue:any-younger
2a30: 3f 20 6c 6f 63 6b 2d 71 75 65 75 65 3a 73 65 74 ? lock-queue:set
2a40: 2d 73 74 61 74 65 29 0a -state).