diff options
Diffstat (limited to 'guix-build-coordinator/coordinator.scm')
-rw-r--r-- | guix-build-coordinator/coordinator.scm | 29 |
1 files changed, 20 insertions, 9 deletions
diff --git a/guix-build-coordinator/coordinator.scm b/guix-build-coordinator/coordinator.scm index bc742cf..18952ad 100644 --- a/guix-build-coordinator/coordinator.scm +++ b/guix-build-coordinator/coordinator.scm @@ -28,6 +28,9 @@ #:use-module (ice-9 threads) #:use-module (ice-9 exceptions) #:use-module (web uri) + #:use-module (oop goops) + #:use-module (logging logger) + #:use-module (logging port-log) #:use-module (gcrypt random) #:use-module (fibers) #:use-module (fibers channels) @@ -50,6 +53,7 @@ build-coordinator-hooks build-coordinator-metrics-registry build-coordinator-allocation-strategy + build-coordinator-logger %default-agent-uri %default-client-uri @@ -78,14 +82,15 @@ (define-record-type <build-coordinator> (make-build-coordinator-record datastore hooks metrics-registry - allocation-strategy) + allocation-strategy logger) build-coordinator? (datastore build-coordinator-datastore) (hooks build-coordinator-hooks) (metrics-registry build-coordinator-metrics-registry) (allocation-strategy build-coordinator-allocation-strategy) (allocator-thread build-coordinator-allocator-thread - set-build-coordinator-allocator-thread!)) + set-build-coordinator-allocator-thread!) + (logger build-coordinator-logger)) (define %known-hooks '(build-submitted @@ -126,11 +131,18 @@ unknown))) hooks)) - (let ((build-coordinator - (make-build-coordinator-record datastore - hooks - metrics-registry - allocation-strategy))) + (let* ((lgr (make <logger>)) + (port-log (make <port-log> #:port (current-output-port))) + (build-coordinator + (make-build-coordinator-record datastore + hooks + metrics-registry + allocation-strategy + lgr))) + + (add-handler! lgr port-log) + (open-log! lgr) + (set-build-coordinator-allocator-thread! build-coordinator (make-build-allocator-thread build-coordinator)) @@ -197,8 +209,7 @@ secret-key-base build-coordinator chunked-request-channel) - (simple-format #t "listening on ~A:~A\n" - host port)))) + (log-msg 'INFO "listening on " host ":" port)))) ;; Start the client messaging server (start-client-request-server |