ale64bit/frostfs-node
1
0
Fork 0
forked from TrueCloudLab/frostfs-node
Code Issues Pull requests Projects Releases Packages Wiki Activity

[#1344] engine: Log errors in Tree* operations

Browse source 
Signed-off-by: Evgenii Stratonikov <evgeniy@nspcc.ru>
This commit is contained in:
Evgenii Stratonikov 2022-05-04 12:42:32 +03:00 committed by fyrchik
parent 910db42748
commit d8ad68d613
1 changed files with 25 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

25
pkg/local_object_storage/engine/tree.go
View file

@ -3,6 +3,7 @@ package engine
import ( import (
"github.com/nspcc-dev/neofs-node/pkg/local_object_storage/pilorama" "github.com/nspcc-dev/neofs-node/pkg/local_object_storage/pilorama"
cidSDK "github.com/nspcc-dev/neofs-sdk-go/container/id" cidSDK "github.com/nspcc-dev/neofs-sdk-go/container/id"
"go.uber.org/zap"
) )
var _ pilorama.Forest = (*StorageEngine)(nil) var _ pilorama.Forest = (*StorageEngine)(nil)
@ -14,6 +15,10 @@ func (e *StorageEngine) TreeMove(cid cidSDK.ID, treeID string, m *pilorama.Move)
for _, sh := range e.sortShardsByWeight(cid) { for _, sh := range e.sortShardsByWeight(cid) {
lm, err = sh.TreeMove(cid, treeID, m) lm, err = sh.TreeMove(cid, treeID, m)
if err != nil { if err != nil {
e.log.Debug("can't put node in a tree",
zap.Stringer("cid", cid),
zap.String("tree", treeID),
zap.String("err", err.Error()))
continue continue
} }
return lm, nil return lm, nil
@ -28,6 +33,10 @@ func (e *StorageEngine) TreeAddByPath(cid cidSDK.ID, treeID string, attr string,
for _, sh := range e.sortShardsByWeight(cid) { for _, sh := range e.sortShardsByWeight(cid) {
lm, err = sh.TreeAddByPath(cid, treeID, attr, path, m) lm, err = sh.TreeAddByPath(cid, treeID, attr, path, m)
if err != nil { if err != nil {
e.log.Debug("can't put node in a tree",
zap.Stringer("cid", cid),
zap.String("tree", treeID),
zap.String("err", err.Error()))
continue continue
} }
return lm, nil return lm, nil
@ -41,6 +50,10 @@ func (e *StorageEngine) TreeApply(cid cidSDK.ID, treeID string, m *pilorama.Move
for _, sh := range e.sortShardsByWeight(cid) { for _, sh := range e.sortShardsByWeight(cid) {
err = sh.TreeApply(cid, treeID, m) err = sh.TreeApply(cid, treeID, m)
if err != nil { if err != nil {
e.log.Debug("can't put node in a tree",
zap.Stringer("cid", cid),
zap.String("tree", treeID),
zap.String("err", err.Error()))
continue continue
} }
return nil return nil
@ -56,6 +69,10 @@ func (e *StorageEngine) TreeGetByPath(cid cidSDK.ID, treeID string, attr string,
for _, sh := range e.sortShardsByWeight(cid) { for _, sh := range e.sortShardsByWeight(cid) {
nodes, err = sh.TreeGetByPath(cid, treeID, attr, path, latest) nodes, err = sh.TreeGetByPath(cid, treeID, attr, path, latest)
if err != nil { if err != nil {
e.log.Debug("can't put node in a tree",
zap.Stringer("cid", cid),
zap.String("tree", treeID),
zap.String("err", err.Error()))
continue continue
} }
return nodes, nil return nodes, nil
@ -70,6 +87,10 @@ func (e *StorageEngine) TreeGetMeta(cid cidSDK.ID, treeID string, nodeID piloram
for _, sh := range e.sortShardsByWeight(cid) { for _, sh := range e.sortShardsByWeight(cid) {
m, err = sh.TreeGetMeta(cid, treeID, nodeID) m, err = sh.TreeGetMeta(cid, treeID, nodeID)
if err != nil { if err != nil {
e.log.Debug("can't put node in a tree",
zap.Stringer("cid", cid),
zap.String("tree", treeID),
zap.String("err", err.Error()))
continue continue
} }
return m, nil return m, nil
@ -84,6 +105,10 @@ func (e *StorageEngine) TreeGetChildren(cid cidSDK.ID, treeID string, nodeID pil
for _, sh := range e.sortShardsByWeight(cid) { for _, sh := range e.sortShardsByWeight(cid) {
nodes, err = sh.TreeGetChildren(cid, treeID, nodeID) nodes, err = sh.TreeGetChildren(cid, treeID, nodeID)
if err != nil { if err != nil {
e.log.Debug("can't put node in a tree",
zap.Stringer("cid", cid),
zap.String("tree", treeID),
zap.String("err", err.Error()))
continue continue
} }
return nodes, nil return nodes, nil