class Fluent::StreamOutput

def configure(conf)
  super
end

def flush_secondary(secondary)
  unless secondary.is_a?(StreamOutput)
    secondary = ReformatWriter.new(secondary)
  end
  @buffer.pop(secondary)
end

def format_stream(tag, es)
  # use PackedForward
  [tag, es.to_msgpack_stream].to_msgpack
end

def initialize
  require 'socket'
  require 'fileutils'
  super
end

def write(chunk)
  sock = connect
  begin
    opt = [1, @send_timeout.to_i].pack('I!I!')  # { int l_onoff; int l_linger; }
    sock.setsockopt(Socket::SOL_SOCKET, Socket::SO_LINGER, opt)
    opt = [@send_timeout.to_i, 0].pack('L!L!')  # struct timeval
    sock.setsockopt(Socket::SOL_SOCKET, Socket::SO_SNDTIMEO, opt)
    chunk.write_to(sock)
  ensure
    sock.close
  end
end