yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Set stats at connection time

This commit is contained in:
zhouzb 2019-08-26 16:43:08 +08:00
parent 29d49b4073
commit 98072dd3d1
2 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
src/emqx_connection.erl
View File

@ -245,6 +245,7 @@ connected(enter, _PrevSt, State = #state{chan_state = ChanState}) ->
#{client_id := ClientId} = emqx_channel:info(client, ChanState), #{client_id := ClientId} = emqx_channel:info(client, ChanState),
ok = emqx_cm:register_channel(ClientId), ok = emqx_cm:register_channel(ClientId),
ok = emqx_cm:set_chan_attrs(ClientId, attrs(State)), ok = emqx_cm:set_chan_attrs(ClientId, attrs(State)),
ok = emqx_cm:set_chan_stats(ClientId, stats(State)),
keep_state_and_data; keep_state_and_data;
connected(cast, {incoming, Packet = ?PACKET(?CONNECT)}, State) -> connected(cast, {incoming, Packet = ?PACKET(?CONNECT)}, State) ->

1
src/emqx_ws_connection.erl
View File

@ -330,6 +330,7 @@ connected(State = #state{chan_state = ChanState}) ->
#{client_id := ClientId} = emqx_channel:info(client, ChanState), #{client_id := ClientId} = emqx_channel:info(client, ChanState),
ok = emqx_cm:register_channel(ClientId), ok = emqx_cm:register_channel(ClientId),
ok = emqx_cm:set_chan_attrs(ClientId, attrs(NState)), ok = emqx_cm:set_chan_attrs(ClientId, attrs(NState)),
ok = emqx_cm:set_chan_stats(ClientId, stats(NState)),
reply(NState). reply(NState).
%%-------------------------------------------------------------------- %%--------------------------------------------------------------------