Bit more logging

src/mtp_down_conn.erl

@@ -115,6 +115,8 @@ handle_info(do_connect, #state{dc_id = DcId} = State) ->
 
 terminate(_Reason, #state{upstreams = Ups}) ->
     %% Should I do this or dc_pool? Maybe only when reason is 'normal'?
+    lager:warning("Downstream terminates with reason ~p; len(upstreams)=~p",
+                  [_Reason, map_size(Ups)]),
     Self = self(),
     lists:foreach(
       fun(Upstream) ->
@@ -228,7 +230,7 @@ up_send(Packet, ConnId, #state{upstreams_rev = UpsRev} = St) ->
         ok = mtp_handler:send(Upstream, Packet),
         St;
       error ->
-        lager:warning("Unknown connection_id=~w; ups=~w", [ConnId, maps:keys(UpsRev)]),
+        lager:warning("Unknown connection_id=~w", [ConnId]),
         ClosedPacket = mtp_rpc:encode_packet(remote_closed, ConnId),
         {ok, St1} = down_send(ClosedPacket, St),
         St1

src/mtp_handler.erl

@@ -176,7 +176,7 @@ terminate(_Reason, #state{started_at = Started} = S) ->
     mtp_metric:histogram_observe(
       [?APP, session_lifetime, seconds],
       erlang:convert_time_unit(Lifetime, millisecond, native), #{}),
-    lager:debug("terminate ~p", [_Reason]),
+    lager:info("terminate ~p", [_Reason]),
     ok.
 
 code_change(_OldVsn, State, _Extra) ->
@@ -262,7 +262,7 @@ up_send(Packet, #state{stage = tunnel,
                        codec = UpCodec,
                        sock = Sock,
                        transport = Transport} = S) ->
-    lager:debug(">TG: ~p", [Packet]),
+    %% lager:debug(">Up: ~p", [Packet]),
     {Encoded, UpCodec1} = mtp_layer:encode_packet(Packet, UpCodec),
     mtp_metric:rt([?APP, upstream_send_duration, seconds],
               fun() ->
@@ -280,7 +280,7 @@ up_send(Packet, #state{stage = tunnel,
     {ok, S#state{codec = UpCodec1}}.
 
 down_send(Packet, #state{down = Down} = S) ->
-    lager:debug("<TG: ~p", [Packet]),
+    %% lager:debug(">Down: ~p", [Packet]),
     ok = mtp_down_conn:send(Down, Packet),
     {ok, S}.