branch master updated: remote-worker: Check if the worker exists.

[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 9018417  remote-worker: Check if the worker exists.
9018417 is described below

commit 90184178348769b4ad24404dcc10aa067171ac28
Author: Mathieu Othacehe <othacehe@gnu.org>
AuthorDate: Tue Oct 5 07:44:41 2021 +0000

    remote-worker: Check if the worker exists.
    
    * src/cuirass/scripts/remote-server.scm (read-worker-exp): Check if the 
worker exists.
---
 src/cuirass/scripts/remote-server.scm | 15 ++++++++-------
 1 file changed, 8 insertions(+), 7 deletions(-)

diff --git a/src/cuirass/scripts/remote-server.scm 
b/src/cuirass/scripts/remote-server.scm
index 2ef775e..4fd11ee 100644
--- a/src/cuirass/scripts/remote-server.scm
+++ b/src/cuirass/scripts/remote-server.scm
@@ -244,7 +244,7 @@ be used to reply to the worker."
       (zmq-server-info (zmq-remote-address msg) (%log-port) (%publish-port))))
     (('worker-request-work name)
      (let ((worker (db-get-worker name)))
-       (when (%debug)
+       (when (and (%debug) worker)
          (log-message "~a (~a): request work."
                       (worker-address worker)
                       (worker-name worker)))
@@ -254,7 +254,7 @@ be used to reply to the worker."
                    (priority (assq-ref build #:priority))
                    (timeout (assq-ref build #:timeout))
                    (max-silent (assq-ref build #:max-silent)))
-               (when (%debug)
+               (when (and (%debug) worker)
                  (log-message "~a (~a): build ~a submitted."
                               (worker-address worker)
                               (worker-name worker)
@@ -267,7 +267,7 @@ be used to reply to the worker."
                                            #:timeout timeout
                                            #:max-silent max-silent)))
              (begin
-               (when (%debug)
+               (when (and (%debug) worker)
                  (log-message "~a (~a): no available build."
                               (worker-address worker)
                               (worker-name worker)))
@@ -278,10 +278,11 @@ be used to reply to the worker."
     (('build-started ('drv drv) ('worker name))
      (let ((log-file (log-path (%cache-directory) drv))
            (worker (db-get-worker name)))
-       (log-message "~a (~a): build started: '~a'."
-                    (worker-address worker)
-                    (worker-name worker)
-                    drv)
+       (when worker
+         (log-message "~a (~a): build started: '~a'."
+                      (worker-address worker)
+                      (worker-name worker)
+                      drv))
        (db-update-build-worker! drv name)
        (db-update-build-status! drv (build-status started)
                                 #:log-file log-file)))))