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

comment log

This commit is contained in:
Feng Lee 2015-08-15 22:31:29 +08:00
parent 786ffa2ab8
commit df43214233
1 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
src/emqttd_session.erl
View File

@ -476,8 +476,7 @@ handle_info({timeout, awaiting_ack, PktId}, Session = #session{client_pid = unde
%% just remove awaiting %% just remove awaiting
noreply(Session#session{awaiting_ack = maps:remove(PktId, AwaitingAck)}); noreply(Session#session{awaiting_ack = maps:remove(PktId, AwaitingAck)});
handle_info({timeout, awaiting_ack, PktId}, Session = #session{client_id = ClientId, handle_info({timeout, awaiting_ack, PktId}, Session = #session{inflight_queue = InflightQ,
inflight_queue = InflightQ,
awaiting_ack = AwaitingAck}) -> awaiting_ack = AwaitingAck}) ->
case maps:find(PktId, AwaitingAck) of case maps:find(PktId, AwaitingAck) of
{ok, {{0, _Timeout}, _TRef}} -> {ok, {{0, _Timeout}, _TRef}} ->
@ -489,8 +488,9 @@ handle_info({timeout, awaiting_ack, PktId}, Session = #session{client_id =
AwaitingAck1 = maps:put(PktId, {{Retries-1, Timeout*2}, TRef}, AwaitingAck), AwaitingAck1 = maps:put(PktId, {{Retries-1, Timeout*2}, TRef}, AwaitingAck),
{noreply, Session#session{awaiting_ack = AwaitingAck1}}; {noreply, Session#session{awaiting_ack = AwaitingAck1}};
error -> error ->
lager:error([{client, ClientId}], "Session ~s " % TODO: too many logs when overloaded...
"Cannot find Awaiting Ack:~p", [ClientId, PktId]), % lager:error([{client, ClientId}], "Session ~s "
% "Cannot find Awaiting Ack:~p", [ClientId, PktId]),
{noreply, Session} {noreply, Session}
end; end;