Fix tcp + tls degradation

fluent#1729 introduced @buffer to TCPCallbackSocket. TLSCallbackSocket also has to have it to be used for in_tcp.
mururu · Dec 28, 2017 · ff2f5fa · ff2f5fa
1 parent bcd7d1a
commit ff2f5fa
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/lib/fluent/plugin_helper/server.rb b/lib/fluent/plugin_helper/server.rb
@@ -446,9 +446,12 @@ def write(data)
       class TLSCallbackSocket < CallbackSocket
         ENABLED_EVENTS = [:data, :write_complete, :close]
 
+        attr_accessor :buffer
+
         def initialize(sock)
           super("tls", sock, ENABLED_EVENTS)
           @peeraddr = (@sock.to_io.peeraddr rescue PEERADDR_FAILED)
+          @buffer = ''
         end
 
         def write(data)