Artifact
43c7c98ef5362228eeb909f207e84fdea2a3ed18:
0000: 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ;;==============
0010: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0020: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0030: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0040: 3d 3d 3d 3d 3d 3d 3d 3d 0a 3b 3b 20 43 6f 70 79 ========.;; Copy
0050: 72 69 67 68 74 20 32 30 31 37 2c 20 4d 61 74 74 right 2017, Matt
0060: 68 65 77 20 57 65 6c 6c 61 6e 64 2e 0a 3b 3b 20 hew Welland..;;
0070: 0a 3b 3b 20 54 68 69 73 20 66 69 6c 65 20 69 73 .;; This file is
0080: 20 70 61 72 74 20 6f 66 20 4d 65 67 61 74 65 73 part of Megates
0090: 74 2e 0a 3b 3b 20 0a 3b 3b 20 20 20 20 20 4d 65 t..;; .;; Me
00a0: 67 61 74 65 73 74 20 69 73 20 66 72 65 65 20 73 gatest is free s
00b0: 6f 66 74 77 61 72 65 3a 20 79 6f 75 20 63 61 6e oftware: you can
00c0: 20 72 65 64 69 73 74 72 69 62 75 74 65 20 69 74 redistribute it
00d0: 20 61 6e 64 2f 6f 72 20 6d 6f 64 69 66 79 0a 3b and/or modify.;
00e0: 3b 20 20 20 20 20 69 74 20 75 6e 64 65 72 20 74 ; it under t
00f0: 68 65 20 74 65 72 6d 73 20 6f 66 20 74 68 65 20 he terms of the
0100: 47 4e 55 20 47 65 6e 65 72 61 6c 20 50 75 62 6c GNU General Publ
0110: 69 63 20 4c 69 63 65 6e 73 65 20 61 73 20 70 75 ic License as pu
0120: 62 6c 69 73 68 65 64 20 62 79 0a 3b 3b 20 20 20 blished by.;;
0130: 20 20 74 68 65 20 46 72 65 65 20 53 6f 66 74 77 the Free Softw
0140: 61 72 65 20 46 6f 75 6e 64 61 74 69 6f 6e 2c 20 are Foundation,
0150: 65 69 74 68 65 72 20 76 65 72 73 69 6f 6e 20 33 either version 3
0160: 20 6f 66 20 74 68 65 20 4c 69 63 65 6e 73 65 2c of the License,
0170: 20 6f 72 0a 3b 3b 20 20 20 20 20 28 61 74 20 79 or.;; (at y
0180: 6f 75 72 20 6f 70 74 69 6f 6e 29 20 61 6e 79 20 our option) any
0190: 6c 61 74 65 72 20 76 65 72 73 69 6f 6e 2e 0a 3b later version..;
01a0: 3b 20 0a 3b 3b 20 20 20 20 20 4d 65 67 61 74 65 ; .;; Megate
01b0: 73 74 20 69 73 20 64 69 73 74 72 69 62 75 74 65 st is distribute
01c0: 64 20 69 6e 20 74 68 65 20 68 6f 70 65 20 74 68 d in the hope th
01d0: 61 74 20 69 74 20 77 69 6c 6c 20 62 65 20 75 73 at it will be us
01e0: 65 66 75 6c 2c 0a 3b 3b 20 20 20 20 20 62 75 74 eful,.;; but
01f0: 20 57 49 54 48 4f 55 54 20 41 4e 59 20 57 41 52 WITHOUT ANY WAR
0200: 52 41 4e 54 59 3b 20 77 69 74 68 6f 75 74 20 65 RANTY; without e
0210: 76 65 6e 20 74 68 65 20 69 6d 70 6c 69 65 64 20 ven the implied
0220: 77 61 72 72 61 6e 74 79 20 6f 66 0a 3b 3b 20 20 warranty of.;;
0230: 20 20 20 4d 45 52 43 48 41 4e 54 41 42 49 4c 49 MERCHANTABILI
0240: 54 59 20 6f 72 20 46 49 54 4e 45 53 53 20 46 4f TY or FITNESS FO
0250: 52 20 41 20 50 41 52 54 49 43 55 4c 41 52 20 50 R A PARTICULAR P
0260: 55 52 50 4f 53 45 2e 20 20 53 65 65 20 74 68 65 URPOSE. See the
0270: 0a 3b 3b 20 20 20 20 20 47 4e 55 20 47 65 6e 65 .;; GNU Gene
0280: 72 61 6c 20 50 75 62 6c 69 63 20 4c 69 63 65 6e ral Public Licen
0290: 73 65 20 66 6f 72 20 6d 6f 72 65 20 64 65 74 61 se for more deta
02a0: 69 6c 73 2e 0a 3b 3b 20 0a 3b 3b 20 20 20 20 20 ils..;; .;;
02b0: 59 6f 75 20 73 68 6f 75 6c 64 20 68 61 76 65 20 You should have
02c0: 72 65 63 65 69 76 65 64 20 61 20 63 6f 70 79 20 received a copy
02d0: 6f 66 20 74 68 65 20 47 4e 55 20 47 65 6e 65 72 of the GNU Gener
02e0: 61 6c 20 50 75 62 6c 69 63 20 4c 69 63 65 6e 73 al Public Licens
02f0: 65 0a 3b 3b 20 20 20 20 20 61 6c 6f 6e 67 20 77 e.;; along w
0300: 69 74 68 20 4d 65 67 61 74 65 73 74 2e 20 20 49 ith Megatest. I
0310: 66 20 6e 6f 74 2c 20 73 65 65 20 3c 68 74 74 70 f not, see <http
0320: 3a 2f 2f 77 77 77 2e 67 6e 75 2e 6f 72 67 2f 6c ://www.gnu.org/l
0330: 69 63 65 6e 73 65 73 2f 3e 2e 0a 0a 3b 3b 3d 3d icenses/>...;;==
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 3d 3d 0a 0a 28 64 65 63 6c 61 72 65 20 28 ====..(declare (
0390: 75 6e 69 74 20 74 63 70 2d 74 72 61 6e 73 70 6f unit tcp-transpo
03a0: 72 74 6d 6f 64 29 29 0a 28 64 65 63 6c 61 72 65 rtmod)).(declare
03b0: 20 28 75 73 65 73 20 64 65 62 75 67 70 72 69 6e (uses debugprin
03c0: 74 29 29 0a 28 64 65 63 6c 61 72 65 20 28 75 73 t)).(declare (us
03d0: 65 73 20 63 6f 6d 6d 6f 6e 6d 6f 64 29 29 0a 0a es commonmod))..
03e0: 28 6d 6f 64 75 6c 65 20 74 63 70 2d 74 72 61 6e (module tcp-tran
03f0: 73 70 6f 72 74 6d 6f 64 0a 09 2a 0a 09 0a 20 20 sportmod..*...
0400: 28 69 6d 70 6f 72 74 20 73 63 68 65 6d 65 0a 09 (import scheme..
0410: 20 20 63 68 69 63 6b 65 6e 0a 09 20 20 64 61 74 chicken.. dat
0420: 61 2d 73 74 72 75 63 74 75 72 65 73 0a 09 20 20 a-structures..
0430: 65 78 74 72 61 73 0a 09 20 20 6d 61 74 63 68 61 extras.. matcha
0440: 62 6c 65 29 0a 20 20 0a 28 69 6d 70 6f 72 74 20 ble). .(import
0450: 28 70 72 65 66 69 78 20 73 71 6c 69 74 65 33 20 (prefix sqlite3
0460: 73 71 6c 69 74 65 33 3a 29 0a 09 70 6f 73 69 78 sqlite3:)..posix
0470: 20 74 79 70 65 64 2d 72 65 63 6f 72 64 73 20 73 typed-records s
0480: 72 66 69 2d 31 38 20 73 72 66 69 2d 31 0a 09 73 rfi-18 srfi-1..s
0490: 72 66 69 2d 36 39 0a 09 73 74 61 63 6b 0a 09 66 rfi-69..stack..f
04a0: 69 6c 65 73 0a 09 70 6f 72 74 73 0a 0a 09 63 6f iles..ports...co
04b0: 6d 6d 6f 6e 6d 6f 64 0a 09 3b 3b 20 64 65 62 75 mmonmod..;; debu
04c0: 67 70 72 69 6e 74 0a 09 29 0a 0a 3b 3b 3d 3d 3d gprint..)..;;===
04d0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
04e0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
04f0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0500: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0510: 3d 3d 3d 0a 3b 3b 20 63 6c 69 65 6e 74 0a 3b 3b ===.;; client.;;
0520: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0530: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0540: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0550: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0560: 3d 3d 3d 3d 3d 3d 0a 0a 3b 3b 20 28 64 65 66 69 ======..;; (defi
0570: 6e 65 20 6b 65 65 70 2d 61 67 65 2d 70 61 72 61 ne keep-age-para
0580: 6d 20 28 6d 61 6b 65 2d 70 61 72 61 6d 65 74 65 m (make-paramete
0590: 72 20 31 30 29 29 20 3b 3b 20 71 69 66 20 66 69 r 10)) ;; qif fi
05a0: 6c 65 20 61 67 65 2c 20 69 66 20 6f 76 65 72 20 le age, if over
05b0: 6d 6f 76 65 20 74 6f 20 61 74 74 69 63 0a 0a 28 move to attic..(
05c0: 64 65 66 73 74 72 75 63 74 20 74 74 0a 20 20 28 defstruct tt. (
05d0: 61 72 65 61 20 23 66 29 0a 20 20 28 63 6f 6e 6e area #f). (conn
05e0: 73 20 28 6d 61 6b 65 2d 68 61 73 68 2d 74 61 62 s (make-hash-tab
05f0: 6c 65 29 29 20 3b 3b 20 64 62 66 6e 61 6d 65 20 le)) ;; dbfname
0600: 2d 3e 20 63 6f 6e 6e 0a 20 20 0a 20 20 29 0a 0a -> conn. . )..
0610: 28 64 65 66 69 6e 65 20 28 74 74 3a 6d 61 6b 65 (define (tt:make
0620: 2d 72 65 6d 6f 74 65 20 61 72 65 61 70 61 74 68 -remote areapath
0630: 29 0a 20 20 28 6d 61 6b 65 2d 74 74 20 61 72 65 ). (make-tt are
0640: 61 3a 20 61 72 65 61 70 61 74 68 29 29 0a 0a 28 a: areapath))..(
0650: 64 65 66 69 6e 65 20 28 74 74 3a 68 61 6e 64 6c define (tt:handl
0660: 65 72 20 72 75 6e 72 65 6d 6f 74 65 20 63 6d 64 er runremote cmd
0670: 20 72 69 64 20 70 61 72 61 6d 73 20 61 74 74 65 rid params atte
0680: 6d 70 74 6e 75 6d 20 61 72 65 61 2d 64 61 74 20 mptnum area-dat
0690: 61 72 65 61 70 61 74 68 20 72 65 61 64 6f 6e 6c areapath readonl
06a0: 79 2d 6d 6f 64 65 20 64 62 66 6e 61 6d 65 29 0a y-mode dbfname).
06b0: 20 20 3b 3b 20 4e 4f 54 45 3a 20 61 72 65 61 70 ;; NOTE: areap
06c0: 61 74 68 20 69 73 20 70 61 73 73 65 64 20 69 6e ath is passed in
06d0: 20 61 6e 64 20 69 6e 20 74 74 20 73 74 72 75 63 and in tt struc
06e0: 74 2e 20 57 65 27 6c 6c 20 75 73 65 20 70 61 73 t. We'll use pas
06f0: 73 65 64 20 69 6e 20 76 61 6c 75 65 20 66 6f 72 sed in value for
0700: 20 6e 6f 77 2e 0a 20 20 28 6c 65 74 2a 20 28 28 now.. (let* ((
0710: 63 6f 6e 6e 20 28 68 61 73 68 2d 74 61 62 6c 65 conn (hash-table
0720: 2d 72 65 66 2f 64 65 66 61 75 6c 74 20 28 74 74 -ref/default (tt
0730: 2d 63 6f 6e 6e 73 20 72 75 6e 72 65 6d 6f 74 65 -conns runremote
0740: 29 20 64 62 66 6e 61 6d 65 20 23 66 29 29 29 0a ) dbfname #f))).
0750: 20 20 20 20 28 69 66 20 63 6f 6e 6e 0a 09 3b 3b (if conn..;;
0760: 20 68 61 76 65 20 63 6f 6e 6e 65 63 74 69 6f 6e have connection
0770: 2c 20 63 61 6c 6c 20 74 68 65 20 73 65 72 76 65 , call the serve
0780: 72 0a 09 28 6c 65 74 2a 20 28 28 72 65 73 20 28 r..(let* ((res (
0790: 74 74 3a 73 65 6e 64 2d 72 65 63 65 69 76 65 20 tt:send-receive
07a0: 72 75 6e 72 65 6d 6f 74 65 20 63 6f 6e 6e 20 63 runremote conn c
07b0: 6d 64 20 72 69 64 20 70 61 72 61 6d 73 29 29 29 md rid params)))
07c0: 0a 09 20 20 28 63 6f 6e 64 0a 09 20 20 20 28 28 .. (cond.. ((
07d0: 6d 65 6d 62 65 72 20 72 65 73 20 27 28 62 75 73 member res '(bus
07e0: 79 20 73 74 61 72 74 69 6e 67 29 29 0a 09 20 20 y starting))..
07f0: 20 20 28 74 68 72 65 61 64 2d 73 6c 65 65 70 21 (thread-sleep!
0800: 20 31 29 0a 09 20 20 20 20 28 74 74 3a 68 61 6e 1).. (tt:han
0810: 64 6c 65 72 20 20 72 75 6e 72 65 6d 6f 74 65 20 dler runremote
0820: 63 6d 64 20 72 69 64 20 70 61 72 61 6d 73 20 61 cmd rid params a
0830: 74 74 65 6d 70 74 6e 75 6d 20 61 72 65 61 2d 64 ttemptnum area-d
0840: 61 74 20 61 72 65 61 70 61 74 68 20 72 65 61 64 at areapath read
0850: 6f 6e 6c 79 2d 6d 6f 64 65 20 64 62 66 6e 61 6d only-mode dbfnam
0860: 65 29 29 0a 09 20 20 20 28 65 6c 73 65 0a 09 20 e)).. (else..
0870: 20 20 20 72 65 73 29 29 29 0a 09 3b 3b 20 6e 6f res)))..;; no
0880: 20 63 6f 6e 6e 20 79 65 74 2c 20 66 69 6e 64 20 conn yet, find
0890: 61 6e 64 20 6f 72 20 73 74 61 72 74 20 61 6e 64 and or start and
08a0: 20 66 69 6e 64 20 61 20 73 65 72 76 65 72 0a 09 find a server..
08b0: 28 6c 65 74 2a 20 28 28 73 65 72 76 65 72 20 28 (let* ((server (
08c0: 74 74 3a 66 69 6e 64 2d 73 65 72 76 65 72 20 61 tt:find-server a
08d0: 72 65 61 70 61 74 68 20 64 62 66 6e 61 6d 65 29 reapath dbfname)
08e0: 29 29 0a 09 20 20 28 69 66 20 73 65 72 76 65 72 )).. (if server
08f0: 0a 09 20 20 20 20 20 20 28 6c 65 74 2a 20 28 28 .. (let* ((
0900: 63 6f 6e 6e 20 28 74 74 3a 73 65 72 76 65 72 2d conn (tt:server-
0910: 63 6f 6e 6e 65 63 74 20 73 65 72 76 65 72 29 29 connect server))
0920: 29 0a 09 09 28 68 61 73 68 2d 74 61 62 6c 65 2d )...(hash-table-
0930: 73 65 74 21 20 28 74 74 2d 63 6f 6e 6e 73 20 72 set! (tt-conns r
0940: 75 6e 72 65 6d 6f 74 65 29 20 64 62 66 6e 61 6d unremote) dbfnam
0950: 65 20 63 6f 6e 6e 29 0a 09 09 28 74 74 3a 68 61 e conn)...(tt:ha
0960: 6e 64 6c 65 72 20 20 72 75 6e 72 65 6d 6f 74 65 ndler runremote
0970: 20 63 6d 64 20 72 69 64 20 70 61 72 61 6d 73 20 cmd rid params
0980: 61 74 74 65 6d 70 74 6e 75 6d 20 61 72 65 61 2d attemptnum area-
0990: 64 61 74 20 61 72 65 61 70 61 74 68 20 72 65 61 dat areapath rea
09a0: 64 6f 6e 6c 79 2d 6d 6f 64 65 20 64 62 66 6e 61 donly-mode dbfna
09b0: 6d 65 29 29 0a 09 20 20 20 20 20 20 3b 3b 20 6e me)).. ;; n
09c0: 6f 20 73 65 72 76 65 72 2c 20 74 72 79 20 74 6f o server, try to
09d0: 20 73 74 61 72 74 20 6f 6e 65 0a 09 20 20 20 20 start one..
09e0: 20 20 28 62 65 67 69 6e 0a 09 09 28 74 74 3a 73 (begin...(tt:s
09f0: 74 61 72 74 2d 73 65 72 76 65 72 20 61 72 65 61 tart-server area
0a00: 70 61 74 68 20 64 62 66 6e 61 6d 65 29 0a 09 09 path dbfname)...
0a10: 28 74 68 72 65 61 64 2d 73 6c 65 65 70 21 20 31 (thread-sleep! 1
0a20: 29 0a 09 09 28 74 74 3a 68 61 6e 64 6c 65 72 20 )...(tt:handler
0a30: 20 72 75 6e 72 65 6d 6f 74 65 20 63 6d 64 20 72 runremote cmd r
0a40: 69 64 20 70 61 72 61 6d 73 20 61 74 74 65 6d 70 id params attemp
0a50: 74 6e 75 6d 20 61 72 65 61 2d 64 61 74 20 61 72 tnum area-dat ar
0a60: 65 61 70 61 74 68 20 72 65 61 64 6f 6e 6c 79 2d eapath readonly-
0a70: 6d 6f 64 65 20 64 62 66 6e 61 6d 65 29 29 29 29 mode dbfname))))
0a80: 29 29 29 0a 0a 28 64 65 66 69 6e 65 20 28 74 74 )))..(define (tt
0a90: 3a 62 69 64 2d 66 6f 72 2d 73 65 72 76 65 72 73 :bid-for-servers
0aa0: 68 69 70 20 72 75 6e 2d 69 64 29 0a 20 20 23 66 hip run-id). #f
0ab0: 29 0a 0a 28 64 65 66 69 6e 65 20 28 74 74 3a 67 )..(define (tt:g
0ac0: 65 74 2d 63 75 72 72 65 6e 74 2d 73 65 72 76 65 et-current-serve
0ad0: 72 20 72 75 6e 2d 69 64 29 0a 20 20 23 66 29 0a r run-id). #f).
0ae0: 0a 28 64 65 66 69 6e 65 20 28 74 74 3a 73 65 6e .(define (tt:sen
0af0: 64 2d 72 65 63 65 69 76 65 20 74 74 64 61 74 20 d-receive ttdat
0b00: 63 6f 6e 6e 20 63 6d 64 20 72 75 6e 2d 69 64 20 conn cmd run-id
0b10: 70 61 72 61 6d 73 29 0a 20 20 23 66 29 0a 0a 3b params). #f)..;
0b20: 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ;===============
0b30: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0b40: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0b50: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0b60: 3d 3d 3d 3d 3d 3d 3d 0a 3b 3b 20 73 65 72 76 65 =======.;; serve
0b70: 72 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d r.;;============
0b80: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0b90: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0ba0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0bb0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a 0a 28 64 65 66 ==========..(def
0bc0: 69 6e 65 20 28 74 74 3a 73 79 6e 63 2d 64 62 73 ine (tt:sync-dbs
0bd0: 20 74 74 64 61 74 29 0a 20 20 23 66 29 0a 0a 28 ttdat). #f)..(
0be0: 64 65 66 69 6e 65 20 28 74 74 3a 73 74 61 72 74 define (tt:start
0bf0: 2d 73 65 72 76 65 72 20 74 74 64 61 74 29 0a 20 -server ttdat).
0c00: 20 23 66 29 0a 0a 28 64 65 66 69 6e 65 20 28 74 #f)..(define (t
0c10: 74 3a 73 65 72 76 65 72 2d 63 6f 6e 6e 65 63 74 t:server-connect
0c20: 20 74 74 64 61 74 29 0a 20 20 23 66 29 0a 0a 28 ttdat). #f)..(
0c30: 64 65 66 69 6e 65 20 28 74 74 3a 66 69 6e 64 2d define (tt:find-
0c40: 73 65 72 76 65 72 20 74 74 64 61 74 29 0a 20 20 server ttdat).
0c50: 23 66 29 0a 0a 28 64 65 66 69 6e 65 20 28 74 74 #f)..(define (tt
0c60: 3a 73 68 75 74 64 6f 77 6e 2d 73 65 72 76 65 72 :shutdown-server
0c70: 20 74 74 64 61 74 29 0a 20 20 23 66 29 0a 0a 0a ttdat). #f)...
0c80: 0a 29 0a .).