Megatest

Diff
Login

Differences From Artifact [d2de8d2ff6]:

To Artifact [ffb8788cf7]:


219
220
221
222
223
224
225
226
227


228
229
230
231
232
233
234
219
220
221
222
223
224
225


226
227
228
229
230
231
232
233
234







-
-
+
+







(define (http-transport:inc-requests-and-prep-to-close-all-connections)
  (mutex-lock! *http-mutex*)
  (set! *http-requests-in-progress* (+ 1 *http-requests-in-progress*)))

;; Send "cmd" with json payload "params" to serverdat and receive result
;;
(define (http-transport:client-api-send-receive run-id serverdat cmd params #!key (numretries 3))
  (let* ((fullurl    (if (list? serverdat)
			 (list-ref serverdat 4) ;; (cadddr serverdat) ;; this is the uri for /api
  (let* ((fullurl    (if (vector? serverdat)
			 (http-transport:server-dat-get-api-req serverdat)
			 (begin
			   (debug:print 0 "FATAL ERROR: http-transport:client-api-send-receive called with no server info")
			   (exit 1))))
	 (res        #f))
    (handle-exceptions
     exn
     (if (> numretries 0)
275
276
277
278
279
280
281
282
283


284
285
286
287
288
289
290
291
292
293
294
295
296
297

298
299
300
301
302
303
304
305

306
307
308

309
310
311
312
313
314
315
275
276
277
278
279
280
281


282
283



284
285
286
287
288
289
290
291
292
293

294
295
296
297
298
299
300
301

302



303
304
305
306
307
308
309
310







-
-
+
+
-
-
-










-
+







-
+
-
-
-
+







	 (debug:print-info 11 "got res=" res)
	 res)))))

;; careful closing of connections stored in *runremote*
;;
(define (http-transport:close-connections run-id)
  (let* ((server-dat (hash-table-ref/default *runremote* run-id #f)))
    (if (and (list? server-dat)
	     (>= (length server-dat) 5))
    (if (vector? server-dat)
	(let ((api-dat (http-transport:server-dat-get-api-uri server-dat)))
	(let ((ctrl-dat (list-ref server-dat 2))
	      (api-dat  (list-ref server-dat 3)))
	  (close-connection! ctrl-dat)
	  (close-connection! api-dat)
	  #t)
	#f)))


(define (make-http-transport:server-dat)(make-vector 5))
(define (http-transport:server-dat-get-iface         vec)    (vector-ref  vec 0))
(define (http-transport:server-dat-get-port          vec)    (vector-ref  vec 1))
(define (http-transport:server-dat-get-api-uri       vec)    (vector-ref  vec 2))
(define (http-transport:server-dat-get-api-url       vec)    (vector-ref  vec 3))
(define (http-transport:server-dat-get-api-request   vec)    (vector-ref  vec 4))
(define (http-transport:server-dat-get-api-req       vec)    (vector-ref  vec 4))

;;
;; connect
;;
(define (http-transport:client-connect iface port)
  (let* ((api-url      (conc "http://" iface ":" port "/api"))
	 (api-uri      (uri-reference (conc "http://" iface ":" port "/api")))
	 (uri-api-dat  (make-request method: 'POST uri: api-uri))
	 (api-req      (make-request method: 'POST uri: api-uri))
	 ;; (uri-ctrl-dat (make-request method: 'POST uri: (uri-reference (conc "http://" iface ":" port "/ctrl"))))
	 (uri-ctrl-dat #f) ;; not used anymore
	 (server-dat   (vector iface port uri-ctrl-dat uri-api-dat api-url)))
	 (server-dat   (vector iface port api-uri api-url api-req)))
    server-dat))

;; run http-transport:keep-running in a parallel thread to monitor that the db is being 
;; used and to shutdown after sometime if it is not.
;;
(define (http-transport:keep-running server-id)
  ;; if none running or if > 20 seconds since