Merge pull request #266 from rambohe-ch/fix-lock-error

bugfix: modify the RWMutex lock to Mutex lock
openyurtio · Apr 19, 2021 · f0b6be1 · f0b6be1
2 parents 00a37bc + 7a6f9b6
commit f0b6be1
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pkg/yurthub/storage/disk/storage.go b/pkg/yurthub/storage/disk/storage.go
@@ -37,7 +37,7 @@ const (
 type diskStorage struct {
 	baseDir          string
 	keyPendingStatus map[string]struct{}
-	sync.RWMutex
+	sync.Mutex
 }
 
 // NewDiskStorage creates a storage.Store for caching data into local disk
@@ -377,8 +377,8 @@ func (ds *diskStorage) Recover(key string) error {
 }
 
 func (ds *diskStorage) lockKey(key string) bool {
-	ds.RLock()
-	defer ds.RUnlock()
+	ds.Lock()
+	defer ds.Unlock()
 	if _, ok := ds.keyPendingStatus[key]; ok {
 		return false
 	}