diff options
| author | Paul Buetow <paul@buetow.org> | 2026-03-10 23:08:29 +0200 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2026-03-10 23:08:29 +0200 |
| commit | feb34d807e85d626a7ff08a51bba17f93375ddaa (patch) | |
| tree | 94b1de33313f7b3e68e232c70c86d63c2ef15a97 /internal/ior.go | |
| parent | db75c8b17549fdfa23cc8622770d257fa0d7420f (diff) | |
config: centralize default buffer sizes (task 388)
Diffstat (limited to 'internal/ior.go')
| -rw-r--r-- | internal/ior.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/internal/ior.go b/internal/ior.go index 8258f01..c14ab37 100644 --- a/internal/ior.go +++ b/internal/ior.go @@ -15,6 +15,7 @@ import ( "syscall" "time" + appconfig "ior/internal/config" "ior/internal/event" "ior/internal/flags" "ior/internal/flamegraph" @@ -201,7 +202,7 @@ func tuiTraceStarterFromRunTrace( bindings.SetEventStreamSource(streamSource) bindings.SetLiveTrie(liveTrie) } - streamEvents := make(chan eventstream.StreamEvent, 4096) + streamEvents := make(chan eventstream.StreamEvent, appconfig.DefaultChannelBufferSize) go func() { for ev := range streamEvents { @@ -372,8 +373,7 @@ func setupBPFModule(parentCtx context.Context, cfg flags.Config) (*bpf.Module, * } func setupEventChannel(bpfModule *bpf.Module) (chan []byte, error) { - // 4096 channel size minimizes event drops. - ch := make(chan []byte, 4096) + ch := make(chan []byte, appconfig.DefaultChannelBufferSize) rb, err := bpfModule.InitRingBuf("event_map", ch) if err != nil { return nil, err |