guix-commits
[Top][All Lists]
Advanced

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

[no subject]


From: Ludovic Courtès
Date: Sat, 15 Jul 2023 11:37:29 -0400 (EDT)

branch: master
commit 0dbd460cf1b40f6450e4b4da93ec1a719ebaafa8
Author: Ludovic Courtès <ludo@gnu.org>
AuthorDate: Sat Jul 15 15:48:41 2023 +0200

    remote-worker: Sleep only after a 'no-build response.
    
    * src/cuirass/scripts/remote-worker.scm (run-command): Move 'no-build
    clause to...
    (start-worker): ... here.  Sleep only after 'no-build'.
---
 src/cuirass/scripts/remote-worker.scm | 11 +++++------
 1 file changed, 5 insertions(+), 6 deletions(-)

diff --git a/src/cuirass/scripts/remote-worker.scm 
b/src/cuirass/scripts/remote-worker.scm
index 70445ae..cbd991c 100644
--- a/src/cuirass/scripts/remote-worker.scm
+++ b/src/cuirass/scripts/remote-worker.scm
@@ -268,11 +268,7 @@ command.  REPLY is a procedure that can be used to reply 
to this server."
                 #:reply reply
                 #:worker worker
                 #:timeout timeout
-                #:max-silent max-silent))
-    (('no-build)
-     (log-info (G_ "~a: no available build.")
-               (worker-name worker))
-     #t)))
+                #:max-silent max-silent))))
 
 (define (spawn-worker-ping worker server)
   "Spawn a thread that periodically pings SERVER."
@@ -378,6 +374,10 @@ and executing them.  The worker can reply on the same 
socket."
                    ((? unspecified?)              ;server reconnect
                     (log-info (G_ "~a: received a bootstrap message.")
                               (worker-name wrk)))
+                   (('no-build)
+                    (log-info (G_ "~a: no available build.")
+                              (worker-name worker))
+                    (sleep (%request-period)))
                    (command
                     (log-debug (G_ "~a: received command: ~s")
                                (worker-name wrk) command)
@@ -385,7 +385,6 @@ and executing them.  The worker can reply on the same 
socket."
                                  #:reply (reply socket)
                                  #:worker worker)))))
 
-           (sleep (%request-period))
            (loop)))))))
 
 (define (worker-management-thunk channel systems)



reply via email to

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