bugfix: modify the RWMutex lock to Mutex lock

MrGirl · Apr 19, 2021 · d5d9273 · d5d9273
1 parent c996995
commit d5d9273
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
 	}