backport of commit 0ab8cfdff681dc42753e080481ae3e9dca6e4031 (#24138)
Co-authored-by: davidadeleon <56207066+davidadeleon@users.noreply.github.com>
This commit is contained in:
parent
9576418a5e
commit
de1275adad
|
@ -0,0 +1,3 @@
|
||||||
|
```release-note:bug
|
||||||
|
core/quotas: Close rate-limit blocked client purge goroutines when sealing
|
||||||
|
```
|
|
@ -814,6 +814,13 @@ func (m *Manager) resetCache() error {
|
||||||
}
|
}
|
||||||
if quota != nil {
|
if quota != nil {
|
||||||
rlq := quota.(*RateLimitQuota)
|
rlq := quota.(*RateLimitQuota)
|
||||||
|
|
||||||
|
// Cancel the quota's purgeBlockedClients goroutine
|
||||||
|
err = rlq.close(context.Background())
|
||||||
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
err = rlq.store.Close(context.Background())
|
err = rlq.store.Close(context.Background())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
|
Loading…
Reference in New Issue