[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]
branch master updated: remote: Use message API.
From: |
Mathieu Othacehe |
Subject: |
branch master updated: remote: Use message API. |
Date: |
Fri, 26 Feb 2021 05:40:24 -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 fa191d8 remote: Use message API.
fa191d8 is described below
commit fa191d877ea2f06792f3ff786799c3735c3f5bcb
Author: Mathieu Othacehe <othacehe@gnu.org>
AuthorDate: Fri Feb 26 11:39:48 2021 +0100
remote: Use message API.
* src/cuirass/remote-server.scm (zmq-start-proxy): Use the message API.
---
src/cuirass/remote-server.scm | 21 ++++++++++++---------
1 file changed, 12 insertions(+), 9 deletions(-)
diff --git a/src/cuirass/remote-server.scm b/src/cuirass/remote-server.scm
index b82a292..005fa59 100644
--- a/src/cuirass/remote-server.scm
+++ b/src/cuirass/remote-server.scm
@@ -374,19 +374,22 @@ 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-name (bytevector-copy
- (zmq-message-content worker)))
- (rest-bv (bytevector-copy
+ (let* ((worker-msg (zmq-msg-init
+ (zmq-message-content worker)))
+ (fetch-msg (zmq-msg-init
+ (zmq-message-content rest)))
+ (command (bv->string
(zmq-message-content rest)))
(reply-worker
(lambda (message)
- (zmq-send-msg-parts-bytevector
+ (zmq-message-send-parts
build-socket
- (list worker-name
- (zmq-empty-delimiter)
- (string->bv message))))))
- (if (need-fetching? (bv->string rest-bv))
- (zmq-send-bytevector fetch-socket rest-bv)
+ (cons worker-msg
+ (map zmq-msg-init
+ (list (zmq-empty-delimiter)
+ (string->bv message))))))))
+ (if (need-fetching? command)
+ (zmq-message-send fetch-socket fetch-msg)
(read-worker-exp rest
#:reply-worker reply-worker))))))
(db-remove-unresponsive-workers (%worker-timeout))
[Prev in Thread] |
Current Thread |
[Next in Thread] |
- branch master updated: remote: Use message API.,
Mathieu Othacehe <=