diff options
| author | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-04-26 13:40:42 +0500 |
|---|---|---|
| committer | Konstantin Lebedev <9497591+kmlebedev@users.noreply.github.com> | 2022-04-26 13:40:42 +0500 |
| commit | 7315d1d0397a939742fb5d704a3bb95ece9d8d31 (patch) | |
| tree | 6c0e06ea967939265eda1ad218e5773632f467a2 | |
| parent | 3bce568c32f78a5bf12f0a31995d4098ca97fc6b (diff) | |
| download | seaweedfs-7315d1d0397a939742fb5d704a3bb95ece9d8d31.tar.xz seaweedfs-7315d1d0397a939742fb5d704a3bb95ece9d8d31.zip | |
waite volume being closed during compression idx
| -rw-r--r-- | weed/storage/volume.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/weed/storage/volume.go b/weed/storage/volume.go index 6d48fbc83..2dfba55c8 100644 --- a/weed/storage/volume.go +++ b/weed/storage/volume.go @@ -195,6 +195,10 @@ func (v *Volume) Close() { v.dataFileAccessLock.Lock() defer v.dataFileAccessLock.Unlock() if v.nm != nil { + for v.isCompacting { + glog.Warningf("Volume being closed during compression idx %d", v.Id) + time.Sleep(time.Second) + } if err := v.nm.Sync(); err != nil { glog.Warningf("Volume Close fail to sync volume idx %d", v.Id) } |