From 983973c84142d94ed60ec7b63fd2476d0400ef84 Mon Sep 17 00:00:00 2001 From: terry-xiaoyu <506895667@qq.com> Date: Thu, 5 Sep 2019 15:59:18 +0800 Subject: [PATCH] Fix set_chan_stats incorrect --- src/emqx_channel.erl | 2 +- test/emqx_client_SUITE.erl | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/emqx_channel.erl b/src/emqx_channel.erl index 65989d9e7..9120e10cb 100644 --- a/src/emqx_channel.erl +++ b/src/emqx_channel.erl @@ -655,7 +655,7 @@ handle_call(Req, Channel) -> handle_cast({register, Attrs, Stats}, #channel{client = #{client_id := ClientId}}) -> ok = emqx_cm:register_channel(ClientId), emqx_cm:set_chan_attrs(ClientId, Attrs), - emqx_cm:set_chan_attrs(ClientId, Stats); + emqx_cm:set_chan_stats(ClientId, Stats); handle_cast(Msg, Channel) -> ?LOG(error, "Unexpected cast: ~p", [Msg]), diff --git a/test/emqx_client_SUITE.erl b/test/emqx_client_SUITE.erl index a00d95603..660892112 100644 --- a/test/emqx_client_SUITE.erl +++ b/test/emqx_client_SUITE.erl @@ -100,7 +100,7 @@ t_cm(_) -> emqtt:subscribe(C, <<"mytopic">>, 0), ct:sleep(1200), Stats = emqx_cm:get_chan_stats(ClientId), - ?assertEqual(1, proplists:get_value(subscriptions, Stats)), + ?assertEqual(1, proplists:get_value(subscriptions_cnt, Stats)), emqx_zone:set_env(external, idle_timeout, IdleTimeout). t_cm_registry(_) ->