diff options
| author | chrislu <chris.lu@gmail.com> | 2025-07-01 00:45:13 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2025-07-01 00:45:13 -0700 |
| commit | e5adc3872a79e062826a387e1e2bb68196f14014 (patch) | |
| tree | e94f674d77b86920f1c82c2013fe0b0cae009352 | |
| parent | 7ab3b19e378c3429db358ddac567d2bf03f4f70e (diff) | |
| download | seaweedfs-e5adc3872a79e062826a387e1e2bb68196f14014.tar.xz seaweedfs-e5adc3872a79e062826a387e1e2bb68196f14014.zip | |
ensure deleted entries are deleted
fix https://github.com/seaweedfs/seaweedfs/issues/6936
| -rw-r--r-- | weed/storage/erasure_coding/ec_encoder.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/storage/erasure_coding/ec_encoder.go b/weed/storage/erasure_coding/ec_encoder.go index a46643f57..6578f823d 100644 --- a/weed/storage/erasure_coding/ec_encoder.go +++ b/weed/storage/erasure_coding/ec_encoder.go @@ -299,7 +299,7 @@ func readNeedleMap(baseFileName string) (*needle_map.MemDb, error) { cm := needle_map.NewMemDb() err = idx.WalkIndexFile(indexFile, 0, func(key types.NeedleId, offset types.Offset, size types.Size) error { - if !offset.IsZero() && size != types.TombstoneFileSize { + if !offset.IsZero() && !size.IsDeleted() { cm.Set(key, offset, size) } else { cm.Delete(key) |