Artifact
219dea7dfd845cda21d1f1cc1adee78199c9cd61:
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 5c 22 22 29 0a 20 20 20 20 20 20 20 ore"\"").
4de0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
4df0: 20 20 20 20 73 79 6e 63 2d 63 6d 64 2d 63 6f 72 sync-cmd-cor
4e00: 65 29 29 0a 20 20 20 20 20 20 20 20 20 28 64 65 e)). (de
4e10: 66 61 75 6c 74 2d 6d 69 6e 2d 69 6e 74 65 72 73 fault-min-inters
4e20: 79 6e 63 2d 64 65 6c 61 79 20 32 29 0a 09 20 28 ync-delay 2).. (
4e30: 6d 69 6e 2d 69 6e 74 65 72 73 79 6e 63 2d 64 65 min-intersync-de
4e40: 6c 61 79 20 28 63 6f 6e 66 69 67 66 3a 6c 6f 6f lay (configf:loo
4e50: 6b 75 70 2d 6e 75 6d 62 65 72 20 2a 63 6f 6e 66 kup-number *conf
4e60: 69 67 64 61 74 2a 20 22 73 65 72 76 65 72 22 20 igdat* "server"
4e70: 22 6d 69 6e 69 6d 75 6d 2d 69 6e 74 65 72 73 79 "minimum-intersy
4e80: 6e 63 2d 64 65 6c 61 79 22 20 64 65 66 61 75 6c nc-delay" defaul
4e90: 74 3a 20 64 65 66 61 75 6c 74 2d 6d 69 6e 2d 69 t: default-min-i
4ea0: 6e 74 65 72 73 79 6e 63 2d 64 65 6c 61 79 29 29 ntersync-delay))
4eb0: 0a 20 20 20 20 20 20 20 20 20 28 64 65 66 61 75 . (defau
4ec0: 6c 74 2d 64 75 74 79 2d 63 79 63 6c 65 20 30 2e lt-duty-cycle 0.
4ed0: 31 29 0a 20 20 20 20 20 20 20 20 20 28 64 75 74 1). (dut
4ee0: 79 2d 63 79 63 6c 65 20 20 20 28 63 6f 6e 66 69 y-cycle (confi
4ef0: 67 66 3a 6c 6f 6f 6b 75 70 2d 6e 75 6d 62 65 72 gf:lookup-number
4f00: 20 2a 63 6f 6e 66 69 67 64 61 74 2a 20 22 73 65 *configdat* "se
4f10: 72 76 65 72 22 20 22 73 79 6e 63 2d 64 75 74 79 rver" "sync-duty
4f20: 2d 63 79 63 6c 65 22 20 64 65 66 61 75 6c 74 3a -cycle" default:
4f30: 20 64 65 66 61 75 6c 74 2d 64 75 74 79 2d 63 79 default-duty-cy
4f40: 63 6c 65 29 29 0a 20 20 20 20 20 20 20 20 20 28 cle)). (
4f50: 6c 61 73 74 2d 73 79 6e 63 2d 73 65 63 6f 6e 64 last-sync-second
4f60: 73 20 31 30 29 20 3b 3b 20 77 65 20 77 69 6c 6c s 10) ;; we will
4f70: 20 61 64 6a 75 73 74 20 74 68 69 73 20 74 6f 20 adjust this to
4f80: 61 20 6d 65 61 73 75 72 65 6d 65 6e 74 20 61 6e a measurement an
4f90: 64 20 64 65 6c 61 79 20 6c 61 73 74 2d 73 79 6e d delay last-syn
4fa0: 63 2d 73 65 63 6f 6e 64 73 20 2a 20 28 31 20 2d c-seconds * (1 -
4fb0: 20 64 75 74 79 2d 63 79 63 6c 65 29 0a 20 20 20 duty-cycle).
4fc0: 20 20 20 20 20 20 28 63 61 6c 63 75 6c 61 74 65 (calculate
4fd0: 2d 6f 66 66 2d 74 69 6d 65 20 28 6c 61 6d 62 64 -off-time (lambd
4fe0: 61 20 28 77 6f 72 6b 2d 64 75 72 61 74 69 6f 6e a (work-duration
4ff0: 20 64 75 74 79 2d 63 79 63 6c 65 29 0a 20 20 20 duty-cycle).
5000: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5010: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 28 (
5020: 2a 20 28 2f 20 28 2d 20 31 20 64 75 74 79 2d 63 * (/ (- 1 duty-c
5030: 79 63 6c 65 29 20 64 75 74 79 2d 63 79 63 6c 65 ycle) duty-cycle
5040: 29 20 6c 61 73 74 2d 73 79 6e 63 2d 73 65 63 6f ) last-sync-seco
5050: 6e 64 73 29 29 29 0a 20 20 20 20 20 20 20 20 20 nds))).
5060: 28 6f 66 66 2d 74 69 6d 65 20 6d 69 6e 2d 69 6e (off-time min-in
5070: 74 65 72 73 79 6e 63 2d 64 65 6c 61 79 29 20 3b tersync-delay) ;
5080: 3b 20 61 64 6a 75 73 74 65 64 20 69 6e 20 63 6c ; adjusted in cl
5090: 6f 73 75 72 65 20 62 65 6c 6f 77 2e 0a 20 20 20 osure below..
50a0: 20 20 20 20 20 20 28 64 6f 2d 61 2d 73 79 6e 63 (do-a-sync
50b0: 0a 20 20 20 20 20 20 20 20 20 20 28 6c 61 6d 62 . (lamb
50c0: 64 61 20 28 29 0a 20 20 20 20 20 20 20 20 20 20 da ().
50d0: 20 20 28 42 42 3e 20 22 53 74 61 72 74 20 64 6f (BB> "Start do
50e0: 2d 61 2d 73 79 6e 63 20 77 69 74 68 20 66 6f 72 -a-sync with for
50f0: 6b 2d 74 6f 2d 62 61 63 6b 67 72 6f 75 6e 64 3d k-to-background=
5100: 22 66 6f 72 6b 2d 74 6f 2d 62 61 63 6b 67 72 6f "fork-to-backgro
5110: 75 6e 64 22 20 70 65 72 73 69 73 74 2d 75 6e 74 und" persist-unt
5120: 69 6c 2d 73 79 6e 63 3d 22 70 65 72 73 69 73 74 il-sync="persist
5130: 2d 75 6e 74 69 6c 2d 73 79 6e 63 29 0a 20 20 20 -until-sync).
5140: 20 20 20 20 20 20 20 20 20 28 6c 65 74 2a 20 28 (let* (
5150: 28 66 69 6e 61 6c 72 65 73 0a 20 20 20 20 20 20 (finalres.
5160: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 28 6c (l
5170: 65 74 20 72 65 74 72 79 2d 6c 6f 6f 70 20 28 28 et retry-loop ((
5180: 6e 75 6d 2d 74 72 69 65 73 20 30 29 29 0a 20 20 num-tries 0)).
5190: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
51a0: 20 20 20 20 20 20 20 28 69 66 20 28 63 6f 6d 6d (if (comm
51b0: 6f 6e 3a 73 69 6d 70 6c 65 2d 66 69 6c 65 2d 6c on:simple-file-l
51c0: 6f 63 6b 20 6c 6f 63 6b 66 69 6c 65 29 0a 09 20 ock lockfile)..
51d0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
51e0: 20 20 20 20 28 62 65 67 69 6e 0a 20 20 20 20 20 (begin.
51f0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5200: 20 20 20 20 20 20 20 20 20 20 28 63 6f 6e 64 0a (cond.
5210: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5220: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5230: 28 28 6e 6f 74 20 28 6f 72 20 66 6f 72 6b 2d 74 ((not (or fork-t
5240: 6f 2d 62 61 63 6b 67 72 6f 75 6e 64 20 70 65 72 o-background per
5250: 73 69 73 74 2d 75 6e 74 69 6c 2d 73 79 6e 63 29 sist-until-sync)
5260: 29 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 ).
5270: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5280: 20 20 20 28 64 65 62 75 67 3a 70 72 69 6e 74 20 (debug:print
5290: 30 20 2a 64 65 66 61 75 6c 74 2d 6c 6f 67 2d 70 0 *default-log-p
52a0: 6f 72 74 2a 20 22 49 4e 46 4f 3a 20 73 79 6e 63 ort* "INFO: sync
52b0: 65 72 20 74 68 72 65 61 64 20 73 6c 65 65 70 69 er thread sleepi
52c0: 6e 67 20 66 6f 72 20 6d 61 78 20 6f 66 20 28 73 ng for max of (s
52d0: 65 72 76 65 72 2e 6d 69 6e 69 6d 75 6d 2d 69 6e erver.minimum-in
52e0: 74 65 72 73 79 6e 63 2d 64 65 6c 61 79 3d 22 6d tersync-delay="m
52f0: 69 6e 2d 69 6e 74 65 72 73 79 6e 63 2d 64 65 6c in-intersync-del
5300: 61 79 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 ay.
5310: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5320: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5330: 20 22 20 2c 20 6f 66 66 2d 74 69 6d 65 3d 22 6f " , off-time="o
5340: 66 66 2d 74 69 6d 65 22 20 73 65 63 6f 6e 64 73 ff-time" seconds
5350: 20 5d 22 29 0a 20 20 20 20 20 20 20 20 20 20 20 ]").
5360: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5370: 20 20 20 20 20 20 28 74 68 72 65 61 64 2d 73 6c (thread-sl
5380: 65 65 70 21 20 28 6d 61 78 20 6f 66 66 2d 74 69 eep! (max off-ti
5390: 6d 65 20 6d 69 6e 2d 69 6e 74 65 72 73 79 6e 63 me min-intersync
53a0: 2d 64 65 6c 61 79 29 29 29 0a 20 20 20 20 20 20 -delay))).
53b0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
53c0: 20 20 20 20 20 20 20 20 20 20 28 65 6c 73 65 0a (else.
53d0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
53e0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
53f0: 20 28 64 65 62 75 67 3a 70 72 69 6e 74 20 30 20 (debug:print 0
5400: 2a 64 65 66 61 75 6c 74 2d 6c 6f 67 2d 70 6f 72 *default-log-por
5410: 74 2a 20 22 49 4e 46 4f 3a 20 73 79 6e 63 65 72 t* "INFO: syncer
5420: 20 74 68 72 65 61 64 20 4e 4f 54 20 73 6c 65 65 thread NOT slee
5430: 70 69 6e 67 20 3b 20 6d 61 79 62 65 20 74 69 6d ping ; maybe tim
5440: 65 2d 74 6f 2d 65 78 69 74 2e 2e 2e 22 29 29 29 e-to-exit...")))
5450: 0a 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 ..
5460: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5470: 20 28 69 66 20 28 6e 6f 74 20 28 63 6f 6e 66 69 (if (not (confi
5480: 67 66 3a 6c 6f 6f 6b 75 70 20 2a 63 6f 6e 66 69 gf:lookup *confi
5490: 67 64 61 74 2a 20 22 73 65 72 76 65 72 22 20 22 gdat* "server" "
54a0: 64 69 73 61 62 6c 65 2d 64 62 2d 73 6e 61 70 73 disable-db-snaps
54b0: 68 6f 74 22 29 29 0a 20 20 20 20 20 20 20 20 20 hot")).
54c0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
54d0: 20 20 20 20 20 20 20 20 20 20 28 63 6f 6d 6d 6f (commo
54e0: 6e 3a 73 6e 61 70 73 68 6f 74 2d 66 69 6c 65 20 n:snapshot-file
54f0: 6d 74 64 62 66 69 6c 65 20 73 75 62 64 69 72 3a mtdbfile subdir:
5500: 20 22 2e 64 62 2d 73 6e 61 70 73 68 6f 74 22 29 ".db-snapshot")
5510: 29 0a 09 09 20 20 20 20 20 20 20 20 20 20 20 20 )...
5520: 20 20 20 28 64 65 6c 65 74 65 2d 66 69 6c 65 2a (delete-file*
5530: 20 73 74 61 67 69 6e 67 2d 66 69 6c 65 29 0a 09 staging-file)..
5540: 09 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 .
5550: 28 6c 65 74 2a 20 28 28 73 74 61 72 74 2d 74 69 (let* ((start-ti
5560: 6d 65 20 28 63 75 72 72 65 6e 74 2d 6d 69 6c 6c me (current-mill
5570: 69 73 65 63 6f 6e 64 73 29 29 0a 20 20 20 20 20 iseconds)).
5580: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5590: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
55a0: 20 28 72 65 73 20 28 73 79 73 74 65 6d 20 73 79 (res (system sy
55b0: 6e 63 2d 63 6d 64 29 29 0a 20 20 20 20 20 20 20 nc-cmd)).
55c0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
55d0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 28 (
55e0: 72 65 73 32 20 0a 20 20 20 20 20 20 20 20 20 20 res2 .
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 20 20 28 63 6f (co
5610: 6e 64 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 nd.
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 20 20 28 28 65 71 3f ((eq?
5640: 20 30 20 72 65 73 29 0a 09 09 20 20 20 20 20 20 0 res)...
5650: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5660: 20 20 20 28 64 65 6c 65 74 65 2d 66 69 6c 65 2a (delete-file*
5670: 20 28 63 6f 6e 63 20 6d 74 64 62 66 69 6c 65 20 (conc mtdbfile
5680: 22 2e 62 61 63 6b 75 70 22 29 29 0a 20 20 20 20 ".backup")).
5690: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
56a0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
56b0: 20 20 20 20 20 28 69 66 20 28 65 71 3f 20 30 20 (if (eq? 0
56c0: 28 66 69 6c 65 2d 73 69 7a 65 20 73 79 6e 63 2d (file-size sync-
56d0: 6c 6f 67 29 29 0a 20 20 20 20 20 20 20 20 20 20 log)).
56e0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
56f0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5700: 20 20 20 28 64 65 6c 65 74 65 2d 66 69 6c 65 20 (delete-file
5710: 73 79 6e 63 2d 6c 6f 67 29 29 0a 09 09 20 20 20 sync-log))...
5720: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5730: 20 20 20 20 20 20 28 73 79 73 74 65 6d 20 28 63 (system (c
5740: 6f 6e 63 20 22 2f 62 69 6e 2f 6d 76 20 22 20 73 onc "/bin/mv " s
5750: 74 61 67 69 6e 67 2d 66 69 6c 65 20 22 20 22 20 taging-file " "
5760: 6d 74 64 62 66 69 6c 65 29 29 0a 20 20 20 20 20 mtdbfile)).
5770: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5780: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5790: 20 20 20 20 0a 20 20 20 20 20 20 20 20 20 20 20 .
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 28 73 (s
57c0: 65 74 21 20 6c 61 73 74 2d 73 79 6e 63 2d 73 65 et! last-sync-se
57d0: 63 6f 6e 64 73 20 28 2f 20 28 2d 20 28 63 75 72 conds (/ (- (cur
57e0: 72 65 6e 74 2d 6d 69 6c 6c 69 73 65 63 6f 6e 64 rent-millisecond
57f0: 73 29 20 73 74 61 72 74 2d 74 69 6d 65 29 20 31 s) start-time) 1
5800: 30 30 30 29 29 0a 20 20 20 20 20 20 20 20 20 20 000)).
5810: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5820: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 28 (
5830: 73 65 74 21 20 6f 66 66 2d 74 69 6d 65 20 28 63 set! off-time (c
5840: 61 6c 63 75 6c 61 74 65 2d 6f 66 66 2d 74 69 6d alculate-off-tim
5850: 65 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 e.
5860: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5870: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5880: 20 20 20 20 20 20 20 20 20 20 20 6c 61 73 74 2d last-
5890: 73 79 6e 63 2d 73 65 63 6f 6e 64 73 0a 20 20 20 sync-seconds.
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 20 20 20 20 20 20 20 20 20
58c0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
58d0: 20 20 20 20 20 20 28 63 6f 6e 64 0a 20 20 20 20 (cond.
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 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5910: 20 20 20 20 20 20 28 28 61 6e 64 20 28 6e 75 6d ((and (num
5920: 62 65 72 3f 20 64 75 74 79 2d 63 79 63 6c 65 29 ber? duty-cycle)
5930: 20 28 3e 20 64 75 74 79 2d 63 79 63 6c 65 20 30 (> duty-cycle 0
5940: 29 20 28 3c 20 64 75 74 79 2d 63 79 63 6c 65 20 ) (< duty-cycle
5950: 31 29 29 0a 20 20 20 20 20 20 20 20 20 20 20 20 1)).
5960: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5970: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5980: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 64 d
5990: 75 74 79 2d 63 79 63 6c 65 29 0a 20 20 20 20 20 uty-cycle).
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 20 20 20 20 20
59c0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
59d0: 20 20 20 20 20 28 65 6c 73 65 0a 20 20 20 20 20 (else.
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 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5a10: 20 20 20 20 20 20 28 64 65 62 75 67 3a 70 72 69 (debug:pri
5a20: 6e 74 20 30 20 2a 64 65 66 61 75 6c 74 2d 6c 6f nt 0 *default-lo
5a30: 67 2d 70 6f 72 74 2a 20 22 57 41 52 4e 49 4e 47 g-port* "WARNING
5a40: 3a 20 5b 22 28 63 6f 6d 6d 6f 6e 3a 68 75 6d 61 : ["(common:huma
5a50: 6e 2d 74 69 6d 65 29 22 5d 20 73 65 72 76 65 72 n-time)"] server
5a60: 2e 73 79 6e 63 2d 64 75 74 79 2d 63 79 63 6c 65 .sync-duty-cycle
5a70: 20 69 73 20 69 6e 76 61 6c 69 64 2e 20 20 53 68 is invalid. Sh
5a80: 6f 75 6c 64 20 62 65 20 61 20 6e 75 6d 62 65 72 ould be a number
5a90: 20 62 65 74 77 65 65 6e 20 30 20 61 6e 64 20 31 between 0 and 1
5aa0: 2c 20 62 75 74 20 22 64 75 74 79 2d 63 79 63 6c , but "duty-cycl
5ab0: 65 22 20 77 61 73 20 73 70 65 63 69 66 69 65 64 e" was specified
5ac0: 2e 20 20 55 73 69 6e 67 20 64 65 66 61 75 6c 74 . Using default
5ad0: 20 76 61 6c 75 65 3a 20 22 64 65 66 61 75 6c 74 value: "default
5ae0: 2d 64 75 74 79 2d 63 79 63 6c 65 29 0a 20 20 20 -duty-cycle).
5af0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5b00: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5b10: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5b20: 20 20 20 20 20 20 20 20 64 65 66 61 75 6c 74 2d default-
5b30: 64 75 74 79 2d 63 79 63 6c 65 29 29 29 29 0a 20 duty-cycle)))).
5b40: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5b50: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5b60: 20 20 20 20 20 20 20 20 0a 20 20 20 20 20 20 20 .
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 28 64 65 62 75 67 3a 70 72 69 6e 74 20 31 (debug:print 1
5ba0: 20 2a 64 65 66 61 75 6c 74 2d 6c 6f 67 2d 70 6f *default-log-po
5bb0: 72 74 2a 20 22 49 4e 46 4f 3a 20 5b 22 28 63 6f rt* "INFO: ["(co
5bc0: 6d 6d 6f 6e 3a 68 75 6d 61 6e 2d 74 69 6d 65 29 mmon:human-time)
5bd0: 22 5d 20 70 69 64 3d 22 28 63 75 72 72 65 6e 74 "] pid="(current
5be0: 2d 70 72 6f 63 65 73 73 2d 69 64 29 22 20 53 59 -process-id)" SY
5bf0: 4e 43 20 74 6f 6f 6b 20 22 6c 61 73 74 2d 73 79 NC took "last-sy
5c00: 6e 63 2d 73 65 63 6f 6e 64 73 22 20 73 65 63 22 nc-seconds" sec"
5c10: 29 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 ).
5c20: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5c30: 20 20 20 20 20 20 20 20 20 20 20 28 64 65 62 75 (debu
5c40: 67 3a 70 72 69 6e 74 20 31 20 2a 64 65 66 61 75 g:print 1 *defau
5c50: 6c 74 2d 6c 6f 67 2d 70 6f 72 74 2a 20 22 49 4e lt-log-port* "IN
5c60: 46 4f 3a 20 5b 22 28 63 6f 6d 6d 6f 6e 3a 68 75 FO: ["(common:hu
5c70: 6d 61 6e 2d 74 69 6d 65 29 22 5d 20 70 69 64 3d man-time)"] pid=
5c80: 22 28 63 75 72 72 65 6e 74 2d 70 72 6f 63 65 73 "(current-proces
5c90: 73 2d 69 64 29 22 20 53 59 4e 43 20 74 6f 6f 6b s-id)" SYNC took
5ca0: 20 22 6c 61 73 74 2d 73 79 6e 63 2d 73 65 63 6f "last-sync-seco
5cb0: 6e 64 73 22 20 73 65 63 20 3b 20 77 69 74 68 20 nds" sec ; with
5cc0: 64 75 74 79 2d 63 79 63 6c 65 20 6f 66 20 22 64 duty-cycle of "d
5cd0: 75 74 79 2d 63 79 63 6c 65 22 20 6f 66 66 20 74 uty-cycle" off t
5ce0: 69 6d 65 20 69 73 20 6e 6f 77 20 22 6f 66 66 2d ime is now "off-
5cf0: 74 69 6d 65 29 0a 20 20 20 20 20 20 20 20 20 20 time).
5d00: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5d10: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 27 '
5d20: 73 79 6e 63 2d 63 6f 6d 70 6c 65 74 65 64 29 0a sync-completed).
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 20 20 20 20 20
5d50: 20 20 20 20 20 20 20 20 28 65 6c 73 65 0a 20 20 (else.
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 20 20 20 28 73 79 73 74 65 6d 20 28 (system (
5d90: 63 6f 6e 63 20 22 2f 62 69 6e 2f 63 70 20 22 73 conc "/bin/cp "s
5da0: 79 6e 63 2d 6c 6f 67 22 20 22 73 79 6e 63 2d 6c ync-log" "sync-l
5db0: 6f 67 22 2e 66 61 69 6c 22 29 29 0a 20 20 20 20 og".fail")).
5dc0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5dd0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5de0: 20 20 20 20 20 28 64 65 62 75 67 3a 70 72 69 6e (debug:prin
5df0: 74 20 30 20 2a 64 65 66 61 75 6c 74 2d 6c 6f 67 t 0 *default-log
5e00: 2d 70 6f 72 74 2a 20 22 45 52 52 4f 52 3a 20 5b -port* "ERROR: [
5e10: 22 28 63 6f 6d 6d 6f 6e 3a 68 75 6d 61 6e 2d 74 "(common:human-t
5e20: 69 6d 65 29 22 5d 20 53 79 6e 63 20 66 61 69 6c ime)"] Sync fail
5e30: 65 64 2e 20 53 65 65 20 6c 6f 67 20 61 74 20 22 ed. See log at "
5e40: 73 79 6e 63 2d 6c 6f 67 22 2e 66 61 69 6c 22 29 sync-log".fail")
5e50: 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 .
5e60: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5e70: 20 20 20 20 20 20 20 20 20 20 28 69 66 20 28 66 (if (f
5e80: 69 6c 65 2d 65 78 69 73 74 73 3f 20 28 63 6f 6e ile-exists? (con
5e90: 63 20 6d 74 64 62 66 69 6c 65 20 22 2e 62 61 63 c mtdbfile ".bac
5ea0: 6b 75 70 22 29 29 0a 20 20 20 20 20 20 20 20 20 kup")).
5eb0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5ec0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5ed0: 20 20 20 20 28 73 79 73 74 65 6d 20 28 63 6f 6e (system (con
5ee0: 63 20 22 2f 62 69 6e 2f 63 70 20 22 6d 74 64 62 c "/bin/cp "mtdb
5ef0: 66 69 6c 65 20 22 2e 62 61 63 6b 75 70 20 22 20 file ".backup "
5f00: 6d 74 64 62 66 69 6c 65 29 29 29 0a 20 20 20 20 mtdbfile))).
5f10: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5f20: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5f30: 20 20 20 20 20 23 66 29 29 29 29 0a 20 20 20 20 #f)))).
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 28 63 6f (co
5f60: 6d 6d 6f 6e 3a 73 69 6d 70 6c 65 2d 66 69 6c 65 mmon:simple-file
5f70: 2d 72 65 6c 65 61 73 65 2d 6c 6f 63 6b 20 6c 6f -release-lock lo
5f80: 63 6b 66 69 6c 65 29 0a 20 20 20 20 20 20 20 20 ckfile).
5f90: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5fa0: 20 20 20 20 20 20 20 20 20 28 42 42 3e 20 22 72 (BB> "r
5fb0: 65 6c 65 61 73 65 64 20 6c 6f 63 6b 66 69 6c 65 eleased lockfile
5fc0: 3a 20 22 20 6c 6f 63 6b 66 69 6c 65 29 0a 20 20 : " lockfile).
5fd0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
5fe0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 28 (
5ff0: 77 68 65 6e 20 28 63 6f 6d 6d 6f 6e 3a 66 69 6c when (common:fil
6000: 65 2d 65 78 69 73 74 73 3f 20 6c 6f 63 6b 66 69 e-exists? lockfi
6010: 6c 65 29 0a 20 20 20 20 20 20 20 20 20 20 20 20 le).
6020: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
6030: 20 20 20 20 20 20 20 28 42 42 3e 20 22 44 49 44 (BB> "DID
6040: 20 4e 4f 54 20 41 43 54 55 41 4c 4c 59 20 52 45 NOT ACTUALLY RE
6050: 4c 45 41 53 45 20 4c 4f 43 4b 46 49 4c 45 22 29 LEASE LOCKFILE")
6060: 29 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 ).
6070: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
6080: 20 20 20 72 65 73 32 29 20 3b 3b 20 65 6e 64 20 res2) ;; end
6090: 6c 65 74 0a 20 20 20 20 20 20 20 20 20 20 20 20 let.
60a0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
60b0: 20 20 20 29 3b 3b 20 65 6e 64 20 62 65 67 69 6e );; end begin
60c0: 0a 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 3b 3b ;;
60e0: 20 65 6c 73 65 0a 20 20 20 20 20 20 20 20 20 20 else.
60f0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
6100: 20 20 20 28 63 6f 6e 64 0a 20 20 20 20 20 20 20 (cond.
6110: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
6120: 20 20 20 20 20 20 20 28 70 65 72 73 69 73 74 2d (persist-
6130: 75 6e 74 69 6c 2d 73 79 6e 63 0a 20 20 20 20 20 until-sync.
6140: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
6150: 20 20 20 20 20 20 20 20 20 20 28 74 68 72 65 61 (threa
6160: 64 2d 73 6c 65 65 70 21 20 31 29 0a 20 20 20 20 d-sleep! 1).
6170: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
6180: 20 20 20 20 20 20 20 20 20 20 20 28 64 65 62 75 (debu
6190: 67 3a 70 72 69 6e 74 20 31 20 2a 64 65 66 61 75 g:print 1 *defau
61a0: 6c 74 2d 6c 6f 67 2d 70 6f 72 74 2a 20 22 49 4e lt-log-port* "IN
61b0: 46 4f 3a 20 5b 22 28 63 6f 6d 6d 6f 6e 3a 68 75 FO: ["(common:hu
61c0: 6d 61 6e 2d 74 69 6d 65 29 22 5d 20 70 69 64 3d man-time)"] pid=
61d0: 22 28 63 75 72 72 65 6e 74 2d 70 72 6f 63 65 73 "(current-proces
61e0: 73 2d 69 64 29 22 20 6f 74 68 65 72 20 53 59 4e s-id)" other SYN
61f0: 43 20 69 6e 20 70 72 6f 67 72 65 73 73 3b 20 77 C in progress; w
6200: 65 27 72 65 20 69 6e 20 61 20 66 6f 72 6b 2d 74 e're in a fork-t
6210: 6f 2d 62 61 63 6b 67 72 6f 75 6e 64 20 73 6f 20 o-background so
6220: 77 65 20 6e 65 65 64 20 74 6f 20 73 75 63 63 65 we need to succe
6230: 65 64 2e 20 20 4c 65 74 27 73 20 77 61 69 74 20 ed. Let's wait
6240: 61 20 6a 69 66 66 79 20 61 6e 64 20 61 6e 64 20 a jiffy and and
6250: 74 72 79 20 61 67 61 69 6e 2e 20 6e 75 6d 2d 74 try again. num-t
6260: 72 69 65 73 3d 22 6e 75 6d 2d 74 72 69 65 73 22 ries="num-tries"
6270: 20 28 77 61 69 74 69 6e 67 20 66 6f 72 20 6c 6f (waiting for lo
6280: 63 6b 66 69 6c 65 3d 22 6c 6f 63 6b 66 69 6c 65 ckfile="lockfile
6290: 22 20 74 6f 20 64 69 73 61 70 70 65 61 72 29 22 " to disappear)"
62a0: 29 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 ).
62b0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
62c0: 20 28 72 65 74 72 79 2d 6c 6f 6f 70 20 28 61 64 (retry-loop (ad
62d0: 64 31 20 6e 75 6d 2d 74 72 69 65 73 29 29 29 0a d1 num-tries))).
62e0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
62f0: 20 20 20 20 20 20 20 20 20 20 20 20 20 28 65 6c (el
6300: 73 65 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 se.
6310: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
6320: 20 20 28 64 65 62 75 67 3a 70 72 69 6e 74 20 31 (debug:print 1
6330: 20 2a 64 65 66 61 75 6c 74 2d 6c 6f 67 2d 70 6f *default-log-po
6340: 72 74 2a 20 22 49 4e 46 4f 3a 20 5b 22 28 63 6f rt* "INFO: ["(co
6350: 6d 6d 6f 6e 3a 68 75 6d 61 6e 2d 74 69 6d 65 29 mmon:human-time)
6360: 22 5d 20 70 69 64 3d 22 28 63 75 72 72 65 6e 74 "] pid="(current
6370: 2d 70 72 6f 63 65 73 73 2d 69 64 29 22 20 6f 74 -process-id)" ot
6380: 68 65 72 20 53 59 4e 43 20 69 6e 20 70 72 6f 67 her SYNC in prog
6390: 72 65 73 73 3b 20 6e 6f 74 20 73 79 6e 63 69 6e ress; not syncin
63a0: 67 2e 22 29 0a 20 20 20 20 20 20 20 20 20 20 20 g.").
63b0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
63c0: 20 20 20 20 27 70 61 72 61 6c 6c 65 6c 2d 73 79 'parallel-sy
63d0: 6e 63 2d 69 6e 2d 70 72 6f 67 72 65 73 73 29 29 nc-in-progress))
63e0: 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 .
63f0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 29 20 )
6400: 3b 3b 20 65 6e 64 20 69 66 20 67 6f 74 20 6c 6f ;; end if got lo
6410: 63 6b 66 69 6c 65 0a 20 20 20 20 20 20 20 20 20 ckfile.
6420: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
6430: 29 0a 20 20 20 20 20 20 20 20 20 20 20 20 20 20 ).
6440: 20 20 20 20 20 20 29 29 0a 20 20 20 20 20 20 20 )).
6450: 20 20 20 20 20 20 20 28 42 42 3e 20 22 45 6e 64 (BB> "End
6460: 20 64 6f 2d 61 2d 73 79 6e 63 20 77 69 74 68 20 do-a-sync with
6470: 66 6f 72 6b 2d 74 6f 2d 62 61 63 6b 67 72 6f 75 fork-to-backgrou
6480: 6e 64 3d 22 66 6f 72 6b 2d 74 6f 2d 62 61 63 6b nd="fork-to-back
6490: 67 72 6f 75 6e 64 22 20 70 65 72 73 69 73 74 2d ground" persist-
64a0: 75 6e 74 69 6c 2d 73 79 6e 63 3d 22 70 65 72 73 until-sync="pers
64b0: 69 73 74 2d 75 6e 74 69 6c 2d 73 79 6e 63 22 20 ist-until-sync"
64c0: 61 6e 64 20 72 65 73 75 6c 74 3d 22 66 69 6e 61 and result="fina
64d0: 6c 72 65 73 29 0a 20 20 20 20 20 20 20 20 20 20 lres).
64e0: 20 20 20 20 66 69 6e 61 6c 72 65 73 29 0a 20 20 finalres).
64f0: 20 20 20 20 20 20 20 20 20 20 29 20 3b 3b 20 65 ) ;; e
6500: 6e 64 20 6c 61 6d 62 64 61 0a 20 20 20 20 20 20 nd lambda.
6510: 20 20 20 20 29 29 0a 20 20 20 20 64 6f 2d 61 2d )). do-a-
6520: 73 79 6e 63 29 29 0a 0a 28 64 65 66 69 6e 65 20 sync))..(define
6530: 28 73 65 72 76 65 72 3a 77 72 69 74 61 62 6c 65 (server:writable
6540: 2d 77 61 74 63 68 64 6f 67 20 64 62 73 74 72 75 -watchdog dbstru
6550: 63 74 29 0a 20 20 28 74 68 72 65 61 64 2d 73 6c ct). (thread-sl
6560: 65 65 70 21 20 31 30 29 20 3b 3b 20 64 65 6c 61 eep! 10) ;; dela
6570: 79 20 66 6f 72 20 73 74 61 72 74 75 70 0a 20 20 y for startup.
6580: 28 6c 65 74 2a 20 28 28 64 6f 2d 61 2d 73 79 6e (let* ((do-a-syn
6590: 63 20 20 28 73 65 72 76 65 72 3a 67 65 74 2d 62 c (server:get-b
65a0: 72 75 74 65 66 6f 72 63 65 2d 73 79 6e 63 65 72 ruteforce-syncer
65b0: 20 64 62 73 74 72 75 63 74 29 29 0a 20 20 20 20 dbstruct)).
65c0: 20 20 20 20 20 28 66 69 6e 61 6c 2d 73 79 6e 63 (final-sync
65d0: 20 28 73 65 72 76 65 72 3a 67 65 74 2d 62 72 75 (server:get-bru
65e0: 74 65 66 6f 72 63 65 2d 73 79 6e 63 65 72 20 64 teforce-syncer d
65f0: 62 73 74 72 75 63 74 20 70 65 72 73 69 73 74 2d bstruct persist-
6600: 75 6e 74 69 6c 2d 73 79 6e 63 3a 20 23 74 29 29 until-sync: #t))
6610: 29 0a 20 20 20 20 28 77 68 65 6e 20 28 61 6e 64 ). (when (and
6620: 20 28 6e 6f 74 20 28 61 72 67 73 3a 67 65 74 2d (not (args:get-
6630: 61 72 67 20 22 2d 73 79 6e 63 2d 74 6f 2d 6d 65 arg "-sync-to-me
6640: 67 61 74 65 73 74 2e 64 62 22 29 29 20 3b 3b 20 gatest.db")) ;;
6650: 63 6f 6e 64 69 74 69 6f 6e 73 20 75 6e 64 65 72 conditions under
6660: 20 77 68 69 63 68 20 77 65 20 64 6f 20 6e 6f 74 which we do not
6670: 20 72 75 6e 20 74 68 65 20 73 79 6e 63 0a 09 20 run the sync..
6680: 20 20 20 20 20 20 28 61 72 67 73 3a 67 65 74 2d (args:get-
6690: 61 72 67 20 22 2d 73 65 72 76 65 72 22 29 29 0a arg "-server")).
66a0: 20 20 20 20 20 20 0a 20 20 20 20 20 20 28 6c 65 . (le
66b0: 74 20 6c 6f 6f 70 20 28 29 0a 09 28 64 6f 2d 61 t loop ()..(do-a
66c0: 2d 73 79 6e 63 29 0a 20 20 20 20 20 20 20 20 28 -sync). (
66d0: 69 66 20 28 6e 6f 74 20 2a 74 69 6d 65 2d 74 6f if (not *time-to
66e0: 2d 65 78 69 74 2a 29 20 28 6c 6f 6f 70 29 29 29 -exit*) (loop)))
66f0: 20 3b 3b 20 6b 65 65 70 20 67 6f 69 6e 67 20 75 ;; keep going u
6700: 6e 6c 65 73 73 20 74 69 6d 65 20 74 6f 20 65 78 nless time to ex
6710: 69 74 0a 0a 20 20 20 20 20 20 3b 3b 20 74 69 6d it.. ;; tim
6720: 65 20 74 6f 20 65 78 69 74 2c 20 63 6c 6f 73 65 e to exit, close
6730: 20 74 68 65 20 6e 6f 2d 73 79 6e 63 20 64 62 20 the no-sync db
6740: 68 65 72 65 0a 20 20 20 20 20 20 28 66 69 6e 61 here. (fina
6750: 6c 2d 73 79 6e 63 29 0a 0a 20 20 20 20 20 20 28 l-sync).. (
6760: 69 66 20 28 63 6f 6d 6d 6f 6e 3a 6c 6f 77 2d 6e if (common:low-n
6770: 6f 69 73 65 2d 70 72 69 6e 74 20 33 30 29 0a 09 oise-print 30)..
6780: 20 20 28 64 65 62 75 67 3a 70 72 69 6e 74 2d 69 (debug:print-i
6790: 6e 66 6f 20 30 20 2a 64 65 66 61 75 6c 74 2d 6c nfo 0 *default-l
67a0: 6f 67 2d 70 6f 72 74 2a 20 22 45 78 69 74 69 6e og-port* "Exitin
67b0: 67 20 77 61 74 63 68 64 6f 67 20 74 69 6d 65 72 g watchdog timer
67c0: 2c 20 2a 74 69 6d 65 2d 74 6f 2d 65 78 69 74 2a , *time-to-exit*
67d0: 20 3d 20 22 20 2a 74 69 6d 65 2d 74 6f 2d 65 78 = " *time-to-ex
67e0: 69 74 2a 22 20 70 69 64 3d 22 28 63 75 72 72 65 it*" pid="(curre
67f0: 6e 74 2d 70 72 6f 63 65 73 73 2d 69 64 29 0a 09 nt-process-id)..
6800: 09 09 20 20 20 20 29 29 29 29 29 0a 0a 0a .. )))))...