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

refactor: make clauses safe for future reordering

This commit is contained in:
Tobias Lindahl 2021-12-07 16:14:32 +01:00
parent e6ecc6ca60
commit 14bef1ba31
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx/src/emqx_channel.erl
View File

@ -796,6 +796,7 @@ handle_deliver(Delivers, Channel = #channel{takeover = true,
{ok, Channel#channel{pendings = NPendings}}; {ok, Channel#channel{pendings = NPendings}};
handle_deliver(Delivers, Channel = #channel{conn_state = disconnected, handle_deliver(Delivers, Channel = #channel{conn_state = disconnected,
takeover = false,
session = Session, session = Session,
clientinfo = #{clientid := ClientId}}) -> clientinfo = #{clientid := ClientId}}) ->
Delivers1 = maybe_nack(Delivers), Delivers1 = maybe_nack(Delivers),
@ -807,6 +808,7 @@ handle_deliver(Delivers, Channel = #channel{conn_state = disconnected,
{ok, NChannel}; {ok, NChannel};
handle_deliver(Delivers, Channel = #channel{session = Session, handle_deliver(Delivers, Channel = #channel{session = Session,
takeover = false,
clientinfo = #{clientid := ClientId} clientinfo = #{clientid := ClientId}
}) -> }) ->
case emqx_session:deliver(emqx_session:ignore_local(Delivers, ClientId, Session), Session) of case emqx_session:deliver(emqx_session:ignore_local(Delivers, ClientId, Session), Session) of