Merge pull request #13 from mbilal92/main

fix concurrent read/write in FindOwnerInt32ID
omec-project · Nov 8, 2023 · 2a78831 · 2a78831
2 parents fd4d121 + be369b5
commit 2a78831
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/drsm/api.go b/drsm/api.go
@@ -110,6 +110,8 @@ func (d *Drsm) ReleaseInt32ID(id int32) error {
 }
 
 func (d *Drsm) FindOwnerInt32ID(id int32) (*PodId, error) {
+	mutex.Lock()
+	defer mutex.Unlock()
 	chunkId := id >> 10
 	chunk, found := d.globalChunkTbl[chunkId]
 	if found == true {