Procházet zdrojové kódy

Merge pull request #2836 from emqx/fix-discard

Fix case clause error
tigercl před 6 roky
rodič
revize
7151ae9823
2 změnil soubory, kde provedl 1 přidání a 4 odebrání
  1. 0 3
      src/emqx_channel.erl
  2. 1 1
      src/emqx_cm.erl

+ 0 - 3
src/emqx_channel.erl

@@ -610,9 +610,6 @@ handle_call(Req, Channel) ->
 %% Handle cast
 %% Handle cast
 %%--------------------------------------------------------------------
 %%--------------------------------------------------------------------
 
 
-handle_cast(discard, Channel) ->
-    {stop, {shutdown, discarded}, Channel};
-
 handle_cast(Msg, Channel) ->
 handle_cast(Msg, Channel) ->
     ?LOG(error, "Unexpected cast: ~p", [Msg]),
     ?LOG(error, "Unexpected cast: ~p", [Msg]),
     {ok, Channel}.
     {ok, Channel}.

+ 1 - 1
src/emqx_cm.erl

@@ -233,7 +233,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
-        #{conn_mod := ConnMod} ->
+        #{client := #{conn_mod := ConnMod}} ->
             ConnMod:discard(ChanPid);
             ConnMod:discard(ChanPid);
         undefined -> ok
         undefined -> ok
     end;
     end;