Преглед изворни кода

Fix case_clause in issue#3455

zhouzb пре 5 година
родитељ
комит
80e2bd19b9
1 измењених фајлова са 4 додато и 4 уклоњено
  1. 4 4
      src/emqx_channel.erl

+ 4 - 4
src/emqx_channel.erl

@@ -896,10 +896,10 @@ handle_timeout(_TRef, expire_awaiting_rel,
 handle_timeout(_TRef, expire_awaiting_rel,
 handle_timeout(_TRef, expire_awaiting_rel,
                Channel = #channel{session = Session}) ->
                Channel = #channel{session = Session}) ->
     case emqx_session:expire(awaiting_rel, Session) of
     case emqx_session:expire(awaiting_rel, Session) of
-        {ok, Session} ->
-            {ok, clean_timer(await_timer, Channel#channel{session = Session})};
-        {ok, Timeout, Session} ->
-            {ok, reset_timer(await_timer, Timeout, Channel#channel{session = Session})}
+        {ok, NSession} ->
+            {ok, clean_timer(await_timer, Channel#channel{session = NSession})};
+        {ok, Timeout, NSession} ->
+            {ok, reset_timer(await_timer, Timeout, Channel#channel{session = NSession})}
     end;
     end;
 
 
 handle_timeout(_TRef, expire_session, Channel) ->
 handle_timeout(_TRef, expire_session, Channel) ->