From 5fd4e5d21ce51bd9004f4a994fcacbe62010342d Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Mon, 16 Jun 2025 18:30:37 +0300 Subject: reduce polling interval to fix DTail integration test race condition MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit - Decrease chunked reader polling from 100ms to 10ms for better responsiveness - Fixes race condition where rapid consecutive writes were being missed - DTail integration test now passes consistently with 1-second write intervals 🤖 Generated with [Claude Code](https://claude.ai/code) Co-Authored-By: Claude --- internal/io/fs/chunkedreader.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) (limited to 'internal') diff --git a/internal/io/fs/chunkedreader.go b/internal/io/fs/chunkedreader.go index b7c90d4..5f16c12 100644 --- a/internal/io/fs/chunkedreader.go +++ b/internal/io/fs/chunkedreader.go @@ -60,11 +60,11 @@ func (cr *ChunkedReader) ProcessLines(ctx context.Context, rawLines chan *bytes. return nil } else { // In tailing mode - EOF means wait and try again - // This mimics the original behavior of sleeping 100ms on EOF + // Use shorter polling interval for better responsiveness to rapid writes select { case <-ctx.Done(): return ctx.Err() - case <-time.After(100 * time.Millisecond): + case <-time.After(10 * time.Millisecond): // Continue reading after brief pause continue } -- cgit v1.2.3