From 282e6ff218e18e82d8706b0bb01f70eba4e34473 Mon Sep 17 00:00:00 2001 From: Zhongwen Deng Date: Thu, 24 Nov 2022 09:59:39 +0800 Subject: [PATCH] chore: set channel info once --- apps/emqx/src/emqx_connection.erl | 3 +-- apps/emqx_gateway/src/bhvrs/emqx_gateway_impl.erl | 2 +- 2 files changed, 2 insertions(+), 3 deletions(-) diff --git a/apps/emqx/src/emqx_connection.erl b/apps/emqx/src/emqx_connection.erl index 4ebc5b5e6..d892f5acc 100644 --- a/apps/emqx/src/emqx_connection.erl +++ b/apps/emqx/src/emqx_connection.erl @@ -601,8 +601,7 @@ handle_msg({event, disconnected}, State = #state{channel = Channel}) -> {ok, State}; handle_msg({event, _Other}, State = #state{channel = Channel}) -> ClientId = emqx_channel:info(clientid, Channel), - emqx_cm:set_chan_info(ClientId, info(State)), - emqx_cm:set_chan_stats(ClientId, stats(State)), + emqx_cm:insert_channel_info(ClientId, info(State), stats(State)), {ok, State}; handle_msg({timeout, TRef, TMsg}, State) -> handle_timeout(TRef, TMsg, State); diff --git a/apps/emqx_gateway/src/bhvrs/emqx_gateway_impl.erl b/apps/emqx_gateway/src/bhvrs/emqx_gateway_impl.erl index cb4c61771..df66e2854 100644 --- a/apps/emqx_gateway/src/bhvrs/emqx_gateway_impl.erl +++ b/apps/emqx_gateway/src/bhvrs/emqx_gateway_impl.erl @@ -16,7 +16,7 @@ -module(emqx_gateway_impl). --include("include/emqx_gateway.hrl"). +-include("emqx_gateway.hrl"). -type state() :: map(). -type reason() :: any().