guix-commits
[Top][All Lists]
Advanced

[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

branch master updated: remote: Make sure new messages are created for ea


From: Mathieu Othacehe
Subject: branch master updated: remote: Make sure new messages are created for each send.
Date: Fri, 26 Feb 2021 06:07:39 -0500

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 44df41c  remote: Make sure new messages are created for each send.
44df41c is described below

commit 44df41ca7a79ae80cf4fcda5ca6ada3a74b60d07
Author: Mathieu Othacehe <othacehe@gnu.org>
AuthorDate: Fri Feb 26 12:06:46 2021 +0100

    remote: Make sure new messages are created for each send.
    
    * src/cuirass/remote-server.scm (zmq-start-proxy): Make sure new messages 
are
    created for each send.
---
 src/cuirass/remote-server.scm | 12 +++++-------
 1 file changed, 5 insertions(+), 7 deletions(-)

diff --git a/src/cuirass/remote-server.scm b/src/cuirass/remote-server.scm
index 005fa59..4d9db15 100644
--- a/src/cuirass/remote-server.scm
+++ b/src/cuirass/remote-server.scm
@@ -374,9 +374,7 @@ 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-msg (zmq-msg-init
-                                 (zmq-message-content worker)))
-                    (fetch-msg (zmq-msg-init
+             (let* ((fetch-msg (zmq-msg-init
                                 (zmq-message-content rest)))
                     (command (bv->string
                               (zmq-message-content rest)))
@@ -384,10 +382,10 @@ frontend to the workers connected through the TCP 
backend."
                     (lambda (message)
                       (zmq-message-send-parts
                        build-socket
-                       (cons worker-msg
-                             (map zmq-msg-init
-                                  (list (zmq-empty-delimiter)
-                                        (string->bv message))))))))
+                       (map zmq-msg-init
+                            (list (zmq-message-content worker)
+                                  (zmq-empty-delimiter)
+                                  (string->bv message)))))))
                (if (need-fetching? command)
                    (zmq-message-send fetch-socket fetch-msg)
                    (read-worker-exp rest



reply via email to

[Prev in Thread] Current Thread [Next in Thread]