diff options
| -rw-r--r-- | internal/server/handlers/readcommand.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/internal/server/handlers/readcommand.go b/internal/server/handlers/readcommand.go index 90a1155..566d400 100644 --- a/internal/server/handlers/readcommand.go +++ b/internal/server/handlers/readcommand.go @@ -172,9 +172,9 @@ func (r *readCommand) read(ctx context.Context, ltx lcontext.LContext, dlog.Server.Info(r.server.user, "Turbo boost check: enabled=", turboBoostEnabled, "mode=", r.mode) // Only enable channel-less for server mode, not serverless mode // Use the serverless field directly as it's more reliable - // Enable turbo boost for cat/grep modes, and also when aggregate (MapReduce) is present + // Enable turbo boost for cat/grep/tail modes, and also when aggregate (MapReduce) is present if turboBoostEnabled && !r.server.serverless && - (r.mode == omode.CatClient || r.mode == omode.GrepClient || r.server.aggregate != nil) { + (r.mode == omode.CatClient || r.mode == omode.GrepClient || r.mode == omode.TailClient || r.server.aggregate != nil) { // Log to stderr for testing verification - only in server mode fmt.Fprintf(os.Stderr, "[DTAIL] Turbo boost enabled: using channel-less implementation for %s\n", path) r.readWithProcessor(ctx, ltx, path, globID, re, reader) |