Merge pull request #223 from keynslug/fix/conn-counter

fix(stats): count connections and subscriptions independently
emqx · Aug 1, 2023 · 5e32f40 · 5e32f40
2 parents db41314 + 98adbe5
commit 5e32f40
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/emqtt_bench.erl b/src/emqtt_bench.erl
@@ -602,6 +602,7 @@ connect(Parent, N, PubSub, Opts) ->
     ContinueFn = fun() -> loop(Parent, N, Client, PubSub, loop_opts(AllOpts)) end,
     case ConnRet of
         {ok, _Props} ->
+            inc_counter(connect_succ),
             Res =
                 case PubSub of
                     conn -> ok;
@@ -619,7 +620,6 @@ connect(Parent, N, PubSub, Opts) ->
                 {error, _SubscribeError} ->
                     maybe_retry(Parent, N, PubSub, Opts, ContinueFn);
                 _ ->
-                    inc_counter(connect_succ),
                     PubSub =:= sub andalso inc_counter(sub),
                     loop(Parent, N, Client, PubSub, loop_opts(AllOpts))
             end;