Fix tcp + ssl degradation

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