diff options
| author | chrislu <chris.lu@gmail.com> | 2022-07-13 00:58:15 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-07-13 00:58:15 -0700 |
| commit | 1451b389a4a78e7ec90aa931c9e8ac2b711f6408 (patch) | |
| tree | 628a8750f134d8a39758403a2453dea82b2138f3 | |
| parent | 31f9f528db11a10d72e86e895bbd663397a0b32f (diff) | |
| download | seaweedfs-1451b389a4a78e7ec90aa931c9e8ac2b711f6408.tar.xz seaweedfs-1451b389a4a78e7ec90aa931c9e8ac2b711f6408.zip | |
Avoid fatal error: sync: Unlock of unlocked RWMutex
fix https://github.com/chrislusf/seaweedfs/issues/3306
| -rw-r--r-- | weed/filer/reader_cache.go | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/filer/reader_cache.go b/weed/filer/reader_cache.go index c319f6c78..4c92f71c8 100644 --- a/weed/filer/reader_cache.go +++ b/weed/filer/reader_cache.go @@ -18,7 +18,7 @@ type ReaderCache struct { } type SingleChunkCacher struct { - sync.RWMutex + sync.Mutex cond *sync.Cond parent *ReaderCache chunkFileId string @@ -183,8 +183,8 @@ func (s *SingleChunkCacher) destroy() { } func (s *SingleChunkCacher) readChunkAt(buf []byte, offset int64) (int, error) { - s.RLock() - defer s.RUnlock() + s.Lock() + defer s.Unlock() for s.completedTime.IsZero() { s.cond.Wait() |