Artifact
6908adafb01ac29e7a6bd1a419fdb065b3eb1c96:
0000: 0a 3b 3b 20 43 6f 70 79 72 69 67 68 74 20 32 30 .;; Copyright 20
0010: 30 36 2d 32 30 31 32 2c 20 4d 61 74 74 68 65 77 06-2012, Matthew
0020: 20 57 65 6c 6c 61 6e 64 2e 0a 3b 3b 20 0a 3b 3b Welland..;; .;;
0030: 20 20 54 68 69 73 20 70 72 6f 67 72 61 6d 20 69 This program i
0040: 73 20 6d 61 64 65 20 61 76 61 69 6c 61 62 6c 65 s made available
0050: 20 75 6e 64 65 72 20 74 68 65 20 47 4e 55 20 47 under the GNU G
0060: 50 4c 20 76 65 72 73 69 6f 6e 20 32 2e 30 20 6f PL version 2.0 o
0070: 72 0a 3b 3b 20 20 67 72 65 61 74 65 72 2e 20 53 r.;; greater. S
0080: 65 65 20 74 68 65 20 61 63 63 6f 6d 70 61 6e 79 ee the accompany
0090: 69 6e 67 20 66 69 6c 65 20 43 4f 50 59 49 4e 47 ing file COPYING
00a0: 20 66 6f 72 20 64 65 74 61 69 6c 73 2e 0a 3b 3b for details..;;
00b0: 20 0a 3b 3b 20 20 54 68 69 73 20 70 72 6f 67 72 .;; This progr
00c0: 61 6d 20 69 73 20 64 69 73 74 72 69 62 75 74 65 am is distribute
00d0: 64 20 57 49 54 48 4f 55 54 20 41 4e 59 20 57 41 d WITHOUT ANY WA
00e0: 52 52 41 4e 54 59 3b 20 77 69 74 68 6f 75 74 20 RRANTY; without
00f0: 65 76 65 6e 20 74 68 65 0a 3b 3b 20 20 69 6d 70 even the.;; imp
0100: 6c 69 65 64 20 77 61 72 72 61 6e 74 79 20 6f 66 lied warranty of
0110: 20 4d 45 52 43 48 41 4e 54 41 42 49 4c 49 54 59 MERCHANTABILITY
0120: 20 6f 72 20 46 49 54 4e 45 53 53 20 46 4f 52 20 or FITNESS FOR
0130: 41 20 50 41 52 54 49 43 55 4c 41 52 0a 3b 3b 20 A PARTICULAR.;;
0140: 20 50 55 52 50 4f 53 45 2e 0a 0a 28 72 65 71 75 PURPOSE...(requ
0150: 69 72 65 2d 65 78 74 65 6e 73 69 6f 6e 20 28 73 ire-extension (s
0160: 72 66 69 20 31 38 29 20 65 78 74 72 61 73 20 74 rfi 18) extras t
0170: 63 70 20 72 70 63 20 73 31 31 6e 29 0a 28 69 6d cp rpc s11n).(im
0180: 70 6f 72 74 20 28 70 72 65 66 69 78 20 72 70 63 port (prefix rpc
0190: 20 72 70 63 3a 29 29 0a 0a 28 75 73 65 20 73 71 rpc:))..(use sq
01a0: 6c 69 74 65 33 20 73 72 66 69 2d 31 20 70 6f 73 lite3 srfi-1 pos
01b0: 69 78 20 72 65 67 65 78 20 72 65 67 65 78 2d 63 ix regex regex-c
01c0: 61 73 65 20 73 72 66 69 2d 36 39 20 68 6f 73 74 ase srfi-69 host
01d0: 69 6e 66 6f 20 7a 6d 71 20 6d 64 35 20 6d 65 73 info zmq md5 mes
01e0: 73 61 67 65 2d 64 69 67 65 73 74 29 0a 28 69 6d sage-digest).(im
01f0: 70 6f 72 74 20 28 70 72 65 66 69 78 20 73 71 6c port (prefix sql
0200: 69 74 65 33 20 73 71 6c 69 74 65 33 3a 29 29 0a ite3 sqlite3:)).
0210: 0a 28 64 65 63 6c 61 72 65 20 28 75 6e 69 74 20 .(declare (unit
0220: 73 65 72 76 65 72 29 29 0a 0a 28 64 65 63 6c 61 server))..(decla
0230: 72 65 20 28 75 73 65 73 20 63 6f 6d 6d 6f 6e 29 re (uses common)
0240: 29 0a 28 64 65 63 6c 61 72 65 20 28 75 73 65 73 ).(declare (uses
0250: 20 64 62 29 29 0a 28 64 65 63 6c 61 72 65 20 28 db)).(declare (
0260: 75 73 65 73 20 74 65 73 74 73 29 29 0a 28 64 65 uses tests)).(de
0270: 63 6c 61 72 65 20 28 75 73 65 73 20 74 61 73 6b clare (uses task
0280: 73 29 29 20 3b 3b 20 74 61 73 6b 73 20 61 72 65 s)) ;; tasks are
0290: 20 77 68 65 72 65 20 73 74 75 66 66 20 69 73 20 where stuff is
02a0: 6d 61 69 6e 74 61 69 6e 65 64 20 61 62 6f 75 74 maintained about
02b0: 20 77 68 61 74 20 69 73 20 72 75 6e 6e 69 6e 67 what is running
02c0: 2e 0a 0a 28 69 6e 63 6c 75 64 65 20 22 63 6f 6d ...(include "com
02d0: 6d 6f 6e 5f 72 65 63 6f 72 64 73 2e 73 63 6d 22 mon_records.scm"
02e0: 29 0a 28 69 6e 63 6c 75 64 65 20 22 64 62 5f 72 ).(include "db_r
02f0: 65 63 6f 72 64 73 2e 73 63 6d 22 29 0a 0a 28 64 ecords.scm")..(d
0300: 65 66 69 6e 65 20 28 73 65 72 76 65 72 3a 6d 61 efine (server:ma
0310: 6b 65 2d 73 65 72 76 65 72 2d 75 72 6c 20 68 6f ke-server-url ho
0320: 73 74 70 6f 72 74 29 0a 20 20 28 69 66 20 28 6e stport). (if (n
0330: 6f 74 20 68 6f 73 74 70 6f 72 74 29 0a 20 20 20 ot hostport).
0340: 20 20 20 23 66 0a 20 20 20 20 20 20 28 63 6f 6e #f. (con
0350: 63 20 22 74 63 70 3a 2f 2f 22 20 28 63 61 72 20 c "tcp://" (car
0360: 68 6f 73 74 70 6f 72 74 29 20 22 3a 22 20 28 63 hostport) ":" (c
0370: 61 64 72 20 68 6f 73 74 70 6f 72 74 29 29 29 29 adr hostport))))
0380: 0a 28 64 65 66 69 6e 65 20 2a 74 69 6d 65 2d 74 .(define *time-t
0390: 6f 2d 65 78 69 74 2a 20 23 66 29 0a 0a 28 64 65 o-exit* #f)..(de
03a0: 66 69 6e 65 20 28 73 65 72 76 65 72 3a 72 75 6e fine (server:run
03b0: 20 68 6f 73 74 6e 29 0a 20 20 28 64 65 62 75 67 hostn). (debug
03c0: 3a 70 72 69 6e 74 20 30 20 22 41 74 74 65 6d 70 :print 0 "Attemp
03d0: 74 69 6e 67 20 74 6f 20 73 74 61 72 74 20 74 68 ting to start th
03e0: 65 20 73 65 72 76 65 72 20 2e 2e 2e 22 29 0a 20 e server ...").
03f0: 20 28 69 66 20 28 6e 6f 74 20 2a 74 6f 70 70 61 (if (not *toppa
0400: 74 68 2a 29 28 73 65 74 75 70 2d 66 6f 72 2d 72 th*)(setup-for-r
0410: 75 6e 29 29 0a 20 20 28 6c 65 74 2a 20 28 28 7a un)). (let* ((z
0420: 6d 71 2d 73 6f 63 6b 65 74 20 20 20 20 20 23 66 mq-socket #f
0430: 29 0a 09 20 28 68 6f 73 74 6e 61 6d 65 20 20 20 ).. (hostname
0440: 20 20 20 20 28 69 66 20 28 73 74 72 69 6e 67 3d (if (string=
0450: 3f 20 22 2d 22 20 68 6f 73 74 6e 29 0a 09 09 09 ? "-" hostn)....
0460: 20 20 20 20 20 28 67 65 74 2d 68 6f 73 74 2d 6e (get-host-n
0470: 61 6d 65 29 20 0a 09 09 09 20 20 20 20 20 68 6f ame) .... ho
0480: 73 74 6e 29 29 0a 09 20 28 69 70 61 64 64 72 73 stn)).. (ipaddrs
0490: 74 72 20 20 20 20 20 20 28 6c 65 74 20 28 28 69 tr (let ((i
04a0: 70 73 74 72 20 28 69 66 20 28 73 74 72 69 6e 67 pstr (if (string
04b0: 3d 3f 20 22 2d 22 20 68 6f 73 74 6e 29 0a 09 09 =? "-" hostn)...
04c0: 09 09 09 20 20 28 73 74 72 69 6e 67 2d 69 6e 74 ... (string-int
04d0: 65 72 73 70 65 72 73 65 20 28 6d 61 70 20 6e 75 ersperse (map nu
04e0: 6d 62 65 72 2d 3e 73 74 72 69 6e 67 20 28 75 38 mber->string (u8
04f0: 76 65 63 74 6f 72 2d 3e 6c 69 73 74 20 28 68 6f vector->list (ho
0500: 73 74 6e 61 6d 65 2d 3e 69 70 20 68 6f 73 74 6e stname->ip hostn
0510: 61 6d 65 29 29 29 20 22 2e 22 29 0a 09 09 09 09 ame))) ".").....
0520: 09 20 20 23 66 29 29 29 0a 09 09 09 20 20 20 28 . #f))).... (
0530: 69 66 20 69 70 73 74 72 20 69 70 73 74 72 20 68 if ipstr ipstr h
0540: 6f 73 74 6e 61 6d 65 29 29 29 29 0a 20 20 20 20 ostname)))).
0550: 28 73 65 74 21 20 7a 6d 71 2d 73 6f 63 6b 65 74 (set! zmq-socket
0560: 20 28 73 65 72 76 65 72 3a 66 69 6e 64 2d 66 72 (server:find-fr
0570: 65 65 2d 70 6f 72 74 2d 61 6e 64 2d 6f 70 65 6e ee-port-and-open
0580: 20 69 70 61 64 64 72 73 74 72 20 7a 6d 71 2d 73 ipaddrstr zmq-s
0590: 6f 63 6b 65 74 20 35 35 35 35 20 30 29 29 0a 20 ocket 5555 0)).
05a0: 20 20 20 28 73 65 74 21 20 2a 63 61 63 68 65 2d (set! *cache-
05b0: 6f 6e 2a 20 23 74 29 0a 20 20 20 20 0a 20 20 20 on* #t). .
05c0: 20 3b 3b 20 77 68 61 74 20 74 6f 20 64 6f 20 77 ;; what to do w
05d0: 68 65 6e 20 77 65 20 71 75 69 74 0a 20 20 20 20 hen we quit.
05e0: 3b 3b 0a 20 20 20 20 28 6f 6e 2d 65 78 69 74 20 ;;. (on-exit
05f0: 28 6c 61 6d 62 64 61 20 28 29 0a 09 20 20 20 20 (lambda ()..
0600: 20 20 20 28 6f 70 65 6e 2d 72 75 6e 2d 63 6c 6f (open-run-clo
0610: 73 65 20 74 61 73 6b 73 3a 73 65 72 76 65 72 2d se tasks:server-
0620: 64 65 72 65 67 69 73 74 65 72 2d 73 65 6c 66 20 deregister-self
0630: 74 61 73 6b 73 3a 6f 70 65 6e 2d 64 62 29 0a 09 tasks:open-db)..
0640: 20 20 20 20 20 20 20 28 6c 65 74 20 6c 6f 6f 70 (let loop
0650: 20 28 29 20 0a 09 09 20 28 6c 65 74 20 28 28 71 () ... (let ((q
0660: 75 65 75 65 2d 6c 65 6e 20 30 29 29 0a 09 09 20 ueue-len 0))...
0670: 20 20 28 74 68 72 65 61 64 2d 73 6c 65 65 70 21 (thread-sleep!
0680: 20 28 72 61 6e 64 6f 6d 20 35 29 29 0a 09 09 20 (random 5))...
0690: 20 20 28 6d 75 74 65 78 2d 6c 6f 63 6b 21 20 2a (mutex-lock! *
06a0: 69 6e 63 6f 6d 69 6e 67 2d 6d 75 74 65 78 2a 29 incoming-mutex*)
06b0: 0a 09 09 20 20 20 28 73 65 74 21 20 71 75 65 75 ... (set! queu
06c0: 65 2d 6c 65 6e 20 28 6c 65 6e 67 74 68 20 2a 69 e-len (length *i
06d0: 6e 63 6f 6d 69 6e 67 2d 64 61 74 61 2a 29 29 0a ncoming-data*)).
06e0: 09 09 20 20 20 28 6d 75 74 65 78 2d 75 6e 6c 6f .. (mutex-unlo
06f0: 63 6b 21 20 2a 69 6e 63 6f 6d 69 6e 67 2d 6d 75 ck! *incoming-mu
0700: 74 65 78 2a 29 0a 09 09 20 20 20 28 69 66 20 28 tex*)... (if (
0710: 3e 20 71 75 65 75 65 2d 6c 65 6e 20 30 29 0a 09 > queue-len 0)..
0720: 09 20 20 20 20 20 20 20 28 62 65 67 69 6e 0a 09 . (begin..
0730: 09 09 20 28 64 65 62 75 67 3a 70 72 69 6e 74 2d .. (debug:print-
0740: 69 6e 66 6f 20 30 20 22 51 75 65 75 65 20 6e 6f info 0 "Queue no
0750: 74 20 66 6c 75 73 68 65 64 2c 20 77 61 69 74 69 t flushed, waiti
0760: 6e 67 20 2e 2e 2e 22 29 0a 09 09 09 20 28 6c 6f ng ...").... (lo
0770: 6f 70 29 29 29 29 29 29 29 0a 0a 20 20 20 20 3b op))))))).. ;
0780: 3b 20 54 68 65 20 68 65 61 76 79 20 6c 69 66 74 ; The heavy lift
0790: 69 6e 67 0a 20 20 20 20 3b 3b 0a 20 20 20 20 28 ing. ;;. (
07a0: 6c 65 74 20 6c 6f 6f 70 20 28 29 0a 20 20 20 20 let loop ().
07b0: 20 20 28 6c 65 74 2a 20 28 28 72 61 77 6d 73 67 (let* ((rawmsg
07c0: 20 28 72 65 63 65 69 76 65 2d 6d 65 73 73 61 67 (receive-messag
07d0: 65 2a 20 7a 6d 71 2d 73 6f 63 6b 65 74 29 29 0a e* zmq-socket)).
07e0: 09 20 20 20 20 20 28 70 61 72 61 6d 73 20 28 64 . (params (d
07f0: 62 3a 73 74 72 69 6e 67 2d 3e 6f 62 6a 20 72 61 b:string->obj ra
0800: 77 6d 73 67 29 29 20 3b 3b 20 28 77 69 74 68 2d wmsg)) ;; (with-
0810: 69 6e 70 75 74 2d 66 72 6f 6d 2d 73 74 72 69 6e input-from-strin
0820: 67 20 72 61 77 6d 73 67 20 28 6c 61 6d 62 64 61 g rawmsg (lambda
0830: 20 28 29 28 64 65 73 65 72 69 61 6c 69 7a 65 29 ()(deserialize)
0840: 29 29 29 0a 09 20 20 20 20 20 28 72 65 73 20 20 ))).. (res
0850: 20 20 23 66 29 29 0a 09 28 64 65 62 75 67 3a 70 #f))..(debug:p
0860: 72 69 6e 74 2d 69 6e 66 6f 20 31 32 20 22 73 65 rint-info 12 "se
0870: 72 76 65 72 3d 3e 20 72 65 63 65 69 76 65 64 20 rver=> received
0880: 70 61 72 61 6d 73 3d 22 20 70 61 72 61 6d 73 29 params=" params)
0890: 0a 09 28 73 65 74 21 20 72 65 73 20 28 63 64 62 ..(set! res (cdb
08a0: 3a 63 61 63 68 65 64 2d 61 63 63 65 73 73 20 70 :cached-access p
08b0: 61 72 61 6d 73 29 29 0a 09 28 64 65 62 75 67 3a arams))..(debug:
08c0: 70 72 69 6e 74 2d 69 6e 66 6f 20 31 32 20 22 73 print-info 12 "s
08d0: 65 72 76 65 72 3d 3e 20 70 72 6f 63 65 73 73 65 erver=> processe
08e0: 64 20 72 65 73 3d 22 20 72 65 73 29 0a 09 28 73 d res=" res)..(s
08f0: 65 6e 64 2d 6d 65 73 73 61 67 65 20 7a 6d 71 2d end-message zmq-
0900: 73 6f 63 6b 65 74 20 28 64 62 3a 6f 62 6a 2d 3e socket (db:obj->
0910: 73 74 72 69 6e 67 20 72 65 73 29 29 0a 09 28 69 string res))..(i
0920: 66 20 28 6e 6f 74 20 2a 74 69 6d 65 2d 74 6f 2d f (not *time-to-
0930: 65 78 69 74 2a 29 0a 09 20 20 20 20 28 6c 6f 6f exit*).. (loo
0940: 70 29 0a 09 20 20 20 20 28 62 65 67 69 6e 0a 09 p).. (begin..
0950: 20 20 20 20 20 20 28 64 62 3a 77 72 69 74 65 2d (db:write-
0960: 63 61 63 68 65 64 2d 64 61 74 61 29 0a 09 20 20 cached-data)..
0970: 20 20 20 20 28 6f 70 65 6e 2d 72 75 6e 2d 63 6c (open-run-cl
0980: 6f 73 65 20 74 61 73 6b 73 3a 73 65 72 76 65 72 ose tasks:server
0990: 2d 64 65 72 65 67 69 73 74 65 72 2d 73 65 6c 66 -deregister-self
09a0: 20 74 61 73 6b 73 3a 6f 70 65 6e 2d 64 62 29 0a tasks:open-db).
09b0: 09 20 20 20 20 20 20 28 65 78 69 74 29 0a 09 20 . (exit)..
09c0: 20 20 20 20 20 29 29 29 29 29 29 0a 0a 3b 3b 20 ))))))..;;
09d0: 72 75 6e 20 73 65 72 76 65 72 3a 6b 65 65 70 2d run server:keep-
09e0: 72 75 6e 6e 69 6e 67 20 69 6e 20 61 20 70 61 72 running in a par
09f0: 61 6c 6c 65 6c 20 74 68 72 65 61 64 20 74 6f 20 allel thread to
0a00: 6d 6f 6e 69 74 6f 72 20 74 68 61 74 20 74 68 65 monitor that the
0a10: 20 64 62 20 69 73 20 62 65 69 6e 67 20 0a 3b 3b db is being .;;
0a20: 20 75 73 65 64 20 61 6e 64 20 74 6f 20 73 68 75 used and to shu
0a30: 74 64 6f 77 6e 20 61 66 74 65 72 20 73 6f 6d 65 tdown after some
0a40: 74 69 6d 65 20 69 66 20 69 74 20 69 73 20 6e 6f time if it is no
0a50: 74 2e 0a 3b 3b 0a 28 64 65 66 69 6e 65 20 28 73 t..;;.(define (s
0a60: 65 72 76 65 72 3a 6b 65 65 70 2d 72 75 6e 6e 69 erver:keep-runni
0a70: 6e 67 29 0a 20 20 3b 3b 20 69 66 20 6e 6f 6e 65 ng). ;; if none
0a80: 20 72 75 6e 6e 69 6e 67 20 6f 72 20 69 66 20 3e running or if >
0a90: 20 32 30 20 73 65 63 6f 6e 64 73 20 73 69 6e 63 20 seconds sinc
0aa0: 65 20 0a 20 20 3b 3b 20 73 65 72 76 65 72 20 6c e . ;; server l
0ab0: 61 73 74 20 75 73 65 64 20 74 68 65 6e 20 73 74 ast used then st
0ac0: 61 72 74 20 73 68 75 74 64 6f 77 6e 0a 20 20 28 art shutdown. (
0ad0: 6c 65 74 20 6c 6f 6f 70 20 28 28 63 6f 75 6e 74 let loop ((count
0ae0: 20 30 29 29 0a 20 20 20 20 28 74 68 72 65 61 64 0)). (thread
0af0: 2d 73 6c 65 65 70 21 20 31 29 20 3b 3b 20 6e 6f -sleep! 1) ;; no
0b00: 20 6e 65 65 64 20 74 6f 20 64 6f 20 74 68 69 73 need to do this
0b10: 20 76 65 72 79 20 6f 66 74 65 6e 0a 20 20 20 20 very often.
0b20: 28 64 62 3a 77 72 69 74 65 2d 63 61 63 68 65 64 (db:write-cached
0b30: 2d 64 61 74 61 29 0a 20 20 20 20 28 70 72 69 6e -data). (prin
0b40: 74 20 22 53 65 72 76 65 72 20 72 75 6e 6e 69 6e t "Server runnin
0b50: 67 2c 20 63 6f 75 6e 74 20 69 73 20 22 20 63 6f g, count is " co
0b60: 75 6e 74 29 0a 20 20 20 20 28 69 66 20 28 3c 20 unt). (if (<
0b70: 63 6f 75 6e 74 20 31 30 29 0a 09 28 6c 6f 6f 70 count 10)..(loop
0b80: 20 28 2b 20 63 6f 75 6e 74 20 31 29 29 0a 09 28 (+ count 1))..(
0b90: 6c 65 74 20 28 28 6e 75 6d 72 75 6e 6e 69 6e 67 let ((numrunning
0ba0: 20 28 6f 70 65 6e 2d 72 75 6e 2d 63 6c 6f 73 65 (open-run-close
0bb0: 20 64 62 3a 67 65 74 2d 63 6f 75 6e 74 2d 74 65 db:get-count-te
0bc0: 73 74 73 2d 72 75 6e 6e 69 6e 67 20 23 66 29 29 sts-running #f))
0bd0: 29 0a 09 20 20 28 69 66 20 28 6f 72 20 28 3e 20 ).. (if (or (>
0be0: 6e 75 6d 72 75 6e 6e 69 6e 67 20 30 29 0a 09 09 numrunning 0)...
0bf0: 20 20 28 3e 20 28 2b 20 2a 6c 61 73 74 2d 64 62 (> (+ *last-db
0c00: 2d 61 63 63 65 73 73 2a 20 36 30 29 28 63 75 72 -access* 60)(cur
0c10: 72 65 6e 74 2d 73 65 63 6f 6e 64 73 29 29 29 0a rent-seconds))).
0c20: 09 20 20 20 20 20 20 28 62 65 67 69 6e 0a 09 09 . (begin...
0c30: 28 64 65 62 75 67 3a 70 72 69 6e 74 2d 69 6e 66 (debug:print-inf
0c40: 6f 20 30 20 22 53 65 72 76 65 72 20 63 6f 6e 74 o 0 "Server cont
0c50: 69 6e 75 69 6e 67 2c 20 74 65 73 74 73 20 72 75 inuing, tests ru
0c60: 6e 6e 69 6e 67 3a 20 22 20 6e 75 6d 72 75 6e 6e nning: " numrunn
0c70: 69 6e 67 20 22 2c 20 73 65 63 6f 6e 64 73 20 73 ing ", seconds s
0c80: 69 6e 63 65 20 6c 61 73 74 20 64 62 20 61 63 63 ince last db acc
0c90: 65 73 73 3a 20 22 20 28 2d 20 28 63 75 72 72 65 ess: " (- (curre
0ca0: 6e 74 2d 73 65 63 6f 6e 64 73 29 20 2a 6c 61 73 nt-seconds) *las
0cb0: 74 2d 64 62 2d 61 63 63 65 73 73 2a 29 29 0a 09 t-db-access*))..
0cc0: 09 28 6c 6f 6f 70 20 30 29 29 29 0a 09 20 20 20 .(loop 0)))..
0cd0: 20 20 20 28 62 65 67 69 6e 0a 09 09 28 64 65 62 (begin...(deb
0ce0: 75 67 3a 70 72 69 6e 74 2d 69 6e 66 6f 20 30 20 ug:print-info 0
0cf0: 22 53 74 61 72 74 69 6e 67 20 74 6f 20 73 68 75 "Starting to shu
0d00: 74 64 6f 77 6e 20 74 68 65 20 73 65 72 76 65 72 tdown the server
0d10: 20 73 69 64 65 22 29 0a 09 09 3b 3b 20 6e 65 65 side")...;; nee
0d20: 64 20 74 6f 20 64 65 6c 65 74 65 20 6f 6e 6c 79 d to delete only
0d30: 20 2a 6d 79 2a 20 73 65 72 76 65 72 20 65 6e 74 *my* server ent
0d40: 72 79 20 28 66 75 74 75 72 65 20 75 73 65 29 0a ry (future use).
0d50: 09 09 28 6f 70 65 6e 2d 72 75 6e 2d 63 6c 6f 73 ..(open-run-clos
0d60: 65 20 64 62 3a 64 65 6c 2d 76 61 72 20 23 66 20 e db:del-var #f
0d70: 22 53 45 52 56 45 52 22 29 0a 09 09 28 74 68 72 "SERVER")...(thr
0d80: 65 61 64 2d 73 6c 65 65 70 21 20 31 30 29 0a 09 ead-sleep! 10)..
0d90: 09 28 64 65 62 75 67 3a 70 72 69 6e 74 2d 69 6e .(debug:print-in
0da0: 66 6f 20 30 20 22 4d 61 78 20 63 61 63 68 65 64 fo 0 "Max cached
0db0: 20 71 75 65 72 69 65 73 20 77 61 73 20 22 20 2a queries was " *
0dc0: 6d 61 78 2d 63 61 63 68 65 2d 73 69 7a 65 2a 29 max-cache-size*)
0dd0: 0a 09 09 28 64 65 62 75 67 3a 70 72 69 6e 74 2d ...(debug:print-
0de0: 69 6e 66 6f 20 30 20 22 53 65 72 76 65 72 20 73 info 0 "Server s
0df0: 68 75 74 64 6f 77 6e 20 63 6f 6d 70 6c 65 74 65 hutdown complete
0e00: 2e 20 45 78 69 74 69 6e 67 22 29 0a 09 09 29 29 . Exiting")...))
0e10: 29 29 29 0a 0a 28 64 65 66 69 6e 65 20 28 73 65 )))..(define (se
0e20: 72 76 65 72 3a 66 69 6e 64 2d 66 72 65 65 2d 70 rver:find-free-p
0e30: 6f 72 74 2d 61 6e 64 2d 6f 70 65 6e 20 68 6f 73 ort-and-open hos
0e40: 74 20 73 20 70 6f 72 74 20 23 21 6b 65 79 20 28 t s port #!key (
0e50: 74 72 79 6e 75 6d 20 35 30 29 29 0a 20 20 28 6c trynum 50)). (l
0e60: 65 74 20 28 28 73 20 28 69 66 20 73 20 73 20 28 et ((s (if s s (
0e70: 6d 61 6b 65 2d 73 6f 63 6b 65 74 20 27 72 65 70 make-socket 'rep
0e80: 29 29 29 0a 09 28 70 20 28 69 66 20 28 6e 75 6d )))..(p (if (num
0e90: 62 65 72 3f 20 70 6f 72 74 29 20 70 6f 72 74 20 ber? port) port
0ea0: 35 35 35 35 29 29 29 0a 20 20 20 20 28 68 61 6e 5555))). (han
0eb0: 64 6c 65 2d 65 78 63 65 70 74 69 6f 6e 73 0a 20 dle-exceptions.
0ec0: 20 20 20 20 65 78 6e 0a 20 20 20 20 20 28 62 65 exn. (be
0ed0: 67 69 6e 0a 20 20 20 20 20 20 20 28 64 65 62 75 gin. (debu
0ee0: 67 3a 70 72 69 6e 74 20 30 20 22 46 61 69 6c 65 g:print 0 "Faile
0ef0: 64 20 74 6f 20 62 69 6e 64 20 74 6f 20 70 6f 72 d to bind to por
0f00: 74 20 22 20 70 20 22 2c 20 74 72 79 69 6e 67 20 t " p ", trying
0f10: 6e 65 78 74 20 70 6f 72 74 22 29 0a 20 20 20 20 next port").
0f20: 20 20 20 28 64 65 62 75 67 3a 70 72 69 6e 74 20 (debug:print
0f30: 30 20 22 20 20 20 45 58 43 45 50 54 49 4f 4e 3a 0 " EXCEPTION:
0f40: 20 22 20 28 28 63 6f 6e 64 69 74 69 6f 6e 2d 70 " ((condition-p
0f50: 72 6f 70 65 72 74 79 2d 61 63 63 65 73 73 6f 72 roperty-accessor
0f60: 20 27 65 78 6e 20 27 6d 65 73 73 61 67 65 29 20 'exn 'message)
0f70: 65 78 6e 29 29 0a 20 20 20 20 20 20 20 28 69 66 exn)). (if
0f80: 20 28 3e 20 74 72 79 6e 75 6d 20 30 29 0a 09 20 (> trynum 0)..
0f90: 20 20 28 73 65 72 76 65 72 3a 66 69 6e 64 2d 66 (server:find-f
0fa0: 72 65 65 2d 70 6f 72 74 2d 61 6e 64 2d 6f 70 65 ree-port-and-ope
0fb0: 6e 20 68 6f 73 74 20 73 20 28 2b 20 70 20 31 29 n host s (+ p 1)
0fc0: 20 74 72 79 6e 75 6d 3a 20 28 2d 20 74 72 79 6e trynum: (- tryn
0fd0: 75 6d 20 31 29 29 0a 09 20 20 20 28 64 65 62 75 um 1)).. (debu
0fe0: 67 3a 70 72 69 6e 74 2d 69 6e 66 6f 20 30 20 22 g:print-info 0 "
0ff0: 54 72 69 65 64 20 70 6f 72 74 73 20 66 72 6f 6d Tried ports from
1000: 20 22 20 28 2d 20 70 20 74 72 79 6e 75 6d 29 20 " (- p trynum)
1010: 22 20 74 6f 20 22 20 70 20 0a 09 09 09 20 20 20 " to " p ....
1020: 20 20 22 20 62 75 74 20 61 6c 6c 20 77 65 72 65 " but all were
1030: 20 69 6e 20 75 73 65 2e 20 50 6c 65 61 73 65 20 in use. Please
1040: 74 72 79 20 61 20 64 69 66 66 65 72 65 6e 74 20 try a different
1050: 70 6f 72 74 20 72 61 6e 67 65 20 62 79 20 73 74 port range by st
1060: 61 72 74 69 6e 67 20 74 68 65 20 73 65 72 76 65 arting the serve
1070: 72 20 77 69 74 68 20 70 61 72 61 6d 65 74 65 72 r with parameter
1080: 20 5c 22 20 2d 70 6f 72 74 20 4e 5c 22 20 77 68 \" -port N\" wh
1090: 65 72 65 20 4e 20 69 73 20 74 68 65 20 73 74 61 ere N is the sta
10a0: 72 74 69 6e 67 20 70 6f 72 74 20 6e 75 6d 62 65 rting port numbe
10b0: 72 20 74 6f 20 75 73 65 22 29 29 29 0a 20 20 20 r to use"))).
10c0: 20 20 28 6c 65 74 20 28 28 7a 6d 71 2d 75 72 6c (let ((zmq-url
10d0: 20 28 63 6f 6e 63 20 22 74 63 70 3a 2f 2f 22 20 (conc "tcp://"
10e0: 68 6f 73 74 20 22 3a 22 20 70 29 29 29 0a 20 20 host ":" p))).
10f0: 20 20 20 20 20 28 70 72 69 6e 74 20 22 54 72 79 (print "Try
1100: 69 6e 67 20 74 6f 20 73 74 61 72 74 20 73 65 72 ing to start ser
1110: 76 65 72 20 6f 6e 20 22 20 7a 6d 71 2d 75 72 6c ver on " zmq-url
1120: 29 0a 20 20 20 20 20 20 20 28 62 69 6e 64 2d 73 ). (bind-s
1130: 6f 63 6b 65 74 20 73 20 7a 6d 71 2d 75 72 6c 29 ocket s zmq-url)
1140: 0a 20 20 20 20 20 20 20 28 73 65 74 21 20 2a 72 . (set! *r
1150: 75 6e 72 65 6d 6f 74 65 2a 20 23 66 29 0a 20 20 unremote* #f).
1160: 20 20 20 20 20 28 64 65 62 75 67 3a 70 72 69 6e (debug:prin
1170: 74 20 30 20 22 53 65 72 76 65 72 20 73 74 61 72 t 0 "Server star
1180: 74 65 64 20 6f 6e 20 22 20 7a 6d 71 2d 75 72 6c ted on " zmq-url
1190: 29 0a 20 20 20 20 20 20 20 28 6f 70 65 6e 2d 72 ). (open-r
11a0: 75 6e 2d 63 6c 6f 73 65 20 74 61 73 6b 73 3a 73 un-close tasks:s
11b0: 65 72 76 65 72 2d 72 65 67 69 73 74 65 72 20 74 erver-register t
11c0: 61 73 6b 73 3a 6f 70 65 6e 2d 64 62 20 28 63 75 asks:open-db (cu
11d0: 72 72 65 6e 74 2d 70 72 6f 63 65 73 73 2d 69 64 rrent-process-id
11e0: 29 20 68 6f 73 74 20 70 20 30 20 27 6c 69 76 65 ) host p 0 'live
11f0: 29 0a 20 20 20 20 20 20 20 73 29 29 29 29 0a 0a ). s))))..
1200: 28 64 65 66 69 6e 65 20 28 73 65 72 76 65 72 3a (define (server:
1210: 6d 6b 2d 73 69 67 6e 61 74 75 72 65 29 0a 20 20 mk-signature).
1220: 28 6d 65 73 73 61 67 65 2d 64 69 67 65 73 74 2d (message-digest-
1230: 73 74 72 69 6e 67 20 28 6d 64 35 2d 70 72 69 6d string (md5-prim
1240: 69 74 69 76 65 29 20 0a 09 09 09 20 28 77 69 74 itive) .... (wit
1250: 68 2d 6f 75 74 70 75 74 2d 74 6f 2d 73 74 72 69 h-output-to-stri
1260: 6e 67 0a 09 09 09 20 20 20 28 6c 61 6d 62 64 61 ng.... (lambda
1270: 20 28 29 0a 09 09 09 20 20 20 20 20 28 77 72 69 ().... (wri
1280: 74 65 20 28 6c 69 73 74 20 28 63 75 72 72 65 6e te (list (curren
1290: 74 2d 64 69 72 65 63 74 6f 72 79 29 0a 09 09 09 t-directory)....
12a0: 09 09 20 20 28 61 72 67 76 29 29 29 29 29 29 29 .. (argv)))))))
12b0: 0a 0a 28 64 65 66 69 6e 65 20 28 73 65 72 76 65 ..(define (serve
12c0: 72 3a 67 65 74 2d 63 6c 69 65 6e 74 2d 73 69 67 r:get-client-sig
12d0: 6e 61 74 75 72 65 29 0a 20 20 28 69 66 20 2a 6d nature). (if *m
12e0: 79 2d 63 6c 69 65 6e 74 2d 73 69 67 6e 61 74 75 y-client-signatu
12f0: 72 65 2a 20 2a 6d 79 2d 63 6c 69 65 6e 74 2d 73 re* *my-client-s
1300: 69 67 6e 61 74 75 72 65 2a 0a 20 20 20 20 20 20 ignature*.
1310: 28 6c 65 74 20 28 28 73 69 67 20 28 73 65 72 76 (let ((sig (serv
1320: 65 72 3a 6d 6b 2d 73 69 67 6e 61 74 75 72 65 29 er:mk-signature)
1330: 29 29 0a 09 28 73 65 74 21 20 2a 6d 79 2d 63 6c ))..(set! *my-cl
1340: 69 65 6e 74 2d 73 69 67 6e 61 74 75 72 65 2a 20 ient-signature*
1350: 73 69 67 29 0a 09 2a 6d 79 2d 63 6c 69 65 6e 74 sig)..*my-client
1360: 2d 73 69 67 6e 61 74 75 72 65 2a 29 29 29 0a 0a -signature*)))..
1370: 3b 3b 20 0a 28 64 65 66 69 6e 65 20 28 73 65 72 ;; .(define (ser
1380: 76 65 72 3a 63 6c 69 65 6e 74 2d 63 6f 6e 6e 65 ver:client-conne
1390: 63 74 20 68 6f 73 74 20 70 6f 72 74 29 0a 20 20 ct host port).
13a0: 28 6c 65 74 20 28 28 63 6f 6e 6e 65 63 74 2d 6f (let ((connect-o
13b0: 6b 20 23 66 29 0a 09 28 7a 6d 71 2d 73 6f 63 6b k #f)..(zmq-sock
13c0: 65 74 20 28 6d 61 6b 65 2d 73 6f 63 6b 65 74 20 et (make-socket
13d0: 27 72 65 71 29 29 0a 09 28 63 6f 6e 75 72 6c 20 'req))..(conurl
13e0: 20 20 20 20 28 73 65 72 76 65 72 3a 6d 61 6b 65 (server:make
13f0: 2d 73 65 72 76 65 72 2d 75 72 6c 20 28 6c 69 73 -server-url (lis
1400: 74 20 68 6f 73 74 20 70 6f 72 74 29 29 29 29 0a t host port)))).
1410: 20 20 20 20 28 63 6f 6e 6e 65 63 74 2d 73 6f 63 (connect-soc
1420: 6b 65 74 20 7a 6d 71 2d 73 6f 63 6b 65 74 20 63 ket zmq-socket c
1430: 6f 6e 75 72 6c 29 0a 20 20 20 20 7a 6d 71 2d 73 onurl). zmq-s
1440: 6f 63 6b 65 74 29 29 0a 20 20 0a 0a 28 64 65 66 ocket)). ..(def
1450: 69 6e 65 20 28 73 65 72 76 65 72 3a 63 6c 69 65 ine (server:clie
1460: 6e 74 2d 6c 6f 67 69 6e 20 7a 6d 71 2d 73 6f 63 nt-login zmq-soc
1470: 6b 65 74 29 0a 20 20 28 63 64 62 3a 6c 6f 67 69 ket). (cdb:logi
1480: 6e 20 7a 6d 71 2d 73 6f 63 6b 65 74 20 2a 74 6f n zmq-socket *to
1490: 70 70 61 74 68 2a 20 28 73 65 72 76 65 72 3a 67 ppath* (server:g
14a0: 65 74 2d 63 6c 69 65 6e 74 2d 73 69 67 6e 61 74 et-client-signat
14b0: 75 72 65 29 29 29 0a 0a 28 64 65 66 69 6e 65 20 ure)))..(define
14c0: 28 73 65 72 76 65 72 3a 63 6c 69 65 6e 74 2d 6c (server:client-l
14d0: 6f 67 6f 75 74 20 7a 6d 71 2d 73 6f 63 6b 65 74 ogout zmq-socket
14e0: 29 0a 20 20 28 6c 65 74 20 28 28 6f 6b 20 28 61 ). (let ((ok (a
14f0: 6e 64 20 28 73 6f 63 6b 65 74 3f 20 7a 6d 71 2d nd (socket? zmq-
1500: 73 6f 63 6b 65 74 29 0a 09 09 20 28 63 64 62 3a socket)... (cdb:
1510: 6c 6f 67 6f 75 74 20 7a 6d 71 2d 73 6f 63 6b 65 logout zmq-socke
1520: 74 20 2a 74 6f 70 70 61 74 68 2a 20 28 73 65 72 t *toppath* (ser
1530: 76 65 72 3a 67 65 74 2d 63 6c 69 65 6e 74 2d 73 ver:get-client-s
1540: 69 67 6e 61 74 75 72 65 29 29 29 29 29 0a 20 20 ignature))))).
1550: 20 20 28 63 6c 6f 73 65 2d 73 6f 63 6b 65 74 20 (close-socket
1560: 7a 6d 71 2d 73 6f 63 6b 65 74 29 0a 20 20 20 20 zmq-socket).
1570: 6f 6b 29 29 0a 0a 3b 3b 20 44 6f 20 61 6c 6c 20 ok))..;; Do all
1580: 74 68 65 20 63 6f 6e 6e 65 63 74 69 6f 6e 20 77 the connection w
1590: 6f 72 6b 2c 20 73 74 61 72 74 20 61 20 73 65 72 ork, start a ser
15a0: 76 65 72 20 69 66 20 6e 6f 74 20 61 6c 72 65 61 ver if not alrea
15b0: 64 79 20 72 75 6e 6e 69 6e 67 0a 28 64 65 66 69 dy running.(defi
15c0: 6e 65 20 28 73 65 72 76 65 72 3a 63 6c 69 65 6e ne (server:clien
15d0: 74 2d 73 65 74 75 70 20 23 21 6b 65 79 20 28 6e t-setup #!key (n
15e0: 75 6d 74 72 69 65 73 20 31 30 29 29 0a 20 20 28 umtries 10)). (
15f0: 69 66 20 28 6e 6f 74 20 2a 74 6f 70 70 61 74 68 if (not *toppath
1600: 2a 29 28 73 65 74 75 70 2d 66 6f 72 2d 72 75 6e *)(setup-for-run
1610: 29 29 0a 20 20 28 6c 65 74 20 28 28 68 6f 73 74 )). (let ((host
1620: 69 6e 66 6f 20 20 20 28 6f 70 65 6e 2d 72 75 6e info (open-run
1630: 2d 63 6c 6f 73 65 20 74 61 73 6b 73 3a 67 65 74 -close tasks:get
1640: 2d 62 65 73 74 2d 73 65 72 76 65 72 20 74 61 73 -best-server tas
1650: 6b 73 3a 6f 70 65 6e 2d 64 62 29 29 29 0a 20 20 ks:open-db))).
1660: 20 20 28 69 66 20 68 6f 73 74 69 6e 66 6f 0a 09 (if hostinfo..
1670: 28 6c 65 74 2a 20 28 28 68 6f 73 74 20 20 20 20 (let* ((host
1680: 20 20 20 28 63 61 72 20 68 6f 73 74 69 6e 66 6f (car hostinfo
1690: 29 29 0a 09 20 20 20 20 20 20 20 28 70 6f 72 74 )).. (port
16a0: 20 20 20 20 20 20 20 28 63 61 64 72 20 68 6f 73 (cadr hos
16b0: 74 69 6e 66 6f 29 29 29 0a 09 20 20 28 64 65 62 tinfo))).. (deb
16c0: 75 67 3a 70 72 69 6e 74 2d 69 6e 66 6f 20 32 20 ug:print-info 2
16d0: 22 53 65 74 74 69 6e 67 20 75 70 20 74 6f 20 63 "Setting up to c
16e0: 6f 6e 6e 65 63 74 20 74 6f 20 22 20 68 6f 73 74 onnect to " host
16f0: 69 6e 66 6f 29 0a 09 20 20 28 68 61 6e 64 6c 65 info).. (handle
1700: 2d 65 78 63 65 70 74 69 6f 6e 73 0a 09 20 20 20 -exceptions..
1710: 65 78 6e 0a 09 20 20 20 28 62 65 67 69 6e 0a 09 exn.. (begin..
1720: 20 20 20 20 20 28 64 65 62 75 67 3a 70 72 69 6e (debug:prin
1730: 74 20 30 20 22 45 52 52 4f 52 3a 20 46 61 69 6c t 0 "ERROR: Fail
1740: 65 64 20 74 6f 20 6f 70 65 6e 20 61 20 63 6f 6e ed to open a con
1750: 6e 65 63 74 69 6f 6e 20 74 6f 20 74 68 65 20 73 nection to the s
1760: 65 72 76 65 72 20 61 74 3a 20 22 20 68 6f 73 74 erver at: " host
1770: 69 6e 66 6f 29 0a 09 20 20 20 20 20 28 64 65 62 info).. (deb
1780: 75 67 3a 70 72 69 6e 74 20 30 20 22 20 20 20 45 ug:print 0 " E
1790: 58 43 45 50 54 49 4f 4e 3a 20 22 20 28 28 63 6f XCEPTION: " ((co
17a0: 6e 64 69 74 69 6f 6e 2d 70 72 6f 70 65 72 74 79 ndition-property
17b0: 2d 61 63 63 65 73 73 6f 72 20 27 65 78 6e 20 27 -accessor 'exn '
17c0: 6d 65 73 73 61 67 65 29 20 65 78 6e 29 29 0a 09 message) exn))..
17d0: 20 20 20 20 20 28 64 65 62 75 67 3a 70 72 69 6e (debug:prin
17e0: 74 20 30 20 22 20 20 20 70 65 72 68 61 70 73 20 t 0 " perhaps
17f0: 6a 6f 62 73 20 6b 69 6c 6c 65 64 20 77 69 74 68 jobs killed with
1800: 20 2d 39 3f 20 52 65 6d 6f 76 69 6e 67 20 73 65 -9? Removing se
1810: 72 76 65 72 20 72 65 63 6f 72 64 73 22 29 0a 09 rver records")..
1820: 20 20 20 20 20 28 6f 70 65 6e 2d 72 75 6e 2d 63 (open-run-c
1830: 6c 6f 73 65 20 74 61 73 6b 73 3a 73 65 72 76 65 lose tasks:serve
1840: 72 2d 64 65 72 65 67 69 73 74 65 72 20 74 61 73 r-deregister tas
1850: 6b 73 3a 6f 70 65 6e 2d 64 62 20 68 6f 73 74 20 ks:open-db host
1860: 70 6f 72 74 3a 20 70 6f 72 74 29 0a 09 20 20 20 port: port)..
1870: 20 20 23 66 29 0a 09 20 20 20 28 6c 65 74 2a 20 #f).. (let*
1880: 28 28 7a 6d 71 2d 73 6f 63 6b 65 74 20 28 73 65 ((zmq-socket (se
1890: 72 76 65 72 3a 63 6c 69 65 6e 74 2d 63 6f 6e 6e rver:client-conn
18a0: 65 63 74 20 68 6f 73 74 20 70 6f 72 74 29 29 0a ect host port)).
18b0: 09 09 20 20 28 6c 6f 67 69 6e 2d 72 65 73 20 20 .. (login-res
18c0: 28 73 65 72 76 65 72 3a 63 6c 69 65 6e 74 2d 6c (server:client-l
18d0: 6f 67 69 6e 20 7a 6d 71 2d 73 6f 63 6b 65 74 29 ogin zmq-socket)
18e0: 29 0a 09 09 20 20 28 63 6f 6e 6e 65 63 74 2d 6f )... (connect-o
18f0: 6b 20 28 69 66 20 28 6e 75 6c 6c 3f 20 6c 6f 67 k (if (null? log
1900: 69 6e 2d 72 65 73 29 20 23 66 20 28 63 61 72 20 in-res) #f (car
1910: 6c 6f 67 69 6e 2d 72 65 73 29 29 29 0a 09 09 20 login-res)))...
1920: 20 28 63 6f 6e 75 72 6c 20 20 20 20 20 28 73 65 (conurl (se
1930: 72 76 65 72 3a 6d 61 6b 65 2d 73 65 72 76 65 72 rver:make-server
1940: 2d 75 72 6c 20 68 6f 73 74 69 6e 66 6f 29 29 29 -url hostinfo)))
1950: 0a 09 20 20 20 20 20 28 69 66 20 63 6f 6e 6e 65 .. (if conne
1960: 63 74 2d 6f 6b 0a 09 09 20 28 62 65 67 69 6e 0a ct-ok... (begin.
1970: 09 09 20 20 20 28 64 65 62 75 67 3a 70 72 69 6e .. (debug:prin
1980: 74 2d 69 6e 66 6f 20 32 20 22 4c 6f 67 67 65 64 t-info 2 "Logged
1990: 20 69 6e 20 61 6e 64 20 63 6f 6e 6e 65 63 74 65 in and connecte
19a0: 64 20 74 6f 20 22 20 63 6f 6e 75 72 6c 29 0a 09 d to " conurl)..
19b0: 09 20 20 20 28 73 65 74 21 20 2a 72 75 6e 72 65 . (set! *runre
19c0: 6d 6f 74 65 2a 20 7a 6d 71 2d 73 6f 63 6b 65 74 mote* zmq-socket
19d0: 29 0a 09 09 20 20 20 23 74 29 0a 09 09 20 28 62 )... #t)... (b
19e0: 65 67 69 6e 0a 09 09 20 20 20 28 64 65 62 75 67 egin... (debug
19f0: 3a 70 72 69 6e 74 2d 69 6e 66 6f 20 32 20 22 46 :print-info 2 "F
1a00: 61 69 6c 65 64 20 74 6f 20 6c 6f 67 69 6e 20 6f ailed to login o
1a10: 72 20 63 6f 6e 6e 65 63 74 20 74 6f 20 22 20 63 r connect to " c
1a20: 6f 6e 75 72 6c 29 0a 09 09 20 20 20 28 73 65 74 onurl)... (set
1a30: 21 20 2a 72 75 6e 72 65 6d 6f 74 65 2a 20 23 66 ! *runremote* #f
1a40: 29 0a 09 09 20 20 20 23 66 29 29 29 29 29 0a 09 )... #f)))))..
1a50: 28 69 66 20 28 3e 20 6e 75 6d 74 72 69 65 73 20 (if (> numtries
1a60: 30 29 0a 09 20 20 20 20 28 6c 65 74 20 28 28 65 0).. (let ((e
1a70: 78 65 20 28 63 61 72 20 28 61 72 67 76 29 29 29 xe (car (argv)))
1a80: 29 0a 09 20 20 20 20 20 20 28 64 65 62 75 67 3a ).. (debug:
1a90: 70 72 69 6e 74 2d 69 6e 66 6f 20 31 20 22 4e 6f print-info 1 "No
1aa0: 20 73 65 72 76 65 72 20 61 76 61 69 6c 61 62 6c server availabl
1ab0: 65 2c 20 61 74 74 65 6d 70 74 69 6e 67 20 74 6f e, attempting to
1ac0: 20 73 74 61 72 74 20 6f 6e 65 2e 2e 2e 22 29 0a start one...").
1ad0: 09 20 20 20 20 20 20 28 70 72 6f 63 65 73 73 2d . (process-
1ae0: 72 75 6e 20 65 78 65 20 28 6c 69 73 74 20 22 2d run exe (list "-
1af0: 73 65 72 76 65 72 22 20 22 2d 22 20 22 2d 64 65 server" "-" "-de
1b00: 62 75 67 22 20 28 63 6f 6e 63 20 2a 76 65 72 62 bug" (conc *verb
1b10: 6f 73 69 74 79 2a 29 29 29 0a 09 20 20 20 20 20 osity*)))..
1b20: 20 3b 3b 20 28 73 79 73 74 65 6d 20 28 63 6f 6e ;; (system (con
1b30: 63 20 20 22 20 2d 73 65 72 76 65 72 20 2d 20 22 c " -server - "
1b40: 20 28 69 66 20 28 61 72 67 73 3a 67 65 74 2d 61 (if (args:get-a
1b50: 72 67 20 22 2d 64 65 62 75 67 22 29 0a 09 20 20 rg "-debug")..
1b60: 20 20 20 20 3b 3b 20 20 20 09 09 09 09 09 20 20 ;; .....
1b70: 20 28 63 6f 6e 63 20 22 2d 64 65 62 75 67 20 22 (conc "-debug "
1b80: 20 28 61 72 67 73 3a 67 65 74 2d 61 72 67 20 22 (args:get-arg "
1b90: 2d 64 65 62 75 67 22 29 29 0a 09 20 20 20 20 20 -debug"))..
1ba0: 20 3b 3b 20 20 20 09 09 09 09 09 20 20 20 22 22 ;; ..... ""
1bb0: 29 0a 09 20 20 20 20 20 20 3b 3b 20 20 20 09 20 ).. ;; .
1bc0: 20 20 20 22 20 26 22 29 29 0a 09 20 20 20 20 20 " &"))..
1bd0: 20 28 73 6c 65 65 70 20 31 30 29 0a 09 20 20 20 (sleep 10)..
1be0: 20 20 20 28 73 65 72 76 65 72 3a 63 6c 69 65 6e (server:clien
1bf0: 74 2d 73 65 74 75 70 20 6e 75 6d 74 72 69 65 73 t-setup numtries
1c00: 3a 20 28 2d 20 6e 75 6d 74 72 69 65 73 20 31 29 : (- numtries 1)
1c10: 29 29 0a 09 20 20 20 20 28 64 65 62 75 67 3a 70 )).. (debug:p
1c20: 72 69 6e 74 2d 69 6e 66 6f 20 31 20 22 54 6f 6f rint-info 1 "Too
1c30: 20 6d 61 6e 79 20 72 65 74 72 69 65 73 2c 20 67 many retries, g
1c40: 69 76 69 6e 67 20 75 70 22 29 29 29 29 29 0a 0a iving up")))))..
1c50: 28 64 65 66 69 6e 65 20 28 73 65 72 76 65 72 3a (define (server:
1c60: 6c 61 75 6e 63 68 29 0a 20 20 28 6c 65 74 2a 20 launch). (let*
1c70: 28 28 74 6f 70 70 61 74 68 20 28 73 65 74 75 70 ((toppath (setup
1c80: 2d 66 6f 72 2d 72 75 6e 29 29 29 0a 20 20 20 20 -for-run))).
1c90: 28 64 65 62 75 67 3a 70 72 69 6e 74 2d 69 6e 66 (debug:print-inf
1ca0: 6f 20 30 20 22 53 74 61 72 74 69 6e 67 20 74 68 o 0 "Starting th
1cb0: 65 20 73 74 61 6e 64 61 6c 6f 6e 65 20 73 65 72 e standalone ser
1cc0: 76 65 72 22 29 0a 20 20 20 20 28 69 66 20 2a 74 ver"). (if *t
1cd0: 6f 70 70 61 74 68 2a 20 0a 09 28 6c 65 74 2a 20 oppath* ..(let*
1ce0: 28 28 74 68 32 20 28 6d 61 6b 65 2d 74 68 72 65 ((th2 (make-thre
1cf0: 61 64 20 28 6c 61 6d 62 64 61 20 28 29 0a 09 09 ad (lambda ()...
1d00: 09 09 20 20 20 28 73 65 72 76 65 72 3a 72 75 6e .. (server:run
1d10: 20 28 61 72 67 73 3a 67 65 74 2d 61 72 67 20 22 (args:get-arg "
1d20: 2d 73 65 72 76 65 72 22 29 29 29 29 29 29 0a 09 -server"))))))..
1d30: 20 20 3b 3b 20 28 74 68 33 20 28 6d 61 6b 65 2d ;; (th3 (make-
1d40: 74 68 72 65 61 64 20 28 6c 61 6d 62 64 61 20 28 thread (lambda (
1d50: 29 0a 09 20 20 3b 3b 20 20 20 20 20 20 20 09 09 ).. ;; ..
1d60: 20 20 20 28 73 65 72 76 65 72 3a 6b 65 65 70 2d (server:keep-
1d70: 72 75 6e 6e 69 6e 67 29 29 29 29 29 0a 09 20 20 running)))))..
1d80: 28 74 68 72 65 61 64 2d 73 74 61 72 74 21 20 74 (thread-start! t
1d90: 68 32 29 0a 09 20 20 3b 3b 20 28 74 68 72 65 61 h2).. ;; (threa
1da0: 64 2d 73 74 61 72 74 21 20 74 68 33 29 0a 09 20 d-start! th3)..
1db0: 20 28 73 65 74 21 20 2a 64 69 64 73 6f 6d 65 74 (set! *didsomet
1dc0: 68 69 6e 67 2a 20 23 74 29 0a 09 20 20 28 74 68 hing* #t).. (th
1dd0: 72 65 61 64 2d 6a 6f 69 6e 21 20 74 68 32 29 29 read-join! th2))
1de0: 0a 09 28 64 65 62 75 67 3a 70 72 69 6e 74 20 30 ..(debug:print 0
1df0: 20 22 45 52 52 4f 52 3a 20 46 61 69 6c 65 64 20 "ERROR: Failed
1e00: 74 6f 20 73 65 74 75 70 20 66 6f 72 20 6d 65 67 to setup for meg
1e10: 61 74 65 73 74 22 29 29 29 29 0a 0a 28 64 65 66 atest"))))..(def
1e20: 69 6e 65 20 28 73 65 72 76 65 72 3a 63 6c 69 65 ine (server:clie
1e30: 6e 74 2d 6c 61 75 6e 63 68 29 0a 20 20 28 69 66 nt-launch). (if
1e40: 20 28 73 65 72 76 65 72 3a 63 6c 69 65 6e 74 2d (server:client-
1e50: 73 65 74 75 70 29 0a 20 20 20 20 20 20 28 64 65 setup). (de
1e60: 62 75 67 3a 70 72 69 6e 74 2d 69 6e 66 6f 20 30 bug:print-info 0
1e70: 20 22 63 6f 6e 6e 65 63 74 65 64 20 61 73 20 63 "connected as c
1e80: 6c 69 65 6e 74 22 29 0a 20 20 20 20 20 20 28 62 lient"). (b
1e90: 65 67 69 6e 0a 09 28 64 65 62 75 67 3a 70 72 69 egin..(debug:pri
1ea0: 6e 74 20 30 20 22 45 52 52 4f 52 3a 20 46 61 69 nt 0 "ERROR: Fai
1eb0: 6c 65 64 20 74 6f 20 63 6f 6e 6e 65 63 74 20 61 led to connect a
1ec0: 73 20 63 6c 69 65 6e 74 22 29 0a 09 28 65 78 69 s client")..(exi
1ed0: 74 29 29 29 29 0a t)))).