75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
|
(debug:print 0 *default-log-port* "query rest needed. blocking for 0.1 second. cmd="cmd", run id="rid", params="params)
(thread-sleep! 0.1) ;; force a rest of a half second
(set! *rmt-query-last-rest-time* now)
(set! *rmt-query-last-call-time* now))
(else ;; sufficient rests have occurred, just record the last query time
(set! *rmt-query-last-call-time* now)))))
(define *alldat* (rmtmod:create-alldat *toppath*))
(define (rmt:send-receive cmd rid params #!key (attemptnum 1)(area-dat #f))
(if (equal? (configf:lookup *configdat* "setup" "newapi") "yes")
(rmtmod:send-receive *alldat* cmd rid params)
|
|
>
>
>
|
|
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
|
(debug:print 0 *default-log-port* "query rest needed. blocking for 0.1 second. cmd="cmd", run id="rid", params="params)
(thread-sleep! 0.1) ;; force a rest of a half second
(set! *rmt-query-last-rest-time* now)
(set! *rmt-query-last-call-time* now))
(else ;; sufficient rests have occurred, just record the last query time
(set! *rmt-query-last-call-time* now)))))
(define *alldat* #f)
(define (rmt:send-receive cmd rid params #!key (attemptnum 1)(area-dat #f))
(if (equal? (configf:lookup *configdat* "setup" "newapi") "yes")
(begin
(if (not *alldat*) ;; add wait here if *toppath* is not set
(set! *alldat* (rmtmod:create-alldat *toppath*)))
(rmtmod:send-receive *alldat* cmd rid params))
(rmt:send-receive-orig cmd rid params attemptnum: 1 area-dat: #f)))
;; RA => e.g. usage (rmt:send-receive 'get-var #f (list varname))
;;
(define (rmt:send-receive-orig cmd rid params #!key (attemptnum 1)(area-dat #f)) ;; start attemptnum at 1 so the modulo below works as expected
#;(common:telemetry-log (conc "rmt:"(->string cmd))
|