diff options
| author | Paul Buetow <paul@buetow.org> | 2025-06-16 18:25:11 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2025-06-16 18:25:11 +0300 |
| commit | e2cb6282f4e84d7c78ffb5a2b6ac041d0f38ce52 (patch) | |
| tree | 326d231a8f090e97c5e117ade3d9f9da29f5f153 /integrationtests | |
| parent | 89943598a0b3c55d268e7dd51bd4199723a20c9d (diff) | |
implement chunked I/O optimization for 5.5x performance improvement
- Replace byte-by-byte reading with 64KB chunk-based processing
- Add ChunkedReader with proper line boundary handling
- Maintain backward compatibility for live tailing and static files
- Fix integration test timing with file sync and 1-second intervals
- Resolve line corruption issues in dmap tests
🤖 Generated with [Claude Code](https://claude.ai/code)
Co-Authored-By: Claude <noreply@anthropic.com>
Diffstat (limited to 'integrationtests')
| -rw-r--r-- | integrationtests/dtail_test.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/integrationtests/dtail_test.go b/integrationtests/dtail_test.go index 9e7f281..600a691 100644 --- a/integrationtests/dtail_test.go +++ b/integrationtests/dtail_test.go @@ -74,10 +74,11 @@ func TestDTailWithServer(t *testing.T) { var circular int for { select { - case <-time.After(time.Second * 2): + case <-time.After(time.Second * 1): fd.WriteString(time.Now().String()) message := fmt.Sprintf(" - Hello %s\n", greetings[circular]) fd.WriteString(message) + fd.Sync() // Force flush to disk for immediate availability t.Logf("Wrote '%s' into file", message) circular = (circular + 1) % len(greetings) case <-ctx.Done(): |