From df4321423307346f0aa893b04480137f66cc74f8 Mon Sep 17 00:00:00 2001
From: Feng Lee <ery.lee@gmail.com>
Date: Sat, 15 Aug 2015 22:31:29 +0800
Subject: [PATCH] comment log

---
 src/emqttd_session.erl | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/src/emqttd_session.erl b/src/emqttd_session.erl
index edf8dfc66..726a83b51 100644
--- a/src/emqttd_session.erl
+++ b/src/emqttd_session.erl
@@ -476,8 +476,7 @@ handle_info({timeout, awaiting_ack, PktId}, Session = #session{client_pid = unde
     %% just remove awaiting
     noreply(Session#session{awaiting_ack = maps:remove(PktId, AwaitingAck)});
 
-handle_info({timeout, awaiting_ack, PktId}, Session = #session{client_id      = ClientId,
-                                                               inflight_queue = InflightQ,
+handle_info({timeout, awaiting_ack, PktId}, Session = #session{inflight_queue = InflightQ,
                                                                awaiting_ack   = AwaitingAck}) ->
     case maps:find(PktId, AwaitingAck) of
         {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),
             {noreply, Session#session{awaiting_ack = AwaitingAck1}};
         error ->
-            lager:error([{client, ClientId}], "Session ~s "
-                            "Cannot find Awaiting Ack:~p", [ClientId, PktId]),
+            % TODO: too many logs when overloaded...
+            % lager:error([{client, ClientId}], "Session ~s "
+            %                "Cannot find Awaiting Ack:~p", [ClientId, PktId]),
             {noreply, Session}
     end;