1181
1182
1183
1184
1185
1186
1187
1188
1189
1190
1191
1192
1193
1194
1195
1196
|
1181
1182
1183
1184
1185
1186
1187
1188
1189
1190
1191
1192
1193
1194
1195
1196
1197
1198
|
+
+
|
res))
;; params = 'target cached remparams
(define (cdb:client-call zmq-socket . params)
(debug:print-info 11 "cdb:client-call zmq-socket=" zmq-socket " params=" params)
(let ((zdat (db:obj->string params)) ;; (with-output-to-string (lambda ()(serialize params))))
(res #f))
;; (signal-mask! signal/int)
(set! *received-response* #f)
(send-message zmq-socket zdat)
;; (signal-unmask! signal/int)
(set! res (db:string->obj (if *client-non-blocking-mode*
(receive-message* zmq-socket)
(receive-message zmq-socket))))
(set! *received-response* #t)
(debug:print-info 11 "zmq-socket " (car params) " res=" res)
res))
|