From d863a60cffee41a317c0b8f1ae7465c6d665232e Mon Sep 17 00:00:00 2001
From: firest <blankalupo@163.com>
Date: Tue, 7 Jun 2022 18:17:06 +0800
Subject: [PATCH] fix(limiter): fix initial value error for `obtained`

---
 apps/emqx/src/emqx_limiter/src/emqx_limiter_server.erl | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/apps/emqx/src/emqx_limiter/src/emqx_limiter_server.erl b/apps/emqx/src/emqx_limiter/src/emqx_limiter_server.erl
index 8cb763a41..4ae6308f0 100644
--- a/apps/emqx/src/emqx_limiter/src/emqx_limiter_server.erl
+++ b/apps/emqx/src/emqx_limiter/src/emqx_limiter_server.erl
@@ -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,