add read lock for getSegment (#25036)

Signed-off-by: aoiasd <zhicheng.yue@zilliz.com>
2023-06-21 14:06:42 +08:00 · 2023-06-21 14:06:42 +08:00 · 7f5de9aab3
parent 3f4356df10
commit 7f5de9aab3
1 changed files with 3 additions and 0 deletions
--- a/internal/datanode/channel_meta.go
+++ b/internal/datanode/channel_meta.go
@ -247,6 +247,9 @@ func (c *ChannelMeta) addSegment(req addSegmentReq) error {
 }

 func (c *ChannelMeta) getSegment(segID UniqueID) *Segment {
+	c.segMu.RLock()
+	defer c.segMu.RUnlock()
+
 	seg, ok := c.segments[segID]
 	if !ok {
 		return nil