Megatest

Check-in [59f2a303f7]
Login
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: 59f2a303f7681f69c32dd0a7d24a0c2dbc4bbd29
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

191

192
193
194
195
196
197
198
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 
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
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
315

316
317
318
319
320
321
322
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 *last-db-access*)
        (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))