Artifact
a2667654651e2b4be5757cc5684bfa9d6fb48abc:
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 37 2c 20 4d 61 74 74 68 65 77 06-2017, Matthew
0020: 20 57 65 6c 6c 61 6e 64 2e 0a 3b 3b 20 0a 3b 3b Welland..;; .;;
0030: 20 54 68 69 73 20 66 69 6c 65 20 69 73 20 70 61 This file is pa
0040: 72 74 20 6f 66 20 4d 65 67 61 74 65 73 74 2e 0a rt of Megatest..
0050: 3b 3b 20 0a 3b 3b 20 20 20 20 20 4d 65 67 61 74 ;; .;; Megat
0060: 65 73 74 20 69 73 20 66 72 65 65 20 73 6f 66 74 est is free soft
0070: 77 61 72 65 3a 20 79 6f 75 20 63 61 6e 20 72 65 ware: you can re
0080: 64 69 73 74 72 69 62 75 74 65 20 69 74 20 61 6e distribute it an
0090: 64 2f 6f 72 20 6d 6f 64 69 66 79 0a 3b 3b 20 20 d/or modify.;;
00a0: 20 20 20 69 74 20 75 6e 64 65 72 20 74 68 65 20 it under the
00b0: 74 65 72 6d 73 20 6f 66 20 74 68 65 20 47 4e 55 terms of the GNU
00c0: 20 47 65 6e 65 72 61 6c 20 50 75 62 6c 69 63 20 General Public
00d0: 4c 69 63 65 6e 73 65 20 61 73 20 70 75 62 6c 69 License as publi
00e0: 73 68 65 64 20 62 79 0a 3b 3b 20 20 20 20 20 74 shed by.;; t
00f0: 68 65 20 46 72 65 65 20 53 6f 66 74 77 61 72 65 he Free Software
0100: 20 46 6f 75 6e 64 61 74 69 6f 6e 2c 20 65 69 74 Foundation, eit
0110: 68 65 72 20 76 65 72 73 69 6f 6e 20 33 20 6f 66 her version 3 of
0120: 20 74 68 65 20 4c 69 63 65 6e 73 65 2c 20 6f 72 the License, or
0130: 0a 3b 3b 20 20 20 20 20 28 61 74 20 79 6f 75 72 .;; (at your
0140: 20 6f 70 74 69 6f 6e 29 20 61 6e 79 20 6c 61 74 option) any lat
0150: 65 72 20 76 65 72 73 69 6f 6e 2e 0a 3b 3b 20 0a er version..;; .
0160: 3b 3b 20 20 20 20 20 4d 65 67 61 74 65 73 74 20 ;; Megatest
0170: 69 73 20 64 69 73 74 72 69 62 75 74 65 64 20 69 is distributed i
0180: 6e 20 74 68 65 20 68 6f 70 65 20 74 68 61 74 20 n the hope that
0190: 69 74 20 77 69 6c 6c 20 62 65 20 75 73 65 66 75 it will be usefu
01a0: 6c 2c 0a 3b 3b 20 20 20 20 20 62 75 74 20 57 49 l,.;; but WI
01b0: 54 48 4f 55 54 20 41 4e 59 20 57 41 52 52 41 4e THOUT ANY WARRAN
01c0: 54 59 3b 20 77 69 74 68 6f 75 74 20 65 76 65 6e TY; without even
01d0: 20 74 68 65 20 69 6d 70 6c 69 65 64 20 77 61 72 the implied war
01e0: 72 61 6e 74 79 20 6f 66 0a 3b 3b 20 20 20 20 20 ranty of.;;
01f0: 4d 45 52 43 48 41 4e 54 41 42 49 4c 49 54 59 20 MERCHANTABILITY
0200: 6f 72 20 46 49 54 4e 45 53 53 20 46 4f 52 20 41 or FITNESS FOR A
0210: 20 50 41 52 54 49 43 55 4c 41 52 20 50 55 52 50 PARTICULAR PURP
0220: 4f 53 45 2e 20 20 53 65 65 20 74 68 65 0a 3b 3b OSE. See the.;;
0230: 20 20 20 20 20 47 4e 55 20 47 65 6e 65 72 61 6c GNU General
0240: 20 50 75 62 6c 69 63 20 4c 69 63 65 6e 73 65 20 Public License
0250: 66 6f 72 20 6d 6f 72 65 20 64 65 74 61 69 6c 73 for more details
0260: 2e 0a 3b 3b 20 0a 3b 3b 20 20 20 20 20 59 6f 75 ..;; .;; You
0270: 20 73 68 6f 75 6c 64 20 68 61 76 65 20 72 65 63 should have rec
0280: 65 69 76 65 64 20 61 20 63 6f 70 79 20 6f 66 20 eived a copy of
0290: 74 68 65 20 47 4e 55 20 47 65 6e 65 72 61 6c 20 the GNU General
02a0: 50 75 62 6c 69 63 20 4c 69 63 65 6e 73 65 0a 3b Public License.;
02b0: 3b 20 20 20 20 20 61 6c 6f 6e 67 20 77 69 74 68 ; along with
02c0: 20 4d 65 67 61 74 65 73 74 2e 20 20 49 66 20 6e Megatest. If n
02d0: 6f 74 2c 20 73 65 65 20 3c 68 74 74 70 3a 2f 2f ot, see <http://
02e0: 77 77 77 2e 67 6e 75 2e 6f 72 67 2f 6c 69 63 65 www.gnu.org/lice
02f0: 6e 73 65 73 2f 3e 2e 0a 3b 3b 0a 0a 28 72 65 71 nses/>..;;..(req
0300: 75 69 72 65 2d 65 78 74 65 6e 73 69 6f 6e 20 28 uire-extension (
0310: 73 72 66 69 20 31 38 29 20 65 78 74 72 61 73 20 srfi 18) extras
0320: 74 63 70 20 73 31 31 6e 29 0a 0a 28 75 73 65 20 tcp s11n)..(use
0330: 73 72 66 69 2d 31 20 70 6f 73 69 78 20 72 65 67 srfi-1 posix reg
0340: 65 78 20 72 65 67 65 78 2d 63 61 73 65 20 73 72 ex regex-case sr
0350: 66 69 2d 36 39 20 68 6f 73 74 69 6e 66 6f 20 6d fi-69 hostinfo m
0360: 64 35 20 6d 65 73 73 61 67 65 2d 64 69 67 65 73 d5 message-diges
0370: 74 0a 20 20 20 20 20 64 69 72 65 63 74 6f 72 79 t. directory
0380: 2d 75 74 69 6c 73 20 70 6f 73 69 78 2d 65 78 74 -utils posix-ext
0390: 72 61 73 20 6d 61 74 63 68 61 62 6c 65 29 0a 0a ras matchable)..
03a0: 28 75 73 65 20 73 70 69 66 66 79 20 75 72 69 2d (use spiffy uri-
03b0: 63 6f 6d 6d 6f 6e 20 69 6e 74 61 72 77 65 62 20 common intarweb
03c0: 68 74 74 70 2d 63 6c 69 65 6e 74 20 73 70 69 66 http-client spif
03d0: 66 79 2d 72 65 71 75 65 73 74 2d 76 61 72 73 29 fy-request-vars)
03e0: 0a 0a 28 64 65 63 6c 61 72 65 20 28 75 6e 69 74 ..(declare (unit
03f0: 20 73 65 72 76 65 72 29 29 0a 0a 28 64 65 63 6c server))..(decl
0400: 61 72 65 20 28 75 73 65 73 20 63 6f 6d 6d 6f 6e are (uses common
0410: 29 29 0a 28 64 65 63 6c 61 72 65 20 28 75 73 65 )).(declare (use
0420: 73 20 64 62 29 29 0a 28 64 65 63 6c 61 72 65 20 s db)).(declare
0430: 28 75 73 65 73 20 74 61 73 6b 73 29 29 20 3b 3b (uses tasks)) ;;
0440: 20 74 61 73 6b 73 20 61 72 65 20 77 68 65 72 65 tasks are where
0450: 20 73 74 75 66 66 20 69 73 20 6d 61 69 6e 74 61 stuff is mainta
0460: 69 6e 65 64 20 61 62 6f 75 74 20 77 68 61 74 20 ined about what
0470: 69 73 20 72 75 6e 6e 69 6e 67 2e 0a 3b 3b 20 28 is running..;; (
0480: 64 65 63 6c 61 72 65 20 28 75 73 65 73 20 73 79 declare (uses sy
0490: 6e 63 68 61 73 68 29 29 0a 28 64 65 63 6c 61 72 nchash)).(declar
04a0: 65 20 28 75 73 65 73 20 68 74 74 70 2d 74 72 61 e (uses http-tra
04b0: 6e 73 70 6f 72 74 29 29 0a 3b 3b 28 64 65 63 6c nsport)).;;(decl
04c0: 61 72 65 20 28 75 73 65 73 20 72 70 63 2d 74 72 are (uses rpc-tr
04d0: 61 6e 73 70 6f 72 74 29 29 0a 28 64 65 63 6c 61 ansport)).(decla
04e0: 72 65 20 28 75 73 65 73 20 6c 61 75 6e 63 68 29 re (uses launch)
04f0: 29 0a 3b 3b 20 28 64 65 63 6c 61 72 65 20 28 75 ).;; (declare (u
0500: 73 65 73 20 64 61 65 6d 6f 6e 29 29 0a 0a 28 69 ses daemon))..(i
0510: 6e 63 6c 75 64 65 20 22 63 6f 6d 6d 6f 6e 5f 72 nclude "common_r
0520: 65 63 6f 72 64 73 2e 73 63 6d 22 29 0a 28 69 6e ecords.scm").(in
0530: 63 6c 75 64 65 20 22 64 62 5f 72 65 63 6f 72 64 clude "db_record
0540: 73 2e 73 63 6d 22 29 0a 0a 28 64 65 66 69 6e 65 s.scm")..(define
0550: 20 28 73 65 72 76 65 72 3a 6d 61 6b 65 2d 73 65 (server:make-se
0560: 72 76 65 72 2d 75 72 6c 20 68 6f 73 74 70 6f 72 rver-url hostpor
0570: 74 29 0a 20 20 28 69 66 20 28 6e 6f 74 20 68 6f t). (if (not ho
0580: 73 74 70 6f 72 74 29 0a 20 20 20 20 20 20 23 66 stport). #f
0590: 0a 20 20 20 20 20 20 28 63 6f 6e 63 20 22 68 74 . (conc "ht
05a0: 74 70 3a 2f 2f 22 20 28 63 61 72 20 68 6f 73 74 tp://" (car host
05b0: 70 6f 72 74 29 20 22 3a 22 20 28 63 61 64 72 20 port) ":" (cadr
05c0: 68 6f 73 74 70 6f 72 74 29 29 29 29 0a 0a 28 64 hostport))))..(d
05d0: 65 66 69 6e 65 20 20 2a 73 65 72 76 65 72 2d 6c efine *server-l
05e0: 6f 6f 70 2d 68 65 61 72 74 2d 62 65 61 74 2a 20 oop-heart-beat*
05f0: 28 63 75 72 72 65 6e 74 2d 73 65 63 6f 6e 64 73 (current-seconds
0600: 29 29 0a 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ))..;;==========
0610: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0620: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0630: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0640: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a 3b 3b 20 ============.;;
0650: 50 20 4b 20 54 20 53 20 20 20 53 20 54 20 55 20 P K T S S T U
0660: 46 20 46 20 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d F F .;;=========
0670: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0680: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0690: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
06a0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a 0a 3b =============..;
06b0: 3b 20 3f 3f 3f 0a 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d ; ???..;;=======
06c0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
06d0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
06e0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
06f0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a ===============.
0700: 3b 3b 20 50 20 4b 20 54 20 53 20 20 20 53 20 54 ;; P K T S S T
0710: 20 55 20 46 20 46 20 0a 3b 3b 3d 3d 3d 3d 3d 3d U F F .;;======
0720: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0730: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0740: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0750: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0760: 0a 0a 3b 3b 20 3f 3f 3f 0a 0a 3b 3b 3d 3d 3d 3d ..;; ???..;;====
0770: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0780: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0790: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
07a0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
07b0: 3d 3d 0a 3b 3b 20 53 20 45 20 52 20 56 20 45 20 ==.;; S E R V E
07c0: 52 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d R.;;============
07d0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
07e0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
07f0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0800: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a 0a 3b 3b 20 43 ==========..;; C
0810: 61 6c 6c 20 74 68 69 73 20 74 6f 20 73 74 61 72 all this to star
0820: 74 20 74 68 65 20 61 63 74 75 61 6c 20 73 65 72 t the actual ser
0830: 76 65 72 0a 3b 3b 0a 0a 3b 3b 20 61 6c 6c 20 72 ver.;;..;; all r
0840: 6f 75 74 65 73 20 74 68 6f 75 67 68 20 68 65 72 outes though her
0850: 65 20 65 6e 64 20 69 6e 20 65 78 69 74 20 2e 2e e end in exit ..
0860: 2e 0a 3b 3b 0a 3b 3b 20 73 74 61 72 74 5f 73 65 ..;;.;; start_se
0870: 72 76 65 72 0a 3b 3b 0a 28 64 65 66 69 6e 65 20 rver.;;.(define
0880: 28 73 65 72 76 65 72 3a 6c 61 75 6e 63 68 20 72 (server:launch r
0890: 75 6e 2d 69 64 20 74 72 61 6e 73 70 6f 72 74 2d un-id transport-
08a0: 74 79 70 65 29 0a 20 20 28 63 61 73 65 20 74 72 type). (case tr
08b0: 61 6e 73 70 6f 72 74 2d 74 79 70 65 0a 20 20 20 ansport-type.
08c0: 20 28 28 68 74 74 70 29 28 68 74 74 70 2d 74 72 ((http)(http-tr
08d0: 61 6e 73 70 6f 72 74 3a 6c 61 75 6e 63 68 29 29 ansport:launch))
08e0: 0a 20 20 20 20 3b 3b 28 28 6e 6d 73 67 29 28 6e . ;;((nmsg)(n
08f0: 6d 73 67 2d 74 72 61 6e 73 70 6f 72 74 3a 6c 61 msg-transport:la
0900: 75 6e 63 68 20 72 75 6e 2d 69 64 29 29 0a 20 20 unch run-id)).
0910: 20 20 3b 3b 28 28 72 70 63 29 20 20 28 72 70 63 ;;((rpc) (rpc
0920: 2d 74 72 61 6e 73 70 6f 72 74 3a 6c 61 75 6e 63 -transport:launc
0930: 68 20 72 75 6e 2d 69 64 29 29 0a 20 20 20 20 28 h run-id)). (
0940: 65 6c 73 65 20 28 64 65 62 75 67 3a 70 72 69 6e else (debug:prin
0950: 74 2d 65 72 72 6f 72 20 30 20 2a 64 65 66 61 75 t-error 0 *defau
0960: 6c 74 2d 6c 6f 67 2d 70 6f 72 74 2a 20 22 75 6e lt-log-port* "un
0970: 6b 6e 6f 77 6e 20 73 65 72 76 65 72 20 74 79 70 known server typ
0980: 65 20 22 20 74 72 61 6e 73 70 6f 72 74 2d 74 79 e " transport-ty
0990: 70 65 29 29 29 29 0a 0a 3b 3b 3d 3d 3d 3d 3d 3d pe))))..;;======
09a0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
09b0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
09c0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
09d0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
09e0: 0a 3b 3b 20 53 20 45 20 52 20 56 20 45 20 52 20 .;; S E R V E R
09f0: 20 20 55 20 54 20 49 20 4c 20 49 20 54 20 49 20 U T I L I T I
0a00: 45 20 53 20 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d E S .;;=========
0a10: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0a20: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0a30: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0a40: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a 0a 3b =============..;
0a50: 3b 20 47 65 74 20 74 68 65 20 74 72 61 6e 73 70 ; Get the transp
0a60: 6f 72 74 0a 28 64 65 66 69 6e 65 20 28 73 65 72 ort.(define (ser
0a70: 76 65 72 3a 67 65 74 2d 74 72 61 6e 73 70 6f 72 ver:get-transpor
0a80: 74 29 0a 20 20 28 69 66 20 2a 74 72 61 6e 73 70 t). (if *transp
0a90: 6f 72 74 2d 74 79 70 65 2a 0a 20 20 20 20 20 20 ort-type*.
0aa0: 2a 74 72 61 6e 73 70 6f 72 74 2d 74 79 70 65 2a *transport-type*
0ab0: 0a 20 20 20 20 20 20 28 6c 65 74 20 28 28 74 74 . (let ((tt
0ac0: 79 70 65 20 28 73 74 72 69 6e 67 2d 3e 73 79 6d ype (string->sym
0ad0: 62 6f 6c 0a 09 09 20 20 20 20 28 6f 72 20 28 61 bol... (or (a
0ae0: 72 67 73 3a 67 65 74 2d 61 72 67 20 22 2d 74 72 rgs:get-arg "-tr
0af0: 61 6e 73 70 6f 72 74 22 29 0a 09 09 09 28 63 6f ansport")....(co
0b00: 6e 66 69 67 66 3a 6c 6f 6f 6b 75 70 20 2a 63 6f nfigf:lookup *co
0b10: 6e 66 69 67 64 61 74 2a 20 22 73 65 72 76 65 72 nfigdat* "server
0b20: 22 20 22 74 72 61 6e 73 70 6f 72 74 22 29 0a 09 " "transport")..
0b30: 09 09 22 72 70 63 22 29 29 29 29 0a 09 28 73 65 .."rpc"))))..(se
0b40: 74 21 20 2a 74 72 61 6e 73 70 6f 72 74 2d 74 79 t! *transport-ty
0b50: 70 65 2a 20 74 74 79 70 65 29 0a 09 74 74 79 70 pe* ttype)..ttyp
0b60: 65 29 29 29 0a 09 20 20 20 20 0a 3b 3b 20 47 65 e))).. .;; Ge
0b70: 6e 65 72 61 74 65 20 61 20 75 6e 69 71 75 65 20 nerate a unique
0b80: 73 69 67 6e 61 74 75 72 65 20 66 6f 72 20 74 68 signature for th
0b90: 69 73 20 73 65 72 76 65 72 0a 28 64 65 66 69 6e is server.(defin
0ba0: 65 20 28 73 65 72 76 65 72 3a 6d 6b 2d 73 69 67 e (server:mk-sig
0bb0: 6e 61 74 75 72 65 29 0a 20 20 28 6d 65 73 73 61 nature). (messa
0bc0: 67 65 2d 64 69 67 65 73 74 2d 73 74 72 69 6e 67 ge-digest-string
0bd0: 20 28 6d 64 35 2d 70 72 69 6d 69 74 69 76 65 29 (md5-primitive)
0be0: 20 0a 09 09 09 20 28 77 69 74 68 2d 6f 75 74 70 .... (with-outp
0bf0: 75 74 2d 74 6f 2d 73 74 72 69 6e 67 0a 09 09 09 ut-to-string....
0c00: 20 20 20 28 6c 61 6d 62 64 61 20 28 29 0a 09 09 (lambda ()...
0c10: 09 20 20 20 20 20 28 77 72 69 74 65 20 28 6c 69 . (write (li
0c20: 73 74 20 28 63 75 72 72 65 6e 74 2d 64 69 72 65 st (current-dire
0c30: 63 74 6f 72 79 29 0a 09 09 09 09 09 20 20 28 61 ctory)...... (a
0c40: 72 67 76 29 29 29 29 29 29 29 0a 0a 3b 3b 20 57 rgv)))))))..;; W
0c50: 68 65 6e 20 75 73 69 6e 67 20 7a 6d 71 20 74 68 hen using zmq th
0c60: 69 73 20 77 6f 75 6c 64 20 73 65 6e 64 20 74 68 is would send th
0c70: 65 20 6d 65 73 73 61 67 65 20 62 61 63 6b 20 28 e message back (
0c80: 74 77 6f 20 73 74 65 70 20 70 72 6f 63 65 73 73 two step process
0c90: 29 0a 3b 3b 20 77 69 74 68 20 73 70 69 66 66 79 ).;; with spiffy
0ca0: 20 6f 72 20 72 70 63 20 74 68 69 73 20 73 69 6d or rpc this sim
0cb0: 70 6c 79 20 72 65 74 75 72 6e 73 20 74 68 65 20 ply returns the
0cc0: 72 65 74 75 72 6e 20 64 61 74 61 20 74 6f 20 62 return data to b
0cd0: 65 20 72 65 74 75 72 6e 65 64 0a 3b 3b 20 0a 28 e returned.;; .(
0ce0: 64 65 66 69 6e 65 20 28 73 65 72 76 65 72 3a 72 define (server:r
0cf0: 65 70 6c 79 20 72 65 74 75 72 6e 2d 61 64 64 72 eply return-addr
0d00: 20 71 75 65 72 79 2d 73 69 67 20 73 75 63 63 65 query-sig succe
0d10: 73 73 2f 66 61 69 6c 20 72 65 73 75 6c 74 29 0a ss/fail result).
0d20: 20 20 28 64 65 62 75 67 3a 70 72 69 6e 74 2d 69 (debug:print-i
0d30: 6e 66 6f 20 31 31 20 2a 64 65 66 61 75 6c 74 2d nfo 11 *default-
0d40: 6c 6f 67 2d 70 6f 72 74 2a 20 22 73 65 72 76 65 log-port* "serve
0d50: 72 3a 72 65 70 6c 79 20 72 65 74 75 72 6e 2d 61 r:reply return-a
0d60: 64 64 72 3d 22 20 72 65 74 75 72 6e 2d 61 64 64 ddr=" return-add
0d70: 72 20 22 2c 20 72 65 73 75 6c 74 3d 22 20 72 65 r ", result=" re
0d80: 73 75 6c 74 29 0a 20 20 3b 3b 20 28 73 65 6e 64 sult). ;; (send
0d90: 2d 6d 65 73 73 61 67 65 20 70 75 62 73 6f 63 6b -message pubsock
0da0: 20 74 61 72 67 65 74 20 73 65 6e 64 2d 6d 6f 72 target send-mor
0db0: 65 3a 20 23 74 29 0a 20 20 3b 3b 20 28 73 65 6e e: #t). ;; (sen
0dc0: 64 2d 6d 65 73 73 61 67 65 20 70 75 62 73 6f 63 d-message pubsoc
0dd0: 6b 20 0a 20 20 28 63 61 73 65 20 28 73 65 72 76 k . (case (serv
0de0: 65 72 3a 67 65 74 2d 74 72 61 6e 73 70 6f 72 74 er:get-transport
0df0: 29 0a 20 20 20 20 28 28 72 70 63 29 20 20 28 64 ). ((rpc) (d
0e00: 62 3a 6f 62 6a 2d 3e 73 74 72 69 6e 67 20 28 76 b:obj->string (v
0e10: 65 63 74 6f 72 20 73 75 63 63 65 73 73 2f 66 61 ector success/fa
0e20: 69 6c 20 71 75 65 72 79 2d 73 69 67 20 72 65 73 il query-sig res
0e30: 75 6c 74 29 29 29 0a 20 20 20 20 28 28 68 74 74 ult))). ((htt
0e40: 70 29 20 28 64 62 3a 6f 62 6a 2d 3e 73 74 72 69 p) (db:obj->stri
0e50: 6e 67 20 28 76 65 63 74 6f 72 20 73 75 63 63 65 ng (vector succe
0e60: 73 73 2f 66 61 69 6c 20 71 75 65 72 79 2d 73 69 ss/fail query-si
0e70: 67 20 72 65 73 75 6c 74 29 29 29 0a 20 20 20 20 g result))).
0e80: 28 28 66 73 29 20 20 20 72 65 73 75 6c 74 29 0a ((fs) result).
0e90: 20 20 20 20 28 65 6c 73 65 20 0a 20 20 20 20 20 (else .
0ea0: 28 64 65 62 75 67 3a 70 72 69 6e 74 2d 65 72 72 (debug:print-err
0eb0: 6f 72 20 30 20 2a 64 65 66 61 75 6c 74 2d 6c 6f or 0 *default-lo
0ec0: 67 2d 70 6f 72 74 2a 20 22 75 6e 72 65 63 6f 67 g-port* "unrecog
0ed0: 6e 69 73 65 64 20 74 72 61 6e 73 70 6f 72 74 20 nised transport
0ee0: 74 79 70 65 3a 20 22 20 2a 74 72 61 6e 73 70 6f type: " *transpo
0ef0: 72 74 2d 74 79 70 65 2a 29 0a 20 20 20 20 20 72 rt-type*). r
0f00: 65 73 75 6c 74 29 29 29 0a 0a 3b 3b 20 47 69 76 esult)))..;; Giv
0f10: 65 6e 20 61 20 72 75 6e 20 69 64 20 73 74 61 72 en a run id star
0f20: 74 20 61 20 73 65 72 76 65 72 20 70 72 6f 63 65 t a server proce
0f30: 73 73 20 20 20 20 23 23 23 20 4e 4f 54 45 20 23 ss ### NOTE #
0f40: 23 23 20 3e 20 66 69 6c 65 20 32 3e 26 31 20 0a ## > file 2>&1 .
0f50: 3b 3b 20 69 66 20 74 68 65 20 72 75 6e 2d 69 64 ;; if the run-id
0f60: 20 69 73 20 7a 65 72 6f 20 61 6e 64 20 74 68 65 is zero and the
0f70: 20 74 61 72 67 65 74 2d 68 6f 73 74 20 69 73 20 target-host is
0f80: 73 65 74 20 0a 3b 3b 20 74 72 79 20 72 75 6e 6e set .;; try runn
0f90: 69 6e 67 20 6f 6e 20 74 68 61 74 20 68 6f 73 74 ing on that host
0fa0: 0a 3b 3b 20 20 20 69 6e 63 69 64 65 6e 74 61 6c .;; incidental
0fb0: 3a 20 72 6f 74 61 74 65 20 6c 6f 67 73 20 69 6e : rotate logs in
0fc0: 20 6c 6f 67 73 2f 20 64 69 72 2e 0a 3b 3b 0a 28 logs/ dir..;;.(
0fd0: 64 65 66 69 6e 65 20 20 28 73 65 72 76 65 72 3a define (server:
0fe0: 72 75 6e 20 61 72 65 61 70 61 74 68 29 20 3b 3b run areapath) ;;
0ff0: 20 61 72 65 61 70 61 74 68 20 69 73 20 2a 74 6f areapath is *to
1000: 70 70 61 74 68 2a 20 66 6f 72 20 61 20 67 69 76 ppath* for a giv
1010: 65 6e 20 74 65 73 74 73 75 69 74 65 20 61 72 65 en testsuite are
1020: 61 0a 20 20 28 6c 65 74 2a 20 28 28 63 75 72 72 a. (let* ((curr
1030: 2d 68 6f 73 74 20 20 20 28 67 65 74 2d 68 6f 73 -host (get-hos
1040: 74 2d 6e 61 6d 65 29 29 0a 20 20 20 20 20 20 20 t-name)).
1050: 20 20 3b 3b 20 28 61 74 74 65 6d 70 74 2d 69 6e ;; (attempt-in
1060: 2d 70 72 6f 67 72 65 73 73 20 28 73 65 72 76 65 -progress (serve
1070: 72 3a 73 74 61 72 74 2d 61 74 74 65 6d 70 74 65 r:start-attempte
1080: 64 3f 20 61 72 65 61 70 61 74 68 29 29 0a 20 20 d? areapath)).
1090: 20 20 20 20 20 20 20 3b 3b 20 28 64 6f 74 2d 73 ;; (dot-s
10a0: 65 72 76 65 72 2d 75 72 6c 20 28 73 65 72 76 65 erver-url (serve
10b0: 72 3a 63 68 65 63 6b 2d 69 66 2d 72 75 6e 6e 69 r:check-if-runni
10c0: 6e 67 20 61 72 65 61 70 61 74 68 29 29 0a 09 20 ng areapath))..
10d0: 28 63 75 72 72 2d 69 70 20 20 20 20 20 28 73 65 (curr-ip (se
10e0: 72 76 65 72 3a 67 65 74 2d 62 65 73 74 2d 67 75 rver:get-best-gu
10f0: 65 73 73 2d 61 64 64 72 65 73 73 20 63 75 72 72 ess-address curr
1100: 2d 68 6f 73 74 29 29 0a 09 20 28 63 75 72 72 2d -host)).. (curr-
1110: 70 69 64 20 20 20 20 28 63 75 72 72 65 6e 74 2d pid (current-
1120: 70 72 6f 63 65 73 73 2d 69 64 29 29 0a 09 20 28 process-id)).. (
1130: 68 6f 6d 65 68 6f 73 74 20 20 20 20 28 63 6f 6d homehost (com
1140: 6d 6f 6e 3a 67 65 74 2d 68 6f 6d 65 68 6f 73 74 mon:get-homehost
1150: 29 29 20 3b 3b 20 63 6f 6e 66 69 67 66 3a 6c 6f )) ;; configf:lo
1160: 6f 6b 75 70 20 2a 63 6f 6e 66 69 67 64 61 74 2a okup *configdat*
1170: 20 22 73 65 72 76 65 72 22 20 22 68 6f 6d 65 68 "server" "homeh
1180: 6f 73 74 22 20 29 29 0a 09 20 28 74 61 72 67 65 ost" )).. (targe
1190: 74 2d 68 6f 73 74 20 28 63 61 72 20 68 6f 6d 65 t-host (car home
11a0: 68 6f 73 74 29 29 0a 09 20 28 74 65 73 74 73 75 host)).. (testsu
11b0: 69 74 65 20 20 20 28 63 6f 6d 6d 6f 6e 3a 67 65 ite (common:ge
11c0: 74 2d 74 65 73 74 73 75 69 74 65 2d 6e 61 6d 65 t-testsuite-name
11d0: 29 29 0a 09 20 28 6c 6f 67 66 69 6c 65 20 20 20 )).. (logfile
11e0: 20 20 28 63 6f 6e 63 20 61 72 65 61 70 61 74 68 (conc areapath
11f0: 20 22 2f 6c 6f 67 73 2f 73 65 72 76 65 72 2e 6c "/logs/server.l
1200: 6f 67 22 29 29 20 3b 3b 20 2d 22 20 63 75 72 72 og")) ;; -" curr
1210: 2d 70 69 64 20 22 2d 22 20 74 61 72 67 65 74 2d -pid "-" target-
1220: 68 6f 73 74 20 22 2e 6c 6f 67 22 29 29 0a 09 20 host ".log"))..
1230: 28 63 6d 64 6c 6e 20 28 63 6f 6e 63 20 28 63 6f (cmdln (conc (co
1240: 6d 6d 6f 6e 3a 67 65 74 2d 6d 65 67 61 74 65 73 mmon:get-megates
1250: 74 2d 65 78 65 29 0a 09 09 20 20 20 20 20 20 22 t-exe)... "
1260: 20 2d 73 65 72 76 65 72 20 22 20 28 6f 72 20 74 -server " (or t
1270: 61 72 67 65 74 2d 68 6f 73 74 20 22 2d 22 29 20 arget-host "-")
1280: 28 69 66 20 28 65 71 75 61 6c 3f 20 28 63 6f 6e (if (equal? (con
1290: 66 69 67 66 3a 6c 6f 6f 6b 75 70 20 2a 63 6f 6e figf:lookup *con
12a0: 66 69 67 64 61 74 2a 20 22 73 65 72 76 65 72 22 figdat* "server"
12b0: 20 22 64 61 65 6d 6f 6e 69 7a 65 22 29 20 22 79 "daemonize") "y
12c0: 65 73 22 29 0a 09 09 09 09 09 09 09 20 20 20 22 es")........ "
12d0: 20 2d 64 61 65 6d 6f 6e 69 7a 65 20 22 0a 09 09 -daemonize "...
12e0: 09 09 09 09 09 20 20 20 22 22 29 0a 09 09 20 20 ..... "")...
12f0: 20 20 20 20 3b 3b 20 22 20 2d 6c 6f 67 20 22 20 ;; " -log "
1300: 6c 6f 67 66 69 6c 65 0a 09 09 20 20 20 20 20 20 logfile...
1310: 22 20 2d 6d 20 74 65 73 74 73 75 69 74 65 3a 22 " -m testsuite:"
1320: 20 74 65 73 74 73 75 69 74 65 29 29 20 3b 3b 20 testsuite)) ;;
1330: 28 63 6f 6e 63 20 22 20 3e 3e 20 22 20 6c 6f 67 (conc " >> " log
1340: 66 69 6c 65 20 22 20 32 3e 26 31 20 26 22 29 29 file " 2>&1 &"))
1350: 29 29 29 0a 09 20 28 6c 6f 67 2d 72 6f 74 61 74 ))).. (log-rotat
1360: 65 20 20 28 6d 61 6b 65 2d 74 68 72 65 61 64 20 e (make-thread
1370: 63 6f 6d 6d 6f 6e 3a 72 6f 74 61 74 65 2d 6c 6f common:rotate-lo
1380: 67 73 20 20 22 73 65 72 76 65 72 20 72 75 6e 2c gs "server run,
1390: 20 72 6f 74 61 74 65 20 6c 6f 67 73 20 74 68 72 rotate logs thr
13a0: 65 61 64 22 29 29 0a 20 20 20 20 20 20 20 20 20 ead")).
13b0: 28 6c 6f 61 64 2d 6c 69 6d 69 74 20 20 28 63 6f (load-limit (co
13c0: 6e 66 69 67 66 3a 6c 6f 6f 6b 75 70 2d 6e 75 6d nfigf:lookup-num
13d0: 62 65 72 20 2a 63 6f 6e 66 69 67 64 61 74 2a 20 ber *configdat*
13e0: 22 6a 6f 62 74 6f 6f 6c 73 22 20 22 6d 61 78 2d "jobtools" "max-
13f0: 73 65 72 76 65 72 2d 73 74 61 72 74 2d 6c 6f 61 server-start-loa
1400: 64 22 20 64 65 66 61 75 6c 74 3a 20 33 2e 30 29 d" default: 3.0)
1410: 29 29 0a 20 20 20 20 3b 3b 20 77 65 20 77 61 6e )). ;; we wan
1420: 74 20 74 68 65 20 72 65 6d 6f 74 65 20 73 65 72 t the remote ser
1430: 76 65 72 20 74 6f 20 73 74 61 72 74 20 69 6e 20 ver to start in
1440: 2a 74 6f 70 70 61 74 68 2a 20 73 6f 20 70 75 73 *toppath* so pus
1450: 68 20 74 68 65 72 65 0a 20 20 20 20 28 70 75 73 h there. (pus
1460: 68 2d 64 69 72 65 63 74 6f 72 79 20 61 72 65 61 h-directory area
1470: 70 61 74 68 29 0a 20 20 20 20 28 64 65 62 75 67 path). (debug
1480: 3a 70 72 69 6e 74 20 30 20 2a 64 65 66 61 75 6c :print 0 *defaul
1490: 74 2d 6c 6f 67 2d 70 6f 72 74 2a 20 22 49 4e 46 t-log-port* "INF
14a0: 4f 3a 20 54 72 79 69 6e 67 20 74 6f 20 73 74 61 O: Trying to sta
14b0: 72 74 20 73 65 72 76 65 72 20 28 22 20 63 6d 64 rt server (" cmd
14c0: 6c 6e 20 22 29 20 2e 2e 2e 22 29 0a 20 20 20 20 ln ") ...").
14d0: 28 74 68 72 65 61 64 2d 73 74 61 72 74 21 20 6c (thread-start! l
14e0: 6f 67 2d 72 6f 74 61 74 65 29 0a 20 20 20 20 0a og-rotate). .
14f0: 20 20 20 20 3b 3b 20 68 6f 73 74 2e 64 6f 6d 61 ;; host.doma
1500: 69 6e 2e 74 6c 64 20 6d 61 74 63 68 20 68 6f 73 in.tld match hos
1510: 74 3f 0a 20 20 20 20 28 69 66 20 28 61 6e 64 20 t?. (if (and
1520: 74 61 72 67 65 74 2d 68 6f 73 74 20 0a 09 20 20 target-host ..
1530: 20 20 20 3b 3b 20 6c 6f 6f 6b 20 61 74 20 74 61 ;; look at ta
1540: 72 67 65 74 20 68 6f 73 74 2c 20 69 73 20 69 74 rget host, is it
1550: 20 68 6f 73 74 2e 64 6f 6d 61 69 6e 2e 74 6c 64 host.domain.tld
1560: 20 6f 72 20 69 70 20 61 64 64 72 65 73 73 20 61 or ip address a
1570: 6e 64 20 64 6f 65 73 20 69 74 20 0a 09 20 20 20 nd does it ..
1580: 20 20 3b 3b 20 6d 61 74 63 68 20 63 75 72 72 65 ;; match curre
1590: 6e 74 20 69 70 20 6f 72 20 68 6f 73 74 6e 61 6d nt ip or hostnam
15a0: 65 0a 09 20 20 20 20 20 28 6e 6f 74 20 28 73 74 e.. (not (st
15b0: 72 69 6e 67 2d 6d 61 74 63 68 20 28 63 6f 6e 63 ring-match (conc
15c0: 20 22 28 22 63 75 72 72 2d 68 6f 73 74 20 22 7c "("curr-host "|
15d0: 22 20 63 75 72 72 2d 68 6f 73 74 22 5c 5c 2e 2e " curr-host"\\..
15e0: 2a 29 22 29 20 74 61 72 67 65 74 2d 68 6f 73 74 *)") target-host
15f0: 29 29 0a 09 20 20 20 20 20 28 6e 6f 74 20 28 65 )).. (not (e
1600: 71 75 61 6c 3f 20 63 75 72 72 2d 69 70 20 74 61 qual? curr-ip ta
1610: 72 67 65 74 2d 68 6f 73 74 29 29 29 0a 09 28 62 rget-host)))..(b
1620: 65 67 69 6e 0a 09 20 20 28 64 65 62 75 67 3a 70 egin.. (debug:p
1630: 72 69 6e 74 2d 69 6e 66 6f 20 30 20 2a 64 65 66 rint-info 0 *def
1640: 61 75 6c 74 2d 6c 6f 67 2d 70 6f 72 74 2a 20 22 ault-log-port* "
1650: 53 74 61 72 74 69 6e 67 20 73 65 72 76 65 72 20 Starting server
1660: 6f 6e 20 22 20 74 61 72 67 65 74 2d 68 6f 73 74 on " target-host
1670: 20 22 2c 20 6c 6f 67 66 69 6c 65 20 69 73 20 22 ", logfile is "
1680: 20 6c 6f 67 66 69 6c 65 29 0a 09 20 20 28 73 65 logfile).. (se
1690: 74 65 6e 76 20 22 54 41 52 47 45 54 48 4f 53 54 tenv "TARGETHOST
16a0: 22 20 74 61 72 67 65 74 2d 68 6f 73 74 29 29 29 " target-host)))
16b0: 0a 20 20 20 20 20 20 0a 20 20 20 20 28 73 65 74 . . (set
16c0: 65 6e 76 20 22 54 41 52 47 45 54 48 4f 53 54 5f env "TARGETHOST_
16d0: 4c 4f 47 46 22 20 6c 6f 67 66 69 6c 65 29 0a 20 LOGF" logfile).
16e0: 20 20 20 28 74 68 72 65 61 64 2d 73 6c 65 65 70 (thread-sleep
16f0: 21 20 28 2f 20 28 72 61 6e 64 6f 6d 20 35 30 30 ! (/ (random 500
1700: 30 29 20 31 30 30 30 29 29 20 3b 3b 20 61 64 64 0) 1000)) ;; add
1710: 20 61 62 6f 75 74 20 61 20 72 61 6e 64 6f 6d 20 about a random
1720: 28 75 70 20 74 6f 20 35 20 73 65 63 6f 6e 64 73 (up to 5 seconds
1730: 29 20 69 6e 69 74 69 61 6c 20 64 65 6c 61 79 2e ) initial delay.
1740: 20 49 74 20 73 65 65 6d 73 20 70 72 65 74 74 79 It seems pretty
1750: 20 63 6f 6d 6d 6f 6e 20 74 68 61 74 20 6d 61 6e common that man
1760: 79 20 72 75 6e 6e 69 6e 67 20 74 65 73 74 73 20 y running tests
1770: 72 65 71 75 65 73 74 20 61 20 73 65 72 76 65 72 request a server
1780: 20 61 74 20 74 68 65 20 73 61 6d 65 20 74 69 6d at the same tim
1790: 65 0a 20 20 20 20 28 63 6f 6d 6d 6f 6e 3a 77 61 e. (common:wa
17a0: 69 74 2d 66 6f 72 2d 6e 6f 72 6d 61 6c 69 7a 65 it-for-normalize
17b0: 64 2d 6c 6f 61 64 20 6c 6f 61 64 2d 6c 69 6d 69 d-load load-limi
17c0: 74 20 22 20 64 65 6c 61 79 69 6e 67 20 73 65 72 t " delaying ser
17d0: 76 65 72 20 73 74 61 72 74 20 64 75 65 20 74 6f ver start due to
17e0: 20 6c 6f 61 64 22 20 74 61 72 67 65 74 2d 68 6f load" target-ho
17f0: 73 74 29 20 3b 3b 20 64 6f 20 6e 6f 74 20 74 72 st) ;; do not tr
1800: 79 20 73 74 61 72 74 69 6e 67 20 73 65 72 76 65 y starting serve
1810: 72 73 20 6f 6e 20 61 6e 20 61 6c 72 65 61 64 79 rs on an already
1820: 20 6f 76 65 72 6c 6f 61 64 65 64 20 6d 61 63 68 overloaded mach
1830: 69 6e 65 2c 20 6a 75 73 74 20 77 61 69 74 20 66 ine, just wait f
1840: 6f 72 65 76 65 72 0a 20 20 20 20 28 73 79 73 74 orever. (syst
1850: 65 6d 20 28 63 6f 6e 63 20 22 6e 62 66 61 6b 65 em (conc "nbfake
1860: 20 22 20 63 6d 64 6c 6e 29 29 0a 20 20 20 20 28 " cmdln)). (
1870: 75 6e 73 65 74 65 6e 76 20 22 54 41 52 47 45 54 unsetenv "TARGET
1880: 48 4f 53 54 5f 4c 4f 47 46 22 29 0a 20 20 20 20 HOST_LOGF").
1890: 28 69 66 20 28 67 65 74 2d 65 6e 76 69 72 6f 6e (if (get-environ
18a0: 6d 65 6e 74 2d 76 61 72 69 61 62 6c 65 20 22 54 ment-variable "T
18b0: 41 52 47 45 54 48 4f 53 54 22 29 28 75 6e 73 65 ARGETHOST")(unse
18c0: 74 65 6e 76 20 22 54 41 52 47 45 54 48 4f 53 54 tenv "TARGETHOST
18d0: 22 29 29 0a 20 20 20 20 28 74 68 72 65 61 64 2d ")). (thread-
18e0: 6a 6f 69 6e 21 20 6c 6f 67 2d 72 6f 74 61 74 65 join! log-rotate
18f0: 29 0a 20 20 20 20 28 70 6f 70 2d 64 69 72 65 63 ). (pop-direc
1900: 74 6f 72 79 29 29 29 0a 0a 3b 3b 20 67 69 76 65 tory)))..;; give
1910: 6e 20 61 20 70 61 74 68 20 74 6f 20 61 20 73 65 n a path to a se
1920: 72 76 65 72 20 6c 6f 67 20 72 65 74 75 72 6e 3a rver log return:
1930: 20 68 6f 73 74 20 70 6f 72 74 20 73 74 61 72 74 host port start
1940: 73 65 63 6f 6e 64 73 0a 3b 3b 0a 28 64 65 66 69 seconds.;;.(defi
1950: 6e 65 20 28 73 65 72 76 65 72 3a 6c 6f 67 66 2d ne (server:logf-
1960: 67 65 74 2d 73 74 61 72 74 2d 69 6e 66 6f 20 6c get-start-info l
1970: 6f 67 66 29 0a 20 20 28 6c 65 74 20 28 28 72 78 ogf). (let ((rx
1980: 20 28 72 65 67 65 78 70 20 22 5e 53 45 52 56 45 (regexp "^SERVE
1990: 52 20 53 54 41 52 54 45 44 3a 20 28 5c 5c 53 2b R STARTED: (\\S+
19a0: 29 3a 28 5c 5c 64 2b 29 20 41 54 20 28 5b 5c 5c ):(\\d+) AT ([\\
19b0: 64 5c 5c 2e 5d 2b 29 22 29 29 29 20 3b 3b 20 53 d\\.]+)"))) ;; S
19c0: 45 52 56 45 52 20 53 54 41 52 54 45 44 3a 20 68 ERVER STARTED: h
19d0: 6f 73 74 3a 70 6f 72 74 20 41 54 20 74 69 6d 65 ost:port AT time
19e0: 73 65 63 73 0a 20 20 20 20 28 68 61 6e 64 6c 65 secs. (handle
19f0: 2d 65 78 63 65 70 74 69 6f 6e 73 0a 09 65 78 6e -exceptions..exn
1a00: 0a 09 28 6c 69 73 74 20 23 66 20 23 66 20 23 66 ..(list #f #f #f
1a10: 29 20 3b 3b 20 6e 6f 20 69 64 65 61 20 77 68 61 ) ;; no idea wha
1a20: 74 20 77 65 6e 74 20 77 72 6f 6e 67 2c 20 63 61 t went wrong, ca
1a30: 6c 6c 20 69 74 20 61 20 62 61 64 20 73 65 72 76 ll it a bad serv
1a40: 65 72 0a 20 20 20 20 20 20 28 77 69 74 68 2d 69 er. (with-i
1a50: 6e 70 75 74 2d 66 72 6f 6d 2d 66 69 6c 65 0a 09 nput-from-file..
1a60: 20 20 6c 6f 67 66 0a 09 28 6c 61 6d 62 64 61 20 logf..(lambda
1a70: 28 29 0a 09 20 20 28 6c 65 74 20 6c 6f 6f 70 20 ().. (let loop
1a80: 28 28 69 6e 6c 20 20 28 72 65 61 64 2d 6c 69 6e ((inl (read-lin
1a90: 65 29 29 0a 09 09 20 20 20 20 20 28 6c 6e 75 6d e))... (lnum
1aa0: 20 30 29 29 0a 09 20 20 20 20 28 69 66 20 28 6e 0)).. (if (n
1ab0: 6f 74 20 28 65 6f 66 2d 6f 62 6a 65 63 74 3f 20 ot (eof-object?
1ac0: 69 6e 6c 29 29 0a 09 09 28 6c 65 74 20 28 28 6d inl))...(let ((m
1ad0: 6c 73 74 20 28 73 74 72 69 6e 67 2d 6d 61 74 63 lst (string-matc
1ae0: 68 20 72 78 20 69 6e 6c 29 29 29 0a 09 09 20 20 h rx inl)))...
1af0: 28 69 66 20 28 6e 6f 74 20 6d 6c 73 74 29 0a 09 (if (not mlst)..
1b00: 09 20 20 20 20 20 20 28 69 66 20 28 3c 20 6c 6e . (if (< ln
1b10: 75 6d 20 35 30 30 29 20 3b 3b 20 67 69 76 65 20 um 500) ;; give
1b20: 75 70 20 69 66 20 6d 6f 72 65 20 74 68 61 6e 20 up if more than
1b30: 35 30 30 20 6c 69 6e 65 73 20 6f 66 20 73 65 72 500 lines of ser
1b40: 76 65 72 20 6c 6f 67 20 72 65 61 64 0a 09 09 09 ver log read....
1b50: 20 20 28 6c 6f 6f 70 20 28 72 65 61 64 2d 6c 69 (loop (read-li
1b60: 6e 65 29 28 2b 20 6c 6e 75 6d 20 31 29 29 0a 09 ne)(+ lnum 1))..
1b70: 09 09 20 20 28 6c 69 73 74 20 23 66 20 23 66 20 .. (list #f #f
1b80: 23 66 29 29 0a 09 09 20 20 20 20 20 20 28 6c 65 #f))... (le
1b90: 74 20 28 28 64 61 74 20 20 28 63 64 72 20 6d 6c t ((dat (cdr ml
1ba0: 73 74 29 29 29 0a 09 09 09 28 6c 69 73 74 20 28 st)))....(list (
1bb0: 63 61 72 20 64 61 74 29 20 3b 3b 20 68 6f 73 74 car dat) ;; host
1bc0: 0a 09 09 09 20 20 20 20 20 20 28 73 74 72 69 6e .... (strin
1bd0: 67 2d 3e 6e 75 6d 62 65 72 20 28 63 61 64 72 20 g->number (cadr
1be0: 64 61 74 29 29 20 3b 3b 20 70 6f 72 74 0a 09 09 dat)) ;; port...
1bf0: 09 20 20 20 20 20 20 28 73 74 72 69 6e 67 2d 3e . (string->
1c00: 6e 75 6d 62 65 72 20 28 63 61 64 64 72 20 64 61 number (caddr da
1c10: 74 29 29 29 29 29 29 0a 09 09 28 6c 69 73 74 20 t))))))...(list
1c20: 23 66 20 23 66 20 23 66 29 29 29 29 29 29 29 29 #f #f #f))))))))
1c30: 0a 0a 3b 3b 20 67 65 74 20 61 20 6c 69 73 74 20 ..;; get a list
1c40: 6f 66 20 73 65 72 76 65 72 73 20 77 69 74 68 20 of servers with
1c50: 61 6c 6c 20 72 65 6c 65 76 61 6e 74 20 64 61 74 all relevant dat
1c60: 61 0a 3b 3b 20 28 20 6d 6f 64 2d 74 69 6d 65 20 a.;; ( mod-time
1c70: 68 6f 73 74 20 70 6f 72 74 20 73 74 61 72 74 2d host port start-
1c80: 74 69 6d 65 20 70 69 64 20 29 0a 3b 3b 0a 28 64 time pid ).;;.(d
1c90: 65 66 69 6e 65 20 28 73 65 72 76 65 72 3a 67 65 efine (server:ge
1ca0: 74 2d 6c 69 73 74 20 61 72 65 61 70 61 74 68 20 t-list areapath
1cb0: 23 21 6b 65 79 20 28 6c 69 6d 69 74 20 23 66 29 #!key (limit #f)
1cc0: 29 0a 20 20 28 6c 65 74 20 28 28 66 6e 61 6d 65 ). (let ((fname
1cd0: 2d 72 78 20 20 20 20 28 72 65 67 65 78 70 20 22 -rx (regexp "
1ce0: 5e 28 7c 2e 2a 2f 29 73 65 72 76 65 72 2d 28 5c ^(|.*/)server-(\
1cf0: 5c 64 2b 29 2d 28 5c 5c 53 2b 29 2e 6c 6f 67 24 \d+)-(\\S+).log$
1d00: 22 29 29 0a 09 28 64 61 79 2d 73 65 63 6f 6e 64 "))..(day-second
1d10: 73 20 28 2a 20 32 34 20 36 30 20 36 30 29 29 29 s (* 24 60 60)))
1d20: 0a 20 20 20 20 3b 3b 20 69 66 20 74 68 65 20 64 . ;; if the d
1d30: 69 72 65 63 74 6f 72 79 20 65 78 69 73 74 73 20 irectory exists
1d40: 63 6f 6e 74 69 6e 75 65 20 74 6f 20 67 65 74 20 continue to get
1d50: 74 68 65 20 6c 69 73 74 0a 20 20 20 20 3b 3b 20 the list. ;;
1d60: 6f 74 68 65 72 77 69 73 65 20 61 74 74 65 6d 70 otherwise attemp
1d70: 74 20 74 6f 20 63 72 65 61 74 65 20 74 68 65 20 t to create the
1d80: 6c 6f 67 73 20 64 69 72 20 61 6e 64 20 74 68 65 logs dir and the
1d90: 6e 0a 20 20 20 20 3b 3b 20 63 6f 6e 74 69 6e 75 n. ;; continu
1da0: 65 0a 20 20 20 20 28 69 66 20 28 69 66 20 28 64 e. (if (if (d
1db0: 69 72 65 63 74 6f 72 79 2d 65 78 69 73 74 73 3f irectory-exists?
1dc0: 20 28 63 6f 6e 63 20 61 72 65 61 70 61 74 68 20 (conc areapath
1dd0: 22 2f 6c 6f 67 73 22 29 29 0a 09 20 20 20 20 27 "/logs")).. '
1de0: 28 29 0a 09 20 20 20 20 28 69 66 20 28 66 69 6c ().. (if (fil
1df0: 65 2d 77 72 69 74 65 2d 61 63 63 65 73 73 3f 20 e-write-access?
1e00: 61 72 65 61 70 61 74 68 29 0a 09 09 28 62 65 67 areapath)...(beg
1e10: 69 6e 0a 09 09 20 20 28 63 6f 6e 64 69 74 69 6f in... (conditio
1e20: 6e 2d 63 61 73 65 0a 09 09 20 20 20 20 20 20 28 n-case... (
1e30: 63 72 65 61 74 65 2d 64 69 72 65 63 74 6f 72 79 create-directory
1e40: 20 28 63 6f 6e 63 20 61 72 65 61 70 61 74 68 20 (conc areapath
1e50: 22 2f 6c 6f 67 73 22 29 20 23 74 29 0a 09 09 20 "/logs") #t)...
1e60: 20 20 20 28 65 78 6e 20 28 69 2f 6f 20 66 69 6c (exn (i/o fil
1e70: 65 29 28 64 65 62 75 67 3a 70 72 69 6e 74 20 30 e)(debug:print 0
1e80: 20 2a 64 65 66 61 75 6c 74 2d 6c 6f 67 2d 70 6f *default-log-po
1e90: 72 74 2a 20 22 45 52 52 4f 52 3a 20 43 61 6e 6e rt* "ERROR: Cann
1ea0: 6f 74 20 63 72 65 61 74 65 20 64 69 72 65 63 74 ot create direct
1eb0: 6f 72 79 20 61 74 20 22 20 28 63 6f 6e 63 20 61 ory at " (conc a
1ec0: 72 65 61 70 61 74 68 20 22 2f 6c 6f 67 73 22 29 reapath "/logs")
1ed0: 29 29 0a 09 09 20 20 20 20 28 65 78 6e 20 28 29 ))... (exn ()
1ee0: 28 64 65 62 75 67 3a 70 72 69 6e 74 20 30 20 2a (debug:print 0 *
1ef0: 64 65 66 61 75 6c 74 2d 6c 6f 67 2d 70 6f 72 74 default-log-port
1f00: 2a 20 22 45 52 52 4f 52 3a 20 55 6e 6b 6e 6f 77 * "ERROR: Unknow
1f10: 6e 20 65 72 72 6f 72 20 61 74 74 65 6d 74 70 69 n error attemtpi
1f20: 6e 67 20 74 6f 20 67 65 74 20 73 65 72 76 65 72 ng to get server
1f30: 20 6c 69 73 74 2e 22 29 29 29 0a 09 09 20 20 28 list.")))... (
1f40: 64 69 72 65 63 74 6f 72 79 2d 65 78 69 73 74 73 directory-exists
1f50: 3f 20 28 63 6f 6e 63 20 61 72 65 61 70 61 74 68 ? (conc areapath
1f60: 20 22 2f 6c 6f 67 73 22 29 29 29 0a 09 09 27 28 "/logs")))...'(
1f70: 29 29 29 0a 09 28 6c 65 74 2a 20 28 28 73 65 72 )))..(let* ((ser
1f80: 76 65 72 2d 6c 6f 67 73 20 20 20 28 67 6c 6f 62 ver-logs (glob
1f90: 20 28 63 6f 6e 63 20 61 72 65 61 70 61 74 68 20 (conc areapath
1fa0: 22 2f 6c 6f 67 73 2f 73 65 72 76 65 72 2d 2a 2e "/logs/server-*.
1fb0: 6c 6f 67 22 29 29 29 0a 09 20 20 20 20 20 20 20 log")))..
1fc0: 28 6e 75 6d 2d 73 65 72 76 2d 6c 6f 67 73 20 28 (num-serv-logs (
1fd0: 6c 65 6e 67 74 68 20 73 65 72 76 65 72 2d 6c 6f length server-lo
1fe0: 67 73 29 29 29 0a 09 20 20 28 69 66 20 28 6e 75 gs))).. (if (nu
1ff0: 6c 6c 3f 20 73 65 72 76 65 72 2d 6c 6f 67 73 29 ll? server-logs)
2000: 0a 09 20 20 20 20 20 20 27 28 29 0a 09 20 20 20 .. '()..
2010: 20 20 20 28 6c 65 74 20 6c 6f 6f 70 20 28 28 68 (let loop ((h
2020: 65 64 20 20 28 63 61 72 20 73 65 72 76 65 72 2d ed (car server-
2030: 6c 6f 67 73 29 29 0a 09 09 09 20 28 74 61 6c 20 logs)).... (tal
2040: 20 28 63 64 72 20 73 65 72 76 65 72 2d 6c 6f 67 (cdr server-log
2050: 73 29 29 0a 09 09 09 20 28 72 65 73 20 27 28 29 s)).... (res '()
2060: 29 29 0a 09 09 28 6c 65 74 2a 20 28 28 6d 6f 64 ))...(let* ((mod
2070: 2d 74 69 6d 65 20 20 28 68 61 6e 64 6c 65 2d 65 -time (handle-e
2080: 78 63 65 70 74 69 6f 6e 73 0a 09 09 09 09 20 20 xceptions.....
2090: 20 20 20 20 65 78 6e 0a 09 09 09 09 20 20 20 20 exn.....
20a0: 20 20 28 63 75 72 72 65 6e 74 2d 73 65 63 6f 6e (current-secon
20b0: 64 73 29 20 3b 3b 20 30 0a 09 09 09 09 20 20 20 ds) ;; 0.....
20c0: 20 28 66 69 6c 65 2d 6d 6f 64 69 66 69 63 61 74 (file-modificat
20d0: 69 6f 6e 2d 74 69 6d 65 20 68 65 64 29 29 29 20 ion-time hed)))
20e0: 3b 3b 20 64 65 66 61 75 6c 74 20 74 6f 20 2a 76 ;; default to *v
20f0: 65 72 79 2a 20 6f 6c 64 20 73 6f 20 6c 6f 67 20 ery* old so log
2100: 67 65 74 73 20 69 67 6e 6f 72 65 64 20 69 66 20 gets ignored if
2110: 64 65 6c 65 74 65 64 0a 09 09 20 20 20 20 20 20 deleted...
2120: 20 28 64 6f 77 6e 2d 74 69 6d 65 20 28 2d 20 28 (down-time (- (
2130: 63 75 72 72 65 6e 74 2d 73 65 63 6f 6e 64 73 29 current-seconds)
2140: 20 6d 6f 64 2d 74 69 6d 65 29 29 0a 09 09 20 20 mod-time))...
2150: 20 20 20 20 20 28 73 65 72 76 2d 64 61 74 20 20 (serv-dat
2160: 28 69 66 20 28 6f 72 20 28 3c 20 6e 75 6d 2d 73 (if (or (< num-s
2170: 65 72 76 2d 6c 6f 67 73 20 31 30 29 0a 09 09 09 erv-logs 10)....
2180: 09 20 20 09 20 20 28 3c 20 64 6f 77 6e 2d 74 69 . . (< down-ti
2190: 6d 65 20 39 30 30 29 29 20 3b 3b 20 64 61 79 2d me 900)) ;; day-
21a0: 73 65 63 6f 6e 64 73 29 29 0a 09 09 09 09 20 20 seconds)).....
21b0: 20 20 20 20 28 73 65 72 76 65 72 3a 6c 6f 67 66 (server:logf
21c0: 2d 67 65 74 2d 73 74 61 72 74 2d 69 6e 66 6f 20 -get-start-info
21d0: 68 65 64 29 0a 09 09 09 09 20 20 20 20 20 20 27 hed)..... '
21e0: 28 29 29 29 20 3b 3b 20 64 6f 6e 27 74 20 77 61 ())) ;; don't wa
21f0: 73 74 65 20 74 69 6d 65 20 70 72 6f 63 65 73 73 ste time process
2200: 69 6e 67 20 73 65 72 76 65 72 20 66 69 6c 65 73 ing server files
2210: 20 6e 6f 74 20 74 6f 75 63 68 65 64 20 69 6e 20 not touched in
2220: 74 68 65 20 31 35 20 6d 69 6e 75 74 65 73 20 69 the 15 minutes i
2230: 66 20 74 68 65 72 65 20 61 72 65 20 6d 6f 72 65 f there are more
2240: 20 74 68 61 6e 20 74 65 6e 20 73 65 72 76 65 72 than ten server
2250: 73 20 74 6f 20 6c 6f 6f 6b 20 61 74 0a 09 09 20 s to look at...
2260: 20 20 20 20 20 20 28 73 65 72 76 2d 72 65 63 20 (serv-rec
2270: 28 63 6f 6e 73 20 6d 6f 64 2d 74 69 6d 65 20 73 (cons mod-time s
2280: 65 72 76 2d 64 61 74 29 29 0a 09 09 20 20 20 20 erv-dat))...
2290: 20 20 20 28 66 6d 61 74 63 68 20 20 20 28 73 74 (fmatch (st
22a0: 72 69 6e 67 2d 6d 61 74 63 68 20 66 6e 61 6d 65 ring-match fname
22b0: 2d 72 78 20 68 65 64 29 29 0a 09 09 20 20 20 20 -rx hed))...
22c0: 20 20 20 28 70 69 64 20 20 20 20 20 20 28 69 66 (pid (if
22d0: 20 66 6d 61 74 63 68 20 28 73 74 72 69 6e 67 2d fmatch (string-
22e0: 3e 6e 75 6d 62 65 72 20 28 6c 69 73 74 2d 72 65 >number (list-re
22f0: 66 20 66 6d 61 74 63 68 20 32 29 29 20 23 66 29 f fmatch 2)) #f)
2300: 29 0a 09 09 20 20 20 20 20 20 20 28 6e 65 77 2d )... (new-
2310: 72 65 73 20 20 28 69 66 20 28 6e 75 6c 6c 3f 20 res (if (null?
2320: 73 65 72 76 2d 64 61 74 29 0a 09 09 09 09 20 20 serv-dat).....
2330: 20 20 20 72 65 73 0a 09 09 09 09 20 20 20 20 20 res.....
2340: 28 63 6f 6e 73 20 28 61 70 70 65 6e 64 20 73 65 (cons (append se
2350: 72 76 2d 72 65 63 20 28 6c 69 73 74 20 70 69 64 rv-rec (list pid
2360: 29 29 20 72 65 73 29 29 29 29 0a 09 09 28 69 66 )) res))))...(if
2370: 20 28 6e 75 6c 6c 3f 20 74 61 6c 29 0a 09 09 20 (null? tal)...
2380: 20 20 20 28 69 66 20 28 61 6e 64 20 6c 69 6d 69 (if (and limi
2390: 74 0a 09 09 09 20 20 20 20 20 28 3e 20 28 6c 65 t.... (> (le
23a0: 6e 67 74 68 20 6e 65 77 2d 72 65 73 29 20 6c 69 ngth new-res) li
23b0: 6d 69 74 29 29 0a 09 09 09 6e 65 77 2d 72 65 73 mit))....new-res
23c0: 20 3b 3b 20 28 74 61 6b 65 20 6e 65 77 2d 72 65 ;; (take new-re
23d0: 73 20 6c 69 6d 69 74 29 20 20 3c 3d 20 6e 65 65 s limit) <= nee
23e0: 64 20 69 6e 74 65 6c 6c 69 67 65 6e 74 20 73 6f d intelligent so
23f0: 72 74 69 6e 67 20 62 65 66 6f 72 65 20 74 68 69 rting before thi
2400: 73 20 77 69 6c 6c 20 77 6f 72 6b 0a 09 09 09 6e s will work....n
2410: 65 77 2d 72 65 73 29 0a 09 09 20 20 20 20 28 6c ew-res)... (l
2420: 6f 6f 70 20 28 63 61 72 20 74 61 6c 29 28 63 64 oop (car tal)(cd
2430: 72 20 74 61 6c 29 20 6e 65 77 2d 72 65 73 29 29 r tal) new-res))
2440: 29 29 29 29 29 29 29 0a 0a 28 64 65 66 69 6e 65 )))))))..(define
2450: 20 28 73 65 72 76 65 72 3a 67 65 74 2d 6e 75 6d (server:get-num
2460: 2d 61 6c 69 76 65 20 73 72 76 6c 73 74 29 0a 20 -alive srvlst).
2470: 20 28 6c 65 74 20 28 28 6e 75 6d 2d 61 6c 69 76 (let ((num-aliv
2480: 65 20 30 29 29 0a 20 20 20 20 28 66 6f 72 2d 65 e 0)). (for-e
2490: 61 63 68 0a 20 20 20 20 20 28 6c 61 6d 62 64 61 ach. (lambda
24a0: 20 28 73 65 72 76 65 72 29 0a 20 20 20 20 20 20 (server).
24b0: 20 28 6d 61 74 63 68 2d 6c 65 74 20 28 28 28 6d (match-let (((m
24c0: 6f 64 2d 74 69 6d 65 20 68 6f 73 74 20 70 6f 72 od-time host por
24d0: 74 20 73 74 61 72 74 2d 74 69 6d 65 20 70 69 64 t start-time pid
24e0: 29 0a 09 09 20 20 20 20 73 65 72 76 65 72 29 29 )... server))
24f0: 0a 09 20 28 6c 65 74 2a 20 28 28 75 70 74 69 6d .. (let* ((uptim
2500: 65 20 20 28 2d 20 28 63 75 72 72 65 6e 74 2d 73 e (- (current-s
2510: 65 63 6f 6e 64 73 29 20 6d 6f 64 2d 74 69 6d 65 econds) mod-time
2520: 29 29 0a 09 09 28 72 75 6e 74 69 6d 65 20 28 69 ))...(runtime (i
2530: 66 20 73 74 61 72 74 2d 74 69 6d 65 0a 09 09 09 f start-time....
2540: 20 20 20 20 20 28 2d 20 6d 6f 64 2d 74 69 6d 65 (- mod-time
2550: 20 73 74 61 72 74 2d 74 69 6d 65 29 0a 09 09 09 start-time)....
2560: 20 20 20 20 20 30 29 29 29 0a 09 20 20 20 28 69 0))).. (i
2570: 66 20 28 3c 20 75 70 74 69 6d 65 20 35 29 28 73 f (< uptime 5)(s
2580: 65 74 21 20 6e 75 6d 2d 61 6c 69 76 65 20 28 2b et! num-alive (+
2590: 20 6e 75 6d 2d 61 6c 69 76 65 20 31 29 29 29 29 num-alive 1))))
25a0: 29 29 0a 20 20 20 20 20 73 72 76 6c 73 74 29 0a )). srvlst).
25b0: 20 20 20 20 6e 75 6d 2d 61 6c 69 76 65 29 29 0a num-alive)).
25c0: 0a 3b 3b 20 67 69 76 65 6e 20 61 20 6c 69 73 74 .;; given a list
25d0: 20 6f 66 20 73 65 72 76 65 72 73 20 67 65 74 20 of servers get
25e0: 61 20 6c 69 73 74 20 6f 66 20 76 61 6c 69 64 20 a list of valid
25f0: 73 65 72 76 65 72 73 2c 20 69 2e 65 2e 20 61 74 servers, i.e. at
2600: 20 6c 65 61 73 74 0a 3b 3b 20 31 30 20 73 65 63 least.;; 10 sec
2610: 6f 6e 64 73 20 6f 6c 64 2c 20 68 61 73 20 73 74 onds old, has st
2620: 61 72 74 65 64 20 61 6e 64 20 69 73 20 6c 65 73 arted and is les
2630: 73 20 74 68 61 6e 20 31 20 68 6f 75 72 20 6f 6c s than 1 hour ol
2640: 64 20 61 6e 64 20 69 73 0a 3b 3b 20 61 63 74 69 d and is.;; acti
2650: 76 65 20 28 69 2e 65 2e 20 6d 6f 64 2d 74 69 6d ve (i.e. mod-tim
2660: 65 20 3c 20 31 30 20 73 65 63 6f 6e 64 73 0a 3b e < 10 seconds.;
2670: 3b 0a 3b 3b 20 6d 6f 64 2d 74 69 6d 65 20 68 6f ;.;; mod-time ho
2680: 73 74 20 70 6f 72 74 20 73 74 61 72 74 2d 74 69 st port start-ti
2690: 6d 65 20 70 69 64 0a 3b 3b 0a 3b 3b 20 73 6f 72 me pid.;;.;; sor
26a0: 74 20 62 79 20 73 74 61 72 74 2d 74 69 6d 65 20 t by start-time
26b0: 64 65 73 63 65 6e 64 69 6e 67 2e 20 49 2e 65 2e descending. I.e.
26c0: 20 67 65 74 20 74 68 65 20 6f 6c 64 65 73 74 20 get the oldest
26d0: 66 69 72 73 74 2e 20 59 6f 75 6e 67 20 73 65 72 first. Young ser
26e0: 76 65 72 73 20 77 69 6c 6c 20 74 68 75 73 20 64 vers will thus d
26f0: 72 6f 70 20 6f 66 66 0a 3b 3b 20 61 6e 64 20 73 rop off.;; and s
2700: 65 72 76 65 72 73 20 73 68 6f 75 6c 64 20 73 74 ervers should st
2710: 69 63 6b 20 61 72 6f 75 6e 64 20 66 6f 72 20 61 ick around for a
2720: 62 6f 75 74 20 74 77 6f 20 68 6f 75 72 73 20 6f bout two hours o
2730: 72 20 73 6f 2e 0a 3b 3b 0a 28 64 65 66 69 6e 65 r so..;;.(define
2740: 20 28 73 65 72 76 65 72 3a 67 65 74 2d 62 65 73 (server:get-bes
2750: 74 20 73 72 76 6c 73 74 29 0a 20 20 28 6c 65 74 t srvlst). (let
2760: 2a 20 28 28 6e 75 6d 73 20 28 73 65 72 76 65 72 * ((nums (server
2770: 3a 67 65 74 2d 6e 75 6d 2d 73 65 72 76 65 72 73 :get-num-servers
2780: 29 29 0a 09 20 28 6e 6f 77 20 20 28 63 75 72 72 )).. (now (curr
2790: 65 6e 74 2d 73 65 63 6f 6e 64 73 29 29 0a 09 20 ent-seconds))..
27a0: 28 73 6c 73 74 20 28 73 6f 72 74 0a 09 09 28 66 (slst (sort...(f
27b0: 69 6c 74 65 72 20 28 6c 61 6d 62 64 61 20 28 72 ilter (lambda (r
27c0: 65 63 29 0a 09 09 09 20 20 28 69 66 20 28 61 6e ec).... (if (an
27d0: 64 20 28 6c 69 73 74 3f 20 72 65 63 29 0a 09 09 d (list? rec)...
27e0: 09 09 20 20 20 28 3e 20 28 6c 65 6e 67 74 68 20 .. (> (length
27f0: 72 65 63 29 20 32 29 29 0a 09 09 09 20 20 20 20 rec) 2))....
2800: 20 20 28 6c 65 74 20 28 28 73 74 61 72 74 2d 74 (let ((start-t
2810: 69 6d 65 20 28 6c 69 73 74 2d 72 65 66 20 72 65 ime (list-ref re
2820: 63 20 33 29 29 0a 09 09 09 09 20 20 20 20 28 6d c 3))..... (m
2830: 6f 64 2d 74 69 6d 65 20 20 20 28 6c 69 73 74 2d od-time (list-
2840: 72 65 66 20 72 65 63 20 30 29 29 29 0a 09 09 09 ref rec 0)))....
2850: 09 3b 3b 20 28 70 72 69 6e 74 20 22 73 74 61 72 .;; (print "star
2860: 74 2d 74 69 6d 65 3a 20 22 20 73 74 61 72 74 2d t-time: " start-
2870: 74 69 6d 65 20 22 20 6d 6f 64 2d 74 69 6d 65 3a time " mod-time:
2880: 20 22 20 6d 6f 64 2d 74 69 6d 65 29 0a 09 09 09 " mod-time)....
2890: 09 28 61 6e 64 20 73 74 61 72 74 2d 74 69 6d 65 .(and start-time
28a0: 20 6d 6f 64 2d 74 69 6d 65 0a 09 09 09 09 20 20 mod-time.....
28b0: 20 20 20 28 3e 20 28 2d 20 6e 6f 77 20 73 74 61 (> (- now sta
28c0: 72 74 2d 74 69 6d 65 29 20 30 29 20 20 20 20 3b rt-time) 0) ;
28d0: 3b 20 62 65 65 6e 20 72 75 6e 6e 69 6e 67 20 61 ; been running a
28e0: 74 20 6c 65 61 73 74 20 30 20 73 65 63 6f 6e 64 t least 0 second
28f0: 73 0a 09 09 09 09 20 20 20 20 20 28 3c 20 28 2d s..... (< (-
2900: 20 6e 6f 77 20 6d 6f 64 2d 74 69 6d 65 29 20 20 now mod-time)
2910: 20 31 36 29 20 20 20 3b 3b 20 73 74 69 6c 6c 20 16) ;; still
2920: 61 6c 69 76 65 20 2d 20 66 69 6c 65 20 74 6f 75 alive - file tou
2930: 63 68 65 64 20 69 6e 20 6c 61 73 74 20 31 36 20 ched in last 16
2940: 73 65 63 6f 6e 64 73 0a 09 09 09 09 20 20 20 20 seconds.....
2950: 20 28 3c 20 28 2d 20 6e 6f 77 20 73 74 61 72 74 (< (- now start
2960: 2d 74 69 6d 65 29 20 20 20 20 20 20 20 0a 09 09 -time) ...
2970: 09 09 09 28 2b 20 28 2d 20 28 73 74 72 69 6e 67 ...(+ (- (string
2980: 2d 3e 6e 75 6d 62 65 72 20 28 6f 72 20 28 63 6f ->number (or (co
2990: 6e 66 69 67 66 3a 6c 6f 6f 6b 75 70 20 2a 63 6f nfigf:lookup *co
29a0: 6e 66 69 67 64 61 74 2a 20 22 73 65 72 76 65 72 nfigdat* "server
29b0: 22 20 22 72 75 6e 74 69 6d 65 22 29 20 22 33 36 " "runtime") "36
29c0: 30 30 22 29 29 0a 09 09 09 09 09 20 20 20 20 20 00"))......
29d0: 20 31 38 30 29 0a 09 09 09 09 09 20 20 20 28 72 180)...... (r
29e0: 61 6e 64 6f 6d 20 33 36 30 29 29 29 20 3b 3b 20 andom 360))) ;;
29f0: 75 6e 64 65 72 20 6f 6e 65 20 68 6f 75 72 20 72 under one hour r
2a00: 75 6e 6e 69 6e 67 20 74 69 6d 65 20 2b 2f 2d 20 unning time +/-
2a10: 31 38 30 0a 09 09 09 09 20 20 20 20 20 29 29 0a 180..... )).
2a20: 09 09 09 20 20 20 20 20 20 23 66 29 29 0a 09 09 ... #f))...
2a30: 09 73 72 76 6c 73 74 29 0a 09 09 28 6c 61 6d 62 .srvlst)...(lamb
2a40: 64 61 20 28 61 20 62 29 0a 09 09 20 20 28 3c 20 da (a b)... (<
2a50: 28 6c 69 73 74 2d 72 65 66 20 61 20 33 29 0a 09 (list-ref a 3)..
2a60: 09 20 20 20 20 20 28 6c 69 73 74 2d 72 65 66 20 . (list-ref
2a70: 62 20 33 29 29 29 29 29 29 0a 20 20 20 20 28 69 b 3)))))). (i
2a80: 66 20 28 3e 20 28 6c 65 6e 67 74 68 20 73 6c 73 f (> (length sls
2a90: 74 29 20 6e 75 6d 73 29 0a 09 28 74 61 6b 65 20 t) nums)..(take
2aa0: 73 6c 73 74 20 6e 75 6d 73 29 0a 09 73 6c 73 74 slst nums)..slst
2ab0: 29 29 29 0a 0a 28 64 65 66 69 6e 65 20 28 73 65 )))..(define (se
2ac0: 72 76 65 72 3a 67 65 74 2d 66 69 72 73 74 2d 62 rver:get-first-b
2ad0: 65 73 74 20 61 72 65 61 70 61 74 68 29 0a 20 20 est areapath).
2ae0: 28 6c 65 74 20 28 28 73 72 76 72 73 20 28 73 65 (let ((srvrs (se
2af0: 72 76 65 72 3a 67 65 74 2d 62 65 73 74 20 28 73 rver:get-best (s
2b00: 65 72 76 65 72 3a 67 65 74 2d 6c 69 73 74 20 61 erver:get-list a
2b10: 72 65 61 70 61 74 68 29 29 29 29 0a 20 20 20 20 reapath)))).
2b20: 28 69 66 20 28 61 6e 64 20 73 72 76 72 73 0a 09 (if (and srvrs..
2b30: 20 20 20 20 20 28 6e 6f 74 20 28 6e 75 6c 6c 3f (not (null?
2b40: 20 73 72 76 72 73 29 29 29 0a 09 28 63 61 72 20 srvrs)))..(car
2b50: 73 72 76 72 73 29 0a 09 23 66 29 29 29 0a 0a 28 srvrs)..#f)))..(
2b60: 64 65 66 69 6e 65 20 28 73 65 72 76 65 72 3a 67 define (server:g
2b70: 65 74 2d 72 61 6e 64 2d 62 65 73 74 20 61 72 65 et-rand-best are
2b80: 61 70 61 74 68 29 0a 20 20 28 6c 65 74 20 28 28 apath). (let ((
2b90: 73 72 76 72 73 20 28 73 65 72 76 65 72 3a 67 65 srvrs (server:ge
2ba0: 74 2d 62 65 73 74 20 28 73 65 72 76 65 72 3a 67 t-best (server:g
2bb0: 65 74 2d 6c 69 73 74 20 61 72 65 61 70 61 74 68 et-list areapath
2bc0: 29 29 29 29 0a 20 20 20 20 28 69 66 20 28 61 6e )))). (if (an
2bd0: 64 20 28 6c 69 73 74 3f 20 73 72 76 72 73 29 0a d (list? srvrs).
2be0: 09 20 20 20 20 20 28 6e 6f 74 20 28 6e 75 6c 6c . (not (null
2bf0: 3f 20 73 72 76 72 73 29 29 29 0a 09 28 6c 65 74 ? srvrs)))..(let
2c00: 2a 20 28 28 6c 65 6e 20 28 6c 65 6e 67 74 68 20 * ((len (length
2c10: 73 72 76 72 73 29 29 0a 09 20 20 20 20 20 20 20 srvrs))..
2c20: 28 69 64 78 20 28 72 61 6e 64 6f 6d 20 6c 65 6e (idx (random len
2c30: 29 29 29 0a 09 20 20 28 6c 69 73 74 2d 72 65 66 ))).. (list-ref
2c40: 20 73 72 76 72 73 20 69 64 78 29 29 0a 09 23 66 srvrs idx))..#f
2c50: 29 29 29 0a 0a 0a 28 64 65 66 69 6e 65 20 28 73 )))...(define (s
2c60: 65 72 76 65 72 3a 72 65 63 6f 72 64 2d 3e 75 72 erver:record->ur
2c70: 6c 20 73 65 72 76 72 29 0a 20 20 28 6d 61 74 63 l servr). (matc
2c80: 68 2d 6c 65 74 20 28 28 28 6d 6f 64 2d 74 69 6d h-let (((mod-tim
2c90: 65 20 68 6f 73 74 20 70 6f 72 74 20 73 74 61 72 e host port star
2ca0: 74 2d 74 69 6d 65 20 70 69 64 29 0a 09 20 20 20 t-time pid)..
2cb0: 20 20 20 20 73 65 72 76 72 29 29 0a 20 20 20 20 servr)).
2cc0: 28 69 66 20 28 61 6e 64 20 68 6f 73 74 20 70 6f (if (and host po
2cd0: 72 74 29 0a 09 28 63 6f 6e 63 20 68 6f 73 74 20 rt)..(conc host
2ce0: 22 3a 22 20 70 6f 72 74 29 0a 09 23 66 29 29 29 ":" port)..#f)))
2cf0: 0a 0a 28 64 65 66 69 6e 65 20 28 73 65 72 76 65 ..(define (serve
2d00: 72 3a 67 65 74 2d 63 6c 69 65 6e 74 2d 73 69 67 r:get-client-sig
2d10: 6e 61 74 75 72 65 29 20 3b 3b 20 42 42 3e 20 77 nature) ;; BB> w
2d20: 68 79 20 69 73 20 74 68 69 73 20 70 72 6f 63 20 hy is this proc
2d30: 6e 61 6d 65 64 20 22 67 65 74 2d 22 3f 20 20 69 named "get-"? i
2d40: 74 20 72 65 74 75 72 6e 73 20 6e 6f 74 68 69 6e t returns nothin
2d50: 67 20 2d 2d 20 73 65 74 21 20 68 61 73 20 6e 6f g -- set! has no
2d60: 74 20 72 65 74 75 72 6e 20 76 61 6c 75 65 2e 0a t return value..
2d70: 20 20 28 69 66 20 2a 6d 79 2d 63 6c 69 65 6e 74 (if *my-client
2d80: 2d 73 69 67 6e 61 74 75 72 65 2a 20 2a 6d 79 2d -signature* *my-
2d90: 63 6c 69 65 6e 74 2d 73 69 67 6e 61 74 75 72 65 client-signature
2da0: 2a 0a 20 20 20 20 20 20 28 6c 65 74 20 28 28 73 *. (let ((s
2db0: 69 67 20 28 73 65 72 76 65 72 3a 6d 6b 2d 73 69 ig (server:mk-si
2dc0: 67 6e 61 74 75 72 65 29 29 29 0a 20 20 20 20 20 gnature))).
2dd0: 20 20 20 28 73 65 74 21 20 2a 6d 79 2d 63 6c 69 (set! *my-cli
2de0: 65 6e 74 2d 73 69 67 6e 61 74 75 72 65 2a 20 73 ent-signature* s
2df0: 69 67 29 0a 20 20 20 20 20 20 20 20 2a 6d 79 2d ig). *my-
2e00: 63 6c 69 65 6e 74 2d 73 69 67 6e 61 74 75 72 65 client-signature
2e10: 2a 29 29 29 0a 0a 3b 3b 20 6b 69 6e 64 20 73 74 *)))..;; kind st
2e20: 61 72 74 20 75 70 20 6f 66 20 73 65 72 76 65 72 art up of server
2e30: 73 2c 20 77 61 69 74 20 34 30 20 73 65 63 6f 6e s, wait 40 secon
2e40: 64 73 20 62 65 66 6f 72 65 20 61 6c 6c 6f 77 69 ds before allowi
2e50: 6e 67 20 61 6e 6f 74 68 65 72 20 73 65 72 76 65 ng another serve
2e60: 72 20 66 6f 72 20 61 20 67 69 76 65 6e 0a 3b 3b r for a given.;;
2e70: 20 72 75 6e 2d 69 64 20 74 6f 20 62 65 20 6c 61 run-id to be la
2e80: 75 6e 63 68 65 64 0a 28 64 65 66 69 6e 65 20 28 unched.(define (
2e90: 73 65 72 76 65 72 3a 6b 69 6e 64 2d 72 75 6e 20 server:kind-run
2ea0: 61 72 65 61 70 61 74 68 29 0a 20 20 28 69 66 20 areapath). (if
2eb0: 28 6e 6f 74 20 28 73 65 72 76 65 72 3a 63 68 65 (not (server:che
2ec0: 63 6b 2d 69 66 2d 72 75 6e 6e 69 6e 67 20 61 72 ck-if-running ar
2ed0: 65 61 70 61 74 68 29 29 20 3b 3b 20 77 68 79 20 eapath)) ;; why
2ee0: 74 72 79 20 69 66 20 74 68 65 72 65 20 69 73 20 try if there is
2ef0: 61 6c 72 65 61 64 79 20 61 20 73 65 72 76 65 72 already a server
2f00: 20 72 75 6e 6e 69 6e 67 3f 0a 20 20 20 20 20 20 running?.
2f10: 28 6c 65 74 2a 20 28 28 6c 61 73 74 2d 72 75 6e (let* ((last-run
2f20: 2d 64 61 74 20 28 68 61 73 68 2d 74 61 62 6c 65 -dat (hash-table
2f30: 2d 72 65 66 2f 64 65 66 61 75 6c 74 20 2a 73 65 -ref/default *se
2f40: 72 76 65 72 2d 6b 69 6e 64 2d 72 75 6e 2a 20 61 rver-kind-run* a
2f50: 72 65 61 70 61 74 68 20 27 28 30 20 30 29 29 29 reapath '(0 0)))
2f60: 20 3b 3b 20 63 61 6c 6c 6e 75 6d 2c 20 77 68 65 ;; callnum, whe
2f70: 6e 72 75 6e 0a 09 20 20 20 20 20 28 63 61 6c 6c nrun.. (call
2f80: 2d 6e 75 6d 20 20 20 20 20 28 63 61 72 20 6c 61 -num (car la
2f90: 73 74 2d 72 75 6e 2d 64 61 74 29 29 0a 09 20 20 st-run-dat))..
2fa0: 20 20 20 28 77 68 65 6e 2d 72 75 6e 20 20 20 20 (when-run
2fb0: 20 28 63 61 64 72 20 6c 61 73 74 2d 72 75 6e 2d (cadr last-run-
2fc0: 64 61 74 29 29 0a 09 20 20 20 20 20 28 72 75 6e dat)).. (run
2fd0: 2d 64 65 6c 61 79 20 20 20 20 28 2b 20 28 63 61 -delay (+ (ca
2fe0: 73 65 20 63 61 6c 6c 2d 6e 75 6d 0a 09 09 09 09 se call-num.....
2ff0: 28 28 30 29 20 20 20 20 30 29 0a 09 09 09 09 28 ((0) 0).....(
3000: 28 31 29 20 20 20 32 30 29 0a 09 09 09 09 28 28 (1) 20).....((
3010: 32 29 20 20 33 30 30 29 0a 09 09 09 09 28 65 6c 2) 300).....(el
3020: 73 65 20 36 30 30 29 29 0a 09 09 09 20 20 20 20 se 600))....
3030: 20 20 28 72 61 6e 64 6f 6d 20 35 29 29 29 20 20 (random 5)))
3040: 20 3b 3b 20 61 64 64 20 61 20 73 6d 61 6c 6c 20 ;; add a small
3050: 72 61 6e 64 6f 6d 20 6e 75 6d 62 65 72 20 6a 75 random number ju
3060: 73 74 20 69 6e 20 63 61 73 65 20 61 20 6c 6f 74 st in case a lot
3070: 20 6f 66 20 6a 6f 62 73 20 68 69 74 20 74 68 65 of jobs hit the
3080: 20 77 6f 72 6b 20 68 6f 73 74 73 20 73 69 6d 75 work hosts simu
3090: 6c 74 61 6e 65 6f 75 73 6c 79 0a 09 20 20 20 20 ltaneously..
30a0: 20 28 6c 6f 63 6b 2d 66 69 6c 65 20 20 20 20 28 (lock-file (
30b0: 63 6f 6e 63 20 61 72 65 61 70 61 74 68 20 22 2f conc areapath "/
30c0: 6c 6f 67 73 2f 73 65 72 76 65 72 2d 73 74 61 72 logs/server-star
30d0: 74 2e 6c 6f 63 6b 22 29 29 29 0a 09 28 69 66 09 t.lock")))..(if.
30e0: 28 3e 20 28 2d 20 28 63 75 72 72 65 6e 74 2d 73 (> (- (current-s
30f0: 65 63 6f 6e 64 73 29 20 77 68 65 6e 2d 72 75 6e econds) when-run
3100: 29 20 72 75 6e 2d 64 65 6c 61 79 29 0a 09 09 28 ) run-delay)...(
3110: 62 65 67 69 6e 0a 09 09 20 20 28 63 6f 6d 6d 6f begin... (commo
3120: 6e 3a 73 69 6d 70 6c 65 2d 66 69 6c 65 2d 6c 6f n:simple-file-lo
3130: 63 6b 2d 61 6e 64 2d 77 61 69 74 20 6c 6f 63 6b ck-and-wait lock
3140: 2d 66 69 6c 65 20 65 78 70 69 72 65 2d 74 69 6d -file expire-tim
3150: 65 3a 20 31 35 29 0a 09 09 20 20 28 73 65 72 76 e: 15)... (serv
3160: 65 72 3a 72 75 6e 20 61 72 65 61 70 61 74 68 29 er:run areapath)
3170: 0a 09 09 20 20 28 74 68 72 65 61 64 2d 73 6c 65 ... (thread-sle
3180: 65 70 21 20 35 29 20 3b 3b 20 64 6f 6e 27 74 20 ep! 5) ;; don't
3190: 72 65 6c 65 61 73 65 20 74 68 65 20 6c 6f 63 6b release the lock
31a0: 20 66 6f 72 20 61 74 20 6c 65 61 73 74 20 61 20 for at least a
31b0: 66 65 77 20 73 65 63 6f 6e 64 73 0a 09 09 20 20 few seconds...
31c0: 28 63 6f 6d 6d 6f 6e 3a 73 69 6d 70 6c 65 2d 66 (common:simple-f
31d0: 69 6c 65 2d 72 65 6c 65 61 73 65 2d 6c 6f 63 6b ile-release-lock
31e0: 20 6c 6f 63 6b 2d 66 69 6c 65 29 29 29 0a 09 28 lock-file)))..(
31f0: 68 61 73 68 2d 74 61 62 6c 65 2d 73 65 74 21 20 hash-table-set!
3200: 2a 73 65 72 76 65 72 2d 6b 69 6e 64 2d 72 75 6e *server-kind-run
3210: 2a 20 61 72 65 61 70 61 74 68 20 28 6c 69 73 74 * areapath (list
3220: 20 28 2b 20 63 61 6c 6c 2d 6e 75 6d 20 31 29 28 (+ call-num 1)(
3230: 63 75 72 72 65 6e 74 2d 73 65 63 6f 6e 64 73 29 current-seconds)
3240: 29 29 29 29 29 0a 0a 28 64 65 66 69 6e 65 20 28 )))))..(define (
3250: 73 65 72 76 65 72 3a 73 74 61 72 74 2d 61 6e 64 server:start-and
3260: 2d 77 61 69 74 20 61 72 65 61 70 61 74 68 20 23 -wait areapath #
3270: 21 6b 65 79 20 28 74 69 6d 65 6f 75 74 20 36 30 !key (timeout 60
3280: 29 29 0a 20 20 28 6c 65 74 20 28 28 67 69 76 65 )). (let ((give
3290: 2d 75 70 2d 74 69 6d 65 20 28 2b 20 28 63 75 72 -up-time (+ (cur
32a0: 72 65 6e 74 2d 73 65 63 6f 6e 64 73 29 20 74 69 rent-seconds) ti
32b0: 6d 65 6f 75 74 29 29 29 0a 20 20 20 20 28 6c 65 meout))). (le
32c0: 74 20 6c 6f 6f 70 20 28 28 73 65 72 76 65 72 2d t loop ((server-
32d0: 75 72 6c 20 28 73 65 72 76 65 72 3a 63 68 65 63 url (server:chec
32e0: 6b 2d 69 66 2d 72 75 6e 6e 69 6e 67 20 61 72 65 k-if-running are
32f0: 61 70 61 74 68 29 29 0a 09 20 20 20 20 20 20 20 apath))..
3300: 28 74 72 79 2d 6e 75 6d 20 20 20 20 30 29 29 0a (try-num 0)).
3310: 20 20 20 20 20 20 28 69 66 20 28 6f 72 20 73 65 (if (or se
3320: 72 76 65 72 2d 75 72 6c 0a 09 20 20 20 20 20 20 rver-url..
3330: 28 3e 20 28 63 75 72 72 65 6e 74 2d 73 65 63 6f (> (current-seco
3340: 6e 64 73 29 20 67 69 76 65 2d 75 70 2d 74 69 6d nds) give-up-tim
3350: 65 29 29 20 3b 3b 20 73 65 72 76 65 72 2d 75 72 e)) ;; server-ur
3360: 6c 20 77 69 6c 6c 20 62 65 20 23 66 20 69 66 20 l will be #f if
3370: 6e 6f 20 73 65 72 76 65 72 20 61 76 61 69 6c 61 no server availa
3380: 62 6c 65 2e 0a 09 20 20 73 65 72 76 65 72 2d 75 ble... server-u
3390: 72 6c 0a 09 20 20 28 6c 65 74 20 28 28 6e 75 6d rl.. (let ((num
33a0: 2d 6f 6b 20 28 6c 65 6e 67 74 68 20 28 73 65 72 -ok (length (ser
33b0: 76 65 72 3a 67 65 74 2d 62 65 73 74 20 28 73 65 ver:get-best (se
33c0: 72 76 65 72 3a 67 65 74 2d 6c 69 73 74 20 61 72 rver:get-list ar
33d0: 65 61 70 61 74 68 29 29 29 29 29 0a 09 20 20 20 eapath)))))..
33e0: 20 28 69 66 20 28 61 6e 64 20 28 3e 20 74 72 79 (if (and (> try
33f0: 2d 6e 75 6d 20 30 29 20 20 3b 3b 20 66 69 72 73 -num 0) ;; firs
3400: 74 20 74 69 6d 65 20 74 68 72 6f 75 67 68 20 73 t time through s
3410: 69 6d 70 6c 79 20 77 61 69 74 20 61 20 6c 69 74 imply wait a lit
3420: 74 6c 65 20 77 68 69 6c 65 20 74 68 65 6e 20 74 tle while then t
3430: 72 79 20 61 67 61 69 6e 0a 09 09 20 20 20 20 20 ry again...
3440: 28 3c 20 6e 75 6d 2d 6f 6b 20 31 29 29 20 20 3b (< num-ok 1)) ;
3450: 3b 20 69 66 20 74 68 65 72 65 20 61 72 65 20 6e ; if there are n
3460: 6f 20 64 65 63 65 6e 74 20 63 61 6e 64 69 64 61 o decent candida
3470: 74 65 73 20 66 6f 72 20 73 65 72 76 65 72 73 20 tes for servers
3480: 74 68 65 6e 20 74 72 79 20 73 74 61 72 74 69 6e then try startin
3490: 67 20 61 20 6e 65 77 20 6f 6e 65 0a 09 09 28 73 g a new one...(s
34a0: 65 72 76 65 72 3a 6b 69 6e 64 2d 72 75 6e 20 61 erver:kind-run a
34b0: 72 65 61 70 61 74 68 29 29 0a 09 20 20 20 20 28 reapath)).. (
34c0: 74 68 72 65 61 64 2d 73 6c 65 65 70 21 20 35 29 thread-sleep! 5)
34d0: 0a 09 20 20 20 20 28 6c 6f 6f 70 20 28 73 65 72 .. (loop (ser
34e0: 76 65 72 3a 63 68 65 63 6b 2d 69 66 2d 72 75 6e ver:check-if-run
34f0: 6e 69 6e 67 20 61 72 65 61 70 61 74 68 29 0a 09 ning areapath)..
3500: 09 20 20 28 2b 20 74 72 79 2d 6e 75 6d 20 31 29 . (+ try-num 1)
3510: 29 29 29 29 29 29 0a 0a 28 64 65 66 69 6e 65 20 ))))))..(define
3520: 73 65 72 76 65 72 3a 74 72 79 2d 72 75 6e 6e 69 server:try-runni
3530: 6e 67 20 73 65 72 76 65 72 3a 72 75 6e 29 20 3b ng server:run) ;
3540: 3b 20 74 68 65 72 65 20 69 73 20 6e 6f 20 6d 6f ; there is no mo
3550: 72 65 20 70 65 72 2d 72 75 6e 20 73 65 72 76 65 re per-run serve
3560: 72 73 20 3b 3b 20 52 45 4d 4f 56 45 20 4d 45 2e rs ;; REMOVE ME.
3570: 20 42 55 47 2e 0a 0a 28 64 65 66 69 6e 65 20 28 BUG...(define (
3580: 73 65 72 76 65 72 3a 67 65 74 2d 6e 75 6d 2d 73 server:get-num-s
3590: 65 72 76 65 72 73 20 23 21 6b 65 79 20 28 6e 75 ervers #!key (nu
35a0: 6d 73 65 72 76 65 72 73 20 32 29 29 0a 20 20 28 mservers 2)). (
35b0: 6c 65 74 20 28 28 6e 73 20 28 73 74 72 69 6e 67 let ((ns (string
35c0: 2d 3e 6e 75 6d 62 65 72 0a 09 20 20 20 20 20 28 ->number.. (
35d0: 6f 72 20 28 63 6f 6e 66 69 67 66 3a 6c 6f 6f 6b or (configf:look
35e0: 75 70 20 2a 63 6f 6e 66 69 67 64 61 74 2a 20 22 up *configdat* "
35f0: 73 65 72 76 65 72 22 20 22 6e 75 6d 73 65 72 76 server" "numserv
3600: 65 72 73 22 29 20 22 6e 6f 74 61 6e 75 6d 62 65 ers") "notanumbe
3610: 72 22 29 29 29 29 0a 20 20 20 20 28 6f 72 20 6e r")))). (or n
3620: 73 20 6e 75 6d 73 65 72 76 65 72 73 29 29 29 0a s numservers))).
3630: 0a 3b 3b 20 6e 6f 20 6c 6f 6e 67 65 72 20 63 61 .;; no longer ca
3640: 72 65 20 69 66 20 6d 75 6c 74 69 70 6c 65 20 73 re if multiple s
3650: 65 72 76 65 72 73 20 61 72 65 20 73 74 61 72 74 ervers are start
3660: 65 64 20 62 79 20 61 63 63 69 64 65 6e 74 2e 20 ed by accident.
3670: 6f 6c 64 65 72 20 73 65 72 76 65 72 73 20 77 69 older servers wi
3680: 6c 6c 20 64 72 6f 70 20 6f 66 66 20 69 6e 20 74 ll drop off in t
3690: 69 6d 65 2e 0a 3b 3b 0a 28 64 65 66 69 6e 65 20 ime..;;.(define
36a0: 28 73 65 72 76 65 72 3a 63 68 65 63 6b 2d 69 66 (server:check-if
36b0: 2d 72 75 6e 6e 69 6e 67 20 61 72 65 61 70 61 74 -running areapat
36c0: 68 29 20 3b 3b 20 20 23 21 6b 65 79 20 28 6e 75 h) ;; #!key (nu
36d0: 6d 73 65 72 76 65 72 73 20 22 32 22 29 29 0a 20 mservers "2")).
36e0: 20 28 6c 65 74 2a 20 28 28 6e 73 20 20 20 20 20 (let* ((ns
36f0: 20 20 20 20 20 20 20 28 73 65 72 76 65 72 3a 67 (server:g
3700: 65 74 2d 6e 75 6d 2d 73 65 72 76 65 72 73 29 29 et-num-servers))
3710: 0a 09 20 28 73 65 72 76 65 72 73 20 20 20 20 20 .. (servers
3720: 20 20 28 73 65 72 76 65 72 3a 67 65 74 2d 62 65 (server:get-be
3730: 73 74 20 28 73 65 72 76 65 72 3a 67 65 74 2d 6c st (server:get-l
3740: 69 73 74 20 61 72 65 61 70 61 74 68 29 29 29 29 ist areapath))))
3750: 0a 20 20 20 20 3b 3b 20 28 70 72 69 6e 74 20 22 . ;; (print "
3760: 73 65 72 76 65 72 73 3a 20 22 20 73 65 72 76 65 servers: " serve
3770: 72 73 20 22 20 6e 73 3a 20 22 20 6e 73 29 0a 20 rs " ns: " ns).
3780: 20 20 20 28 69 66 20 28 6f 72 20 28 61 6e 64 20 (if (or (and
3790: 73 65 72 76 65 72 73 0a 09 09 20 28 6e 75 6c 6c servers... (null
37a0: 3f 20 73 65 72 76 65 72 73 29 29 0a 09 20 20 20 ? servers))..
37b0: 20 28 6e 6f 74 20 73 65 72 76 65 72 73 29 0a 09 (not servers)..
37c0: 20 20 20 20 28 61 6e 64 20 28 6c 69 73 74 3f 20 (and (list?
37d0: 73 65 72 76 65 72 73 29 0a 09 09 20 28 3c 20 28 servers)... (< (
37e0: 6c 65 6e 67 74 68 20 73 65 72 76 65 72 73 29 20 length servers)
37f0: 28 72 61 6e 64 6f 6d 20 6e 73 29 29 29 29 20 3b (random ns)))) ;
3800: 3b 20 73 6f 6d 65 77 68 65 72 65 20 62 65 74 77 ; somewhere betw
3810: 65 65 6e 20 30 20 61 6e 64 20 6e 75 6d 73 65 72 een 0 and numser
3820: 76 65 72 73 0a 20 20 20 20 20 20 20 20 23 66 0a vers. #f.
3830: 20 20 20 20 20 20 20 20 28 6c 65 74 20 6c 6f 6f (let loo
3840: 70 20 28 28 68 65 64 20 28 63 61 72 20 73 65 72 p ((hed (car ser
3850: 76 65 72 73 29 29 0a 20 20 20 20 20 20 20 20 20 vers)).
3860: 20 20 20 20 20 20 20 20 20 20 28 74 61 6c 20 28 (tal (
3870: 63 64 72 20 73 65 72 76 65 72 73 29 29 29 0a 20 cdr servers))).
3880: 20 20 20 20 20 20 20 20 20 28 6c 65 74 20 28 28 (let ((
3890: 72 65 73 20 28 73 65 72 76 65 72 3a 63 68 65 63 res (server:chec
38a0: 6b 2d 73 65 72 76 65 72 20 68 65 64 29 29 29 0a k-server hed))).
38b0: 20 20 20 20 20 20 20 20 20 20 20 20 28 69 66 20 (if
38c0: 72 65 73 0a 20 20 20 20 20 20 20 20 20 20 20 20 res.
38d0: 20 20 20 20 72 65 73 0a 20 20 20 20 20 20 20 20 res.
38e0: 20 20 20 20 20 20 20 20 28 69 66 20 28 6e 75 6c (if (nul
38f0: 6c 3f 20 74 61 6c 29 0a 20 20 20 20 20 20 20 20 l? tal).
3900: 20 20 20 20 20 20 20 20 20 20 20 20 23 66 0a 20 #f.
3910: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
3920: 20 20 20 28 6c 6f 6f 70 20 28 63 61 72 20 74 61 (loop (car ta
3930: 6c 29 28 63 64 72 20 74 61 6c 29 29 29 29 29 29 l)(cdr tal))))))
3940: 29 29 29 0a 0a 3b 3b 20 70 69 6e 67 20 74 68 65 )))..;; ping the
3950: 20 67 69 76 65 6e 20 73 65 72 76 65 72 0a 3b 3b given server.;;
3960: 0a 28 64 65 66 69 6e 65 20 28 73 65 72 76 65 72 .(define (server
3970: 3a 63 68 65 63 6b 2d 73 65 72 76 65 72 20 73 65 :check-server se
3980: 72 76 65 72 2d 72 65 63 6f 72 64 29 0a 20 20 28 rver-record). (
3990: 6c 65 74 2a 20 28 28 73 65 72 76 65 72 2d 75 72 let* ((server-ur
39a0: 6c 20 28 73 65 72 76 65 72 3a 72 65 63 6f 72 64 l (server:record
39b0: 2d 3e 75 72 6c 20 73 65 72 76 65 72 2d 72 65 63 ->url server-rec
39c0: 6f 72 64 29 29 0a 20 20 20 20 20 20 20 20 20 28 ord)). (
39d0: 72 65 73 20 20 20 20 20 20 20 20 28 63 61 73 65 res (case
39e0: 20 2a 74 72 61 6e 73 70 6f 72 74 2d 74 79 70 65 *transport-type
39f0: 2a 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 *.
3a00: 20 20 20 20 20 20 20 20 20 28 28 68 74 74 70 29 ((http)
3a10: 28 73 65 72 76 65 72 3a 70 69 6e 67 20 73 65 72 (server:ping ser
3a20: 76 65 72 2d 75 72 6c 29 29 0a 20 20 20 20 20 20 ver-url)).
3a30: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
3a40: 20 3b 3b 20 28 28 6e 6d 73 67 29 28 6e 6d 73 67 ;; ((nmsg)(nmsg
3a50: 2d 74 72 61 6e 73 70 6f 72 74 3a 70 69 6e 67 20 -transport:ping
3a60: 28 74 61 73 6b 73 3a 68 6f 73 74 69 6e 66 6f 2d (tasks:hostinfo-
3a70: 67 65 74 2d 69 6e 74 65 72 66 61 63 65 20 73 65 get-interface se
3a80: 72 76 65 72 29 0a 20 20 20 20 20 20 20 20 20 20 rver).
3a90: 20 20 20 20 20 20 20 20 20 20 20 20 20 29 29 29 )))
3aa0: 0a 20 20 20 20 28 69 66 20 72 65 73 0a 20 20 20 . (if res.
3ab0: 20 20 20 20 20 73 65 72 76 65 72 2d 75 72 6c 0a server-url.
3ac0: 09 23 66 29 29 29 0a 0a 28 64 65 66 69 6e 65 20 .#f)))..(define
3ad0: 28 73 65 72 76 65 72 3a 6b 69 6c 6c 20 73 65 72 (server:kill ser
3ae0: 76 72 29 0a 20 20 28 6d 61 74 63 68 2d 6c 65 74 vr). (match-let
3af0: 20 28 28 28 6d 6f 64 2d 74 69 6d 65 20 68 6f 73 (((mod-time hos
3b00: 74 6e 61 6d 65 20 70 6f 72 74 20 73 74 61 72 74 tname port start
3b10: 2d 74 69 6d 65 20 70 69 64 29 0a 09 20 20 20 20 -time pid)..
3b20: 20 20 20 73 65 72 76 72 29 29 0a 20 20 20 20 28 servr)). (
3b30: 74 61 73 6b 73 3a 6b 69 6c 6c 2d 73 65 72 76 65 tasks:kill-serve
3b40: 72 20 68 6f 73 74 6e 61 6d 65 20 70 69 64 29 29 r hostname pid))
3b50: 29 0a 0a 3b 3b 20 63 61 6c 6c 65 64 20 69 6e 20 )..;; called in
3b60: 6d 65 67 61 74 65 73 74 2e 73 63 6d 2c 20 68 6f megatest.scm, ho
3b70: 73 74 2d 70 6f 72 74 20 69 73 20 73 74 72 69 6e st-port is strin
3b80: 67 20 68 6f 73 74 6e 61 6d 65 3a 70 6f 72 74 0a g hostname:port.
3b90: 3b 3b 0a 3b 3b 20 4e 4f 54 45 3a 20 54 68 69 73 ;;.;; NOTE: This
3ba0: 20 69 73 20 4e 4f 54 20 63 61 6c 6c 65 64 20 64 is NOT called d
3bb0: 69 72 65 63 74 6c 79 20 66 72 6f 6d 20 63 6c 69 irectly from cli
3bc0: 65 6e 74 73 20 61 73 20 6e 6f 74 20 61 6c 6c 20 ents as not all
3bd0: 74 72 61 6e 73 70 6f 72 74 73 20 73 75 70 70 6f transports suppo
3be0: 72 74 20 61 20 63 6c 69 65 6e 74 20 72 75 6e 6e rt a client runn
3bf0: 69 6e 67 0a 3b 3b 20 20 20 20 20 20 20 69 6e 20 ing.;; in
3c00: 74 68 65 20 73 61 6d 65 20 70 72 6f 63 65 73 73 the same process
3c10: 20 61 73 20 74 68 65 20 73 65 72 76 65 72 2e 0a as the server..
3c20: 3b 3b 0a 28 64 65 66 69 6e 65 20 28 73 65 72 76 ;;.(define (serv
3c30: 65 72 3a 70 69 6e 67 20 68 6f 73 74 2d 70 6f 72 er:ping host-por
3c40: 74 2d 69 6e 20 23 21 6b 65 79 20 28 64 6f 2d 65 t-in #!key (do-e
3c50: 78 69 74 20 23 66 29 29 0a 20 20 28 6c 65 74 20 xit #f)). (let
3c60: 28 28 68 6f 73 74 3a 70 6f 72 74 20 28 69 66 20 ((host:port (if
3c70: 28 6e 6f 74 20 68 6f 73 74 2d 70 6f 72 74 2d 69 (not host-port-i
3c80: 6e 29 20 3b 3b 20 75 73 65 20 72 65 61 64 2d 64 n) ;; use read-d
3c90: 6f 74 73 65 72 76 65 72 20 74 6f 20 66 69 6e 64 otserver to find
3ca0: 0a 09 09 20 20 20 20 20 20 20 23 66 20 3b 3b 20 ... #f ;;
3cb0: 28 73 65 72 76 65 72 3a 63 68 65 63 6b 2d 69 66 (server:check-if
3cc0: 2d 72 75 6e 6e 69 6e 67 20 2a 74 6f 70 70 61 74 -running *toppat
3cd0: 68 2a 29 0a 09 09 3b 3b 20 28 69 66 20 28 6e 75 h*)...;; (if (nu
3ce0: 6d 62 65 72 3f 20 68 6f 73 74 2d 70 6f 72 74 2d mber? host-port-
3cf0: 69 6e 29 20 3b 3b 20 77 65 20 77 65 72 65 20 68 in) ;; we were h
3d00: 61 6e 64 65 64 20 61 20 73 65 72 76 65 72 2d 69 anded a server-i
3d10: 64 0a 09 09 3b 3b 20 09 20 20 20 28 6c 65 74 20 d...;; . (let
3d20: 28 28 73 72 65 63 20 28 74 61 73 6b 73 3a 67 65 ((srec (tasks:ge
3d30: 74 2d 73 65 72 76 65 72 2d 62 79 2d 69 64 20 28 t-server-by-id (
3d40: 64 62 3a 64 65 6c 61 79 2d 69 66 2d 62 75 73 79 db:delay-if-busy
3d50: 20 28 74 61 73 6b 73 3a 6f 70 65 6e 2d 64 62 29 (tasks:open-db)
3d60: 29 20 68 6f 73 74 2d 70 6f 72 74 2d 69 6e 29 29 ) host-port-in))
3d70: 29 0a 09 09 3b 3b 20 09 20 20 20 20 20 3b 3b 20 )...;; . ;;
3d80: 28 70 72 69 6e 74 20 22 73 72 65 63 3a 20 22 20 (print "srec: "
3d90: 73 72 65 63 20 22 20 68 6f 73 74 2d 70 6f 72 74 srec " host-port
3da0: 2d 69 6e 3a 20 22 20 68 6f 73 74 2d 70 6f 72 74 -in: " host-port
3db0: 2d 69 6e 29 0a 09 09 3b 3b 20 09 20 20 20 20 20 -in)...;; .
3dc0: 28 69 66 20 73 72 65 63 0a 09 09 3b 3b 20 09 09 (if srec...;; ..
3dd0: 20 28 63 6f 6e 63 20 28 76 65 63 74 6f 72 2d 72 (conc (vector-r
3de0: 65 66 20 73 72 65 63 20 33 29 20 22 3a 22 20 28 ef srec 3) ":" (
3df0: 76 65 63 74 6f 72 2d 72 65 66 20 73 72 65 63 20 vector-ref srec
3e00: 34 29 29 0a 09 09 3b 3b 20 09 09 20 28 63 6f 6e 4))...;; .. (con
3e10: 63 20 22 6e 6f 20 73 75 63 68 20 73 65 72 76 65 c "no such serve
3e20: 72 2d 69 64 20 22 20 68 6f 73 74 2d 70 6f 72 74 r-id " host-port
3e30: 2d 69 6e 29 29 29 0a 09 09 20 20 20 20 20 20 20 -in)))...
3e40: 68 6f 73 74 2d 70 6f 72 74 2d 69 6e 29 29 29 20 host-port-in)))
3e50: 3b 3b 20 29 0a 20 20 20 20 28 6c 65 74 2a 20 28 ;; ). (let* (
3e60: 28 68 6f 73 74 2d 70 6f 72 74 20 28 69 66 20 68 (host-port (if h
3e70: 6f 73 74 3a 70 6f 72 74 0a 09 09 09 20 20 28 6c ost:port.... (l
3e80: 65 74 20 28 28 73 6c 73 74 20 28 73 74 72 69 6e et ((slst (strin
3e90: 67 2d 73 70 6c 69 74 20 20 20 68 6f 73 74 3a 70 g-split host:p
3ea0: 6f 72 74 20 22 3a 22 29 29 29 0a 09 09 09 20 20 ort ":")))....
3eb0: 20 20 28 69 66 20 28 65 71 3f 20 28 6c 65 6e 67 (if (eq? (leng
3ec0: 74 68 20 73 6c 73 74 29 20 32 29 0a 09 09 09 09 th slst) 2).....
3ed0: 28 6c 69 73 74 20 28 63 61 72 20 73 6c 73 74 29 (list (car slst)
3ee0: 28 73 74 72 69 6e 67 2d 3e 6e 75 6d 62 65 72 20 (string->number
3ef0: 28 63 61 64 72 20 73 6c 73 74 29 29 29 0a 09 09 (cadr slst)))...
3f00: 09 09 23 66 29 29 0a 09 09 09 20 20 23 66 29 29 ..#f)).... #f))
3f10: 29 0a 3b 3b 09 20 20 20 28 74 6f 70 70 61 74 68 ).;;. (toppath
3f20: 20 20 20 20 20 20 20 28 6c 61 75 6e 63 68 3a 73 (launch:s
3f30: 65 74 75 70 29 29 29 0a 20 20 20 20 20 20 3b 3b etup))). ;;
3f40: 20 28 70 72 69 6e 74 20 22 68 6f 73 74 2d 70 6f (print "host-po
3f50: 72 74 3d 22 20 68 6f 73 74 2d 70 6f 72 74 29 0a rt=" host-port).
3f60: 20 20 20 20 20 20 28 69 66 20 28 6e 6f 74 20 68 (if (not h
3f70: 6f 73 74 2d 70 6f 72 74 29 0a 09 20 20 28 62 65 ost-port).. (be
3f80: 67 69 6e 0a 09 20 20 20 20 28 69 66 20 68 6f 73 gin.. (if hos
3f90: 74 2d 70 6f 72 74 2d 69 6e 0a 09 09 28 64 65 62 t-port-in...(deb
3fa0: 75 67 3a 70 72 69 6e 74 20 30 20 2a 64 65 66 61 ug:print 0 *defa
3fb0: 75 6c 74 2d 6c 6f 67 2d 70 6f 72 74 2a 20 20 22 ult-log-port* "
3fc0: 45 52 52 4f 52 3a 20 62 61 64 20 68 6f 73 74 3a ERROR: bad host:
3fd0: 70 6f 72 74 22 29 29 0a 09 20 20 20 20 28 69 66 port")).. (if
3fe0: 20 64 6f 2d 65 78 69 74 20 28 65 78 69 74 20 31 do-exit (exit 1
3ff0: 29 29 0a 09 20 20 20 20 23 66 29 0a 09 20 20 28 )).. #f).. (
4000: 6c 65 74 2a 20 28 28 69 66 61 63 65 20 20 20 20 let* ((iface
4010: 20 20 28 63 61 72 20 68 6f 73 74 2d 70 6f 72 74 (car host-port
4020: 29 29 0a 09 09 20 28 70 6f 72 74 20 20 20 20 20 ))... (port
4030: 20 20 28 63 61 64 72 20 68 6f 73 74 2d 70 6f 72 (cadr host-por
4040: 74 29 29 0a 09 09 20 28 73 65 72 76 65 72 2d 64 t))... (server-d
4050: 61 74 20 28 68 74 74 70 2d 74 72 61 6e 73 70 6f at (http-transpo
4060: 72 74 3a 63 6c 69 65 6e 74 2d 63 6f 6e 6e 65 63 rt:client-connec
4070: 74 20 69 66 61 63 65 20 70 6f 72 74 29 29 0a 09 t iface port))..
4080: 09 20 28 6c 6f 67 69 6e 2d 72 65 73 20 20 28 72 . (login-res (r
4090: 6d 74 3a 6c 6f 67 69 6e 2d 6e 6f 2d 61 75 74 6f mt:login-no-auto
40a0: 2d 63 6c 69 65 6e 74 2d 73 65 74 75 70 20 73 65 -client-setup se
40b0: 72 76 65 72 2d 64 61 74 29 29 29 0a 09 20 20 20 rver-dat)))..
40c0: 20 28 69 66 20 28 61 6e 64 20 28 6c 69 73 74 3f (if (and (list?
40d0: 20 6c 6f 67 69 6e 2d 72 65 73 29 0a 09 09 20 20 login-res)...
40e0: 20 20 20 28 63 61 72 20 6c 6f 67 69 6e 2d 72 65 (car login-re
40f0: 73 29 29 0a 09 09 28 62 65 67 69 6e 0a 09 09 20 s))...(begin...
4100: 20 3b 3b 20 28 70 72 69 6e 74 20 22 4c 4f 47 49 ;; (print "LOGI
4110: 4e 5f 4f 4b 22 29 0a 09 09 20 20 28 69 66 20 64 N_OK")... (if d
4120: 6f 2d 65 78 69 74 20 28 65 78 69 74 20 30 29 29 o-exit (exit 0))
4130: 0a 09 09 20 20 23 74 29 0a 09 09 28 62 65 67 69 ... #t)...(begi
4140: 6e 0a 09 09 20 20 3b 3b 20 28 70 72 69 6e 74 20 n... ;; (print
4150: 22 4c 4f 47 49 4e 5f 46 41 49 4c 45 44 22 29 0a "LOGIN_FAILED").
4160: 09 09 20 20 28 69 66 20 64 6f 2d 65 78 69 74 20 .. (if do-exit
4170: 28 65 78 69 74 20 31 29 29 0a 09 09 20 20 23 66 (exit 1))... #f
4180: 29 29 29 29 29 29 29 0a 0a 3b 3b 20 72 75 6e 20 )))))))..;; run
4190: 70 69 6e 67 20 69 6e 20 73 65 70 61 72 61 74 65 ping in separate
41a0: 20 70 72 6f 63 65 73 73 2c 20 73 61 66 65 73 74 process, safest
41b0: 20 77 61 79 20 69 6e 20 73 6f 6d 65 20 63 61 73 way in some cas
41c0: 65 73 0a 3b 3b 0a 28 64 65 66 69 6e 65 20 28 73 es.;;.(define (s
41d0: 65 72 76 65 72 3a 70 69 6e 67 2d 73 65 72 76 65 erver:ping-serve
41e0: 72 20 69 66 61 63 65 70 6f 72 74 29 0a 20 20 28 r ifaceport). (
41f0: 77 69 74 68 2d 69 6e 70 75 74 2d 66 72 6f 6d 2d with-input-from-
4200: 70 69 70 65 20 0a 20 20 20 28 63 6f 6e 63 20 28 pipe . (conc (
4210: 63 6f 6d 6d 6f 6e 3a 67 65 74 2d 6d 65 67 61 74 common:get-megat
4220: 65 73 74 2d 65 78 65 29 20 22 20 2d 70 69 6e 67 est-exe) " -ping
4230: 20 22 20 69 66 61 63 65 70 6f 72 74 29 0a 20 20 " ifaceport).
4240: 20 28 6c 61 6d 62 64 61 20 28 29 0a 20 20 20 20 (lambda ().
4250: 20 28 6c 65 74 20 6c 6f 6f 70 20 28 28 69 6e 6c (let loop ((inl
4260: 20 28 72 65 61 64 2d 6c 69 6e 65 29 29 0a 09 09 (read-line))...
4270: 28 72 65 73 20 22 4e 4f 52 45 50 4c 59 22 29 29 (res "NOREPLY"))
4280: 0a 20 20 20 20 20 20 20 28 69 66 20 28 65 6f 66 . (if (eof
4290: 2d 6f 62 6a 65 63 74 3f 20 69 6e 6c 29 0a 09 20 -object? inl)..
42a0: 20 20 28 63 61 73 65 20 28 73 74 72 69 6e 67 2d (case (string-
42b0: 3e 73 79 6d 62 6f 6c 20 72 65 73 29 0a 09 20 20 >symbol res)..
42c0: 20 20 20 28 28 4e 4f 52 45 50 4c 59 29 20 20 23 ((NOREPLY) #
42d0: 66 29 0a 09 20 20 20 20 20 28 28 4c 4f 47 49 4e f).. ((LOGIN
42e0: 5f 4f 4b 29 20 23 74 29 0a 09 20 20 20 20 20 28 _OK) #t).. (
42f0: 65 6c 73 65 20 20 20 20 20 20 20 23 66 29 29 0a else #f)).
4300: 09 20 20 20 28 6c 6f 6f 70 20 28 72 65 61 64 2d . (loop (read-
4310: 6c 69 6e 65 29 20 69 6e 6c 29 29 29 29 29 29 0a line) inl)))))).
4320: 0a 3b 3b 20 4e 4f 54 20 55 53 45 44 20 28 77 65 .;; NOT USED (we
4330: 6c 6c 2c 20 6f 6b 2c 20 72 65 66 65 72 65 6e 63 ll, ok, referenc
4340: 65 20 69 6e 20 72 70 63 2d 74 72 61 6e 73 70 6f e in rpc-transpo
4350: 72 74 20 62 75 74 20 6f 74 68 65 72 77 69 73 65 rt but otherwise
4360: 20 6e 6f 74 20 75 73 65 64 29 2e 0a 3b 3b 0a 28 not used)..;;.(
4370: 64 65 66 69 6e 65 20 28 73 65 72 76 65 72 3a 6c define (server:l
4380: 6f 67 69 6e 20 74 6f 70 70 61 74 68 29 0a 20 20 ogin toppath).
4390: 28 6c 61 6d 62 64 61 20 28 74 6f 70 70 61 74 68 (lambda (toppath
43a0: 29 0a 20 20 20 20 28 73 65 74 21 20 2a 64 62 2d ). (set! *db-
43b0: 6c 61 73 74 2d 61 63 63 65 73 73 2a 20 28 63 75 last-access* (cu
43c0: 72 72 65 6e 74 2d 73 65 63 6f 6e 64 73 29 29 20 rrent-seconds))
43d0: 3b 3b 20 6d 69 67 68 74 20 6e 6f 74 20 62 65 20 ;; might not be
43e0: 6e 65 65 64 65 64 2e 0a 20 20 20 20 28 69 66 20 needed.. (if
43f0: 28 65 71 75 61 6c 3f 20 2a 74 6f 70 70 61 74 68 (equal? *toppath
4400: 2a 20 74 6f 70 70 61 74 68 29 0a 09 23 74 0a 09 * toppath)..#t..
4410: 23 66 29 29 29 0a 0a 3b 3b 20 74 69 6d 65 6f 75 #f)))..;; timeou
4420: 74 20 69 73 20 68 6d 73 20 73 74 72 69 6e 67 3a t is hms string:
4430: 20 31 68 20 35 6d 20 33 73 2c 20 64 65 66 61 75 1h 5m 3s, defau
4440: 6c 74 20 69 73 20 31 20 6d 69 6e 75 74 65 0a 3b lt is 1 minute.;
4450: 3b 0a 28 64 65 66 69 6e 65 20 28 73 65 72 76 65 ;.(define (serve
4460: 72 3a 65 78 70 69 72 61 74 69 6f 6e 2d 74 69 6d r:expiration-tim
4470: 65 6f 75 74 29 0a 20 20 28 6c 65 74 20 28 28 74 eout). (let ((t
4480: 6d 6f 20 28 63 6f 6e 66 69 67 66 3a 6c 6f 6f 6b mo (configf:look
4490: 75 70 20 2a 63 6f 6e 66 69 67 64 61 74 2a 20 22 up *configdat* "
44a0: 73 65 72 76 65 72 22 20 22 74 69 6d 65 6f 75 74 server" "timeout
44b0: 22 29 29 29 0a 20 20 20 20 28 69 66 20 28 61 6e "))). (if (an
44c0: 64 20 28 73 74 72 69 6e 67 3f 20 74 6d 6f 29 0a d (string? tmo).
44d0: 09 20 20 20 20 20 28 63 6f 6d 6d 6f 6e 3a 68 6d . (common:hm
44e0: 73 2d 73 74 72 69 6e 67 2d 3e 73 65 63 6f 6e 64 s-string->second
44f0: 73 20 74 6d 6f 29 29 20 3b 3b 20 42 55 47 3a 20 s tmo)) ;; BUG:
4500: 68 6d 73 2d 73 74 72 69 6e 67 2d 3e 73 65 63 6f hms-string->seco
4510: 6e 64 73 20 69 73 20 62 72 6f 6b 65 6e 2c 20 69 nds is broken, i
4520: 66 20 67 69 76 65 6e 20 22 31 30 22 20 72 65 74 f given "10" ret
4530: 75 72 6e 73 20 30 2e 20 41 6c 73 6f 2c 20 69 74 urns 0. Also, it
4540: 20 64 6f 65 73 6e 27 74 20 62 65 6c 6f 6e 67 20 doesn't belong
4550: 69 6e 20 74 68 69 73 20 6c 6f 67 69 63 20 75 6e in this logic un
4560: 6c 65 73 73 20 74 68 65 20 73 74 72 69 6e 67 2d less the string-
4570: 3e 6e 75 6d 62 65 72 20 69 73 20 63 68 61 6e 67 >number is chang
4580: 65 64 20 62 65 6c 6f 77 0a 20 20 20 20 20 20 20 ed below.
4590: 20 28 2a 20 33 36 30 30 20 28 73 74 72 69 6e 67 (* 3600 (string
45a0: 2d 3e 6e 75 6d 62 65 72 20 74 6d 6f 29 29 0a 09 ->number tmo))..
45b0: 36 30 29 29 29 0a 0a 28 64 65 66 69 6e 65 20 28 60)))..(define (
45c0: 73 65 72 76 65 72 3a 67 65 74 2d 62 65 73 74 2d server:get-best-
45d0: 67 75 65 73 73 2d 61 64 64 72 65 73 73 20 68 6f guess-address ho
45e0: 73 74 6e 61 6d 65 29 0a 20 20 28 6c 65 74 20 28 stname). (let (
45f0: 28 72 65 73 20 23 66 29 29 0a 20 20 20 20 28 66 (res #f)). (f
4600: 6f 72 2d 65 61 63 68 20 0a 20 20 20 20 20 28 6c or-each . (l
4610: 61 6d 62 64 61 20 28 61 64 72 29 0a 20 20 20 20 ambda (adr).
4620: 20 20 20 28 69 66 20 28 6e 6f 74 20 28 65 71 3f (if (not (eq?
4630: 20 28 75 38 76 65 63 74 6f 72 2d 72 65 66 20 61 (u8vector-ref a
4640: 64 72 20 30 29 20 31 32 37 29 29 0a 09 20 20 20 dr 0) 127))..
4650: 28 73 65 74 21 20 72 65 73 20 61 64 72 29 29 29 (set! res adr)))
4660: 0a 20 20 20 20 20 3b 3b 20 4e 4f 54 45 3a 20 54 . ;; NOTE: T
4670: 68 69 73 20 63 61 6e 20 66 61 69 6c 20 77 68 65 his can fail whe
4680: 6e 20 74 68 65 72 65 20 69 73 20 6e 6f 20 6d 65 n there is no me
4690: 6e 74 69 6f 6e 20 6f 66 20 74 68 65 20 68 6f 73 ntion of the hos
46a0: 74 20 69 6e 20 2f 65 74 63 2f 68 6f 73 74 73 2e t in /etc/hosts.
46b0: 20 46 49 58 4d 45 0a 20 20 20 20 20 28 76 65 63 FIXME. (vec
46c0: 74 6f 72 2d 3e 6c 69 73 74 20 28 68 6f 73 74 69 tor->list (hosti
46d0: 6e 66 6f 2d 61 64 64 72 65 73 73 65 73 20 28 68 nfo-addresses (h
46e0: 6f 73 74 6e 61 6d 65 2d 3e 68 6f 73 74 69 6e 66 ostname->hostinf
46f0: 6f 20 68 6f 73 74 6e 61 6d 65 29 29 29 29 0a 20 o hostname)))).
4700: 20 20 20 28 73 74 72 69 6e 67 2d 69 6e 74 65 72 (string-inter
4710: 73 70 65 72 73 65 20 0a 20 20 20 20 20 28 6d 61 sperse . (ma
4720: 70 20 6e 75 6d 62 65 72 2d 3e 73 74 72 69 6e 67 p number->string
4730: 0a 09 20 20 28 75 38 76 65 63 74 6f 72 2d 3e 6c .. (u8vector->l
4740: 69 73 74 0a 09 20 20 20 28 69 66 20 72 65 73 20 ist.. (if res
4750: 72 65 73 20 28 68 6f 73 74 6e 61 6d 65 2d 3e 69 res (hostname->i
4760: 70 20 68 6f 73 74 6e 61 6d 65 29 29 29 29 20 22 p hostname)))) "
4770: 2e 22 29 29 29 0a 0a 3b 3b 20 28 64 65 66 69 6e .")))..;; (defin
4780: 65 20 73 65 72 76 65 72 3a 73 79 6e 63 2d 6c 6f e server:sync-lo
4790: 63 6b 2d 74 6f 6b 65 6e 20 22 53 45 52 56 45 52 ck-token "SERVER
47a0: 5f 53 59 4e 43 5f 4c 4f 43 4b 22 29 0a 3b 3b 20 _SYNC_LOCK").;;
47b0: 28 64 65 66 69 6e 65 20 28 73 65 72 76 65 72 3a (define (server:
47c0: 72 65 6c 65 61 73 65 2d 73 79 6e 63 2d 6c 6f 63 release-sync-loc
47d0: 6b 29 0a 3b 3b 20 20 20 28 64 62 3a 6e 6f 2d 73 k).;; (db:no-s
47e0: 79 6e 63 2d 64 65 6c 21 20 2a 6e 6f 2d 73 79 6e ync-del! *no-syn
47f0: 63 2d 64 62 2a 20 73 65 72 76 65 72 3a 73 79 6e c-db* server:syn
4800: 63 2d 6c 6f 63 6b 2d 74 6f 6b 65 6e 29 29 0a 3b c-lock-token)).;
4810: 3b 20 28 64 65 66 69 6e 65 20 28 73 65 72 76 65 ; (define (serve
4820: 72 3a 68 61 76 65 2d 73 79 6e 63 2d 6c 6f 63 6b r:have-sync-lock
4830: 3f 29 0a 3b 3b 20 20 20 28 6c 65 74 2a 20 28 28 ?).;; (let* ((
4840: 68 61 76 65 2d 6c 6f 63 6b 2d 70 61 69 72 20 28 have-lock-pair (
4850: 64 62 3a 6e 6f 2d 73 79 6e 63 2d 67 65 74 2d 6c db:no-sync-get-l
4860: 6f 63 6b 20 2a 6e 6f 2d 73 79 6e 63 2d 64 62 2a ock *no-sync-db*
4870: 20 73 65 72 76 65 72 3a 73 79 6e 63 2d 6c 6f 63 server:sync-loc
4880: 6b 2d 74 6f 6b 65 6e 29 29 0a 3b 3b 20 20 20 20 k-token)).;;
4890: 20 20 20 20 20 20 28 68 61 76 65 2d 6c 6f 63 6b (have-lock
48a0: 3f 20 20 20 20 20 28 63 61 72 20 68 61 76 65 2d ? (car have-
48b0: 6c 6f 63 6b 2d 70 61 69 72 29 29 0a 3b 3b 20 20 lock-pair)).;;
48c0: 20 20 20 20 20 20 20 20 28 6c 6f 63 6b 2d 74 69 (lock-ti
48d0: 6d 65 20 20 20 20 20 20 28 63 64 72 20 68 61 76 me (cdr hav
48e0: 65 2d 6c 6f 63 6b 2d 70 61 69 72 29 29 0a 3b 3b e-lock-pair)).;;
48f0: 20 20 20 20 20 20 20 20 20 20 28 6c 6f 63 6b 2d (lock-
4900: 61 67 65 20 20 20 20 20 20 20 28 2d 20 28 63 75 age (- (cu
4910: 72 72 65 6e 74 2d 73 65 63 6f 6e 64 73 29 20 6c rrent-seconds) l
4920: 6f 63 6b 2d 74 69 6d 65 29 29 29 0a 3b 3b 20 20 ock-time))).;;
4930: 20 20 20 28 63 6f 6e 64 0a 3b 3b 20 20 20 20 20 (cond.;;
4940: 20 28 68 61 76 65 2d 6c 6f 63 6b 3f 20 23 74 29 (have-lock? #t)
4950: 0a 3b 3b 20 20 20 20 20 20 28 28 3e 6c 6f 63 6b .;; ((>lock
4960: 2d 61 67 65 0a 3b 3b 20 20 20 20 20 20 20 20 28 -age.;; (
4970: 2a 20 33 20 28 63 6f 6e 66 69 67 66 3a 6c 6f 6f * 3 (configf:loo
4980: 6b 75 70 2d 6e 75 6d 62 65 72 20 2a 63 6f 6e 66 kup-number *conf
4990: 69 67 64 61 74 2a 20 22 73 65 72 76 65 72 22 20 igdat* "server"
49a0: 22 6d 69 6e 69 6d 75 6d 2d 69 6e 74 65 72 73 79 "minimum-intersy
49b0: 6e 63 2d 64 65 6c 61 79 22 20 64 65 66 61 75 6c nc-delay" defaul
49c0: 74 3a 20 31 38 30 29 29 29 0a 3b 3b 20 20 20 20 t: 180))).;;
49d0: 20 20 20 28 73 65 72 76 65 72 3a 72 65 6c 65 61 (server:relea
49e0: 73 65 2d 73 79 6e 63 2d 6c 6f 63 6b 29 0a 3b 3b se-sync-lock).;;
49f0: 20 20 20 20 20 20 20 28 73 65 72 76 65 72 3a 68 (server:h
4a00: 61 76 65 2d 73 79 6e 63 2d 6c 6f 63 6b 3f 29 29 ave-sync-lock?))
4a10: 0a 3b 3b 20 20 20 20 20 20 28 65 6c 73 65 20 23 .;; (else #
4a20: 66 29 29 29 29 0a 0a 3b 3b 20 6d 6f 76 69 6e 67 f))))..;; moving
4a30: 20 74 68 69 73 20 68 65 72 65 20 61 73 20 69 74 this here as it
4a40: 20 6e 65 65 64 73 20 61 63 63 65 73 73 20 74 6f needs access to
4a50: 20 64 62 20 61 6e 64 20 63 61 6e 6e 6f 74 20 62 db and cannot b
4a60: 65 20 69 6e 20 63 6f 6d 6d 6f 6e 2e 0a 3b 3b 0a e in common..;;.
4a70: 0a 28 64 65 66 69 6e 65 20 28 73 65 72 76 65 72 .(define (server
4a80: 3a 67 65 74 2d 62 72 75 74 65 66 6f 72 63 65 2d :get-bruteforce-
4a90: 73 79 6e 63 65 72 20 64 62 73 74 72 75 63 74 20 syncer dbstruct
4aa0: 23 21 6b 65 79 20 28 66 6f 72 6b 2d 74 6f 2d 62 #!key (fork-to-b
4ab0: 61 63 6b 67 72 6f 75 6e 64 20 23 66 29 20 28 70 ackground #f) (p
4ac0: 65 72 73 69 73 74 2d 75 6e 74 69 6c 2d 73 79 6e ersist-until-syn
4ad0: 63 20 23 66 29 29 0a 20 20 28 6c 65 74 2a 20 28 c #f)). (let* (
4ae0: 28 73 71 6c 69 74 65 2d 65 78 65 20 20 20 28 6f (sqlite-exe (o
4af0: 72 20 28 67 65 74 2d 65 6e 76 69 72 6f 6e 6d 65 r (get-environme
4b00: 6e 74 2d 76 61 72 69 61 62 6c 65 20 22 4d 54 5f nt-variable "MT_
4b10: 53 51 4c 49 54 45 33 5f 45 58 45 22 29 29 29 20 SQLITE3_EXE")))
4b20: 3b 3b 20 64 65 66 69 6e 65 64 20 69 6e 20 63 66 ;; defined in cf
4b30: 67 2e 73 68 0a 20 20 20 20 20 20 20 20 20 28 73 g.sh. (s
4b40: 79 6e 63 2d 6c 6f 67 20 20 20 20 20 28 6f 72 20 ync-log (or
4b50: 28 61 72 67 73 3a 67 65 74 2d 61 72 67 20 22 2d (args:get-arg "-
4b60: 73 79 6e 63 2d 6c 6f 67 22 29 20 28 63 6f 6e 63 sync-log") (conc
4b70: 20 2a 74 6f 70 70 61 74 68 2a 20 22 2f 6c 6f 67 *toppath* "/log
4b80: 73 2f 73 79 6e 63 2d 22 20 28 63 75 72 72 65 6e s/sync-" (curren
4b90: 74 2d 70 72 6f 63 65 73 73 2d 69 64 29 20 22 2d t-process-id) "-
4ba0: 22 20 28 67 65 74 2d 68 6f 73 74 2d 6e 61 6d 65 " (get-host-name
4bb0: 29 20 22 2e 6c 6f 67 22 29 29 29 0a 09 20 28 74 ) ".log"))).. (t
4bc0: 6d 70 2d 61 72 65 61 20 20 20 20 20 28 63 6f 6d mp-area (com
4bd0: 6d 6f 6e 3a 67 65 74 2d 64 62 2d 74 6d 70 2d 61 mon:get-db-tmp-a
4be0: 72 65 61 29 29 0a 09 20 28 74 6d 70 2d 64 62 20 rea)).. (tmp-db
4bf0: 20 20 20 20 20 20 28 63 6f 6e 63 20 74 6d 70 2d (conc tmp-
4c00: 61 72 65 61 20 22 2f 6d 65 67 61 74 65 73 74 2e area "/megatest.
4c10: 64 62 22 29 29 0a 09 20 28 73 74 61 67 69 6e 67 db")).. (staging
4c20: 2d 66 69 6c 65 20 28 63 6f 6e 63 20 2a 74 6f 70 -file (conc *top
4c30: 70 61 74 68 2a 20 22 2f 2e 6d 65 67 61 74 65 73 path* "/.megates
4c40: 74 2e 64 62 22 29 29 0a 09 20 28 6d 74 64 62 66 t.db")).. (mtdbf
4c50: 69 6c 65 20 20 20 20 20 28 63 6f 6e 63 20 2a 74 ile (conc *t
4c60: 6f 70 70 61 74 68 2a 20 22 2f 6d 65 67 61 74 65 oppath* "/megate
4c70: 73 74 2e 64 62 22 29 29 0a 09 20 28 6c 6f 63 6b st.db")).. (lock
4c80: 66 69 6c 65 20 20 20 20 20 28 63 6f 6d 6d 6f 6e file (common
4c90: 3a 67 65 74 2d 73 79 6e 63 2d 6c 6f 63 6b 2d 66 :get-sync-lock-f
4ca0: 69 6c 65 70 61 74 68 29 29 0a 20 20 20 20 20 20 ilepath)).
4cb0: 20 20 20 28 73 79 6e 63 2d 63 6d 64 2d 63 6f 72 (sync-cmd-cor
4cc0: 65 20 20 20 20 20 28 63 6f 6e 63 20 73 71 6c 69 e (conc sqli
4cd0: 74 65 2d 65 78 65 22 20 22 20 74 6d 70 2d 64 62 te-exe" " tmp-db
4ce0: 20 22 20 2e 64 75 6d 70 20 7c 20 22 73 71 6c 69 " .dump | "sqli
4cf0: 74 65 2d 65 78 65 22 20 22 20 73 74 61 67 69 6e te-exe" " stagin
4d00: 67 2d 66 69 6c 65 20 22 26 3e 22 73 79 6e 63 2d g-file "&>"sync-
4d10: 6c 6f 67 29 29 0a 20 20 20 20 20 20 20 20 20 28 log)). (
4d20: 73 79 6e 63 2d 63 6d 64 20 20 20 20 20 28 69 66 sync-cmd (if
4d30: 20 66 6f 72 6b 2d 74 6f 2d 62 61 63 6b 67 72 6f fork-to-backgro
4d40: 75 6e 64 20 0a 20 20 20 20 20 20 20 20 20 20 20 und .
4d50: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
4d60: 28 63 6f 6e 63 20 22 2f 75 73 72 2f 62 69 6e 2f (conc "/usr/bin/
4d70: 65 6e 76 20 4e 42 46 41 4b 45 5f 4c 4f 47 3d 22 env NBFAKE_LOG="
4d80: 2a 74 6f 70 70 61 74 68 2a 22 2f 6c 6f 67 73 2f *toppath*"/logs/
4d90: 6c 61 73 74 2d 73 65 72 76 65 72 2d 73 79 6e 63 last-server-sync
4da0: 2d 22 28 63 75 72 72 65 6e 74 2d 70 72 6f 63 65 -"(current-proce
4db0: 73 73 2d 69 64 29 22 2e 6c 6f 67 20 6e 62 66 61 ss-id)".log nbfa
4dc0: 6b 65 20 5c 22 22 73 79 6e 63 2d 63 6d 64 2d 63 ke \""sync-cmd-c
4dd0: 6f 72 65 22 20 26 26 20 2f 62 69 6e 2f 6d 76 20 ore" && /bin/mv
4de0: 2d 66 20 22 20 73 74 61 67 69 6e 67 2d 66 69 6c -f " staging-fil
4df0: 65 20 22 20 22 20 6d 74 64 62 66 69 6c 65 22 20 e " " mtdbfile"
4e00: 5c 22 22 29 0a 20 20 20 20 20 20 20 20 20 20 20 \"").
4e10: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
4e20: 73 79 6e 63 2d 63 6d 64 2d 63 6f 72 65 29 29 0a sync-cmd-core)).
4e30: 20 20 20 20 20 20 20 20 20 28 64 65 66 61 75 6c (defaul
4e40: 74 2d 6d 69 6e 2d 69 6e 74 65 72 73 79 6e 63 2d t-min-intersync-
4e50: 64 65 6c 61 79 20 32 29 0a 09 20 28 6d 69 6e 2d delay 2).. (min-
4e60: 69 6e 74 65 72 73 79 6e 63 2d 64 65 6c 61 79 20 intersync-delay
4e70: 28 63 6f 6e 66 69 67 66 3a 6c 6f 6f 6b 75 70 2d (configf:lookup-
4e80: 6e 75 6d 62 65 72 20 2a 63 6f 6e 66 69 67 64 61 number *configda
4e90: 74 2a 20 22 73 65 72 76 65 72 22 20 22 6d 69 6e t* "server" "min
4ea0: 69 6d 75 6d 2d 69 6e 74 65 72 73 79 6e 63 2d 64 imum-intersync-d
4eb0: 65 6c 61 79 22 20 64 65 66 61 75 6c 74 3a 20 64 elay" default: d
4ec0: 65 66 61 75 6c 74 2d 6d 69 6e 2d 69 6e 74 65 72 efault-min-inter
4ed0: 73 79 6e 63 2d 64 65 6c 61 79 29 29 0a 20 20 20 sync-delay)).
4ee0: 20 20 20 20 20 20 28 64 65 66 61 75 6c 74 2d 64 (default-d
4ef0: 75 74 79 2d 63 79 63 6c 65 20 30 2e 31 29 0a 20 uty-cycle 0.1).
4f00: 20 20 20 20 20 20 20 20 28 64 75 74 79 2d 63 79 (duty-cy
4f10: 63 6c 65 20 20 20 28 63 6f 6e 66 69 67 66 3a 6c cle (configf:l
4f20: 6f 6f 6b 75 70 2d 6e 75 6d 62 65 72 20 2a 63 6f ookup-number *co
4f30: 6e 66 69 67 64 61 74 2a 20 22 73 65 72 76 65 72 nfigdat* "server
4f40: 22 20 22 73 79 6e 63 2d 64 75 74 79 2d 63 79 63 " "sync-duty-cyc
4f50: 6c 65 22 20 64 65 66 61 75 6c 74 3a 20 64 65 66 le" default: def
4f60: 61 75 6c 74 2d 64 75 74 79 2d 63 79 63 6c 65 29 ault-duty-cycle)
4f70: 29 0a 20 20 20 20 20 20 20 20 20 28 6c 61 73 74 ). (last
4f80: 2d 73 79 6e 63 2d 73 65 63 6f 6e 64 73 20 31 30 -sync-seconds 10
4f90: 29 20 3b 3b 20 77 65 20 77 69 6c 6c 20 61 64 6a ) ;; we will adj
4fa0: 75 73 74 20 74 68 69 73 20 74 6f 20 61 20 6d 65 ust this to a me
4fb0: 61 73 75 72 65 6d 65 6e 74 20 61 6e 64 20 64 65 asurement and de
4fc0: 6c 61 79 20 6c 61 73 74 2d 73 79 6e 63 2d 73 65 lay last-sync-se
4fd0: 63 6f 6e 64 73 20 2a 20 28 31 20 2d 20 64 75 74 conds * (1 - dut
4fe0: 79 2d 63 79 63 6c 65 29 0a 20 20 20 20 20 20 20 y-cycle).
4ff0: 20 20 28 63 61 6c 63 75 6c 61 74 65 2d 6f 66 66 (calculate-off
5000: 2d 74 69 6d 65 20 28 6c 61 6d 62 64 61 20 28 77 -time (lambda (w
5010: 6f 72 6b 2d 64 75 72 61 74 69 6f 6e 20 64 75 74 ork-duration dut
5020: 79 2d 63 79 63 6c 65 29 0a 20 20 20 20 20 20 20 y-cycle).
5030: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5040: 20 20 20 20 20 20 20 20 20 20 20 28 2a 20 28 2f (* (/
5050: 20 28 2d 20 31 20 64 75 74 79 2d 63 79 63 6c 65 (- 1 duty-cycle
5060: 29 20 64 75 74 79 2d 63 79 63 6c 65 29 20 6c 61 ) duty-cycle) la
5070: 73 74 2d 73 79 6e 63 2d 73 65 63 6f 6e 64 73 29 st-sync-seconds)
5080: 29 29 0a 20 20 20 20 20 20 20 20 20 28 6f 66 66 )). (off
5090: 2d 74 69 6d 65 20 6d 69 6e 2d 69 6e 74 65 72 73 -time min-inters
50a0: 79 6e 63 2d 64 65 6c 61 79 29 20 3b 3b 20 61 64 ync-delay) ;; ad
50b0: 6a 75 73 74 65 64 20 69 6e 20 63 6c 6f 73 75 72 justed in closur
50c0: 65 20 62 65 6c 6f 77 2e 0a 20 20 20 20 20 20 20 e below..
50d0: 20 20 28 64 6f 2d 61 2d 73 79 6e 63 0a 20 20 20 (do-a-sync.
50e0: 20 20 20 20 20 20 20 28 6c 61 6d 62 64 61 20 28 (lambda (
50f0: 29 0a 20 20 20 20 20 20 20 20 20 20 20 20 28 42 ). (B
5100: 42 3e 20 22 53 74 61 72 74 20 64 6f 2d 61 2d 73 B> "Start do-a-s
5110: 79 6e 63 20 77 69 74 68 20 66 6f 72 6b 2d 74 6f ync with fork-to
5120: 2d 62 61 63 6b 67 72 6f 75 6e 64 3d 22 66 6f 72 -background="for
5130: 6b 2d 74 6f 2d 62 61 63 6b 67 72 6f 75 6e 64 22 k-to-background"
5140: 20 70 65 72 73 69 73 74 2d 75 6e 74 69 6c 2d 73 persist-until-s
5150: 79 6e 63 3d 22 70 65 72 73 69 73 74 2d 75 6e 74 ync="persist-unt
5160: 69 6c 2d 73 79 6e 63 29 0a 20 20 20 20 20 20 20 il-sync).
5170: 20 20 20 20 20 28 6c 65 74 2a 20 28 28 66 69 6e (let* ((fin
5180: 61 6c 72 65 73 0a 20 20 20 20 20 20 20 20 20 20 alres.
5190: 20 20 20 20 20 20 20 20 20 20 28 6c 65 74 20 72 (let r
51a0: 65 74 72 79 2d 6c 6f 6f 70 20 28 28 6e 75 6d 2d etry-loop ((num-
51b0: 74 72 69 65 73 20 30 29 29 0a 20 20 20 20 20 20 tries 0)).
51c0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
51d0: 20 20 20 28 69 66 20 28 63 6f 6d 6d 6f 6e 3a 73 (if (common:s
51e0: 69 6d 70 6c 65 2d 66 69 6c 65 2d 6c 6f 63 6b 20 imple-file-lock
51f0: 6c 6f 63 6b 66 69 6c 65 29 0a 09 20 20 20 20 20 lockfile)..
5200: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5210: 28 62 65 67 69 6e 0a 20 20 20 20 20 20 20 20 20 (begin.
5220: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5230: 20 20 20 20 20 20 28 63 6f 6e 64 0a 20 20 20 20 (cond.
5240: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5250: 20 20 20 20 20 20 20 20 20 20 20 20 28 28 6e 6f ((no
5260: 74 20 28 6f 72 20 66 6f 72 6b 2d 74 6f 2d 62 61 t (or fork-to-ba
5270: 63 6b 67 72 6f 75 6e 64 20 70 65 72 73 69 73 74 ckground persist
5280: 2d 75 6e 74 69 6c 2d 73 79 6e 63 29 29 0a 20 20 -until-sync)).
5290: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
52a0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 28 (
52b0: 64 65 62 75 67 3a 70 72 69 6e 74 20 30 20 2a 64 debug:print 0 *d
52c0: 65 66 61 75 6c 74 2d 6c 6f 67 2d 70 6f 72 74 2a efault-log-port*
52d0: 20 22 49 4e 46 4f 3a 20 73 79 6e 63 65 72 20 74 "INFO: syncer t
52e0: 68 72 65 61 64 20 73 6c 65 65 70 69 6e 67 20 66 hread sleeping f
52f0: 6f 72 20 6d 61 78 20 6f 66 20 28 73 65 72 76 65 or max of (serve
5300: 72 2e 6d 69 6e 69 6d 75 6d 2d 69 6e 74 65 72 73 r.minimum-inters
5310: 79 6e 63 2d 64 65 6c 61 79 3d 22 6d 69 6e 2d 69 ync-delay="min-i
5320: 6e 74 65 72 73 79 6e 63 2d 64 65 6c 61 79 0a 20 ntersync-delay.
5330: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5340: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5350: 20 20 20 20 20 20 20 20 20 20 20 20 20 22 20 2c " ,
5360: 20 6f 66 66 2d 74 69 6d 65 3d 22 6f 66 66 2d 74 off-time="off-t
5370: 69 6d 65 22 20 73 65 63 6f 6e 64 73 20 5d 22 29 ime" seconds ]")
5380: 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 .
5390: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
53a0: 20 20 28 74 68 72 65 61 64 2d 73 6c 65 65 70 21 (thread-sleep!
53b0: 20 28 6d 61 78 20 6f 66 66 2d 74 69 6d 65 20 6d (max off-time m
53c0: 69 6e 2d 69 6e 74 65 72 73 79 6e 63 2d 64 65 6c in-intersync-del
53d0: 61 79 29 29 29 0a 20 20 20 20 20 20 20 20 20 20 ay))).
53e0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
53f0: 20 20 20 20 20 20 28 65 6c 73 65 0a 20 20 20 20 (else.
5400: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5410: 20 20 20 20 20 20 20 20 20 20 20 20 20 28 64 65 (de
5420: 62 75 67 3a 70 72 69 6e 74 20 30 20 2a 64 65 66 bug:print 0 *def
5430: 61 75 6c 74 2d 6c 6f 67 2d 70 6f 72 74 2a 20 22 ault-log-port* "
5440: 49 4e 46 4f 3a 20 73 79 6e 63 65 72 20 74 68 72 INFO: syncer thr
5450: 65 61 64 20 4e 4f 54 20 73 6c 65 65 70 69 6e 67 ead NOT sleeping
5460: 20 3b 20 6d 61 79 62 65 20 74 69 6d 65 2d 74 6f ; maybe time-to
5470: 2d 65 78 69 74 2e 2e 2e 22 29 29 29 0a 0a 20 20 -exit...")))..
5480: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5490: 20 20 20 20 20 20 20 20 20 20 20 20 20 28 69 66 (if
54a0: 20 28 6e 6f 74 20 28 63 6f 6e 66 69 67 66 3a 6c (not (configf:l
54b0: 6f 6f 6b 75 70 20 2a 63 6f 6e 66 69 67 64 61 74 ookup *configdat
54c0: 2a 20 22 73 65 72 76 65 72 22 20 22 64 69 73 61 * "server" "disa
54d0: 62 6c 65 2d 64 62 2d 73 6e 61 70 73 68 6f 74 22 ble-db-snapshot"
54e0: 29 29 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 )).
54f0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5500: 20 20 20 20 20 20 28 63 6f 6d 6d 6f 6e 3a 73 6e (common:sn
5510: 61 70 73 68 6f 74 2d 66 69 6c 65 20 6d 74 64 62 apshot-file mtdb
5520: 66 69 6c 65 20 73 75 62 64 69 72 3a 20 22 2e 64 file subdir: ".d
5530: 62 2d 73 6e 61 70 73 68 6f 74 22 29 29 0a 09 09 b-snapshot"))...
5540: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 28 (
5550: 64 65 6c 65 74 65 2d 66 69 6c 65 2a 20 73 74 61 delete-file* sta
5560: 67 69 6e 67 2d 66 69 6c 65 29 0a 09 09 20 20 20 ging-file)...
5570: 20 20 20 20 20 20 20 20 20 20 20 20 28 6c 65 74 (let
5580: 2a 20 28 28 73 74 61 72 74 2d 74 69 6d 65 20 28 * ((start-time (
5590: 63 75 72 72 65 6e 74 2d 6d 69 6c 6c 69 73 65 63 current-millisec
55a0: 6f 6e 64 73 29 29 0a 20 20 20 20 20 20 20 20 20 onds)).
55b0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
55c0: 20 20 20 20 20 20 20 20 20 20 20 20 20 28 72 65 (re
55d0: 73 20 28 73 79 73 74 65 6d 20 73 79 6e 63 2d 63 s (system sync-c
55e0: 6d 64 29 29 0a 20 20 20 20 20 20 20 20 20 20 20 md)).
55f0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5600: 20 20 20 20 20 20 20 20 20 20 20 28 72 65 73 32 (res2
5610: 20 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 .
5620: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5630: 20 20 20 20 20 20 20 20 20 28 63 6f 6e 64 0a 20 (cond.
5640: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5650: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5660: 20 20 20 20 20 20 20 28 28 65 71 3f 20 30 20 72 ((eq? 0 r
5670: 65 73 29 0a 09 09 20 20 20 20 20 20 20 20 20 20 es)...
5680: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 28 (
5690: 64 65 6c 65 74 65 2d 66 69 6c 65 2a 20 28 63 6f delete-file* (co
56a0: 6e 63 20 6d 74 64 62 66 69 6c 65 20 22 2e 62 61 nc mtdbfile ".ba
56b0: 63 6b 75 70 22 29 29 0a 20 20 20 20 20 20 20 20 ckup")).
56c0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
56d0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
56e0: 20 28 69 66 20 28 65 71 3f 20 30 20 28 66 69 6c (if (eq? 0 (fil
56f0: 65 2d 73 69 7a 65 20 73 79 6e 63 2d 6c 6f 67 29 e-size sync-log)
5700: 29 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 ).
5710: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5720: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 28 (
5730: 64 65 6c 65 74 65 2d 66 69 6c 65 20 73 79 6e 63 delete-file sync
5740: 2d 6c 6f 67 29 29 0a 09 09 20 20 20 20 20 20 20 -log))...
5750: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5760: 20 20 28 73 79 73 74 65 6d 20 28 63 6f 6e 63 20 (system (conc
5770: 22 2f 62 69 6e 2f 6d 76 20 22 20 73 74 61 67 69 "/bin/mv " stagi
5780: 6e 67 2d 66 69 6c 65 20 22 20 22 20 6d 74 64 62 ng-file " " mtdb
5790: 66 69 6c 65 29 29 0a 20 20 20 20 20 20 20 20 20 file)).
57a0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
57b0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
57c0: 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 .
57d0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
57e0: 20 20 20 20 20 20 20 20 20 20 28 73 65 74 21 20 (set!
57f0: 6c 61 73 74 2d 73 79 6e 63 2d 73 65 63 6f 6e 64 last-sync-second
5800: 73 20 28 2f 20 28 2d 20 28 63 75 72 72 65 6e 74 s (/ (- (current
5810: 2d 6d 69 6c 6c 69 73 65 63 6f 6e 64 73 29 20 73 -milliseconds) s
5820: 74 61 72 74 2d 74 69 6d 65 29 20 31 30 30 30 29 tart-time) 1000)
5830: 29 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 ).
5840: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5850: 20 20 20 20 20 20 20 20 20 20 20 28 73 65 74 21 (set!
5860: 20 6f 66 66 2d 74 69 6d 65 20 28 63 61 6c 63 75 off-time (calcu
5870: 6c 61 74 65 2d 6f 66 66 2d 74 69 6d 65 0a 20 20 late-off-time.
5880: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5890: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
58a0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
58b0: 20 20 20 20 20 20 20 6c 61 73 74 2d 73 79 6e 63 last-sync
58c0: 2d 73 65 63 6f 6e 64 73 0a 20 20 20 20 20 20 20 -seconds.
58d0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
58e0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
58f0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5900: 20 20 28 63 6f 6e 64 0a 20 20 20 20 20 20 20 20 (cond.
5910: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5920: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5930: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5940: 20 20 28 28 61 6e 64 20 28 6e 75 6d 62 65 72 3f ((and (number?
5950: 20 64 75 74 79 2d 63 79 63 6c 65 29 20 28 3e 20 duty-cycle) (>
5960: 64 75 74 79 2d 63 79 63 6c 65 20 30 29 20 28 3c duty-cycle 0) (<
5970: 20 64 75 74 79 2d 63 79 63 6c 65 20 31 29 29 0a duty-cycle 1)).
5980: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5990: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
59a0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
59b0: 20 20 20 20 20 20 20 20 20 20 20 64 75 74 79 2d duty-
59c0: 63 79 63 6c 65 29 0a 20 20 20 20 20 20 20 20 20 cycle).
59d0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
59e0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
59f0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5a00: 20 28 65 6c 73 65 0a 20 20 20 20 20 20 20 20 20 (else.
5a10: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5a20: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5a30: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5a40: 20 20 28 64 65 62 75 67 3a 70 72 69 6e 74 20 30 (debug:print 0
5a50: 20 2a 64 65 66 61 75 6c 74 2d 6c 6f 67 2d 70 6f *default-log-po
5a60: 72 74 2a 20 22 57 41 52 4e 49 4e 47 3a 20 5b 22 rt* "WARNING: ["
5a70: 28 63 6f 6d 6d 6f 6e 3a 68 75 6d 61 6e 2d 74 69 (common:human-ti
5a80: 6d 65 29 22 5d 20 73 65 72 76 65 72 2e 73 79 6e me)"] server.syn
5a90: 63 2d 64 75 74 79 2d 63 79 63 6c 65 20 69 73 20 c-duty-cycle is
5aa0: 69 6e 76 61 6c 69 64 2e 20 20 53 68 6f 75 6c 64 invalid. Should
5ab0: 20 62 65 20 61 20 6e 75 6d 62 65 72 20 62 65 74 be a number bet
5ac0: 77 65 65 6e 20 30 20 61 6e 64 20 31 2c 20 62 75 ween 0 and 1, bu
5ad0: 74 20 22 64 75 74 79 2d 63 79 63 6c 65 22 20 77 t "duty-cycle" w
5ae0: 61 73 20 73 70 65 63 69 66 69 65 64 2e 20 20 55 as specified. U
5af0: 73 69 6e 67 20 64 65 66 61 75 6c 74 20 76 61 6c sing default val
5b00: 75 65 3a 20 22 64 65 66 61 75 6c 74 2d 64 75 74 ue: "default-dut
5b10: 79 2d 63 79 63 6c 65 29 0a 20 20 20 20 20 20 20 y-cycle).
5b20: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5b30: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5b40: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5b50: 20 20 20 20 64 65 66 61 75 6c 74 2d 64 75 74 79 default-duty
5b60: 2d 63 79 63 6c 65 29 29 29 29 0a 20 20 20 20 20 -cycle)))).
5b70: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5b80: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5b90: 20 20 20 20 0a 20 20 20 20 20 20 20 20 20 20 20 .
5ba0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5bb0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 28 64 (d
5bc0: 65 62 75 67 3a 70 72 69 6e 74 20 31 20 2a 64 65 ebug:print 1 *de
5bd0: 66 61 75 6c 74 2d 6c 6f 67 2d 70 6f 72 74 2a 20 fault-log-port*
5be0: 22 49 4e 46 4f 3a 20 5b 22 28 63 6f 6d 6d 6f 6e "INFO: ["(common
5bf0: 3a 68 75 6d 61 6e 2d 74 69 6d 65 29 22 5d 20 70 :human-time)"] p
5c00: 69 64 3d 22 28 63 75 72 72 65 6e 74 2d 70 72 6f id="(current-pro
5c10: 63 65 73 73 2d 69 64 29 22 20 53 59 4e 43 20 74 cess-id)" SYNC t
5c20: 6f 6f 6b 20 22 6c 61 73 74 2d 73 79 6e 63 2d 73 ook "last-sync-s
5c30: 65 63 6f 6e 64 73 22 20 73 65 63 22 29 0a 20 20 econds" sec").
5c40: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5c50: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5c60: 20 20 20 20 20 20 20 28 64 65 62 75 67 3a 70 72 (debug:pr
5c70: 69 6e 74 20 31 20 2a 64 65 66 61 75 6c 74 2d 6c int 1 *default-l
5c80: 6f 67 2d 70 6f 72 74 2a 20 22 49 4e 46 4f 3a 20 og-port* "INFO:
5c90: 5b 22 28 63 6f 6d 6d 6f 6e 3a 68 75 6d 61 6e 2d ["(common:human-
5ca0: 74 69 6d 65 29 22 5d 20 70 69 64 3d 22 28 63 75 time)"] pid="(cu
5cb0: 72 72 65 6e 74 2d 70 72 6f 63 65 73 73 2d 69 64 rrent-process-id
5cc0: 29 22 20 53 59 4e 43 20 74 6f 6f 6b 20 22 6c 61 )" SYNC took "la
5cd0: 73 74 2d 73 79 6e 63 2d 73 65 63 6f 6e 64 73 22 st-sync-seconds"
5ce0: 20 73 65 63 20 3b 20 77 69 74 68 20 64 75 74 79 sec ; with duty
5cf0: 2d 63 79 63 6c 65 20 6f 66 20 22 64 75 74 79 2d -cycle of "duty-
5d00: 63 79 63 6c 65 22 20 6f 66 66 20 74 69 6d 65 20 cycle" off time
5d10: 69 73 20 6e 6f 77 20 22 6f 66 66 2d 74 69 6d 65 is now "off-time
5d20: 29 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 ).
5d30: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5d40: 20 20 20 20 20 20 20 20 20 20 20 27 73 79 6e 63 'sync
5d50: 2d 63 6f 6d 70 6c 65 74 65 64 29 0a 20 20 20 20 -completed).
5d60: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5d70: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5d80: 20 20 20 20 28 65 6c 73 65 0a 20 20 20 20 20 20 (else.
5d90: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5da0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5db0: 20 20 20 28 73 79 73 74 65 6d 20 28 63 6f 6e 63 (system (conc
5dc0: 20 22 2f 62 69 6e 2f 63 70 20 22 73 79 6e 63 2d "/bin/cp "sync-
5dd0: 6c 6f 67 22 20 22 73 79 6e 63 2d 6c 6f 67 22 2e log" "sync-log".
5de0: 66 61 69 6c 22 29 29 0a 20 20 20 20 20 20 20 20 fail")).
5df0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5e00: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5e10: 20 28 64 65 62 75 67 3a 70 72 69 6e 74 20 30 20 (debug:print 0
5e20: 2a 64 65 66 61 75 6c 74 2d 6c 6f 67 2d 70 6f 72 *default-log-por
5e30: 74 2a 20 22 45 52 52 4f 52 3a 20 5b 22 28 63 6f t* "ERROR: ["(co
5e40: 6d 6d 6f 6e 3a 68 75 6d 61 6e 2d 74 69 6d 65 29 mmon:human-time)
5e50: 22 5d 20 53 79 6e 63 20 66 61 69 6c 65 64 2e 20 "] Sync failed.
5e60: 53 65 65 20 6c 6f 67 20 61 74 20 22 73 79 6e 63 See log at "sync
5e70: 2d 6c 6f 67 22 2e 66 61 69 6c 22 29 0a 20 20 20 -log".fail").
5e80: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5e90: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5ea0: 20 20 20 20 20 20 28 69 66 20 28 66 69 6c 65 2d (if (file-
5eb0: 65 78 69 73 74 73 3f 20 28 63 6f 6e 63 20 6d 74 exists? (conc mt
5ec0: 64 62 66 69 6c 65 20 22 2e 62 61 63 6b 75 70 22 dbfile ".backup"
5ed0: 29 29 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 )).
5ee0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5ef0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5f00: 28 73 79 73 74 65 6d 20 28 63 6f 6e 63 20 22 2f (system (conc "/
5f10: 62 69 6e 2f 63 70 20 22 6d 74 64 62 66 69 6c 65 bin/cp "mtdbfile
5f20: 20 22 2e 62 61 63 6b 75 70 20 22 20 6d 74 64 62 ".backup " mtdb
5f30: 66 69 6c 65 29 29 29 0a 20 20 20 20 20 20 20 20 file))).
5f40: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5f50: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5f60: 20 23 66 29 29 29 29 0a 20 20 20 20 20 20 20 20 #f)))).
5f70: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5f80: 20 20 20 20 20 20 20 20 20 28 63 6f 6d 6d 6f 6e (common
5f90: 3a 73 69 6d 70 6c 65 2d 66 69 6c 65 2d 72 65 6c :simple-file-rel
5fa0: 65 61 73 65 2d 6c 6f 63 6b 20 6c 6f 63 6b 66 69 ease-lock lockfi
5fb0: 6c 65 29 0a 20 20 20 20 20 20 20 20 20 20 20 20 le).
5fc0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5fd0: 20 20 20 20 20 28 42 42 3e 20 22 72 65 6c 65 61 (BB> "relea
5fe0: 73 65 64 20 6c 6f 63 6b 66 69 6c 65 3a 20 22 20 sed lockfile: "
5ff0: 6c 6f 63 6b 66 69 6c 65 29 0a 20 20 20 20 20 20 lockfile).
6000: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
6010: 20 20 20 20 20 20 20 20 20 20 20 28 77 68 65 6e (when
6020: 20 28 63 6f 6d 6d 6f 6e 3a 66 69 6c 65 2d 65 78 (common:file-ex
6030: 69 73 74 73 3f 20 6c 6f 63 6b 66 69 6c 65 29 0a ists? lockfile).
6040: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
6050: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
6060: 20 20 20 28 42 42 3e 20 22 44 49 44 20 4e 4f 54 (BB> "DID NOT
6070: 20 41 43 54 55 41 4c 4c 59 20 52 45 4c 45 41 53 ACTUALLY RELEAS
6080: 45 20 4c 4f 43 4b 46 49 4c 45 22 29 29 0a 20 20 E LOCKFILE")).
6090: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
60a0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 72 r
60b0: 65 73 32 29 20 3b 3b 20 65 6e 64 20 6c 65 74 0a es2) ;; end let.
60c0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
60d0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 29 )
60e0: 3b 3b 20 65 6e 64 20 62 65 67 69 6e 0a 20 20 20 ;; end begin.
60f0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
6100: 20 20 20 20 20 20 20 20 20 20 3b 3b 20 65 6c 73 ;; els
6110: 65 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 e.
6120: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 28 (
6130: 63 6f 6e 64 0a 20 20 20 20 20 20 20 20 20 20 20 cond.
6140: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
6150: 20 20 20 28 70 65 72 73 69 73 74 2d 75 6e 74 69 (persist-unti
6160: 6c 2d 73 79 6e 63 0a 20 20 20 20 20 20 20 20 20 l-sync.
6170: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
6180: 20 20 20 20 20 20 28 74 68 72 65 61 64 2d 73 6c (thread-sl
6190: 65 65 70 21 20 31 29 0a 20 20 20 20 20 20 20 20 eep! 1).
61a0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
61b0: 20 20 20 20 20 20 20 28 64 65 62 75 67 3a 70 72 (debug:pr
61c0: 69 6e 74 20 31 20 2a 64 65 66 61 75 6c 74 2d 6c int 1 *default-l
61d0: 6f 67 2d 70 6f 72 74 2a 20 22 49 4e 46 4f 3a 20 og-port* "INFO:
61e0: 5b 22 28 63 6f 6d 6d 6f 6e 3a 68 75 6d 61 6e 2d ["(common:human-
61f0: 74 69 6d 65 29 22 5d 20 70 69 64 3d 22 28 63 75 time)"] pid="(cu
6200: 72 72 65 6e 74 2d 70 72 6f 63 65 73 73 2d 69 64 rrent-process-id
6210: 29 22 20 6f 74 68 65 72 20 53 59 4e 43 20 69 6e )" other SYNC in
6220: 20 70 72 6f 67 72 65 73 73 3b 20 77 65 27 72 65 progress; we're
6230: 20 69 6e 20 61 20 66 6f 72 6b 2d 74 6f 2d 62 61 in a fork-to-ba
6240: 63 6b 67 72 6f 75 6e 64 20 73 6f 20 77 65 20 6e ckground so we n
6250: 65 65 64 20 74 6f 20 73 75 63 63 65 65 64 2e 20 eed to succeed.
6260: 20 4c 65 74 27 73 20 77 61 69 74 20 61 20 6a 69 Let's wait a ji
6270: 66 66 79 20 61 6e 64 20 61 6e 64 20 74 72 79 20 ffy and and try
6280: 61 67 61 69 6e 2e 20 6e 75 6d 2d 74 72 69 65 73 again. num-tries
6290: 3d 22 6e 75 6d 2d 74 72 69 65 73 22 20 28 77 61 ="num-tries" (wa
62a0: 69 74 69 6e 67 20 66 6f 72 20 6c 6f 63 6b 66 69 iting for lockfi
62b0: 6c 65 3d 22 6c 6f 63 6b 66 69 6c 65 22 20 74 6f le="lockfile" to
62c0: 20 64 69 73 61 70 70 65 61 72 29 22 29 0a 20 20 disappear)").
62d0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
62e0: 20 20 20 20 20 20 20 20 20 20 20 20 20 28 72 65 (re
62f0: 74 72 79 2d 6c 6f 6f 70 20 28 61 64 64 31 20 6e try-loop (add1 n
6300: 75 6d 2d 74 72 69 65 73 29 29 29 0a 20 20 20 20 um-tries))).
6310: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
6320: 20 20 20 20 20 20 20 20 20 20 28 65 6c 73 65 0a (else.
6330: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
6340: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 28 (
6350: 74 68 72 65 61 64 2d 73 6c 65 65 70 21 20 28 6d thread-sleep! (m
6360: 61 78 20 6f 66 66 2d 74 69 6d 65 20 28 2b 20 6c ax off-time (+ l
6370: 61 73 74 2d 73 79 6e 63 2d 73 65 63 6f 6e 64 73 ast-sync-seconds
6380: 20 6d 69 6e 2d 69 6e 74 65 72 73 79 6e 63 2d 64 min-intersync-d
6390: 65 6c 61 79 29 29 29 0a 20 20 20 20 20 20 20 20 elay))).
63a0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
63b0: 20 20 20 20 20 20 20 28 64 65 62 75 67 3a 70 72 (debug:pr
63c0: 69 6e 74 20 31 20 2a 64 65 66 61 75 6c 74 2d 6c int 1 *default-l
63d0: 6f 67 2d 70 6f 72 74 2a 20 22 49 4e 46 4f 3a 20 og-port* "INFO:
63e0: 5b 22 28 63 6f 6d 6d 6f 6e 3a 68 75 6d 61 6e 2d ["(common:human-
63f0: 74 69 6d 65 29 22 5d 20 70 69 64 3d 22 28 63 75 time)"] pid="(cu
6400: 72 72 65 6e 74 2d 70 72 6f 63 65 73 73 2d 69 64 rrent-process-id
6410: 29 22 20 6f 74 68 65 72 20 53 59 4e 43 20 69 6e )" other SYNC in
6420: 20 70 72 6f 67 72 65 73 73 3b 20 6e 6f 74 20 73 progress; not s
6430: 79 6e 63 69 6e 67 2e 22 29 0a 20 20 20 20 20 20 yncing.").
6440: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
6450: 20 20 20 20 20 20 20 20 20 27 70 61 72 61 6c 6c 'parall
6460: 65 6c 2d 73 79 6e 63 2d 69 6e 2d 70 72 6f 67 72 el-sync-in-progr
6470: 65 73 73 29 29 0a 20 20 20 20 20 20 20 20 20 20 ess)).
6480: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
6490: 20 20 20 29 20 3b 3b 20 65 6e 64 20 69 66 20 67 ) ;; end if g
64a0: 6f 74 20 6c 6f 63 6b 66 69 6c 65 0a 20 20 20 20 ot lockfile.
64b0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
64c0: 20 20 20 20 20 29 0a 20 20 20 20 20 20 20 20 20 ).
64d0: 20 20 20 20 20 20 20 20 20 20 20 29 29 0a 20 20 )).
64e0: 20 20 20 20 20 20 20 20 20 20 20 20 28 42 42 3e (BB>
64f0: 20 22 45 6e 64 20 64 6f 2d 61 2d 73 79 6e 63 20 "End do-a-sync
6500: 77 69 74 68 20 66 6f 72 6b 2d 74 6f 2d 62 61 63 with fork-to-bac
6510: 6b 67 72 6f 75 6e 64 3d 22 66 6f 72 6b 2d 74 6f kground="fork-to
6520: 2d 62 61 63 6b 67 72 6f 75 6e 64 22 20 70 65 72 -background" per
6530: 73 69 73 74 2d 75 6e 74 69 6c 2d 73 79 6e 63 3d sist-until-sync=
6540: 22 70 65 72 73 69 73 74 2d 75 6e 74 69 6c 2d 73 "persist-until-s
6550: 79 6e 63 22 20 61 6e 64 20 72 65 73 75 6c 74 3d ync" and result=
6560: 22 66 69 6e 61 6c 72 65 73 29 0a 20 20 20 20 20 "finalres).
6570: 20 20 20 20 20 20 20 20 20 66 69 6e 61 6c 72 65 finalre
6580: 73 29 0a 20 20 20 20 20 20 20 20 20 20 20 20 29 s). )
6590: 20 3b 3b 20 65 6e 64 20 6c 61 6d 62 64 61 0a 20 ;; end lambda.
65a0: 20 20 20 20 20 20 20 20 20 29 29 0a 20 20 20 20 )).
65b0: 64 6f 2d 61 2d 73 79 6e 63 29 29 0a 0a 28 64 65 do-a-sync))..(de
65c0: 66 69 6e 65 20 28 73 65 72 76 65 72 3a 77 72 69 fine (server:wri
65d0: 74 61 62 6c 65 2d 77 61 74 63 68 64 6f 67 20 64 table-watchdog d
65e0: 62 73 74 72 75 63 74 29 0a 20 20 28 74 68 72 65 bstruct). (thre
65f0: 61 64 2d 73 6c 65 65 70 21 20 31 30 29 20 3b 3b ad-sleep! 10) ;;
6600: 20 64 65 6c 61 79 20 66 6f 72 20 73 74 61 72 74 delay for start
6610: 75 70 0a 20 20 28 6c 65 74 2a 20 28 28 64 6f 2d up. (let* ((do-
6620: 61 2d 73 79 6e 63 20 20 28 73 65 72 76 65 72 3a a-sync (server:
6630: 67 65 74 2d 62 72 75 74 65 66 6f 72 63 65 2d 73 get-bruteforce-s
6640: 79 6e 63 65 72 20 64 62 73 74 72 75 63 74 29 29 yncer dbstruct))
6650: 0a 20 20 20 20 20 20 20 20 20 28 66 69 6e 61 6c . (final
6660: 2d 73 79 6e 63 20 28 73 65 72 76 65 72 3a 67 65 -sync (server:ge
6670: 74 2d 62 72 75 74 65 66 6f 72 63 65 2d 73 79 6e t-bruteforce-syn
6680: 63 65 72 20 64 62 73 74 72 75 63 74 20 66 6f 72 cer dbstruct for
6690: 6b 2d 74 6f 2d 62 61 63 6b 67 72 6f 75 6e 64 3a k-to-background:
66a0: 20 23 74 20 70 65 72 73 69 73 74 2d 75 6e 74 69 #t persist-unti
66b0: 6c 2d 73 79 6e 63 3a 20 23 74 29 29 29 0a 20 20 l-sync: #t))).
66c0: 20 20 28 77 68 65 6e 20 28 61 6e 64 20 28 6e 6f (when (and (no
66d0: 74 20 28 61 72 67 73 3a 67 65 74 2d 61 72 67 20 t (args:get-arg
66e0: 22 2d 73 79 6e 63 2d 74 6f 2d 6d 65 67 61 74 65 "-sync-to-megate
66f0: 73 74 2e 64 62 22 29 29 20 3b 3b 20 63 6f 6e 64 st.db")) ;; cond
6700: 69 74 69 6f 6e 73 20 75 6e 64 65 72 20 77 68 69 itions under whi
6710: 63 68 20 77 65 20 64 6f 20 6e 6f 74 20 72 75 6e ch we do not run
6720: 20 74 68 65 20 73 79 6e 63 0a 09 20 20 20 20 20 the sync..
6730: 20 20 28 61 72 67 73 3a 67 65 74 2d 61 72 67 20 (args:get-arg
6740: 22 2d 73 65 72 76 65 72 22 29 29 0a 20 20 20 20 "-server")).
6750: 20 20 0a 20 20 20 20 20 20 28 6c 65 74 20 6c 6f . (let lo
6760: 6f 70 20 28 29 0a 09 28 64 6f 2d 61 2d 73 79 6e op ()..(do-a-syn
6770: 63 29 0a 20 20 20 20 20 20 20 20 28 69 66 20 28 c). (if (
6780: 6e 6f 74 20 2a 74 69 6d 65 2d 74 6f 2d 65 78 69 not *time-to-exi
6790: 74 2a 29 20 28 6c 6f 6f 70 29 29 29 20 3b 3b 20 t*) (loop))) ;;
67a0: 6b 65 65 70 20 67 6f 69 6e 67 20 75 6e 6c 65 73 keep going unles
67b0: 73 20 74 69 6d 65 20 74 6f 20 65 78 69 74 0a 0a s time to exit..
67c0: 20 20 20 20 20 20 3b 3b 20 74 69 6d 65 20 74 6f ;; time to
67d0: 20 65 78 69 74 2c 20 63 6c 6f 73 65 20 74 68 65 exit, close the
67e0: 20 6e 6f 2d 73 79 6e 63 20 64 62 20 68 65 72 65 no-sync db here
67f0: 0a 20 20 20 20 20 20 28 66 69 6e 61 6c 2d 73 79 . (final-sy
6800: 6e 63 29 0a 0a 20 20 20 20 20 20 28 69 66 20 28 nc).. (if (
6810: 63 6f 6d 6d 6f 6e 3a 6c 6f 77 2d 6e 6f 69 73 65 common:low-noise
6820: 2d 70 72 69 6e 74 20 33 30 29 0a 09 20 20 28 64 -print 30).. (d
6830: 65 62 75 67 3a 70 72 69 6e 74 2d 69 6e 66 6f 20 ebug:print-info
6840: 30 20 2a 64 65 66 61 75 6c 74 2d 6c 6f 67 2d 70 0 *default-log-p
6850: 6f 72 74 2a 20 22 45 78 69 74 69 6e 67 20 77 61 ort* "Exiting wa
6860: 74 63 68 64 6f 67 20 74 69 6d 65 72 2c 20 2a 74 tchdog timer, *t
6870: 69 6d 65 2d 74 6f 2d 65 78 69 74 2a 20 3d 20 22 ime-to-exit* = "
6880: 20 2a 74 69 6d 65 2d 74 6f 2d 65 78 69 74 2a 22 *time-to-exit*"
6890: 20 70 69 64 3d 22 28 63 75 72 72 65 6e 74 2d 70 pid="(current-p
68a0: 72 6f 63 65 73 73 2d 69 64 29 0a 09 09 09 20 20 rocess-id)....
68b0: 20 20 29 29 29 29 29 0a 0a 0a )))))...