summaryrefslogtreecommitdiff
path: root/internal/server/handlers/readcommand.go
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2026-03-05 19:09:27 +0200
committerPaul Buetow <paul@buetow.org>2026-03-05 19:09:27 +0200
commitec1504e0cedbfeffc35e50a09633e51e93bf0e2d (patch)
treeedd7259fc8eacd10b2bc3015096548c8fc36d461 /internal/server/handlers/readcommand.go
parent5d1b9f1062d38c301c0995ec6da980bdf5e48332 (diff)
more on this
Diffstat (limited to 'internal/server/handlers/readcommand.go')
-rw-r--r--internal/server/handlers/readcommand.go2
1 files changed, 2 insertions, 0 deletions
diff --git a/internal/server/handlers/readcommand.go b/internal/server/handlers/readcommand.go
index f99c740..c03900f 100644
--- a/internal/server/handlers/readcommand.go
+++ b/internal/server/handlers/readcommand.go
@@ -372,6 +372,8 @@ func (r *readCommand) ensureTurboModeEnabled() {
return
}
r.server.EnableTurboMode()
+ // Wake a potentially blocked reader goroutine so it can switch to turbo drain path.
+ r.server.SendServerMessage(".turbo wake")
}
func (r *readCommand) makeTurboWriter() TurboWriter {