From d25225ff232b1a7169b55be7f177dd75810313d6 Mon Sep 17 00:00:00 2001
From: Masahiro Nakagawa <repeatedly@gmail.com>
Date: Wed, 17 Aug 2016 06:27:54 +0900
Subject: [PATCH] Fix es_size typo. fix #1163

---
 lib/fluent/compat/output.rb | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/lib/fluent/compat/output.rb b/lib/fluent/compat/output.rb
index 24cbf386cd..d169a6818c 100644
--- a/lib/fluent/compat/output.rb
+++ b/lib/fluent/compat/output.rb
@@ -361,11 +361,12 @@ def handle_stream_simple(tag, es, enqueue: false)
         end
 
         meta = metadata(nil, nil, nil)
+        size = es.size
         data = es.map{|time,record| format(tag, time, record) }
         write_guard do
           @buffer.write({meta => data}, enqueue: enqueue)
         end
-        @counters_monitor.synchronize{ @emit_records += es_size }
+        @counters_monitor.synchronize{ @emit_records += size }
         [meta]
       end