From 409fa1df5c884389f863a6194b64ffafda476a60 Mon Sep 17 00:00:00 2001 From: Christopher Baines Date: Wed, 8 Jan 2025 12:23:18 +0000 Subject: [PATCH] Allow customising the resource-pool put-message timeout --- knots/resource-pool.scm | 15 +++++++++------ 1 file changed, 9 insertions(+), 6 deletions(-) diff --git a/knots/resource-pool.scm b/knots/resource-pool.scm index 23bc9eb..9b2dce4 100644 --- a/knots/resource-pool.scm +++ b/knots/resource-pool.scm @@ -71,8 +71,7 @@ lifetime scheduler (name "unnamed") - ;; Add options for customizing timeouts - ) + (put-message-timeout 0.5)) (define (initializer/safe) (with-exception-handler (lambda (exn) @@ -157,7 +156,8 @@ (wrap-operation (put-operation reply new-resource) (const #t)) - (wrap-operation (sleep-operation 1) + (wrap-operation (sleep-operation + put-message-timeout) (const #f)))))) (unless checkout-success? (set! checkout-failure-count @@ -180,7 +180,8 @@ (wrap-operation (put-operation reply (car available)) (const #t)) - (wrap-operation (sleep-operation 1) + (wrap-operation (sleep-operation + put-message-timeout) (const #f)))))) (unless checkout-success? (set! checkout-failure-count @@ -215,7 +216,8 @@ (put-operation (last waiters) resource) (const #t)) - (wrap-operation (sleep-operation 1) + (wrap-operation (sleep-operation + put-message-timeout) (const #f)))))) (unless checkout-success? (set! checkout-failure-count @@ -269,7 +271,8 @@ (wrap-operation (put-operation reply stats) (const #t)) - (wrap-operation (sleep-operation 1) + (wrap-operation (sleep-operation + put-message-timeout) (const #f))))))) (loop resources