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

Do not log context canceled errors during EC assemble #1540

Merged
fyrchik merged 2 commits from dstepanov-yadro/frostfs-node:fix/do_not_log_ec_assemble_context_canceled into master 2024-12-05 12:39:50 +00:00
Conversation 0 Commits 2 Files changed 1 +4 -4
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit 2fe0029207 - Show all commits

8
pkg/services/object/get/assemblerec.go
View file

@ -238,13 +238,13 @@ func (a *assemblerec) tryGetChunkFromLocalStorage(ctx context.Context, ch object
var object *objectSDK.Object var object *objectSDK.Object
if a.head { if a.head {
object, err = a.localStorage.Head(ctx, addr, false) object, err = a.localStorage.Head(ctx, addr, false)
if err != nil { if err != nil && !errors.Is(err, context.Canceled) {
a.log.Warn(ctx, logs.GetUnableToHeadPartECObject, zap.String("node", "local"), zap.Stringer("part_id", objID), zap.Error(err)) a.log.Warn(ctx, logs.GetUnableToHeadPartECObject, zap.String("node", "local"), zap.Stringer("part_id", objID), zap.Error(err))
return nil return nil
} }
} else { } else {
object, err = a.localStorage.Get(ctx, addr) object, err = a.localStorage.Get(ctx, addr)
if err != nil { if err != nil && !errors.Is(err, context.Canceled) {
a.log.Warn(ctx, logs.GetUnableToGetPartECObject, zap.String("node", "local"), zap.Stringer("part_id", objID), zap.Error(err)) a.log.Warn(ctx, logs.GetUnableToGetPartECObject, zap.String("node", "local"), zap.Stringer("part_id", objID), zap.Error(err))
return nil return nil
} }
@ -286,13 +286,13 @@ func (a *assemblerec) tryGetChunkFromRemoteStorage(ctx context.Context, node cli
var object *objectSDK.Object var object *objectSDK.Object
if a.head { if a.head {
object, err = a.remoteStorage.headObjectFromNode(ctx, addr, node, false) object, err = a.remoteStorage.headObjectFromNode(ctx, addr, node, false)
if err != nil { if err != nil && !errors.Is(err, context.Canceled) {
a.log.Warn(ctx, logs.GetUnableToHeadPartECObject, zap.String("node", hex.EncodeToString(node.PublicKey())), zap.Stringer("part_id", objID), zap.Error(err)) a.log.Warn(ctx, logs.GetUnableToHeadPartECObject, zap.String("node", hex.EncodeToString(node.PublicKey())), zap.Stringer("part_id", objID), zap.Error(err))
return nil return nil
} }
} else { } else {
object, err = a.remoteStorage.getObjectFromNode(ctx, addr, node) object, err = a.remoteStorage.getObjectFromNode(ctx, addr, node)
if err != nil { if err != nil && !errors.Is(err, context.Canceled) {
a.log.Warn(ctx, logs.GetUnableToGetPartECObject, zap.String("node", hex.EncodeToString(node.PublicKey())), zap.Stringer("part_id", objID), zap.Error(err)) a.log.Warn(ctx, logs.GetUnableToGetPartECObject, zap.String("node", hex.EncodeToString(node.PublicKey())), zap.Stringer("part_id", objID), zap.Error(err))
return nil return nil
} }