Index: db.scm ================================================================== --- db.scm +++ db.scm @@ -1168,11 +1168,11 @@ (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)) (send-message zmq-socket zdat) - (set! res (db:string->obj (receive-message zmq-socket zdat))) + (set! res (db:string->obj (receive-message* zmq-socket zdat))) (debug:print-info 11 "zmq-socket " (car params) " res=" res) res)) (define (cdb:set-verbosity zmq-socket val) (cdb:client-call zmq-socket 'set-verbosity #f val)) Index: server.scm ================================================================== --- server.scm +++ server.scm @@ -60,11 +60,11 @@ (loop))))))) ;; The heavy lifting ;; (let loop () - (let* ((rawmsg (receive-message zmq-socket)) + (let* ((rawmsg (receive-message* zmq-socket)) (params (db:string->obj rawmsg)) ;; (with-input-from-string rawmsg (lambda ()(deserialize)))) (res #f)) (debug:print-info 12 "server=> received params=" params) (set! res (cdb:cached-access params)) (debug:print-info 12 "server=> processed res=" res)