aboutsummaryrefslogtreecommitdiff
path: root/guix-build-coordinator/agent-messaging
diff options
context:
space:
mode:
authorChristopher Baines <mail@cbaines.net>2022-04-09 22:36:16 +0100
committerChristopher Baines <mail@cbaines.net>2022-04-09 22:36:16 +0100
commitde4a303beedc3414d7ca9a8ad948d0fc676e7e77 (patch)
tree231d5fa18f74bfc98e2b47f2220403e9237c834e /guix-build-coordinator/agent-messaging
parent777edfcb5e0a83add6ef28da18f9c767a41845e6 (diff)
downloadbuild-coordinator-de4a303beedc3414d7ca9a8ad948d0fc676e7e77.tar
build-coordinator-de4a303beedc3414d7ca9a8ad948d0fc676e7e77.tar.gz
Add a timeout for submitting outputs
Diffstat (limited to 'guix-build-coordinator/agent-messaging')
-rw-r--r--guix-build-coordinator/agent-messaging/http.scm45
1 files changed, 24 insertions, 21 deletions
diff --git a/guix-build-coordinator/agent-messaging/http.scm b/guix-build-coordinator/agent-messaging/http.scm
index 21b64d1..2c07336 100644
--- a/guix-build-coordinator/agent-messaging/http.scm
+++ b/guix-build-coordinator/agent-messaging/http.scm
@@ -339,27 +339,30 @@
(seek file-port bytes SEEK_SET)
(log 'INFO "resuming upload from byte " bytes))
- (let-values (((response body)
- (call-with-streaming-http-request
- (uri #:resume? (integer? bytes))
- (lambda (port)
- (with-time-logging
- (simple-format #f "sending ~A" file)
- (dump-port file-port port
- #:buffer-size 65536)))
- #:headers `((Authorization . ,auth-value))
- #:method (if bytes 'POST 'PUT)
- #:report-bytes-sent report-bytes-sent)))
- (when (>= (response-code response) 400)
- (raise-exception
- (make-exception-with-message
- (coordinator-handle-failed-request
- log
- 'PUT
- (uri-path
- (uri #:resume? (integer? bytes)))
- response
- body))))))))))
+ (with-timeout (* 20 60) ; 20 minutes
+ (raise-exception
+ (make-exception-with-message "timeout submitting output"))
+ (let-values (((response body)
+ (call-with-streaming-http-request
+ (uri #:resume? (integer? bytes))
+ (lambda (port)
+ (with-time-logging
+ (simple-format #f "sending ~A" file)
+ (dump-port file-port port
+ #:buffer-size 65536)))
+ #:headers `((Authorization . ,auth-value))
+ #:method (if bytes 'POST 'PUT)
+ #:report-bytes-sent report-bytes-sent)))
+ (when (>= (response-code response) 400)
+ (raise-exception
+ (make-exception-with-message
+ (coordinator-handle-failed-request
+ log
+ 'PUT
+ (uri-path
+ (uri #:resume? (integer? bytes)))
+ response
+ body)))))))))))
#:times 100
#:delay (random 15)))