test/plugin/in_stream.rb in fluentd-0.10.35 vs test/plugin/in_stream.rb in fluentd-0.10.36
- old
+ new
@@ -132,18 +132,20 @@
TMP_DIR = File.dirname(__FILE__) + "/../tmp"
CONFIG = %[
path #{TMP_DIR}/unix
+ backlog 1000
]
def create_driver(conf=CONFIG)
super(Fluent::UnixInput, conf)
end
def test_configure
d = create_driver
assert_equal "#{TMP_DIR}/unix", d.instance.path
+ assert_equal 1000, d.instance.backlog
end
def connect
UNIXSocket.new("#{TMP_DIR}/unix")
end