TrueCloudLab/frostfs-node
19
1
Fork 27
Code Issues 90 Pull requests 4 Projects Releases 1 Activity Actions

WIP: Process EC container for Get/GetRange/Head concurrently #1237

Closed
dstepanov-yadro wants to merge 6 commits from dstepanov-yadro/frostfs-node:fix/ec_get_failover into master
pull from: dstepanov-yadro/frostfs-node:fix/ec_get_failover
merge into: TrueCloudLab:master
Conversation 1 Commits 6 Files changed 15 +3 -3
2 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files
Showing only changes of commit fa642d95c7 - Show all commits

2
pkg/services/object/get/container.go
View file

@ -110,7 +110,7 @@ func (r *request) processRepNodes(ctx context.Context, traverser *placement.Trav
client.NodeInfoFromNetmapElement(&info, addrs[i]) client.NodeInfoFromNetmapElement(&info, addrs[i])
if r.processNode(ctx, info) { if r.processRepNode(ctx, info) {
r.log.Debug(logs.GetCompletingTheOperation) r.log.Debug(logs.GetCompletingTheOperation)
return true return true
} }

4
pkg/services/object/get/remote.go
View file

@ -15,8 +15,8 @@ import (
var errECObjectInRepContainer = errors.New("found erasure-coded object in REP container") var errECObjectInRepContainer = errors.New("found erasure-coded object in REP container")
func (r *request) processNode(ctx context.Context, info client.NodeInfo) bool { func (r *request) processRepNode(ctx context.Context, info client.NodeInfo) bool {
ctx, span := tracing.StartSpanFromContext(ctx, "getService.processNode") ctx, span := tracing.StartSpanFromContext(ctx, "getService.processRepNode")
defer span.End() defer span.End()
r.log.Debug(logs.ProcessingNode, zap.String("node_key", hex.EncodeToString(info.PublicKey()))) r.log.Debug(logs.ProcessingNode, zap.String("node_key", hex.EncodeToString(info.PublicKey())))