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

Fix duplicate send pubrec packet

This commit is contained in:
turtled 2017-04-18 17:19:04 +08:00
parent aa360d4378
commit 9d3676884c
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/emqttd_session.erl
View File

@ -738,7 +738,7 @@ acked(pubrec, PacketId, State = #state{client_id = ClientId,
emqttd_hooks:run('message.acked', [ClientId, Username], Msg), emqttd_hooks:run('message.acked', [ClientId, Username], Msg),
State#state{inflight = Inflight:update(PacketId, {pubrel, PacketId, os:timestamp()})}; State#state{inflight = Inflight:update(PacketId, {pubrel, PacketId, os:timestamp()})};
{pubrel, PacketId, _Ts} -> {pubrel, PacketId, _Ts} ->
?LOG(error, "~p packet_id:~p, duplicate send pubrec packet", [ClientId, PacketId], State), ?LOG(warning, "Duplicated PUBREC Packet: ~p", [PacketId], State),
State State
end; end;