yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #8153 from lafirest/fix/limiter_obtained 

fix(limiter): fix initial value error for `obtained`
This commit is contained in:
lafirest 2022-06-08 13:46:30 +08:00 committed by GitHub
parent 91578a10f3 d863a60cff
commit 0aab063dd5
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apps/emqx/src/emqx_limiter/src/emqx_limiter_server.erl
View File

@ -507,6 +507,7 @@ make_bucket([{Name, Conf} | T], Type, GlobalCfg, Factor, CounterNum, DelayBucket
infinity ->
Rate = infinity,
Capacity = infinity,
Initial = 0,
Ref = emqx_limiter_bucket_ref:new(undefined, undefined, Rate),
emqx_limiter_manager:insert_bucket(Path, Ref),
CounterNum2 = CounterNum,
@ -528,7 +529,7 @@ make_bucket([{Name, Conf} | T], Type, GlobalCfg, Factor, CounterNum, DelayBucket
Bucket = #{
name => Name,
rate => Rate,
obtained => 0,
obtained => Initial,
correction => 0,
capacity => Capacity,
counter => undefined,