Concurrent map read and map write causing fatal error

[hengyoush]

Describe the bug
Encountering a fatal error: concurrent map read and map write in the kyanos.

To Reproduce
Steps to reproduce the behavior:

./kyanos watch redis

Expected behavior
no panic

Screenshots/Log
panic.log

Information (please complete the following information):

• OS: [e.g. use uname -ar]

[dosubot]

To resolve the fatal error: concurrent map read and map write issue in kyanos, ensure that all access to shared data structures, such as maps, is properly synchronized. Use a sync.Mutex to protect access to these structures. For example, if you have a slice or map that is accessed by multiple goroutines, wrap the read and write operations with lock.Lock() and lock.Unlock() to prevent concurrent access.

Here's a snippet showing how to use a mutex to protect access to a shared slice:

func (m *model) updateRowsInTable() {
    lock.Lock()
    defer lock.Unlock()
    // operations on m.records
}

Similarly, ensure that any goroutine accessing shared data is also protected:

go func(mod *model, channel chan *common.AnnotatedRecord) {
    for {
        select {
        case <-ctx.Done():
            return
        case r := <-ch:
            lock.Lock()
            *m.records = append(*m.records, r)
            if len(*m.records) > m.options.MaxRecords {
                *m.records = (*m.records)[(len(*m.records) - m.options.MaxRecords):]
            }
            lock.Unlock()
        }
    }
}(m, ch)

Make sure every access to shared data is protected by the mutex to prevent concurrent read and write operations ^[1].

To continue talking to Dosu, mention @dosu.

---

^{Help Dosu learn! Give it feedback: Great Response | Irrelevant Answer | Incorrect Sources | Too Verbose | Hallucination | Other}