fix(stats): count connections and subscriptions independently

emqx · Aug 1, 2023 · 98adbe5 · 98adbe5
1 parent db41314
commit 98adbe5
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;