fix(controller): add lock for listsegment func

Signed-off-by: jyjiangkai <jyjiangkai@163.com>
vanus-labs · Feb 8, 2023 · a7c2e7b · a7c2e7b
1 parent 1b4e82a
commit a7c2e7b
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/internal/controller/eventbus/eventlog/eventlog.go b/internal/controller/eventbus/eventlog/eventlog.go
@@ -343,6 +343,8 @@ func (mgr *eventlogManager) GetEventLogSegmentList(elID vanus.ID) []*Segment {
 		return result
 	}
 	el, _ := v.(*eventlog)
+	mgr.mutex.Lock()
+	defer mgr.mutex.Unlock()
 	s := el.head()
 	for s != nil {
 		result = append(result, s)