Fix tcp + ssl degradation

fluent#1729 introduced @buffer to TCPCallbackSocket. TLSCallbackSocket has to have it to be used for in_tcp.
mururu · Dec 28, 2017 · 6dfd56d · 6dfd56d
1 parent 7c54760
commit 6dfd56d
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)