milvus-io
/
milvus
mirror of https://github.com/milvus-io/milvus.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix querynode concurrent map rw panic (#19867) 

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>

Signed-off-by: Congqi Xia <congqi.xia@zilliz.com>
pull/19828/head
congqixia 2022-10-18 19:47:36 +08:00 committed by GitHub
parent 5b9988b627
commit 48463a12ef
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
internal/querynode/shard_cluster.go
View File

@ -1197,6 +1197,8 @@ func (sc *ShardCluster) Query(ctx context.Context, req *querypb.QueryRequest, wi
}
func (sc *ShardCluster) GetSegmentInfos() []shardSegmentInfo {
sc.mut.RLock()
defer sc.mut.RUnlock()
ret := make([]shardSegmentInfo, 0, len(sc.segments))
for _, info := range sc.segments {
ret = append(ret, info)
@ -1205,7 +1207,7 @@ func (sc *ShardCluster) GetSegmentInfos() []shardSegmentInfo {
}
func (sc *ShardCluster) getVersion() int64 {
sc.mut.RLock()
defer sc.mut.RUnlock()
sc.mutVersion.RLock()
defer sc.mutVersion.RUnlock()
return sc.version
}