require 'test/unit' require 'fileutils' require 'fluent/log' require 'fluent/test' unless defined?(Test::Unit::AssertionFailedError) class Test::Unit::AssertionFailedError < StandardError end end def unused_port s = TCPServer.open(0) port = s.addr[1] s.close port end def ipv6_enabled? require 'socket' begin TCPServer.open("::1", 0) true rescue false end end $log = Fluent::Log.new(Fluent::Test::DummyLogDevice.new, Fluent::Log::LEVEL_WARN)