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

[#1709] qos: Add context.Done check before schedule request

Browse source 
Do not push request to schedule queue, if context is already cancelled.

Change-Id: Ieef837a7d423158e3dbb0c3b4efecaa20744c845
Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>
This commit is contained in:
Dmitrii Stepanov 2025-04-21 10:53:51 +03:00
parent 4bcb672630
commit a27e003508
Signed by: dstepanov-yadro
GPG key ID: 237AF1A763293BC0
1 changed files with 5 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
internal/qos/limiter.go
View file

@ -149,6 +149,11 @@ func (n *mClockLimiter) WriteRequest(ctx context.Context) (ReleaseFunc, error) {
} }
func requestArrival(ctx context.Context, s scheduler, stats map[string]*stat) (ReleaseFunc, error) { func requestArrival(ctx context.Context, s scheduler, stats map[string]*stat) (ReleaseFunc, error) {
select {
case <-ctx.Done():
return nil, ctx.Err()
default:
}
tag, ok := tagging.IOTagFromContext(ctx) tag, ok := tagging.IOTagFromContext(ctx)
if !ok { if !ok {
tag = IOTagClient.String() tag = IOTagClient.String()