diff --git a/lib/lumberjack/client.rb b/lib/lumberjack/client.rb index 2ab819915b099e860570573361383ebb016889e7..d7845e938ffa5c89a2b14f82b1289a2a391f2917 100644 --- a/lib/lumberjack/client.rb +++ b/lib/lumberjack/client.rb @@ -100,7 +100,7 @@ module Lumberjack public def write_hash(hash) frame = to_frame(hash, inc) - ack if (@sequence - @last_ack) >= @window_size + ack if (@sequence - (@last_ack + 1)) >= @window_size write frame end @@ -110,7 +110,7 @@ module Lumberjack type = @socket.read(1) raise "Whoa we shouldn't get this frame: #{type}" if type != "A" @last_ack = @socket.read(4).unpack("N").first - ack if (@sequence - @last_ack) >= @window_size + ack if (@sequence - (@last_ack + 1)) >= @window_size end private