the isFsync parameter is essentially IsAsyncWrite and it needs to be turned off if s.isStopping

https://github.com/seaweedfs/seaweedfs/commit/d8c574a5ef1a811f9a0d447097d9edfcc0c1d84c#r159132764
This commit is contained in:
chrislu
2025-06-05 00:19:10 -07:00
parent 2f3de5e199
commit 35f0daa198
+1 -1
View File
@@ -441,7 +441,7 @@ func (s *Store) WriteVolumeNeedle(i needle.VolumeId, n *needle.Needle, checkCook
err = fmt.Errorf("volume %d is read only", i)
return
}
_, _, isUnchanged, err = v.writeNeedle2(n, checkCookie, fsync || s.isStopping)
_, _, isUnchanged, err = v.writeNeedle2(n, checkCookie, fsync && !s.isStopping)
return
}
glog.V(0).Infoln("volume", i, "not found!")