diff options
| author | Paul Buetow <paul@buetow.org> | 2026-03-02 10:31:26 +0200 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2026-03-02 10:31:26 +0200 |
| commit | 3002bdcaa4ec22aa46b6c98eefda2f926dfff618 (patch) | |
| tree | 43cc06e2bd690b41b33a3b56735823affed541bb /internal/server/handlers/basehandler.go | |
| parent | 29e50d7b6ebb9e6c59d079ef5b7551b1acd950fb (diff) | |
handlers: use turbo EOF acknowledgement instead of sleep heuristic
Diffstat (limited to 'internal/server/handlers/basehandler.go')
| -rw-r--r-- | internal/server/handlers/basehandler.go | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/internal/server/handlers/basehandler.go b/internal/server/handlers/basehandler.go index a61da48..f21262e 100644 --- a/internal/server/handlers/basehandler.go +++ b/internal/server/handlers/basehandler.go @@ -366,3 +366,8 @@ func (h *baseHandler) GetTurboChannel() chan []byte { func (h *baseHandler) TurboChannelLen() int { return h.turbo.channelLen() } + +// WaitForTurboEOFAck waits until turbo reader acknowledges EOF or timeout. +func (h *baseHandler) WaitForTurboEOFAck(timeout time.Duration) bool { + return h.turbo.waitForEOFAck(timeout) +} |