TrueCloudLab/frostfs-node
20
1
Fork 28
Code Issues 109 Pull requests 4 Projects Releases 2 Packages 4 Activity Actions

[#1639] services/object: Remove non-blocking pools for Put operation

Browse source 
Signed-off-by: Aleksey Savchuk <a.savchuk@yadro.com>
This commit is contained in:
Aleksey Savchuk 2025-02-06 11:50:12 +03:00
parent 15983ca56e
commit 1def0458ef
Signed by: a-savchuk
GPG key ID: 70C0A7FF6F9C4639
7 changed files with 6 additions and 73 deletions
Download patch file Download diff file Expand all files Collapse all files

10
pkg/services/object/common/writer/common.go
View file

@ -79,11 +79,11 @@ func (n *NodeIterator) forEachAddress(ctx context.Context, traverser *placement.
continue
}
workerPool, isLocal := n.cfg.getWorkerPool(addr.PublicKey())
isLocal := n.cfg.NetmapKeys.IsLocalKey(addr.PublicKey())
item := new(bool)
wg.Add(1)
if err := workerPool.Submit(func() {
go func() {
defer wg.Done()
err := f(ctx, NodeDescriptor{Local: isLocal, Info: addr})
@ -95,11 +95,7 @@ func (n *NodeIterator) forEachAddress(ctx context.Context, traverser *placement.
traverser.SubmitSuccess()
*item = true
}); err != nil {
wg.Done()
svcutil.LogWorkerPoolError(ctx, n.cfg.Logger, "PUT", err)
return true
}
}()
// Mark the container node as processed in order to exclude it
// in subsequent container broadcast. Note that we don't