aboutsummaryrefslogtreecommitdiff
path: root/weed/storage/volume_write.go
diff options
context:
space:
mode:
authorJaehoon Kim <kisow.github.io@navercorp.com>2025-10-17 04:21:51 +0900
committerGitHub <noreply@github.com>2025-10-16 12:21:51 -0700
commitd22e3d3495b962c7654414f7fa88b07ee06e4c16 (patch)
tree59bcc19409206137576542228d16b286d27ffdf6 /weed/storage/volume_write.go
parent3d25f206c83e893d6dc5ea419a8702f0f44655e0 (diff)
downloadseaweedfs-d22e3d3495b962c7654414f7fa88b07ee06e4c16.tar.xz
seaweedfs-d22e3d3495b962c7654414f7fa88b07ee06e4c16.zip
Fix uncleanable orphans issue with `volume.fsck -forcePurging` (#7332)
- Modified `needle_map_memory.go` to include needles with size=0 during needle map loading - Updated `volume_write.go` to handle size=0 needles in delete operations
Diffstat (limited to 'weed/storage/volume_write.go')
-rw-r--r--weed/storage/volume_write.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/storage/volume_write.go b/weed/storage/volume_write.go
index 2dc94851c..8cb00bc15 100644
--- a/weed/storage/volume_write.go
+++ b/weed/storage/volume_write.go
@@ -221,7 +221,7 @@ func (v *Volume) doDeleteRequest(n *needle.Needle) (Size, error) {
glog.V(4).Infof("delete needle %s", needle.NewFileIdFromNeedle(v.Id, n).String())
nv, ok := v.nm.Get(n.Id)
// fmt.Println("key", n.Id, "volume offset", nv.Offset, "data_size", n.Size, "cached size", nv.Size)
- if ok && nv.Size.IsValid() {
+ if ok && !nv.Size.IsDeleted() {
var offset uint64
var err error
size := nv.Size