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

Fix crash

This commit is contained in:
zhouzb 2019-09-20 20:27:08 +08:00
parent b72a82e50b
commit db1cf4469b
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/emqx_cm.erl
View File

@ -239,7 +239,7 @@ discard_session(ClientId) when is_binary(ClientId) ->
discard_session(ClientId, ChanPid) when node(ChanPid) == node() -> discard_session(ClientId, ChanPid) when node(ChanPid) == node() ->
case get_chan_attrs(ClientId, ChanPid) of case get_chan_attrs(ClientId, ChanPid) of
#{client := #{conn_mod := ConnMod}} -> #{conninfo := #{conn_mod := ConnMod}} ->
ConnMod:call(ChanPid, discard); ConnMod:call(ChanPid, discard);
undefined -> ok undefined -> ok
end; end;