branch wip-offload updated: tmp9

[Mathieu Othacehe]

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

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

The following commit(s) were added to refs/heads/wip-offload by this push:
     new 2c1b281  tmp9
2c1b281 is described below

commit 2c1b281f5d47104c63b404bd32da060d71721808
Author: Mathieu Othacehe <othacehe@gnu.org>
AuthorDate: Mon Dec 14 11:48:04 2020 +0100

    tmp9
---
 src/cuirass/remote-server.scm | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git a/src/cuirass/remote-server.scm b/src/cuirass/remote-server.scm
index 849b554..47ac15e 100644
--- a/src/cuirass/remote-server.scm
+++ b/src/cuirass/remote-server.scm
@@ -254,7 +254,7 @@ be used to reply to the worker."
 
 (define (zmq-fetch-worker-socket)
   "Return a socket used to communicate with the fetch workers."
-  (let ((socket (zmq-create-socket %zmq-context ZMQ_DEALER))
+  (let ((socket (zmq-create-socket %zmq-context ZMQ_REP))
         (endpoint (zmq-fetch-workers-endpoint)))
     (zmq-connect socket endpoint)
     socket))
@@ -406,7 +406,7 @@ socket."
      (set-thread-name name)
      (let ((socket (zmq-fetch-worker-socket)))
        (let loop ()
-         (match (zmq-get-msg-parts-bytevector socket '())
+         (match (zmq-get-msg-parts-bytevector socket)
            ((client empty rest)
             (let ((message (bv->string rest)))
               (run-fetch (bv->string rest)
@@ -479,15 +479,15 @@ frontend to the workers connected through the TCP 
backend."
                (read-worker-exp (bv->string rest)
                                 #:reply-worker reply-worker)))
             ((worker empty client empty rest)
-             (let ((message (list client (zmq-empty-delimiter) rest)))
-               (pk (bv->string rest))
+             (let ((message (list empty client (zmq-empty-delimiter) rest)))
                (if (need-fetching? (bv->string rest))
                    (zmq-send-msg-parts-bytevector fetch-socket message)
                    (zmq-send-msg-parts-bytevector client-socket message))))))
         ;; fetch-worker -> remote-server.
         (when (zmq-socket-ready? items fetch-socket)
-          (let ((msg (zmq-get-msg-parts-bytevector fetch-socket)))
-            (zmq-send-msg-parts-bytevector client-socket msg)))
+          (match (zmq-get-msg-parts-bytevector fetch-socket)
+            ((empty . rest)
+             (zmq-send-msg-parts-bytevector client-socket rest))))
 
         (remove-unresponsive-workers!)
         (loop)))))