Log delays for the coordinator thread channels

1 files changed, 31 insertions, 9 deletions

diff --git a/guix-build-coordinator/coordinator.scm b/guix-build-coordinator/coordinator.scm
index 61e004d..f9081dc 100644
--- a/guix-build-coordinator/coordinator.scm
+++ b/guix-build-coordinator/coordinator.scm
@@ -217,16 +217,38 @@
   (let ((chunked-request-channel
          ;; There are fibers issues when trying to read the chunked
          ;; requests, so do this in dedicated threads.
-         (make-worker-thread-channel (const '())
-                                     #:parallelism 16
-                                     #:log-exception?
-                                     (lambda (exn)
-                                       (not
-                                        (chunked-input-ended-prematurely-error?
-                                         exn)))))
+         (make-worker-thread-channel
+          (const '())
+          #:parallelism 16
+          #:log-exception?
+          (lambda (exn)
+            (not
+             (chunked-input-ended-prematurely-error?
+              exn)))
+          #:delay-logger
+          (lambda (seconds-delayed)
+            (log-delay "chunked request channel"
+                       seconds-delayed)
+            (when (> seconds-delayed 0.1)
+              (format
+               (current-error-port)
+               "warning: chunked request channel delayed by ~1,2f seconds~%"
+               seconds-delayed)))))
+
+
         (substitutes-channel
-         (make-worker-thread-channel (const '())
-                                     #:parallelism 2)))
+         (make-worker-thread-channel
+          (const '())
+          #:parallelism 2
+          #:delay-logger
+          (lambda (seconds-delayed)
+            (log-delay "substitute channel"
+                       seconds-delayed)
+            (when (> seconds-delayed 0.1)
+              (format
+               (current-error-port)
+               "warning: substitutes channel delayed by ~1,2f seconds~%"
+               seconds-delayed))))))
 
     (let ((finished? (make-condition)))
       (call-with-sigint