TrueCloudLab/frostfs-node
20
1
Fork 27
Code Issues 105 Pull requests 10 Projects Releases 2 Activity Actions

[#98] fstree: Do not fail iteration over just removed files #157

Merged
fyrchik merged 1 commit from carpawell/frostfs-node:fix/fstree-iteration-over-deleted-files into master 2023-03-22 07:26:28 +00:00
Conversation 0 Commits 1 Files changed 2 +7 -3
2 changed files with 7 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
CHANGELOG.md
View file

@ -50,6 +50,7 @@ Changelog for FrostFS Node
- Actually use `object.put.pool_size_local` and independent pool for local puts (#64). - Actually use `object.put.pool_size_local` and independent pool for local puts (#64).
- Pretty printer of basic ACL in the NeoFS CLI (#2259) - Pretty printer of basic ACL in the NeoFS CLI (#2259)
- Adding of public key for nns group `group.frostfs` at init step (#130) - Adding of public key for nns group `group.frostfs` at init step (#130)
- Iterating over just removed files by FSTree (#98)
### Removed ### Removed
### Updated ### Updated

9
pkg/local_object_storage/blobstor/fstree/fstree.go
View file

@ -135,13 +135,16 @@ func (t *FSTree) iterate(depth uint64, curPath []string, prm common.IteratePrm)
continue continue
} }
data, err := os.ReadFile(filepath.Join(curPath...))
if err != nil && os.IsNotExist(err) {
continue
}
if prm.LazyHandler != nil { if prm.LazyHandler != nil {
err = prm.LazyHandler(addr, func() ([]byte, error) { err = prm.LazyHandler(addr, func() ([]byte, error) {
return os.ReadFile(filepath.Join(curPath...)) return data, err
}) })
} else { } else {
var data []byte
data, err = os.ReadFile(filepath.Join(curPath...))
if err == nil { if err == nil {
data, err = t.Decompress(data) data, err = t.Decompress(data)
} }