From 3002bdcaa4ec22aa46b6c98eefda2f926dfff618 Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Mon, 2 Mar 2026 10:31:26 +0200 Subject: handlers: use turbo EOF acknowledgement instead of sleep heuristic --- internal/config/server.go | 3 +++ 1 file changed, 3 insertions(+) (limited to 'internal/config') diff --git a/internal/config/server.go b/internal/config/server.go index 6d25965..80b52e9 100644 --- a/internal/config/server.go +++ b/internal/config/server.go @@ -94,6 +94,8 @@ type ServerConfig struct { TurboFlushPollIntervalMs int `json:",omitempty"` // Turbo read retry interval in milliseconds when data is expected but not yet available. TurboReadRetryIntervalMs int `json:",omitempty"` + // Maximum time to wait for turbo EOF acknowledgement after signaling EOF, in milliseconds. + TurboEOFAckTimeoutMs int `json:",omitempty"` // Wait for turbo aggregate serialization during shutdown in milliseconds. ShutdownTurboSerializeWaitMs int `json:",omitempty"` // Final idle recheck wait before shutdown in milliseconds. @@ -128,6 +130,7 @@ func newDefaultServerConfig() *ServerConfig { TurboFlushTimeoutMs: 2000, TurboFlushPollIntervalMs: 10, TurboReadRetryIntervalMs: 1, + TurboEOFAckTimeoutMs: 2000, ShutdownTurboSerializeWaitMs: 500, ShutdownIdleRecheckWaitMs: 10, } -- cgit v1.2.3