branch master updated: remote: Use message API.

[Mathieu Othacehe]

This is an automated email from the git hooks/post-receive script.

mothacehe pushed a commit to branch master
in repository guix-cuirass.

The following commit(s) were added to refs/heads/master by this push:
     new fa191d8  remote: Use message API.
fa191d8 is described below

commit fa191d877ea2f06792f3ff786799c3735c3f5bcb
Author: Mathieu Othacehe <othacehe@gnu.org>
AuthorDate: Fri Feb 26 11:39:48 2021 +0100

    remote: Use message API.
    
    * src/cuirass/remote-server.scm (zmq-start-proxy): Use the message API.
---
 src/cuirass/remote-server.scm | 21 ++++++++++++---------
 1 file changed, 12 insertions(+), 9 deletions(-)

diff --git a/src/cuirass/remote-server.scm b/src/cuirass/remote-server.scm
index b82a292..005fa59 100644
--- a/src/cuirass/remote-server.scm
+++ b/src/cuirass/remote-server.scm
@@ -374,19 +374,22 @@ frontend to the workers connected through the TCP 
backend."
         (when (zmq-socket-ready? items build-socket)
           (match (zmq-message-receive* build-socket)
             ((worker empty rest)
-             (let* ((worker-name (bytevector-copy
-                                  (zmq-message-content worker)))
-                    (rest-bv (bytevector-copy
+             (let* ((worker-msg (zmq-msg-init
+                                 (zmq-message-content worker)))
+                    (fetch-msg (zmq-msg-init
+                                (zmq-message-content rest)))
+                    (command (bv->string
                               (zmq-message-content rest)))
                     (reply-worker
                     (lambda (message)
-                      (zmq-send-msg-parts-bytevector
+                      (zmq-message-send-parts
                        build-socket
-                       (list worker-name
-                             (zmq-empty-delimiter)
-                             (string->bv message))))))
-               (if (need-fetching? (bv->string rest-bv))
-                   (zmq-send-bytevector fetch-socket rest-bv)
+                       (cons worker-msg
+                             (map zmq-msg-init
+                                  (list (zmq-empty-delimiter)
+                                        (string->bv message))))))))
+               (if (need-fetching? command)
+                   (zmq-message-send fetch-socket fetch-msg)
                    (read-worker-exp rest
                                     #:reply-worker reply-worker))))))
         (db-remove-unresponsive-workers (%worker-timeout))