Artifact
10dc2fb7f70865e7bfbe2d91c42df3d47f8808bb:
0000: 3b 3b 20 75 6c 65 78 3a 20 44 69 73 74 72 69 62 ;; ulex: Distrib
0010: 75 74 65 64 20 73 71 6c 69 74 65 33 20 64 62 0a uted sqlite3 db.
0020: 3b 3b 3b 0a 3b 3b 20 43 6f 70 79 72 69 67 68 74 ;;;.;; Copyright
0030: 20 28 43 29 20 32 30 31 38 2d 32 30 32 31 20 4d (C) 2018-2021 M
0040: 61 74 74 20 57 65 6c 6c 61 6e 64 0a 3b 3b 20 52 att Welland.;; R
0050: 65 64 69 73 74 72 69 62 75 74 69 6f 6e 20 61 6e edistribution an
0060: 64 20 75 73 65 20 69 6e 20 73 6f 75 72 63 65 20 d use in source
0070: 61 6e 64 20 62 69 6e 61 72 79 20 66 6f 72 6d 73 and binary forms
0080: 2c 20 77 69 74 68 20 6f 72 20 77 69 74 68 6f 75 , with or withou
0090: 74 0a 3b 3b 20 6d 6f 64 69 66 69 63 61 74 69 6f t.;; modificatio
00a0: 6e 2c 20 69 73 20 70 65 72 6d 69 74 74 65 64 2e n, is permitted.
00b0: 0a 3b 3b 0a 3b 3b 20 54 48 49 53 20 53 4f 46 54 .;;.;; THIS SOFT
00c0: 57 41 52 45 20 49 53 20 50 52 4f 56 49 44 45 44 WARE IS PROVIDED
00d0: 20 42 59 20 54 48 45 20 41 55 54 48 4f 52 20 60 BY THE AUTHOR `
00e0: 60 41 53 20 49 53 27 27 20 41 4e 44 20 41 4e 59 `AS IS'' AND ANY
00f0: 20 45 58 50 52 45 53 53 0a 3b 3b 20 4f 52 20 49 EXPRESS.;; OR I
0100: 4d 50 4c 49 45 44 20 57 41 52 52 41 4e 54 49 45 MPLIED WARRANTIE
0110: 53 2c 20 49 4e 43 4c 55 44 49 4e 47 2c 20 42 55 S, INCLUDING, BU
0120: 54 20 4e 4f 54 20 4c 49 4d 49 54 45 44 20 54 4f T NOT LIMITED TO
0130: 2c 20 54 48 45 20 49 4d 50 4c 49 45 44 0a 3b 3b , THE IMPLIED.;;
0140: 20 57 41 52 52 41 4e 54 49 45 53 20 4f 46 20 4d WARRANTIES OF M
0150: 45 52 43 48 41 4e 54 41 42 49 4c 49 54 59 20 41 ERCHANTABILITY A
0160: 4e 44 20 46 49 54 4e 45 53 53 20 46 4f 52 20 41 ND FITNESS FOR A
0170: 20 50 41 52 54 49 43 55 4c 41 52 20 50 55 52 50 PARTICULAR PURP
0180: 4f 53 45 0a 3b 3b 20 41 52 45 20 44 49 53 43 4c OSE.;; ARE DISCL
0190: 41 49 4d 45 44 2e 20 20 49 4e 20 4e 4f 20 45 56 AIMED. IN NO EV
01a0: 45 4e 54 20 53 48 41 4c 4c 20 54 48 45 20 41 55 ENT SHALL THE AU
01b0: 54 48 4f 52 20 4f 52 20 43 4f 4e 54 52 49 42 55 THOR OR CONTRIBU
01c0: 54 4f 52 53 20 42 45 0a 3b 3b 20 4c 49 41 42 4c TORS BE.;; LIABL
01d0: 45 20 46 4f 52 20 41 4e 59 20 44 49 52 45 43 54 E FOR ANY DIRECT
01e0: 2c 20 49 4e 44 49 52 45 43 54 2c 20 49 4e 43 49 , INDIRECT, INCI
01f0: 44 45 4e 54 41 4c 2c 20 53 50 45 43 49 41 4c 2c DENTAL, SPECIAL,
0200: 20 45 58 45 4d 50 4c 41 52 59 2c 20 4f 52 0a 3b EXEMPLARY, OR.;
0210: 3b 20 43 4f 4e 53 45 51 55 45 4e 54 49 41 4c 20 ; CONSEQUENTIAL
0220: 44 41 4d 41 47 45 53 20 28 49 4e 43 4c 55 44 49 DAMAGES (INCLUDI
0230: 4e 47 2c 20 42 55 54 20 4e 4f 54 20 4c 49 4d 49 NG, BUT NOT LIMI
0240: 54 45 44 20 54 4f 2c 20 50 52 4f 43 55 52 45 4d TED TO, PROCUREM
0250: 45 4e 54 0a 3b 3b 20 4f 46 20 53 55 42 53 54 49 ENT.;; OF SUBSTI
0260: 54 55 54 45 20 47 4f 4f 44 53 20 4f 52 20 53 45 TUTE GOODS OR SE
0270: 52 56 49 43 45 53 3b 20 4c 4f 53 53 20 4f 46 20 RVICES; LOSS OF
0280: 55 53 45 2c 20 44 41 54 41 2c 20 4f 52 20 50 52 USE, DATA, OR PR
0290: 4f 46 49 54 53 3b 20 4f 52 0a 3b 3b 20 42 55 53 OFITS; OR.;; BUS
02a0: 49 4e 45 53 53 20 49 4e 54 45 52 52 55 50 54 49 INESS INTERRUPTI
02b0: 4f 4e 29 20 48 4f 57 45 56 45 52 20 43 41 55 53 ON) HOWEVER CAUS
02c0: 45 44 20 41 4e 44 20 4f 4e 20 41 4e 59 20 54 48 ED AND ON ANY TH
02d0: 45 4f 52 59 20 4f 46 0a 3b 3b 20 4c 49 41 42 49 EORY OF.;; LIABI
02e0: 4c 49 54 59 2c 20 57 48 45 54 48 45 52 20 49 4e LITY, WHETHER IN
02f0: 20 43 4f 4e 54 52 41 43 54 2c 20 53 54 52 49 43 CONTRACT, STRIC
0300: 54 20 4c 49 41 42 49 4c 49 54 59 2c 20 4f 52 20 T LIABILITY, OR
0310: 54 4f 52 54 0a 3b 3b 20 28 49 4e 43 4c 55 44 49 TORT.;; (INCLUDI
0320: 4e 47 20 4e 45 47 4c 49 47 45 4e 43 45 20 4f 52 NG NEGLIGENCE OR
0330: 20 4f 54 48 45 52 57 49 53 45 29 20 41 52 49 53 OTHERWISE) ARIS
0340: 49 4e 47 20 49 4e 20 41 4e 59 20 57 41 59 20 4f ING IN ANY WAY O
0350: 55 54 20 4f 46 20 54 48 45 0a 3b 3b 20 55 53 45 UT OF THE.;; USE
0360: 20 4f 46 20 54 48 49 53 20 53 4f 46 54 57 41 52 OF THIS SOFTWAR
0370: 45 2c 20 45 56 45 4e 20 49 46 20 41 44 56 49 53 E, EVEN IF ADVIS
0380: 45 44 20 4f 46 20 54 48 45 20 50 4f 53 53 49 42 ED OF THE POSSIB
0390: 49 4c 49 54 59 20 4f 46 20 53 55 43 48 0a 3b 3b ILITY OF SUCH.;;
03a0: 20 44 41 4d 41 47 45 2e 0a 0a 3b 3b 3d 3d 3d 3d DAMAGE...;;====
03b0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
03c0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
03d0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
03e0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
03f0: 3d 3d 0a 3b 3b 20 41 42 4f 55 54 3a 0a 3b 3b 20 ==.;; ABOUT:.;;
0400: 20 20 53 65 65 20 52 45 41 44 4d 45 20 69 6e 20 See README in
0410: 74 68 65 20 64 69 73 74 72 69 62 75 74 69 6f 6e the distribution
0420: 20 61 74 20 68 74 74 70 73 3a 2f 2f 77 77 77 2e at https://www.
0430: 6b 69 61 74 6f 61 2e 63 6f 6d 2f 66 6f 73 73 69 kiatoa.com/fossi
0440: 6c 73 2f 75 6c 65 78 0a 3b 3b 20 4e 4f 54 45 53 ls/ulex.;; NOTES
0450: 3a 0a 3b 3b 20 20 20 57 68 79 20 73 71 6c 2d 64 :.;; Why sql-d
0460: 65 2d 6c 69 74 65 20 61 6e 64 20 6e 6f 74 20 73 e-lite and not s
0470: 61 79 2c 20 64 62 69 3f 20 20 2d 20 70 65 72 66 ay, dbi? - perf
0480: 6f 72 6d 61 6e 63 65 20 6d 6f 73 74 6c 79 2c 20 ormance mostly,
0490: 74 68 65 6e 20 73 69 6d 70 6c 69 63 69 74 79 2e then simplicity.
04a0: 0a 3b 3b 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d .;;.;;==========
04b0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
04c0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
04d0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
04e0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a 0a 28 6d ============..(m
04f0: 6f 64 75 6c 65 20 75 6c 65 78 0a 09 2a 0a 20 20 odule ulex..*.
0500: 20 20 23 3b 28 0a 20 20 20 20 20 0a 20 20 20 20 #;(. .
0510: 20 3b 3b 20 4e 4f 54 45 3a 20 6c 6f 6f 6b 69 6e ;; NOTE: lookin
0520: 67 20 66 6f 72 20 74 68 65 20 68 61 6e 64 6c 65 g for the handle
0530: 72 20 70 72 6f 63 20 2d 20 66 69 6e 64 20 74 68 r proc - find th
0540: 65 20 72 75 6e 2d 6c 69 73 74 65 6e 65 72 20 3a e run-listener :
0550: 29 0a 20 20 20 20 20 0a 20 20 20 20 20 72 75 6e ). . run
0560: 2d 6c 69 73 74 65 6e 65 72 20 20 20 20 20 3b 3b -listener ;;
0570: 20 28 72 75 6e 2d 6c 69 73 74 65 6e 65 72 20 68 (run-listener h
0580: 61 6e 64 6c 65 72 2d 70 72 6f 63 20 5b 70 6f 72 andler-proc [por
0590: 74 5d 29 20 3d 3e 20 75 63 6f 6e 6e 0a 0a 20 20 t]) => uconn..
05a0: 20 20 20 3b 3b 20 4e 4f 54 45 3a 20 68 61 6e 64 ;; NOTE: hand
05b0: 6c 65 72 2d 70 72 6f 63 20 70 61 72 61 6d 73 3b ler-proc params;
05c0: 0a 20 20 20 20 20 3b 3b 20 20 20 20 20 20 20 28 . ;; (
05d0: 68 61 6e 64 6c 65 72 2d 70 72 6f 63 20 72 65 6d handler-proc rem
05e0: 2d 68 6f 73 74 2d 70 6f 72 74 20 71 72 79 6b 65 -host-port qryke
05f0: 79 20 63 6d 64 20 70 61 72 61 6d 73 29 0a 0a 20 y cmd params)..
0600: 20 20 20 20 73 65 6e 64 2d 72 65 63 65 69 76 65 send-receive
0610: 20 20 20 20 20 3b 3b 20 28 73 65 6e 64 2d 72 65 ;; (send-re
0620: 63 65 69 76 65 20 75 63 6f 6e 6e 20 68 6f 73 74 ceive uconn host
0630: 2d 70 6f 72 74 20 63 6d 64 20 64 61 74 61 29 0a -port cmd data).
0640: 0a 20 20 20 20 20 3b 3b 20 4e 4f 54 45 3a 20 63 . ;; NOTE: c
0650: 6d 64 20 63 61 6e 20 62 65 20 61 6e 79 20 70 6c md can be any pl
0660: 61 69 6e 20 74 65 78 74 20 73 79 6d 62 6f 6c 20 ain text symbol
0670: 65 78 63 65 70 74 20 66 6f 72 20 74 68 65 73 65 except for these
0680: 3b 0a 20 20 20 20 20 3b 3b 20 20 20 20 20 20 20 ;. ;;
0690: 20 20 27 70 69 6e 67 20 27 61 63 6b 20 27 67 6f 'ping 'ack 'go
06a0: 6f 64 62 79 65 20 27 72 65 73 70 6f 6e 73 65 0a odbye 'response.
06b0: 20 20 20 20 20 0a 20 20 20 20 20 73 65 74 2d 77 . set-w
06c0: 6f 72 6b 2d 68 61 6e 64 6c 65 72 20 3b 3b 20 28 ork-handler ;; (
06d0: 73 65 74 2d 77 6f 72 6b 2d 68 61 6e 64 6c 65 72 set-work-handler
06e0: 20 70 72 6f 63 29 0a 0a 20 20 20 20 20 77 61 69 proc).. wai
06f0: 74 2d 61 6e 64 2d 63 6c 6f 73 65 20 20 20 3b 3b t-and-close ;;
0700: 20 28 77 61 69 74 2d 61 6e 64 2d 63 6c 6f 73 65 (wait-and-close
0710: 20 75 63 6f 6e 6e 29 0a 0a 20 20 20 20 20 75 6c uconn).. ul
0720: 65 78 2d 6c 69 73 74 65 6e 65 72 3f 0a 20 20 20 ex-listener?.
0730: 20 20 0a 20 20 20 20 20 3b 3b 20 6e 65 65 64 65 . ;; neede
0740: 64 20 74 6f 20 67 65 74 20 74 68 65 20 69 6e 74 d to get the int
0750: 65 72 66 61 63 65 3a 70 6f 72 74 20 74 68 61 74 erface:port that
0760: 20 77 61 73 20 61 75 74 6f 6d 61 74 69 63 61 6c was automatical
0770: 6c 79 20 66 6f 75 6e 64 0a 20 20 20 20 20 75 64 ly found. ud
0780: 61 74 2d 70 6f 72 74 0a 20 20 20 20 20 75 64 61 at-port. uda
0790: 74 2d 68 6f 73 74 2d 70 6f 72 74 0a 20 20 20 20 t-host-port.
07a0: 20 0a 20 20 20 20 20 3b 3b 20 66 6f 72 20 74 65 . ;; for te
07b0: 73 74 69 6e 67 20 6f 6e 6c 79 0a 20 20 20 20 20 sting only.
07c0: 3b 3b 20 70 70 2d 75 63 6f 6e 6e 0a 20 20 20 20 ;; pp-uconn.
07d0: 20 29 0a 0a 28 69 6d 70 6f 72 74 20 73 63 68 65 )..(import sche
07e0: 6d 65 0a 09 63 68 69 63 6b 65 6e 2e 62 61 73 65 me..chicken.base
07f0: 0a 09 63 68 69 63 6b 65 6e 2e 66 69 6c 65 0a 09 ..chicken.file..
0800: 63 68 69 63 6b 65 6e 2e 74 69 6d 65 0a 09 63 68 chicken.time..ch
0810: 69 63 6b 65 6e 2e 63 6f 6e 64 69 74 69 6f 6e 0a icken.condition.
0820: 09 63 68 69 63 6b 65 6e 2e 73 74 72 69 6e 67 0a .chicken.string.
0830: 09 63 68 69 63 6b 65 6e 2e 73 6f 72 74 0a 09 63 .chicken.sort..c
0840: 68 69 63 6b 65 6e 2e 70 72 65 74 74 79 2d 70 72 hicken.pretty-pr
0850: 69 6e 74 0a 09 3b 3b 20 63 68 69 63 6b 65 6e 2e int..;; chicken.
0860: 74 63 70 0a 09 0a 09 61 64 64 72 65 73 73 2d 69 tcp....address-i
0870: 6e 66 6f 0a 09 6d 61 69 6c 62 6f 78 0a 09 6d 61 nfo..mailbox..ma
0880: 74 63 68 61 62 6c 65 0a 09 3b 3b 20 71 75 65 75 tchable..;; queu
0890: 65 73 0a 09 72 65 67 65 78 0a 09 72 65 67 65 78 es..regex..regex
08a0: 2d 63 61 73 65 0a 09 73 31 31 6e 0a 09 73 72 66 -case..s11n..srf
08b0: 69 2d 31 0a 09 73 72 66 69 2d 31 38 0a 09 73 72 i-1..srfi-18..sr
08c0: 66 69 2d 34 0a 09 73 72 66 69 2d 36 39 0a 09 73 fi-4..srfi-69..s
08d0: 79 73 74 65 6d 2d 69 6e 66 6f 72 6d 61 74 69 6f ystem-informatio
08e0: 6e 0a 09 74 63 70 36 0a 09 74 79 70 65 64 2d 72 n..tcp6..typed-r
08f0: 65 63 6f 72 64 73 0a 09 3b 3b 20 74 63 70 2d 73 ecords..;; tcp-s
0900: 65 72 76 65 72 0a 09 0a 09 29 0a 0a 3b 3b 20 75 erver....)..;; u
0910: 64 61 74 20 73 74 72 75 63 74 2c 20 75 73 65 64 dat struct, used
0920: 20 62 79 20 62 6f 74 68 20 63 61 6c 6c 65 72 20 by both caller
0930: 61 6e 64 20 63 61 6c 6c 65 65 0a 3b 3b 20 69 6e and callee.;; in
0940: 73 74 61 6e 74 69 61 74 65 64 20 61 73 20 75 63 stantiated as uc
0950: 6f 6e 6e 20 62 79 20 63 6f 6e 76 65 6e 74 69 6f onn by conventio
0960: 6e 0a 3b 3b 0a 28 64 65 66 73 74 72 75 63 74 20 n.;;.(defstruct
0970: 75 64 61 74 0a 20 20 3b 3b 20 74 68 65 20 6c 69 udat. ;; the li
0980: 73 74 65 6e 65 72 20 73 69 64 65 0a 20 20 28 70 stener side. (p
0990: 6f 72 74 20 23 66 29 0a 20 20 28 68 6f 73 74 2d ort #f). (host-
09a0: 70 6f 72 74 20 23 66 29 0a 20 20 28 73 6f 63 6b port #f). (sock
09b0: 65 74 20 23 66 29 0a 20 20 3b 3b 20 74 68 65 20 et #f). ;; the
09c0: 70 65 65 72 73 0a 20 20 28 70 65 65 72 73 20 20 peers. (peers
09d0: 28 6d 61 6b 65 2d 68 61 73 68 2d 74 61 62 6c 65 (make-hash-table
09e0: 29 29 20 3b 3b 20 68 6f 73 74 3a 70 6f 72 74 2d )) ;; host:port-
09f0: 3e 70 65 65 72 0a 20 20 3b 3b 20 77 6f 72 6b 20 >peer. ;; work
0a00: 68 61 6e 64 6c 69 6e 67 0a 20 20 28 77 6f 72 6b handling. (work
0a10: 2d 71 75 65 75 65 20 28 6d 61 6b 65 2d 6d 61 69 -queue (make-mai
0a20: 6c 62 6f 78 29 29 0a 20 20 28 77 6f 72 6b 2d 70 lbox)). (work-p
0a30: 72 6f 63 20 20 23 66 29 20 20 20 20 20 20 20 20 roc #f)
0a40: 20 20 20 20 20 20 20 20 3b 3b 20 73 65 74 20 62 ;; set b
0a50: 79 20 75 73 65 72 0a 20 20 28 63 6e 75 6d 20 20 y user. (cnum
0a60: 20 20 20 20 20 30 29 20 20 20 20 20 20 20 20 20 0)
0a70: 20 20 20 20 20 20 20 20 3b 3b 20 63 6f 6f 6b 69 ;; cooki
0a80: 65 20 6e 75 6d 62 65 72 0a 20 20 28 6d 62 6f 78 e number. (mbox
0a90: 65 73 20 20 20 20 20 28 6d 61 6b 65 2d 68 61 73 es (make-has
0aa0: 68 2d 74 61 62 6c 65 29 29 20 3b 3b 20 66 6f 72 h-table)) ;; for
0ab0: 20 74 68 65 20 72 65 70 6c 69 65 73 0a 20 20 28 the replies. (
0ac0: 61 76 61 69 6c 2d 63 6d 62 6f 78 65 73 20 27 28 avail-cmboxes '(
0ad0: 29 29 20 20 20 20 20 20 20 20 20 20 20 20 3b 3b )) ;;
0ae0: 20 6c 69 73 74 20 6f 66 20 28 3c 63 6f 6f 6b 69 list of (<cooki
0af0: 65 3e 20 2e 20 3c 6d 62 6f 78 3e 29 20 66 6f 72 e> . <mbox>) for
0b00: 20 72 65 2d 75 73 65 0a 20 20 3b 3b 20 74 68 72 re-use. ;; thr
0b10: 65 61 64 73 0a 20 20 28 6e 75 6d 74 68 72 65 61 eads. (numthrea
0b20: 64 73 20 35 30 29 0a 20 20 28 63 6d 64 2d 74 68 ds 50). (cmd-th
0b30: 72 65 61 64 20 23 66 29 0a 20 20 28 77 6f 72 6b read #f). (work
0b40: 2d 71 75 65 75 65 2d 74 68 72 65 61 64 20 23 66 -queue-thread #f
0b50: 29 0a 20 20 28 6e 75 6d 2d 74 68 72 65 61 64 73 ). (num-threads
0b60: 2d 72 75 6e 6e 69 6e 67 20 30 29 0a 20 20 29 20 -running 0). )
0b70: 0a 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ..;;============
0b80: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0b90: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0ba0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0bb0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a 3b 3b 20 6c 69 ==========.;; li
0bc0: 73 74 65 6e 65 72 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d stener.;;=======
0bd0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0be0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0bf0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
0c00: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a ===============.
0c10: 0a 3b 3b 20 69 73 20 75 63 6f 6e 6e 20 61 20 75 .;; is uconn a u
0c20: 6c 65 78 20 63 6f 6e 6e 65 63 74 6f 72 20 28 6c lex connector (l
0c30: 69 73 74 65 6e 65 72 29 0a 3b 3b 0a 28 64 65 66 istener).;;.(def
0c40: 69 6e 65 20 28 75 6c 65 78 2d 6c 69 73 74 65 6e ine (ulex-listen
0c50: 65 72 3f 20 75 63 6f 6e 6e 29 0a 20 20 28 75 64 er? uconn). (ud
0c60: 61 74 3f 20 75 63 6f 6e 6e 29 29 0a 0a 3b 3b 20 at? uconn))..;;
0c70: 63 72 65 61 74 65 20 61 20 74 63 70 20 6c 69 73 create a tcp lis
0c80: 74 65 6e 65 72 20 61 6e 64 20 72 65 74 75 72 6e tener and return
0c90: 20 61 20 70 6f 70 75 6c 61 74 65 64 20 75 64 61 a populated uda
0ca0: 74 20 73 74 72 75 63 74 20 77 69 74 68 0a 3b 3b t struct with.;;
0cb0: 20 6d 79 20 70 6f 72 74 2c 20 61 64 64 72 65 73 my port, addres
0cc0: 73 2c 20 68 6f 73 74 6e 61 6d 65 2c 20 70 69 64 s, hostname, pid
0cd0: 20 65 74 63 2e 0a 3b 3b 20 72 65 74 75 72 6e 20 etc..;; return
0ce0: 23 66 20 69 66 20 66 61 69 6c 20 74 6f 20 66 69 #f if fail to fi
0cf0: 6e 64 20 61 20 70 6f 72 74 20 74 6f 20 61 6c 6c nd a port to all
0d00: 6f 63 61 74 65 2e 0a 3b 3b 0a 3b 3b 20 20 69 66 ocate..;;.;; if
0d10: 20 75 64 61 74 61 2d 69 6e 20 69 73 20 23 66 20 udata-in is #f
0d20: 63 72 65 61 74 65 20 74 68 65 20 72 65 63 6f 72 create the recor
0d30: 64 0a 3b 3b 20 20 69 66 20 74 68 65 72 65 20 69 d.;; if there i
0d40: 73 20 61 6c 72 65 61 64 79 20 61 20 73 65 72 76 s already a serv
0d50: 2d 6c 69 73 74 65 6e 65 72 20 72 65 74 75 72 6e -listener return
0d60: 20 74 68 65 20 75 64 61 74 61 0a 3b 3b 0a 28 64 the udata.;;.(d
0d70: 65 66 69 6e 65 20 28 73 65 74 75 70 2d 6c 69 73 efine (setup-lis
0d80: 74 65 6e 65 72 20 75 63 6f 6e 6e 20 23 21 6f 70 tener uconn #!op
0d90: 74 69 6f 6e 61 6c 20 28 70 6f 72 74 20 34 32 34 tional (port 424
0da0: 32 29 29 0a 20 20 28 68 61 6e 64 6c 65 2d 65 78 2)). (handle-ex
0db0: 63 65 70 74 69 6f 6e 73 0a 20 20 20 65 78 6e 0a ceptions. exn.
0dc0: 20 20 20 28 69 66 20 28 3c 20 70 6f 72 74 20 36 (if (< port 6
0dd0: 35 35 33 35 29 0a 20 20 20 20 20 20 20 28 62 65 5535). (be
0de0: 67 69 6e 0a 09 20 28 74 68 72 65 61 64 2d 73 6c gin.. (thread-sl
0df0: 65 65 70 21 20 30 2e 31 29 20 3b 3b 20 49 27 6d eep! 0.1) ;; I'm
0e00: 20 6e 6f 74 20 73 75 72 65 20 74 68 69 73 20 68 not sure this h
0e10: 65 6c 70 73 20 62 75 74 20 67 69 76 65 20 74 68 elps but give th
0e20: 65 20 4f 53 20 73 6f 6d 65 20 74 69 6d 65 20 74 e OS some time t
0e30: 6f 20 64 6f 20 69 74 27 73 20 74 68 69 6e 67 0a o do it's thing.
0e40: 09 20 28 70 72 69 6e 74 20 22 55 4c 45 58 20 49 . (print "ULEX I
0e50: 4e 46 4f 3a 20 73 6b 69 70 70 69 6e 67 20 70 6f NFO: skipping po
0e60: 72 74 20 61 6c 72 65 61 64 79 20 69 6e 20 75 73 rt already in us
0e70: 65 20 22 70 6f 72 74 29 0a 09 20 28 73 65 74 75 e "port).. (setu
0e80: 70 2d 6c 69 73 74 65 6e 65 72 20 75 63 6f 6e 6e p-listener uconn
0e90: 20 28 2b 20 70 6f 72 74 20 31 29 29 29 0a 20 20 (+ port 1))).
0ea0: 20 20 20 20 20 23 66 29 0a 20 20 20 28 63 6f 6e #f). (con
0eb0: 6e 65 63 74 2d 6c 69 73 74 65 6e 65 72 20 75 63 nect-listener uc
0ec0: 6f 6e 6e 20 70 6f 72 74 29 29 29 0a 0a 28 64 65 onn port)))..(de
0ed0: 66 69 6e 65 20 28 63 6f 6e 6e 65 63 74 2d 6c 69 fine (connect-li
0ee0: 73 74 65 6e 65 72 20 75 63 6f 6e 6e 20 70 6f 72 stener uconn por
0ef0: 74 29 0a 20 20 3b 3b 20 28 74 63 70 2d 6c 69 73 t). ;; (tcp-lis
0f00: 74 65 6e 65 72 2d 73 6f 63 6b 65 74 20 4c 49 53 tener-socket LIS
0f10: 54 45 4e 45 52 29 28 73 6f 63 6b 65 74 2d 6e 61 TENER)(socket-na
0f20: 6d 65 20 73 6f 29 0a 20 20 3b 3b 20 73 6f 63 6b me so). ;; sock
0f30: 61 64 64 72 2d 61 64 64 72 65 73 73 2c 20 73 6f addr-address, so
0f40: 63 6b 61 64 64 72 2d 70 6f 72 74 2c 20 73 6f 63 ckaddr-port, soc
0f50: 6b 61 64 64 72 2d 3e 73 74 72 69 6e 67 0a 20 20 kaddr->string.
0f60: 28 6c 65 74 2a 20 28 28 74 6c 73 6e 20 28 74 63 (let* ((tlsn (tc
0f70: 70 2d 6c 69 73 74 65 6e 20 70 6f 72 74 20 31 30 p-listen port 10
0f80: 30 30 20 23 66 29 29 20 3b 3b 20 28 74 63 70 2d 00 #f)) ;; (tcp-
0f90: 6c 69 73 74 65 6e 20 54 43 50 50 4f 52 54 20 5b listen TCPPORT [
0fa0: 42 41 43 4b 4c 4f 47 20 5b 48 4f 53 54 5d 5d 29 BACKLOG [HOST]])
0fb0: 0a 09 20 28 61 64 64 72 20 28 67 65 74 2d 68 6f .. (addr (get-ho
0fc0: 73 74 2d 6e 61 6d 65 29 29 29 20 3b 3b 20 28 67 st-name))) ;; (g
0fd0: 65 74 2d 6d 79 2d 62 65 73 74 2d 61 64 64 72 65 et-my-best-addre
0fe0: 73 73 29 29 29 20 3b 3b 20 28 68 6f 73 74 69 6e ss))) ;; (hostin
0ff0: 66 6f 2d 61 64 64 72 65 73 73 65 73 20 28 68 6f fo-addresses (ho
1000: 73 74 2d 69 6e 66 6f 72 6d 61 74 69 6f 6e 20 28 st-information (
1010: 63 75 72 72 65 6e 74 2d 68 6f 73 74 6e 61 6d 65 current-hostname
1020: 29 29 29 0a 20 20 20 20 28 75 64 61 74 2d 70 6f ))). (udat-po
1030: 72 74 2d 73 65 74 21 20 20 20 20 20 20 75 63 6f rt-set! uco
1040: 6e 6e 20 70 6f 72 74 29 0a 20 20 20 20 28 75 64 nn port). (ud
1050: 61 74 2d 68 6f 73 74 2d 70 6f 72 74 2d 73 65 74 at-host-port-set
1060: 21 20 75 63 6f 6e 6e 20 28 63 6f 6e 63 20 61 64 ! uconn (conc ad
1070: 64 72 22 3a 22 70 6f 72 74 29 29 0a 20 20 20 20 dr":"port)).
1080: 28 75 64 61 74 2d 73 6f 63 6b 65 74 2d 73 65 74 (udat-socket-set
1090: 21 20 20 20 20 75 63 6f 6e 6e 20 74 6c 73 6e 29 ! uconn tlsn)
10a0: 0a 20 20 20 20 75 63 6f 6e 6e 29 29 0a 0a 3b 3b . uconn))..;;
10b0: 20 72 75 6e 2d 6c 69 73 74 65 6e 65 72 20 64 6f run-listener do
10c0: 65 73 20 61 6c 6c 20 74 68 65 20 77 6f 72 6b 20 es all the work
10d0: 6f 66 20 73 74 61 72 74 69 6e 67 20 61 20 6c 69 of starting a li
10e0: 73 74 65 6e 65 72 20 69 6e 20 61 20 74 68 72 65 stener in a thre
10f0: 61 64 0a 3b 3b 20 69 74 20 74 68 65 6e 20 72 65 ad.;; it then re
1100: 74 75 72 6e 73 20 63 6f 6e 74 72 6f 6c 0a 3b 3b turns control.;;
1110: 0a 28 64 65 66 69 6e 65 20 28 72 75 6e 2d 6c 69 .(define (run-li
1120: 73 74 65 6e 65 72 20 68 61 6e 64 6c 65 72 2d 70 stener handler-p
1130: 72 6f 63 20 23 21 6f 70 74 69 6f 6e 61 6c 20 28 roc #!optional (
1140: 70 6f 72 74 2d 73 75 67 67 65 73 74 69 6f 6e 20 port-suggestion
1150: 34 32 34 32 29 29 0a 20 20 28 6c 65 74 2a 20 28 4242)). (let* (
1160: 28 75 63 6f 6e 6e 20 28 6d 61 6b 65 2d 75 64 61 (uconn (make-uda
1170: 74 29 29 29 0a 20 20 20 20 28 75 64 61 74 2d 77 t))). (udat-w
1180: 6f 72 6b 2d 70 72 6f 63 2d 73 65 74 21 20 75 63 ork-proc-set! uc
1190: 6f 6e 6e 20 68 61 6e 64 6c 65 72 2d 70 72 6f 63 onn handler-proc
11a0: 29 0a 20 20 20 20 28 74 63 70 2d 62 75 66 66 65 ). (tcp-buffe
11b0: 72 2d 73 69 7a 65 20 32 30 34 38 29 0a 20 20 20 r-size 2048).
11c0: 20 28 69 66 20 28 73 65 74 75 70 2d 6c 69 73 74 (if (setup-list
11d0: 65 6e 65 72 20 75 63 6f 6e 6e 20 70 6f 72 74 2d ener uconn port-
11e0: 73 75 67 67 65 73 74 69 6f 6e 29 0a 09 28 6c 65 suggestion)..(le
11f0: 74 2a 20 28 28 74 68 31 20 28 6d 61 6b 65 2d 74 t* ((th1 (make-t
1200: 68 72 65 61 64 20 28 6c 61 6d 62 64 61 20 28 29 hread (lambda ()
1210: 28 75 6c 65 78 2d 63 6d 64 2d 6c 6f 6f 70 20 75 (ulex-cmd-loop u
1220: 63 6f 6e 6e 29 29 20 22 55 6c 65 78 20 63 6f 6d conn)) "Ulex com
1230: 6d 61 6e 64 20 6c 6f 6f 70 22 29 29 29 0a 09 20 mand loop")))..
1240: 20 28 74 68 72 65 61 64 2d 73 74 61 72 74 21 20 (thread-start!
1250: 74 68 31 29 0a 09 20 20 28 75 64 61 74 2d 63 6d th1).. (udat-cm
1260: 64 2d 74 68 72 65 61 64 2d 73 65 74 21 20 75 63 d-thread-set! uc
1270: 6f 6e 6e 20 74 68 31 29 0a 09 20 20 28 70 72 69 onn th1).. (pri
1280: 6e 74 20 22 63 6d 64 20 6c 6f 6f 70 20 73 74 61 nt "cmd loop sta
1290: 72 74 65 64 22 29 0a 09 20 20 75 63 6f 6e 6e 29 rted").. uconn)
12a0: 0a 09 28 61 73 73 65 72 74 20 23 66 20 22 45 52 ..(assert #f "ER
12b0: 52 4f 52 3a 20 72 75 6e 2d 6c 69 73 74 65 6e 65 ROR: run-listene
12c0: 72 20 63 61 6c 6c 65 64 20 77 69 74 68 6f 75 74 r called without
12d0: 20 70 72 6f 70 65 72 20 73 65 74 75 70 2e 22 29 proper setup.")
12e0: 29 29 29 0a 0a 28 64 65 66 69 6e 65 20 28 77 61 )))..(define (wa
12f0: 69 74 2d 61 6e 64 2d 63 6c 6f 73 65 20 75 63 6f it-and-close uco
1300: 6e 6e 29 0a 20 20 28 6c 65 74 20 6c 6f 6f 70 20 nn). (let loop
1310: 28 29 0a 20 20 20 20 28 69 66 20 28 6e 6f 74 20 (). (if (not
1320: 28 75 64 61 74 2d 63 6d 64 2d 74 68 72 65 61 64 (udat-cmd-thread
1330: 20 75 63 6f 6e 6e 29 29 0a 09 28 62 65 67 69 6e uconn))..(begin
1340: 0a 09 20 20 28 74 68 72 65 61 64 2d 73 6c 65 65 .. (thread-slee
1350: 70 21 20 31 29 0a 09 20 20 28 6c 6f 6f 70 29 29 p! 1).. (loop))
1360: 29 29 0a 20 20 28 74 68 72 65 61 64 2d 6a 6f 69 )). (thread-joi
1370: 6e 21 20 28 75 64 61 74 2d 63 6d 64 2d 74 68 72 n! (udat-cmd-thr
1380: 65 61 64 20 75 63 6f 6e 6e 29 29 0a 20 20 23 3b ead uconn)). #;
1390: 28 74 63 70 2d 63 6c 6f 73 65 20 28 75 64 61 74 (tcp-close (udat
13a0: 2d 73 6f 63 6b 65 74 20 75 63 6f 6e 6e 29 29 29 -socket uconn)))
13b0: 0a 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ..;;============
13c0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
13d0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
13e0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
13f0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a 3b 3b 20 70 65 ==========.;; pe
1400: 65 72 73 20 61 6e 64 20 63 6f 6e 6e 65 63 74 69 ers and connecti
1410: 6f 6e 73 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ons.;;==========
1420: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
1430: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
1440: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
1450: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a 0a 28 64 ============..(d
1460: 65 66 69 6e 65 20 2a 73 65 6e 64 2d 6d 75 74 65 efine *send-mute
1470: 78 2a 20 28 6d 61 6b 65 2d 6d 75 74 65 78 29 29 x* (make-mutex))
1480: 0a 0a 3b 3b 20 73 65 6e 64 20 73 74 72 75 63 74 ..;; send struct
1490: 75 72 65 64 20 64 61 74 61 20 74 6f 20 72 65 63 ured data to rec
14a0: 69 70 69 65 6e 74 0a 3b 3b 0a 3b 3b 20 20 4e 4f ipient.;;.;; NO
14b0: 54 45 3a 20 71 72 79 6b 65 79 20 69 73 20 77 68 TE: qrykey is wh
14c0: 61 74 20 77 61 73 20 63 61 6c 6c 65 64 20 74 68 at was called th
14d0: 65 20 22 63 6f 6f 6b 69 65 22 20 70 72 65 76 69 e "cookie" previ
14e0: 6f 75 73 6c 79 0a 3b 3b 0a 3b 3b 20 20 20 20 20 ously.;;.;;
14f0: 72 65 74 76 61 6c 20 74 65 6c 6c 73 20 73 65 6e retval tells sen
1500: 64 20 74 6f 20 65 78 70 65 63 74 20 61 6e 64 20 d to expect and
1510: 77 61 69 74 20 66 6f 72 20 72 65 74 75 72 6e 20 wait for return
1520: 64 61 74 61 20 28 6f 6e 65 20 6c 69 6e 65 29 20 data (one line)
1530: 61 6e 64 20 72 65 74 75 72 6e 20 69 74 20 6f 72 and return it or
1540: 20 74 69 6d 65 20 6f 75 74 0a 3b 3b 20 20 20 20 time out.;;
1550: 20 20 20 74 68 69 73 20 69 73 20 66 6f 72 20 70 this is for p
1560: 69 6e 67 20 77 68 65 72 65 20 77 65 20 64 6f 6e ing where we don
1570: 27 74 20 77 61 6e 74 20 74 6f 20 6e 65 63 65 73 't want to neces
1580: 73 61 72 69 6c 79 20 68 61 76 65 20 73 65 74 20 sarily have set
1590: 75 70 20 6f 75 72 20 6f 77 6e 20 73 65 72 76 65 up our own serve
15a0: 72 20 79 65 74 2e 0a 3b 3b 0a 3b 3b 20 4e 4f 54 r yet..;;.;; NOT
15b0: 45 3a 20 73 65 65 20 62 65 6c 6f 77 20 66 6f 72 E: see below for
15c0: 20 62 65 67 69 6e 6e 69 6e 67 73 20 6f 66 20 63 beginnings of c
15d0: 6f 64 65 20 74 6f 20 61 6c 6c 6f 77 20 72 65 2d ode to allow re-
15e0: 75 73 65 20 6f 66 20 74 63 70 20 63 6f 6e 6e 65 use of tcp conne
15f0: 63 74 69 6f 6e 73 0a 3b 3b 20 20 20 20 20 20 20 ctions.;;
1600: 20 2d 20 49 20 62 65 6c 69 65 76 65 20 28 77 69 - I believe (wi
1610: 74 68 6f 75 74 20 73 75 62 73 74 61 6e 74 69 61 thout substantia
1620: 6c 20 65 76 69 64 65 6e 63 65 29 20 74 68 61 74 l evidence) that
1630: 20 72 65 2d 75 73 69 6e 67 20 63 6f 6e 6e 65 63 re-using connec
1640: 74 69 6f 6e 73 20 77 69 6c 6c 0a 3b 3b 20 20 20 tions will.;;
1650: 20 20 20 20 20 20 20 62 65 20 62 65 6e 65 66 69 be benefi
1660: 63 69 61 6c 20 2e 2e 2e 0a 3b 3b 0a 28 64 65 66 cial ....;;.(def
1670: 69 6e 65 20 28 73 65 6e 64 2d 72 65 63 65 69 76 ine (send-receiv
1680: 65 20 75 64 61 74 61 20 68 6f 73 74 2d 70 6f 72 e udata host-por
1690: 74 20 63 6d 64 20 70 61 72 61 6d 73 29 0a 20 20 t cmd params).
16a0: 28 6d 75 74 65 78 2d 6c 6f 63 6b 21 20 2a 73 65 (mutex-lock! *se
16b0: 6e 64 2d 6d 75 74 65 78 2a 29 0a 20 20 28 6c 65 nd-mutex*). (le
16c0: 74 2a 20 28 28 6d 79 2d 68 6f 73 74 2d 70 6f 72 t* ((my-host-por
16d0: 74 20 28 75 64 61 74 2d 68 6f 73 74 2d 70 6f 72 t (udat-host-por
16e0: 74 20 75 64 61 74 61 29 29 20 20 20 20 20 20 20 t udata))
16f0: 20 20 20 3b 3b 20 72 65 6d 6f 74 65 20 77 69 6c ;; remote wil
1700: 6c 20 72 65 74 75 72 6e 20 74 6f 20 74 68 69 73 l return to this
1710: 0a 09 20 28 69 73 6d 65 20 20 20 20 20 20 20 20 .. (isme
1720: 20 28 65 71 75 61 6c 3f 20 68 6f 73 74 2d 70 6f (equal? host-po
1730: 72 74 20 6d 79 2d 68 6f 73 74 2d 70 6f 72 74 29 rt my-host-port)
1740: 29 20 3b 3b 20 63 61 6c 6c 69 6e 67 20 6d 79 73 ) ;; calling mys
1750: 65 6c 66 3f 0a 09 20 3b 3b 20 64 61 74 20 69 73 elf?.. ;; dat is
1760: 20 61 20 73 65 6c 66 2d 63 6f 6e 74 61 69 6e 65 a self-containe
1770: 64 20 77 6f 72 6b 20 62 6c 6f 63 6b 20 74 68 61 d work block tha
1780: 74 20 63 61 6e 20 62 65 20 73 65 6e 74 20 6f 72 t can be sent or
1790: 20 68 61 6e 64 6c 65 64 20 6c 6f 63 61 6c 6c 79 handled locally
17a0: 0a 09 20 28 64 61 74 20 20 20 20 20 20 20 20 20 .. (dat
17b0: 20 28 6c 69 73 74 20 6d 79 2d 68 6f 73 74 2d 70 (list my-host-p
17c0: 6f 72 74 20 63 6d 64 20 70 61 72 61 6d 73 29 29 ort cmd params))
17d0: 0a 09 20 28 70 61 72 74 73 20 20 20 20 20 20 20 .. (parts
17e0: 20 28 73 74 72 69 6e 67 2d 73 70 6c 69 74 20 68 (string-split h
17f0: 6f 73 74 2d 70 6f 72 74 20 22 3a 22 29 29 0a 09 ost-port ":"))..
1800: 20 28 68 6f 73 74 20 20 20 20 20 20 20 20 20 28 (host (
1810: 63 61 72 20 70 61 72 74 73 29 29 0a 09 20 28 70 car parts)).. (p
1820: 6f 72 74 20 20 20 20 20 20 20 20 20 28 73 74 72 ort (str
1830: 69 6e 67 2d 3e 6e 75 6d 62 65 72 20 28 63 61 64 ing->number (cad
1840: 72 20 70 61 72 74 73 29 29 29 29 0a 20 20 20 20 r parts)))).
1850: 28 69 66 20 69 73 6d 65 0a 09 28 75 6c 65 78 2d (if isme..(ulex-
1860: 68 61 6e 64 6c 65 72 20 75 64 61 74 61 20 64 61 handler udata da
1870: 74 29 20 3b 3b 20 6e 6f 20 74 72 61 6e 73 6d 69 t) ;; no transmi
1880: 73 73 69 6f 6e 20 6e 65 65 64 65 64 0a 09 28 6c ssion needed..(l
1890: 65 74 2d 76 61 6c 75 65 73 20 28 28 28 69 6e 70 et-values (((inp
18a0: 20 6f 75 70 29 28 74 63 70 2d 63 6f 6e 6e 65 63 oup)(tcp-connec
18b0: 74 20 68 6f 73 74 2d 70 6f 72 74 29 29 29 0a 09 t host-port)))..
18c0: 20 20 28 6c 65 74 20 28 28 72 65 73 20 28 69 66 (let ((res (if
18d0: 20 28 61 6e 64 20 69 6e 70 20 6f 75 70 29 0a 09 (and inp oup)..
18e0: 09 09 20 28 62 65 67 69 6e 0a 09 09 09 20 20 20 .. (begin....
18f0: 28 73 65 72 69 61 6c 69 7a 65 20 64 61 74 20 6f (serialize dat o
1900: 75 70 29 0a 09 09 09 20 20 20 28 64 65 73 65 72 up).... (deser
1910: 69 61 6c 69 7a 65 20 69 6e 70 29 29 20 3b 3b 20 ialize inp)) ;;
1920: 79 65 73 2c 20 77 65 20 61 6c 77 61 79 73 20 77 yes, we always w
1930: 61 6e 74 20 61 6e 20 61 63 6b 0a 09 09 09 20 28 ant an ack.... (
1940: 62 65 67 69 6e 0a 09 09 09 20 20 20 28 70 72 69 begin.... (pri
1950: 6e 74 20 22 45 52 52 4f 52 3a 20 73 65 6e 64 20 nt "ERROR: send
1960: 63 61 6c 6c 65 64 20 62 75 74 20 6e 6f 20 72 65 called but no re
1970: 63 65 69 76 65 72 20 68 61 73 20 62 65 65 6e 20 ceiver has been
1980: 73 65 74 75 70 2e 20 50 6c 65 61 73 65 20 63 61 setup. Please ca
1990: 6c 6c 20 73 65 74 75 70 20 66 69 72 73 74 21 22 ll setup first!"
19a0: 29 0a 09 09 09 20 20 20 23 66 29 29 29 29 0a 09 ).... #f))))..
19b0: 20 20 20 20 28 63 6c 6f 73 65 2d 69 6e 70 75 74 (close-input
19c0: 2d 70 6f 72 74 20 69 6e 70 29 0a 09 20 20 20 20 -port inp)..
19d0: 28 63 6c 6f 73 65 2d 6f 75 74 70 75 74 2d 70 6f (close-output-po
19e0: 72 74 20 6f 75 70 29 0a 09 20 20 20 20 28 6d 75 rt oup).. (mu
19f0: 74 65 78 2d 75 6e 6c 6f 63 6b 21 20 2a 73 65 6e tex-unlock! *sen
1a00: 64 2d 6d 75 74 65 78 2a 29 0a 09 20 20 20 20 72 d-mutex*).. r
1a10: 65 73 29 29 29 29 29 0a 0a 3b 3b 3d 3d 3d 3d 3d es)))))..;;=====
1a20: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
1a30: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
1a40: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
1a50: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
1a60: 3d 0a 3b 3b 20 72 65 73 70 6f 6e 64 65 72 20 73 =.;; responder s
1a70: 69 64 65 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ide.;;==========
1a80: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
1a90: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
1aa0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
1ab0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a 0a 3b 3b ============..;;
1ac0: 20 74 61 6b 65 20 61 20 72 65 71 75 65 73 74 2c take a request,
1ad0: 20 72 64 61 74 2c 20 61 6e 64 20 69 66 20 6e 6f rdat, and if no
1ae0: 74 20 69 6d 6d 65 64 69 61 74 65 20 70 75 74 20 t immediate put
1af0: 69 74 20 69 6e 20 74 68 65 20 77 6f 72 6b 20 71 it in the work q
1b00: 75 65 75 65 0a 3b 3b 0a 3b 3b 20 52 65 73 65 72 ueue.;;.;; Reser
1b10: 76 65 64 20 63 6d 64 73 3b 20 61 63 6b 20 70 69 ved cmds; ack pi
1b20: 6e 67 20 67 6f 6f 64 62 79 65 20 72 65 73 70 6f ng goodbye respo
1b30: 6e 73 65 0a 3b 3b 0a 28 64 65 66 69 6e 65 20 28 nse.;;.(define (
1b40: 75 6c 65 78 2d 68 61 6e 64 6c 65 72 20 75 63 6f ulex-handler uco
1b50: 6e 6e 20 72 64 61 74 29 0a 20 20 28 61 73 73 65 nn rdat). (asse
1b60: 72 74 20 28 6c 69 73 74 3f 20 72 64 61 74 29 20 rt (list? rdat)
1b70: 22 46 41 54 41 4c 3a 20 75 6c 65 78 2d 68 61 6e "FATAL: ulex-han
1b80: 64 6c 65 72 20 67 69 76 65 20 72 64 61 74 20 61 dler give rdat a
1b90: 73 20 6e 6f 74 20 6c 69 73 74 22 29 0a 20 20 28 s not list"). (
1ba0: 6d 61 74 63 68 20 72 64 61 74 0a 20 20 20 20 28 match rdat. (
1bb0: 28 72 65 6d 2d 68 6f 73 74 2d 70 6f 72 74 20 63 (rem-host-port c
1bc0: 6d 64 20 70 61 72 61 6d 73 29 0a 20 20 20 20 20 md params).
1bd0: 28 64 6f 2d 77 6f 72 6b 20 75 63 6f 6e 6e 20 72 (do-work uconn r
1be0: 64 61 74 29 29 0a 20 20 20 20 28 65 6c 73 65 0a dat)). (else.
1bf0: 20 20 20 20 20 28 70 72 69 6e 74 20 22 42 41 44 (print "BAD
1c00: 20 44 41 54 41 3f 20 63 6f 6e 74 72 6f 6c 64 61 DATA? controlda
1c10: 74 3d 22 20 72 64 61 74 29 0a 20 20 20 20 20 27 t=" rdat). '
1c20: 62 61 64 2d 64 61 74 61 29 0a 20 20 20 20 29 29 bad-data). ))
1c30: 0a 0a 3b 3b 20 67 69 76 65 6e 20 61 6e 20 61 6c ..;; given an al
1c40: 72 65 61 64 79 20 73 65 74 20 75 70 20 75 63 6f ready set up uco
1c50: 6e 6e 20 73 74 61 72 74 20 74 68 65 20 63 6d 64 nn start the cmd
1c60: 2d 6c 6f 6f 70 0a 3b 3b 0a 23 3b 28 64 65 66 69 -loop.;;.#;(defi
1c70: 6e 65 20 28 75 6c 65 78 2d 63 6d 64 2d 6c 6f 6f ne (ulex-cmd-loo
1c80: 70 20 75 63 6f 6e 6e 29 0a 20 20 28 6c 65 74 2a p uconn). (let*
1c90: 20 28 28 73 65 72 76 2d 6c 69 73 74 65 6e 65 72 ((serv-listener
1ca0: 20 28 75 64 61 74 2d 73 6f 63 6b 65 74 20 75 63 (udat-socket uc
1cb0: 6f 6e 6e 29 29 0a 09 20 28 73 65 72 76 65 72 20 onn)).. (server
1cc0: 20 20 20 20 20 20 20 28 6d 61 6b 65 2d 74 63 70 (make-tcp
1cd0: 2d 73 65 72 76 65 72 0a 09 09 09 20 73 65 72 76 -server.... serv
1ce0: 2d 6c 69 73 74 65 6e 65 72 0a 09 09 09 20 28 6c -listener.... (l
1cf0: 61 6d 62 64 61 20 28 29 0a 09 09 09 20 20 20 28 ambda ().... (
1d00: 6c 65 74 2a 20 28 28 72 64 61 74 20 20 28 64 65 let* ((rdat (de
1d10: 73 65 72 69 61 6c 69 7a 65 29 29 20 3b 3b 20 27 serialize)) ;; '
1d20: 28 6d 79 2d 68 6f 73 74 2d 70 6f 72 74 20 71 72 (my-host-port qr
1d30: 79 6b 65 79 20 63 6d 64 20 70 61 72 61 6d 73 29 ykey cmd params)
1d40: 0a 09 09 09 09 20 20 28 72 65 73 70 20 20 28 75 ..... (resp (u
1d50: 6c 65 78 2d 68 61 6e 64 6c 65 72 20 75 63 6f 6e lex-handler ucon
1d60: 6e 20 72 64 61 74 29 29 29 0a 09 09 09 20 20 20 n rdat)))....
1d70: 20 20 28 69 66 20 72 65 73 70 0a 09 09 09 09 20 (if resp.....
1d80: 28 73 65 72 69 61 6c 69 7a 65 20 72 65 73 70 29 (serialize resp)
1d90: 0a 09 09 09 09 20 28 77 72 69 74 65 20 72 65 73 ..... (write res
1da0: 70 29 29 29 29 29 29 29 0a 20 20 20 20 28 73 65 p))))))). (se
1db0: 72 76 65 72 29 29 29 0a 0a 3b 3b 20 67 69 76 65 rver)))..;; give
1dc0: 6e 20 61 6e 20 61 6c 72 65 61 64 79 20 73 65 74 n an already set
1dd0: 20 75 70 20 75 63 6f 6e 6e 20 73 74 61 72 74 20 up uconn start
1de0: 74 68 65 20 63 6d 64 2d 6c 6f 6f 70 0a 3b 3b 0a the cmd-loop.;;.
1df0: 28 64 65 66 69 6e 65 20 28 75 6c 65 78 2d 63 6d (define (ulex-cm
1e00: 64 2d 6c 6f 6f 70 20 75 63 6f 6e 6e 29 0a 20 20 d-loop uconn).
1e10: 28 6c 65 74 2a 20 28 28 73 65 72 76 2d 6c 69 73 (let* ((serv-lis
1e20: 74 65 6e 65 72 20 28 75 64 61 74 2d 73 6f 63 6b tener (udat-sock
1e30: 65 74 20 75 63 6f 6e 6e 29 29 0a 09 20 28 6c 69 et uconn)).. (li
1e40: 73 74 65 6e 65 72 20 20 20 20 20 20 28 6c 61 6d stener (lam
1e50: 62 64 61 20 28 29 0a 09 09 09 20 20 28 6c 65 74 bda ().... (let
1e60: 20 6c 6f 6f 70 20 28 28 73 74 61 74 65 20 27 73 loop ((state 's
1e70: 74 61 72 74 29 29 0a 09 09 09 20 20 20 20 28 6c tart)).... (l
1e80: 65 74 2d 76 61 6c 75 65 73 20 28 28 28 69 6e 70 et-values (((inp
1e90: 20 6f 75 70 29 28 74 63 70 2d 61 63 63 65 70 74 oup)(tcp-accept
1ea0: 20 73 65 72 76 2d 6c 69 73 74 65 6e 65 72 29 29 serv-listener))
1eb0: 29 0a 09 09 09 20 20 20 20 20 20 28 6c 65 74 2a ).... (let*
1ec0: 20 28 28 72 64 61 74 20 20 28 64 65 73 65 72 69 ((rdat (deseri
1ed0: 61 6c 69 7a 65 20 69 6e 70 29 29 20 3b 3b 20 27 alize inp)) ;; '
1ee0: 28 6d 79 2d 68 6f 73 74 2d 70 6f 72 74 20 71 72 (my-host-port qr
1ef0: 79 6b 65 79 20 63 6d 64 20 70 61 72 61 6d 73 29 ykey cmd params)
1f00: 0a 09 09 09 09 20 20 20 20 20 28 72 65 73 70 20 ..... (resp
1f10: 20 28 75 6c 65 78 2d 68 61 6e 64 6c 65 72 20 75 (ulex-handler u
1f20: 63 6f 6e 6e 20 72 64 61 74 29 29 29 0a 09 09 09 conn rdat)))....
1f30: 09 28 73 65 72 69 61 6c 69 7a 65 20 72 65 73 70 .(serialize resp
1f40: 20 6f 75 70 29 0a 09 09 09 09 28 63 6c 6f 73 65 oup).....(close
1f50: 2d 69 6e 70 75 74 2d 70 6f 72 74 20 69 6e 70 29 -input-port inp)
1f60: 0a 09 09 09 09 28 63 6c 6f 73 65 2d 6f 75 74 70 .....(close-outp
1f70: 75 74 2d 70 6f 72 74 20 6f 75 70 29 29 0a 09 09 ut-port oup))...
1f80: 09 20 20 20 20 20 20 28 6c 6f 6f 70 20 73 74 61 . (loop sta
1f90: 74 65 29 29 29 29 29 29 0a 20 20 20 3b 3b 20 73 te)))))). ;; s
1fa0: 74 61 72 74 20 4e 20 6f 66 20 74 68 65 6d 0a 20 tart N of them.
1fb0: 20 20 28 6c 65 74 20 6c 6f 6f 70 20 28 28 74 68 (let loop ((th
1fc0: 6e 75 6d 20 20 20 30 29 0a 09 20 20 20 20 20 20 num 0)..
1fd0: 20 28 74 68 72 65 61 64 73 20 27 28 29 29 29 0a (threads '())).
1fe0: 20 20 20 20 20 20 28 69 66 20 28 3c 20 74 68 6e (if (< thn
1ff0: 75 6d 20 31 30 30 29 0a 09 20 20 28 6c 65 74 2a um 100).. (let*
2000: 20 28 28 74 68 20 28 6d 61 6b 65 2d 74 68 72 65 ((th (make-thre
2010: 61 64 20 6c 69 73 74 65 6e 65 72 20 28 63 6f 6e ad listener (con
2020: 63 20 22 6c 69 73 74 65 6e 65 72 22 20 74 68 6e c "listener" thn
2030: 75 6d 29 29 29 29 0a 09 20 20 20 20 28 74 68 72 um)))).. (thr
2040: 65 61 64 2d 73 74 61 72 74 21 20 74 68 29 0a 09 ead-start! th)..
2050: 20 20 20 20 28 6c 6f 6f 70 20 28 2b 20 74 68 6e (loop (+ thn
2060: 75 6d 20 31 29 0a 09 09 20 20 28 63 6f 6e 73 20 um 1)... (cons
2070: 74 68 20 74 68 72 65 61 64 73 29 29 29 0a 09 20 th threads)))..
2080: 20 28 6d 61 70 20 74 68 72 65 61 64 2d 6a 6f 69 (map thread-joi
2090: 6e 21 20 74 68 72 65 61 64 73 29 29 29 29 29 0a n! threads))))).
20a0: 0a 3b 3b 20 61 64 64 20 61 20 70 72 6f 63 20 74 .;; add a proc t
20b0: 6f 20 74 68 65 20 63 6d 64 20 6c 69 73 74 2c 20 o the cmd list,
20c0: 74 68 65 73 65 20 61 72 65 20 64 6f 6e 65 20 73 these are done s
20d0: 79 6d 65 74 72 69 63 61 6c 6c 79 20 28 69 2e 65 ymetrically (i.e
20e0: 2e 20 69 6e 20 61 6c 6c 20 69 6e 73 74 61 6e 63 . in all instanc
20f0: 65 73 29 0a 3b 3b 20 73 6f 20 74 68 61 74 20 74 es).;; so that t
2100: 68 65 20 70 72 6f 63 20 63 61 6e 20 62 65 20 64 he proc can be d
2110: 65 72 65 66 65 72 65 6e 63 65 64 20 72 65 6d 6f ereferenced remo
2120: 74 65 6c 79 0a 3b 3b 0a 28 64 65 66 69 6e 65 20 tely.;;.(define
2130: 28 73 65 74 2d 77 6f 72 6b 2d 68 61 6e 64 6c 65 (set-work-handle
2140: 72 20 75 63 6f 6e 6e 20 70 72 6f 63 29 0a 20 20 r uconn proc).
2150: 28 75 64 61 74 2d 77 6f 72 6b 2d 70 72 6f 63 2d (udat-work-proc-
2160: 73 65 74 21 20 75 63 6f 6e 6e 20 70 72 6f 63 29 set! uconn proc)
2170: 29 0a 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d )..;;===========
2180: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
2190: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
21a0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
21b0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a 3b 3b 20 77 ===========.;; w
21c0: 6f 72 6b 20 71 75 65 75 65 73 20 2d 20 74 68 69 ork queues - thi
21d0: 73 20 69 73 20 61 6c 6c 20 68 61 70 70 65 6e 69 s is all happeni
21e0: 6e 67 20 6f 6e 20 74 68 65 20 6c 69 73 74 65 6e ng on the listen
21f0: 65 72 20 73 69 64 65 0a 3b 3b 3d 3d 3d 3d 3d 3d er side.;;======
2200: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
2210: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
2220: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
2230: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
2240: 0a 0a 3b 3b 20 72 64 61 74 20 69 73 20 28 72 65 ..;; rdat is (re
2250: 6d 2d 68 6f 73 74 2d 70 6f 72 74 20 71 72 79 6b m-host-port qryk
2260: 65 79 20 63 6d 64 20 70 61 72 61 6d 73 29 0a 09 ey cmd params)..
2270: 09 09 09 09 20 20 20 20 20 0a 28 64 65 66 69 6e .... .(defin
2280: 65 20 28 61 64 64 2d 74 6f 2d 77 6f 72 6b 2d 71 e (add-to-work-q
2290: 75 65 75 65 20 75 63 6f 6e 6e 20 72 64 61 74 29 ueue uconn rdat)
22a0: 0a 20 20 23 3b 28 71 75 65 75 65 2d 61 64 64 21 . #;(queue-add!
22b0: 20 28 75 64 61 74 2d 77 6f 72 6b 2d 71 75 65 75 (udat-work-queu
22c0: 65 20 75 63 6f 6e 6e 29 20 72 64 61 74 29 0a 20 e uconn) rdat).
22d0: 20 28 6d 61 69 6c 62 6f 78 2d 73 65 6e 64 21 20 (mailbox-send!
22e0: 28 75 64 61 74 2d 77 6f 72 6b 2d 71 75 65 75 65 (udat-work-queue
22f0: 20 75 63 6f 6e 6e 29 20 72 64 61 74 29 29 0a 0a uconn) rdat))..
2300: 28 64 65 66 69 6e 65 20 28 64 6f 2d 77 6f 72 6b (define (do-work
2310: 20 75 63 6f 6e 6e 20 72 64 61 74 29 0a 20 20 28 uconn rdat). (
2320: 6c 65 74 2a 20 28 28 70 72 6f 63 20 28 75 64 61 let* ((proc (uda
2330: 74 2d 77 6f 72 6b 2d 70 72 6f 63 20 75 63 6f 6e t-work-proc ucon
2340: 6e 29 29 29 20 3b 3b 20 67 65 74 20 69 74 20 65 n))) ;; get it e
2350: 61 63 68 20 74 69 6d 65 20 2d 20 63 6f 6e 63 65 ach time - conce
2360: 69 76 65 62 6c 79 20 69 74 20 63 6f 75 6c 64 20 ivebly it could
2370: 63 68 61 6e 67 65 0a 20 20 20 20 3b 3b 20 70 75 change. ;; pu
2380: 74 20 74 68 69 73 20 66 6f 6c 6c 6f 77 69 6e 67 t this following
2390: 20 69 6e 74 6f 20 61 20 64 6f 2d 77 6f 72 6b 20 into a do-work
23a0: 70 72 6f 63 65 64 75 72 65 0a 20 20 20 20 28 6d procedure. (m
23b0: 61 74 63 68 20 72 64 61 74 0a 20 20 20 20 20 20 atch rdat.
23c0: 28 28 72 65 6d 2d 68 6f 73 74 2d 70 6f 72 74 20 ((rem-host-port
23d0: 63 6d 64 20 70 61 72 61 6d 73 29 0a 20 20 20 20 cmd params).
23e0: 20 20 20 28 6c 65 74 2a 20 28 28 73 74 61 72 74 (let* ((start
23f0: 2d 74 69 6d 65 20 28 63 75 72 72 65 6e 74 2d 6d -time (current-m
2400: 69 6c 6c 69 73 65 63 6f 6e 64 73 29 29 0a 09 20 illiseconds))..
2410: 20 20 20 20 20 28 72 65 73 75 6c 74 20 28 70 72 (result (pr
2420: 6f 63 20 72 65 6d 2d 68 6f 73 74 2d 70 6f 72 74 oc rem-host-port
2430: 20 63 6d 64 20 70 61 72 61 6d 73 29 29 0a 09 20 cmd params))..
2440: 20 20 20 20 20 28 65 6e 64 2d 74 69 6d 65 20 28 (end-time (
2450: 63 75 72 72 65 6e 74 2d 6d 69 6c 6c 69 73 65 63 current-millisec
2460: 6f 6e 64 73 29 29 0a 09 20 20 20 20 20 20 28 72 onds)).. (r
2470: 75 6e 2d 74 69 6d 65 20 28 2d 20 65 6e 64 2d 74 un-time (- end-t
2480: 69 6d 65 20 73 74 61 72 74 2d 74 69 6d 65 29 29 ime start-time))
2490: 29 0a 09 20 28 69 66 20 28 3e 20 72 75 6e 2d 74 ).. (if (> run-t
24a0: 69 6d 65 20 31 30 30 30 29 0a 09 20 20 20 20 20 ime 1000)..
24b0: 28 70 72 69 6e 74 20 22 55 4c 45 58 20 49 4e 46 (print "ULEX INF
24c0: 4f 3a 20 4e 6f 74 65 20 74 68 61 74 20 22 63 6d O: Note that "cm
24d0: 64 22 20 77 69 74 68 20 70 61 72 61 6d 73 20 22 d" with params "
24e0: 70 61 72 61 6d 73 22 20 74 6f 6f 6b 20 22 72 75 params" took "ru
24f0: 6e 2d 74 69 6d 65 22 6d 73 20 74 6f 20 63 6f 6d n-time"ms to com
2500: 70 6c 65 74 65 2e 22 29 29 0a 09 20 72 65 73 75 plete.")).. resu
2510: 6c 74 29 29 0a 20 20 20 20 20 20 28 65 6c 73 65 lt)). (else
2520: 0a 20 20 20 20 20 20 20 28 70 72 69 6e 74 20 22 . (print "
2530: 45 52 52 4f 52 3a 20 72 64 61 74 20 22 72 64 61 ERROR: rdat "rda
2540: 74 22 2c 20 64 69 64 20 6e 6f 74 20 6d 61 74 63 t", did not matc
2550: 68 20 72 65 6d 2d 68 6f 73 74 2d 70 6f 72 74 20 h rem-host-port
2560: 71 72 79 6b 65 79 20 63 6d 64 20 70 61 72 61 6d qrykey cmd param
2570: 73 22 29 0a 20 20 20 20 20 20 20 23 66 29 29 29 s"). #f)))
2580: 29 0a 20 20 20 20 20 20 20 20 20 20 20 0a 3b 3b ). .;;
2590: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
25a0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
25b0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
25c0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
25d0: 3d 3d 3d 3d 3d 3d 0a 3b 3b 20 6d 69 73 63 20 75 ======.;; misc u
25e0: 74 69 6c 73 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d tils.;;=========
25f0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
2600: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
2610: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
2620: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a 0a 28 =============..(
2630: 64 65 66 69 6e 65 20 28 6d 61 6b 65 2d 63 6f 6f define (make-coo
2640: 6b 69 65 20 75 63 6f 6e 6e 29 0a 20 20 28 6c 65 kie uconn). (le
2650: 74 20 28 28 6e 65 77 63 6e 75 6d 20 28 2b 20 28 t ((newcnum (+ (
2660: 75 64 61 74 2d 63 6e 75 6d 20 75 63 6f 6e 6e 29 udat-cnum uconn)
2670: 20 31 29 29 29 0a 20 20 20 20 28 75 64 61 74 2d 1))). (udat-
2680: 63 6e 75 6d 2d 73 65 74 21 20 75 63 6f 6e 6e 20 cnum-set! uconn
2690: 6e 65 77 63 6e 75 6d 29 0a 20 20 20 20 28 63 6f newcnum). (co
26a0: 6e 63 20 28 75 64 61 74 2d 68 6f 73 74 2d 70 6f nc (udat-host-po
26b0: 72 74 20 75 63 6f 6e 6e 29 20 22 3a 22 0a 09 20 rt uconn) ":"..
26c0: 20 6e 65 77 63 6e 75 6d 29 29 29 0a 0a 3b 3b 20 newcnum)))..;;
26d0: 63 6f 6f 6b 69 65 2f 6d 62 6f 78 65 73 0a 0a 3b cookie/mboxes..;
26e0: 3b 20 77 65 20 73 74 6f 72 65 20 65 61 63 68 20 ; we store each
26f0: 6d 62 6f 78 20 77 69 74 68 20 61 20 63 6f 6f 6b mbox with a cook
2700: 69 65 20 28 3c 63 6f 6f 6b 69 65 3e 20 2e 20 3c ie (<cookie> . <
2710: 6d 62 6f 78 3e 29 0a 3b 3b 0a 28 64 65 66 69 6e mbox>).;;.(defin
2720: 65 20 28 67 65 74 2d 63 6d 62 6f 78 20 75 63 6f e (get-cmbox uco
2730: 6e 6e 29 0a 20 20 28 69 66 20 28 6e 75 6c 6c 3f nn). (if (null?
2740: 20 28 75 64 61 74 2d 61 76 61 69 6c 2d 63 6d 62 (udat-avail-cmb
2750: 6f 78 65 73 20 75 63 6f 6e 6e 29 29 0a 20 20 20 oxes uconn)).
2760: 20 20 20 28 6c 65 74 20 28 28 63 6f 6f 6b 69 65 (let ((cookie
2770: 20 28 6d 61 6b 65 2d 63 6f 6f 6b 69 65 20 75 63 (make-cookie uc
2780: 6f 6e 6e 29 29 0a 09 20 20 20 20 28 6d 62 6f 78 onn)).. (mbox
2790: 20 20 20 28 6d 61 6b 65 2d 6d 61 69 6c 62 6f 78 (make-mailbox
27a0: 29 29 29 0a 09 28 68 61 73 68 2d 74 61 62 6c 65 )))..(hash-table
27b0: 2d 73 65 74 21 20 28 75 64 61 74 2d 6d 62 6f 78 -set! (udat-mbox
27c0: 65 73 20 75 63 6f 6e 6e 29 20 63 6f 6f 6b 69 65 es uconn) cookie
27d0: 20 6d 62 6f 78 29 0a 09 60 28 2c 63 6f 6f 6b 69 mbox)..`(,cooki
27e0: 65 20 2e 20 2c 6d 62 6f 78 29 29 0a 20 20 20 20 e . ,mbox)).
27f0: 20 20 28 6c 65 74 20 28 28 63 6d 62 6f 78 20 28 (let ((cmbox (
2800: 63 61 72 20 28 75 64 61 74 2d 61 76 61 69 6c 2d car (udat-avail-
2810: 63 6d 62 6f 78 65 73 20 75 63 6f 6e 6e 29 29 29 cmboxes uconn)))
2820: 29 0a 09 28 75 64 61 74 2d 61 76 61 69 6c 2d 63 )..(udat-avail-c
2830: 6d 62 6f 78 65 73 2d 73 65 74 21 20 75 63 6f 6e mboxes-set! ucon
2840: 6e 20 28 63 64 72 20 28 75 64 61 74 2d 61 76 61 n (cdr (udat-ava
2850: 69 6c 2d 63 6d 62 6f 78 65 73 20 75 63 6f 6e 6e il-cmboxes uconn
2860: 29 29 29 0a 09 63 6d 62 6f 78 29 29 29 0a 0a 28 )))..cmbox)))..(
2870: 64 65 66 69 6e 65 20 28 70 75 74 2d 63 6d 62 6f define (put-cmbo
2880: 78 20 75 63 6f 6e 6e 20 63 6d 62 6f 78 29 0a 20 x uconn cmbox).
2890: 20 28 75 64 61 74 2d 61 76 61 69 6c 2d 63 6d 62 (udat-avail-cmb
28a0: 6f 78 65 73 2d 73 65 74 21 20 75 63 6f 6e 6e 20 oxes-set! uconn
28b0: 28 63 6f 6e 73 20 63 6d 62 6f 78 20 28 75 64 61 (cons cmbox (uda
28c0: 74 2d 61 76 61 69 6c 2d 63 6d 62 6f 78 65 73 20 t-avail-cmboxes
28d0: 75 63 6f 6e 6e 29 29 29 29 0a 0a 28 64 65 66 69 uconn))))..(defi
28e0: 6e 65 20 28 70 70 2d 75 63 6f 6e 6e 20 75 63 6f ne (pp-uconn uco
28f0: 6e 6e 29 0a 20 20 28 70 70 20 28 75 64 61 74 2d nn). (pp (udat-
2900: 3e 61 6c 69 73 74 20 75 63 6f 6e 6e 29 29 29 0a >alist uconn))).
2910: 0a 20 20 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d . .;;==========
2920: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
2930: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
2940: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
2950: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a 3b 3b 20 ============.;;
2960: 6e 65 74 77 6f 72 6b 20 75 74 69 6c 69 74 69 65 network utilitie
2970: 73 0a 3b 3b 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d s.;;============
2980: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
2990: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
29a0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================
29b0: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 0a 0a 3b 3b 20 4e ==========..;; N
29c0: 4f 54 45 3a 20 4c 6f 6f 6b 20 61 74 20 61 64 64 OTE: Look at add
29d0: 72 65 73 73 2d 69 6e 66 6f 20 65 67 67 20 61 73 ress-info egg as
29e0: 20 61 6c 74 65 72 6e 61 74 69 76 65 20 74 6f 20 alternative to
29f0: 73 6f 6d 65 20 6f 66 20 74 68 69 73 0a 0a 28 64 some of this..(d
2a00: 65 66 69 6e 65 20 28 72 61 74 65 2d 69 70 20 69 efine (rate-ip i
2a10: 70 61 64 64 72 29 0a 20 20 28 72 65 67 65 78 2d paddr). (regex-
2a20: 63 61 73 65 20 69 70 61 64 64 72 0a 20 20 20 20 case ipaddr.
2a30: 28 20 22 5e 31 32 37 5c 5c 2e 2e 2a 22 20 5f 20 ( "^127\\..*" _
2a40: 30 20 29 0a 20 20 20 20 28 20 22 5e 28 31 30 5c 0 ). ( "^(10\
2a50: 5c 2e 30 7c 31 39 32 5c 5c 2e 31 36 38 29 5c 5c \.0|192\\.168)\\
2a60: 2e 2e 2a 22 20 5f 20 31 20 29 0a 20 20 20 20 28 ..*" _ 1 ). (
2a70: 20 65 6c 73 65 20 32 20 29 20 29 29 0a 0a 3b 3b else 2 ) ))..;;
2a80: 20 43 68 61 6e 67 65 20 74 68 69 73 20 74 6f 20 Change this to
2a90: 62 69 61 73 20 66 6f 72 20 61 64 64 72 65 73 73 bias for address
2aa0: 65 73 20 77 69 74 68 20 61 20 72 65 61 73 6f 6e es with a reason
2ab0: 61 62 6c 65 20 62 72 6f 61 64 63 61 73 74 20 76 able broadcast v
2ac0: 61 6c 75 65 3f 0a 3b 3b 0a 28 64 65 66 69 6e 65 alue?.;;.(define
2ad0: 20 28 69 70 2d 70 72 65 66 2d 6c 65 73 73 3f 20 (ip-pref-less?
2ae0: 61 20 62 29 0a 20 20 28 3e 20 28 72 61 74 65 2d a b). (> (rate-
2af0: 69 70 20 61 29 20 28 72 61 74 65 2d 69 70 20 62 ip a) (rate-ip b
2b00: 29 29 29 0a 0a 28 64 65 66 69 6e 65 20 28 67 65 )))..(define (ge
2b10: 74 2d 6d 79 2d 62 65 73 74 2d 61 64 64 72 65 73 t-my-best-addres
2b20: 73 29 0a 20 20 28 6c 65 74 20 28 28 61 6c 6c 2d s). (let ((all-
2b30: 6d 79 2d 61 64 64 72 65 73 73 65 73 20 28 67 65 my-addresses (ge
2b40: 74 2d 61 6c 6c 2d 69 70 73 29 29 29 0a 20 20 20 t-all-ips))).
2b50: 20 28 63 6f 6e 64 0a 20 20 20 20 20 28 28 6e 75 (cond. ((nu
2b60: 6c 6c 3f 20 61 6c 6c 2d 6d 79 2d 61 64 64 72 65 ll? all-my-addre
2b70: 73 73 65 73 29 0a 20 20 20 20 20 20 28 67 65 74 sses). (get
2b80: 2d 68 6f 73 74 2d 6e 61 6d 65 29 29 20 20 20 20 -host-name))
2b90: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
2ba0: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
2bb0: 20 20 20 20 20 20 3b 3b 20 6e 6f 20 69 6e 74 65 ;; no inte
2bc0: 72 66 61 63 65 73 3f 0a 20 20 20 20 20 28 28 65 rfaces?. ((e
2bd0: 71 3f 20 28 6c 65 6e 67 74 68 20 61 6c 6c 2d 6d q? (length all-m
2be0: 79 2d 61 64 64 72 65 73 73 65 73 29 20 31 29 0a y-addresses) 1).
2bf0: 20 20 20 20 20 20 28 63 61 72 20 61 6c 6c 2d 6d (car all-m
2c00: 79 2d 61 64 64 72 65 73 73 65 73 29 29 20 20 20 y-addresses))
2c10: 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20 20
2c20: 20 20 20 3b 3b 20 6f 6e 6c 79 20 6f 6e 65 20 74 ;; only one t
2c30: 6f 20 63 68 6f 6f 73 65 20 66 72 6f 6d 2c 20 6a o choose from, j
2c40: 75 73 74 20 67 6f 20 77 69 74 68 20 69 74 0a 20 ust go with it.
2c50: 20 20 20 20 28 65 6c 73 65 0a 20 20 20 20 20 20 (else.
2c60: 28 63 61 72 20 28 73 6f 72 74 20 61 6c 6c 2d 6d (car (sort all-m
2c70: 79 2d 61 64 64 72 65 73 73 65 73 20 69 70 2d 70 y-addresses ip-p
2c80: 72 65 66 2d 6c 65 73 73 3f 29 29 29 29 29 29 0a ref-less?)))))).
2c90: 0a 28 64 65 66 69 6e 65 20 28 67 65 74 2d 61 6c .(define (get-al
2ca0: 6c 2d 69 70 73 2d 73 6f 72 74 65 64 29 0a 20 20 l-ips-sorted).
2cb0: 28 73 6f 72 74 20 28 67 65 74 2d 61 6c 6c 2d 69 (sort (get-all-i
2cc0: 70 73 29 20 69 70 2d 70 72 65 66 2d 6c 65 73 73 ps) ip-pref-less
2cd0: 3f 29 29 0a 0a 28 64 65 66 69 6e 65 20 28 67 65 ?))..(define (ge
2ce0: 74 2d 61 6c 6c 2d 69 70 73 29 0a 20 20 28 6d 61 t-all-ips). (ma
2cf0: 70 20 61 64 64 72 65 73 73 2d 69 6e 66 6f 2d 68 p address-info-h
2d00: 6f 73 74 0a 20 20 20 20 20 20 20 28 66 69 6c 74 ost. (filt
2d10: 65 72 20 28 6c 61 6d 62 64 61 20 28 78 29 0a 09 er (lambda (x)..
2d20: 09 20 28 65 71 75 61 6c 3f 20 28 61 64 64 72 65 . (equal? (addre
2d30: 73 73 2d 69 6e 66 6f 2d 74 79 70 65 20 78 29 20 ss-info-type x)
2d40: 27 74 63 70 29 29 0a 09 20 20 20 20 20 20 20 28 'tcp)).. (
2d50: 61 64 64 72 65 73 73 2d 69 6e 66 6f 73 20 28 67 address-infos (g
2d60: 65 74 2d 68 6f 73 74 2d 6e 61 6d 65 29 29 29 29 et-host-name))))
2d70: 29 0a 0a 29 0a )..).