Overview
| Comment: | some nmsg stuff and typo fix in manual |
|---|---|
| Downloads: | Tarball | ZIP archive | SQL archive |
| Timelines: | family | ancestors | descendants | both | trunk |
| Files: | files | file ages | folders |
| SHA1: |
59f2a303f7681f69c32dd0a7d24a0c2d |
| User & Date: | matt on 2015-09-28 22:01:48 |
| Other Links: | manifest | tags |
Context
|
2016-06-21
| ||
| 04:12 | Merged v1.61 into trunk check-in: 6f4408fd20 user: matt tags: trunk | |
|
2015-09-28
| ||
| 22:01 | some nmsg stuff and typo fix in manual check-in: 59f2a303f7 user: matt tags: trunk | |
|
2015-09-21
| ||
| 21:06 | reference.txt check-in: 892fac9e25 user: matt tags: trunk | |
Changes
Modified docs/manual/reference.txt from [88bde1cc13] to [e5763f44c8].
| ︙ | ︙ | |||
184 185 186 187 188 189 190 | .Testconfig for Test C ---------------------- [requirements] waiton A B [itemmap] A (\d+)/aa aa/\1 | > | | 184 185 186 187 188 189 190 191 192 193 194 195 196 197 198 199 | .Testconfig for Test C ---------------------- [requirements] waiton A B [itemmap] A (\d+)/aa aa/\1 B (\d+)/bb -------------------- .Testconfig for Test D ---------------------- [requirements] waiton C itemmap (\d+)/res \1/aa ---------------------- |
| ︙ | ︙ |
Modified nmsg-transport.scm from [81ad0e0130] to [e7860c12f1].
| ︙ | ︙ | |||
41 42 43 44 45 46 47 48 49 50 51 52 53 54 |
(http-transport:server-dat-get-port vec))
(conc "http://"
(http-transport:server-dat-get-iface vec)
":"
(http-transport:server-dat-get-port vec))
#f))
;; Transition to pub --> sub with pull <-- push
;;
;; 1. client sends request to server via push to the pull port
;; 2. server puts request in queue or processes immediately as appropriate
;; 3. server puts responses from completed requests into pub port
;;
;; TODO
| > > > > > > > | 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 |
(http-transport:server-dat-get-port vec))
(conc "http://"
(http-transport:server-dat-get-iface vec)
":"
(http-transport:server-dat-get-port vec))
#f))
(define (http-transport:server-dat-update-last-access vec)
(if (vector? vec)
(vector-set! vec 5 (current-seconds))
(begin
(print-call-chain (current-error-port))
(debug:print 0 "ERROR: call to http-transport:server-dat-update-last-access with non-vector!!"))))
;; Transition to pub --> sub with pull <-- push
;;
;; 1. client sends request to server via push to the pull port
;; 2. server puts request in queue or processes immediately as appropriate
;; 3. server puts responses from completed requests into pub port
;;
;; TODO
|
| ︙ | ︙ | |||
308 309 310 311 312 313 314 |
;; NB// sync currently does NOT return queue-length
(let () ;; (queue-len (cdb:client-call server-info 'sync #t 1)))
;; (print "Server running, count is " count)
(if (< count 1) ;; 3x3 = 9 secs aprox
(loop (+ count 1)))
(mutex-lock! *heartbeat-mutex*)
| | | 315 316 317 318 319 320 321 322 323 324 325 326 327 328 329 |
;; NB// sync currently does NOT return queue-length
(let () ;; (queue-len (cdb:client-call server-info 'sync #t 1)))
;; (print "Server running, count is " count)
(if (< count 1) ;; 3x3 = 9 secs aprox
(loop (+ count 1)))
(mutex-lock! *heartbeat-mutex*)
(set! last-access (http-transport:server-dat-get-last-access server-info)) ;; *last-db-access*)
(mutex-unlock! *heartbeat-mutex*)
(db:sync-touched *inmemdb* run-id force-sync: #t)
(if (and *server-run*
(> (+ last-access server-timeout)
(current-seconds)))
(begin
(debug:print-info 0 "Server continuing, seconds since last db access: " (- (current-seconds) last-access))
|
| ︙ | ︙ |