Artifact d187681c700edb8d5c4cf086eb5751a80d99da7e:
- File fs-transport.scm — part of check-in [5deab59f4e] at 2013-01-27 16:45:03 on branch multi-transport — Default of direct fs access done (user: matt size: 1443) [more...]
- File oldsrc/fs-transport.scm — part of check-in [cb5f28cabe] at 2014-02-26 23:42:45 on branch v1.60 — Moved ping of server into a separate process (user: matt size: 1443)
0000: 0a 3b 3b 20 43 6f 70 79 72 69 67 68 74 20 32 30 .;; Copyright 20 0010: 30 36 2d 32 30 31 32 2c 20 4d 61 74 74 68 65 77 06-2012, Matthew 0020: 20 57 65 6c 6c 61 6e 64 2e 0a 3b 3b 20 0a 3b 3b Welland..;; .;; 0030: 20 20 54 68 69 73 20 70 72 6f 67 72 61 6d 20 69 This program i 0040: 73 20 6d 61 64 65 20 61 76 61 69 6c 61 62 6c 65 s made available 0050: 20 75 6e 64 65 72 20 74 68 65 20 47 4e 55 20 47 under the GNU G 0060: 50 4c 20 76 65 72 73 69 6f 6e 20 32 2e 30 20 6f PL version 2.0 o 0070: 72 0a 3b 3b 20 20 67 72 65 61 74 65 72 2e 20 53 r.;; greater. S 0080: 65 65 20 74 68 65 20 61 63 63 6f 6d 70 61 6e 79 ee the accompany 0090: 69 6e 67 20 66 69 6c 65 20 43 4f 50 59 49 4e 47 ing file COPYING 00a0: 20 66 6f 72 20 64 65 74 61 69 6c 73 2e 0a 3b 3b for details..;; 00b0: 20 0a 3b 3b 20 20 54 68 69 73 20 70 72 6f 67 72 .;; This progr 00c0: 61 6d 20 69 73 20 64 69 73 74 72 69 62 75 74 65 am is distribute 00d0: 64 20 57 49 54 48 4f 55 54 20 41 4e 59 20 57 41 d WITHOUT ANY WA 00e0: 52 52 41 4e 54 59 3b 20 77 69 74 68 6f 75 74 20 RRANTY; without 00f0: 65 76 65 6e 20 74 68 65 0a 3b 3b 20 20 69 6d 70 even the.;; imp 0100: 6c 69 65 64 20 77 61 72 72 61 6e 74 79 20 6f 66 lied warranty of 0110: 20 4d 45 52 43 48 41 4e 54 41 42 49 4c 49 54 59 MERCHANTABILITY 0120: 20 6f 72 20 46 49 54 4e 45 53 53 20 46 4f 52 20 or FITNESS FOR 0130: 41 20 50 41 52 54 49 43 55 4c 41 52 0a 3b 3b 20 A PARTICULAR.;; 0140: 20 50 55 52 50 4f 53 45 2e 0a 0a 28 72 65 71 75 PURPOSE...(requ 0150: 69 72 65 2d 65 78 74 65 6e 73 69 6f 6e 20 28 73 ire-extension (s 0160: 72 66 69 20 31 38 29 20 65 78 74 72 61 73 20 74 rfi 18) extras t 0170: 63 70 20 73 31 31 6e 29 0a 0a 28 75 73 65 20 73 cp s11n)..(use s 0180: 71 6c 69 74 65 33 20 73 72 66 69 2d 31 20 70 6f qlite3 srfi-1 po 0190: 73 69 78 20 72 65 67 65 78 20 72 65 67 65 78 2d six regex regex- 01a0: 63 61 73 65 20 73 72 66 69 2d 36 39 20 68 6f 73 case srfi-69 hos 01b0: 74 69 6e 66 6f 20 6d 64 35 20 6d 65 73 73 61 67 tinfo md5 messag 01c0: 65 2d 64 69 67 65 73 74 29 0a 28 69 6d 70 6f 72 e-digest).(impor 01d0: 74 20 28 70 72 65 66 69 78 20 73 71 6c 69 74 65 t (prefix sqlite 01e0: 33 20 73 71 6c 69 74 65 33 3a 29 29 0a 0a 28 75 3 sqlite3:))..(u 01f0: 73 65 20 73 70 69 66 66 79 20 75 72 69 2d 63 6f se spiffy uri-co 0200: 6d 6d 6f 6e 20 69 6e 74 61 72 77 65 62 20 68 74 mmon intarweb ht 0210: 74 70 2d 63 6c 69 65 6e 74 20 73 70 69 66 66 79 tp-client spiffy 0220: 2d 72 65 71 75 65 73 74 2d 76 61 72 73 29 0a 0a -request-vars).. 0230: 28 74 63 70 2d 62 75 66 66 65 72 2d 73 69 7a 65 (tcp-buffer-size 0240: 20 32 30 34 38 29 0a 0a 28 64 65 63 6c 61 72 65 2048)..(declare 0250: 20 28 75 6e 69 74 20 66 73 2d 74 72 61 6e 73 70 (unit fs-transp 0260: 6f 72 74 29 29 0a 0a 28 64 65 63 6c 61 72 65 20 ort))..(declare 0270: 28 75 73 65 73 20 63 6f 6d 6d 6f 6e 29 29 0a 28 (uses common)).( 0280: 64 65 63 6c 61 72 65 20 28 75 73 65 73 20 64 62 declare (uses db 0290: 29 29 0a 28 64 65 63 6c 61 72 65 20 28 75 73 65 )).(declare (use 02a0: 73 20 74 65 73 74 73 29 29 0a 28 64 65 63 6c 61 s tests)).(decla 02b0: 72 65 20 28 75 73 65 73 20 74 61 73 6b 73 29 29 re (uses tasks)) 02c0: 20 3b 3b 20 74 61 73 6b 73 20 61 72 65 20 77 68 ;; tasks are wh 02d0: 65 72 65 20 73 74 75 66 66 20 69 73 20 6d 61 69 ere stuff is mai 02e0: 6e 74 61 69 6e 65 64 20 61 62 6f 75 74 20 77 68 ntained about wh 02f0: 61 74 20 69 73 20 72 75 6e 6e 69 6e 67 2e 0a 0a at is running... 0300: 28 69 6e 63 6c 75 64 65 20 22 63 6f 6d 6d 6f 6e (include "common 0310: 5f 72 65 63 6f 72 64 73 2e 73 63 6d 22 29 0a 28 _records.scm").( 0320: 69 6e 63 6c 75 64 65 20 22 64 62 5f 72 65 63 6f include "db_reco 0330: 72 64 73 2e 73 63 6d 22 29 0a 0a 0a 3b 3b 3d 3d rds.scm")...;;== 0340: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================ 0350: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================ 0360: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================ 0370: 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d 3d ================ 0380: 3d 3d 3d 3d 0a 3b 3b 20 46 20 53 20 20 20 54 20 ====.;; F S T 0390: 52 20 41 20 4e 20 53 20 50 20 4f 20 52 20 54 20 R A N S P O R T 03a0: 20 20 53 20 45 20 52 20 56 20 45 20 52 0a 3b 3b S E R V E R.;; 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 3d 3d 3d 3d 0a 0a 3b 3b 20 54 68 65 72 65 ======..;; There 0400: 20 69 73 20 6e 6f 20 22 73 65 72 76 65 72 22 20 is no "server" 0410: 70 65 72 20 73 65 20 62 75 74 20 61 20 63 6f 6e per se but a con 0420: 76 69 65 6e 63 65 20 72 6f 75 74 69 6e 65 20 74 vience routine t 0430: 6f 20 6d 61 6b 65 20 69 74 20 6e 6f 6e 0a 3b 3b o make it non.;; 0440: 20 6e 65 63 65 73 73 61 72 79 20 74 6f 20 62 65 necessary to be 0450: 20 72 65 6f 70 65 6e 69 6e 67 20 74 68 65 20 64 reopening the d 0460: 62 20 6f 76 65 72 20 61 6e 64 20 6f 76 65 72 20 b over and over 0470: 61 67 61 69 6e 2e 0a 3b 3b 0a 0a 28 64 65 66 69 again..;;..(defi 0480: 6e 65 20 28 66 73 3a 70 72 6f 63 65 73 73 2d 71 ne (fs:process-q 0490: 75 65 75 65 2d 69 74 65 6d 20 70 61 63 6b 65 74 ueue-item packet 04a0: 29 0a 20 20 28 69 66 20 28 6e 6f 74 20 2a 6d 65 ). (if (not *me 04b0: 67 61 74 65 73 74 2d 64 62 2a 29 20 3b 3b 20 77 gatest-db*) ;; w 04c0: 65 20 77 69 6c 6c 20 72 65 71 75 69 72 65 20 74 e will require t 04d0: 68 61 74 20 28 73 65 74 75 70 2d 66 6f 72 2d 72 hat (setup-for-r 04e0: 75 6e 29 20 68 61 73 20 61 6c 72 65 61 64 79 20 un) has already 04f0: 62 65 65 6e 20 63 61 6c 6c 65 64 0a 20 20 20 20 been called. 0500: 20 20 28 73 65 74 21 20 2a 6d 65 67 61 74 65 73 (set! *megates 0510: 74 2d 64 62 2a 20 28 6f 70 65 6e 2d 64 62 29 29 t-db* (open-db)) 0520: 29 0a 20 20 28 64 65 62 75 67 3a 70 72 69 6e 74 ). (debug:print 0530: 2d 69 6e 66 6f 20 31 31 20 22 66 73 3a 70 72 6f -info 11 "fs:pro 0540: 63 65 73 73 2d 71 75 65 75 65 2d 69 74 65 6d 20 cess-queue-item 0550: 63 61 6c 6c 65 64 20 77 69 74 68 20 70 61 63 6b called with pack 0560: 65 74 3d 22 20 70 61 63 6b 65 74 29 0a 20 20 28 et=" packet). ( 0570: 64 62 3a 70 72 6f 63 65 73 73 2d 71 75 65 75 65 db:process-queue 0580: 2d 69 74 65 6d 20 2a 6d 65 67 61 74 65 73 74 2d -item *megatest- 0590: 64 62 2a 20 70 61 63 6b 65 74 29 29 0a 20 20 20 db* packet)). 05a0: 20 20 20