Adjust the formula to account for network hiccups

Author: lhoguin

deps/rabbit/src/rabbit_reader.erl

@@ -546,10 +546,11 @@ maybe_resize_buffer(State=#v1{sock=Sock, dynamic_buffer_size=BufferSize0,
     LowDynamicBuffer = 1024,
     HighDynamicBuffer = 131072,
     DataLen = byte_size(Data),
-    MovingAvg = (MovingAvg0 + DataLen) div 2,
+    MovingAvg = (MovingAvg0 * 31 + DataLen) div 32,
     if
         BufferSize0 < HighDynamicBuffer andalso MovingAvg > BufferSize0 * 0.9 ->
             BufferSize = min(BufferSize0 * 2, HighDynamicBuffer),
+%            erlang:display({up,BufferSize}),
             case rabbit_net:setopts(Sock, [{buffer, BufferSize}]) of
                 ok -> State#v1{
                     dynamic_buffer_size=BufferSize,
@@ -560,6 +561,7 @@ maybe_resize_buffer(State=#v1{sock=Sock, dynamic_buffer_size=BufferSize0,
             end;
         BufferSize0 > LowDynamicBuffer andalso MovingAvg < BufferSize0 * 0.4 ->
             BufferSize = max(BufferSize0 div 2, LowDynamicBuffer),
+%            erlang:display({down,BufferSize}),
             case rabbit_net:setopts(Sock, [{buffer, BufferSize}]) of
                 ok -> State#v1{
                     dynamic_buffer_size=BufferSize,