sendnrw/netbird
2
0
Fork 0
mirror of https://github.com/netbirdio/netbird.git synced 2026-04-16 07:16:38 +00:00
Code Issues Packages Projects Releases Wiki Activity

[management] revert ctx dependency in get account with backpressure (#5878)

Browse Source 
(cherry picked from commit 7f666b8022)
This commit is contained in:
Vlad
2026-04-14 12:16:03 +02:00
committed by pascal
parent 4eed459f27
commit 7989bbff3b
1 changed files with 4 additions and 13 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
management/server/account_request_buffer.go
View File

@@ -63,20 +63,11 @@ func (ac *AccountRequestBuffer) GetAccountWithBackpressure(ctx context.Context,
log.WithContext(ctx).Tracef("requesting account %s with backpressure", accountID) log.WithContext(ctx).Tracef("requesting account %s with backpressure", accountID)
startTime := time.Now() startTime := time.Now()
ac.getAccountRequestCh <- req
select { result := <-req.ResultChan
case <-ctx.Done(): log.WithContext(ctx).Tracef("got account with backpressure after %s", time.Since(startTime))
return nil, ctx.Err() return result.Account, result.Err
case ac.getAccountRequestCh <- req:
}
select {
case <-ctx.Done():
return nil, ctx.Err()
case result := <-req.ResultChan:
log.WithContext(ctx).Tracef("got account with backpressure after %s", time.Since(startTime))
return result.Account, result.Err
}
} }
func (ac *AccountRequestBuffer) processGetAccountBatch(ctx context.Context, accountID string) { func (ac *AccountRequestBuffer) processGetAccountBatch(ctx context.Context, accountID string) {