[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
[no subject]
|
From: |
Ludovic Courtès |
|
Date: |
Thu, 22 Jun 2023 15:56:49 -0400 (EDT) |
branch: master
commit 6c877943da9c3c0291e7121a65970e34b49dec56
Author: Ludovic Courtès <ludo@gnu.org>
AuthorDate: Sun Jun 18 15:05:12 2023 +0200
remote-server: Slight clarification.
* src/cuirass/scripts/remote-server.scm (zmq-start-proxy): Move
'fetch-msg' right where it's used.
---
src/cuirass/scripts/remote-server.scm | 22 ++++++++++------------
1 file changed, 10 insertions(+), 12 deletions(-)
diff --git a/src/cuirass/scripts/remote-server.scm
b/src/cuirass/scripts/remote-server.scm
index 590beca..e93b2b6 100644
--- a/src/cuirass/scripts/remote-server.scm
+++ b/src/cuirass/scripts/remote-server.scm
@@ -479,20 +479,18 @@ frontend to the workers connected through the TCP
backend."
(when (memq build-socket items)
(match (zmq-message-receive* build-socket)
((worker empty rest)
- (let* ((fetch-msg (zmq-msg-init
- (zmq-message-content rest)))
- (command (bv->string
- (zmq-message-content rest)))
+ (let* ((command (bv->string (zmq-message-content rest)))
(reply-worker
- (lambda (message)
- (zmq-message-send-parts
- build-socket
- (map zmq-msg-init
- (list (zmq-message-content worker)
- (zmq-empty-delimiter)
- (string->bv message)))))))
+ (lambda (message)
+ (zmq-message-send-parts
+ build-socket
+ (map zmq-msg-init
+ (list (zmq-message-content worker)
+ (zmq-empty-delimiter)
+ (string->bv message)))))))
(if (need-fetching? command)
- (begin
+ (let ((fetch-msg (zmq-msg-init
+ (zmq-message-content rest))))
(atomic-box-fetch-and-inc! %fetch-queue-size)
(zmq-message-send fetch-socket fetch-msg))
(read-worker-exp rest