[no subject]

[Ludovic Courtès]

branch: master
commit 343c92bbad793519939e2efd6ccb75ec22ccca0c
Author: Ludovic Courtès <ludo@gnu.org>
AuthorDate: Tue Oct 10 12:15:45 2023 +0200

    remote-server: Rename ‘zmq-start-proxy’.
    
    * src/cuirass/scripts/remote-server.scm (zmq-start-proxy): Rename to…
    (serve-build-requests): … this.  Update docstring.
    (cuirass-remote-server): Adjust accordingly.
---
 src/cuirass/scripts/remote-server.scm | 11 +++++++----
 1 file changed, 7 insertions(+), 4 deletions(-)

diff --git a/src/cuirass/scripts/remote-server.scm 
b/src/cuirass/scripts/remote-server.scm
index 3368696..40f4b96 100644
--- a/src/cuirass/scripts/remote-server.scm
+++ b/src/cuirass/scripts/remote-server.scm
@@ -454,10 +454,13 @@ requested received on its channel."
 all network interfaces."
   (string-append "tcp://*:" (number->string backend-port)))
 
-(define (zmq-start-proxy backend-port fetch-worker)
+(define (serve-build-requests backend-port fetch-worker)
   "Open a zmq socket on BACKEND-PORT and listen for messages coming from
-'cuirass remote-worker' messages.  When a message denoting a successful build
-is received, pass it on to FETCH-WORKER to download the build's output(s)."
+'cuirass remote-worker' processes, and reply to 'worker-request-work'
+messages: this is a \"work stealing\" strategy.
+
+When a message denoting a successful build is received, pass it on to
+FETCH-WORKER to download the build's output(s)."
   (let ((build-socket (zmq-create-socket %zmq-context ZMQ_ROUTER)))
 
     ;; Send bootstrap messages on worker connection to wake up the workers
@@ -640,7 +643,7 @@ exiting."
              (let ((fetch-worker (spawn-fetch-worker)))
                (catch 'zmq-error
                  (lambda ()
-                   (zmq-start-proxy backend-port fetch-worker))
+                   (serve-build-requests backend-port fetch-worker))
                  (lambda (key errno message . _)
                    (log-error (G_ "failed to start worker/database proxy: ~a")
                               message)