diff --git a/syndicate/engine.rkt b/syndicate/engine.rkt index e12633f..7d95738 100644 --- a/syndicate/engine.rkt +++ b/syndicate/engine.rkt @@ -14,7 +14,7 @@ (require (only-in racket/exn exn->string)) (require "support/counter.rkt") -(define-logger syndicate/task) +(define-logger syndicate/engine) (struct engine (id thread [inhabitant-count #:mutable]) #:methods gen:custom-write @@ -27,10 +27,10 @@ (define e (engine (generate-engine-id) (thread (lambda () (thread-receive) ;; delay boot until we're ready - (log-syndicate/task-debug "~a starting" e) + (log-syndicate/engine-debug "~a starting" e) (with-handlers ([exn? (handle-unexpected-task-runner-termination e)]) (let loop () - (log-syndicate/task-debug + (log-syndicate/engine-debug "~a task count: ~a" e (engine-inhabitant-count e)) (if (positive? (engine-inhabitant-count e)) ;; We have some non-daemon users so just block @@ -43,7 +43,7 @@ [thunk (thunk) (loop)]))) - (log-syndicate/task-debug "~a stopping" e)))) + (log-syndicate/engine-debug "~a stopping" e)))) initial-inhabitant-count)) (thread-send (engine-thread e) 'boot) e) @@ -53,7 +53,7 @@ (set-engine-inhabitant-count! e (+ (engine-inhabitant-count e) delta))))) (define ((handle-unexpected-task-runner-termination e) exn) - (log-syndicate/task-error "~a terminated unexpectedly!\n~a" e (exn->string exn)) + (log-syndicate/engine-error "~a terminated unexpectedly!\n~a" e (exn->string exn)) (exit 1)) (define (queue-task! e thunk)