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

[#1608] policer: Add IO tag to context

Browse source 
Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>
This commit is contained in:
Dmitrii Stepanov 2025-01-29 17:45:40 +03:00
parent acec938b2d
commit bfe325e61d
Signed by: dstepanov-yadro
GPG key ID: 237AF1A763293BC0
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
pkg/services/policer/process.go
View file

@ -7,7 +7,9 @@ import (
"time" "time"
"git.frostfs.info/TrueCloudLab/frostfs-node/internal/logs" "git.frostfs.info/TrueCloudLab/frostfs-node/internal/logs"
"git.frostfs.info/TrueCloudLab/frostfs-node/internal/qos"
"git.frostfs.info/TrueCloudLab/frostfs-node/pkg/local_object_storage/engine" "git.frostfs.info/TrueCloudLab/frostfs-node/pkg/local_object_storage/engine"
"git.frostfs.info/TrueCloudLab/frostfs-qos/tagging"
cid "git.frostfs.info/TrueCloudLab/frostfs-sdk-go/container/id" cid "git.frostfs.info/TrueCloudLab/frostfs-sdk-go/container/id"
"go.uber.org/zap" "go.uber.org/zap"
) )
@ -18,6 +20,7 @@ func (p *Policer) Run(ctx context.Context) {
} }
func (p *Policer) shardPolicyWorker(ctx context.Context) { func (p *Policer) shardPolicyWorker(ctx context.Context) {
ctx = tagging.ContextWithIOTag(ctx, qos.IOTagPolicer.String())
for { for {
select { select {
case <-ctx.Done(): case <-ctx.Done():