Skip to content

Commit

Permalink
Merge pull request #966 from fluent/bye-warning-moris-0
Browse files Browse the repository at this point in the history
Suppress warnings
  • Loading branch information
tagomoris committed May 20, 2016
2 parents 120b441 + 1341204 commit 02eb1a6
Show file tree
Hide file tree
Showing 14 changed files with 64 additions and 33 deletions.
4 changes: 2 additions & 2 deletions Rakefile
Original file line number Diff line number Diff line change
Expand Up @@ -14,8 +14,8 @@ Rake::TestTask.new(:base_test) do |t|
# $ bundle exec rake base_test TEST=test/test_*.rb
t.libs << "test"
t.test_files = Dir["test/**/test_*.rb"].sort
t.verbose = false
t.warning = false
t.verbose = true
t.warning = true
t.ruby_opts = ["-Eascii-8bit:ascii-8bit"]
end

Expand Down
1 change: 1 addition & 0 deletions lib/fluent/plugin/buffer/file_chunk.rb
Original file line number Diff line number Diff line change
Expand Up @@ -44,6 +44,7 @@ def initialize(metadata, path, mode, perm: system_config.file_permission || FILE
super(metadata)
@permission = perm
@bytesize = @size = @adding_bytes = @adding_size = 0
@meta = nil

case mode
when :create then create_new_chunk(path, perm)
Expand Down
1 change: 1 addition & 0 deletions lib/fluent/plugin/filter_record_transformer.rb
Original file line number Diff line number Diff line change
Expand Up @@ -315,6 +315,7 @@ def expand(str, placeholders, force_stringify = false)
class CleanroomExpander
def expand(__str_to_eval__, tag, time, record, tag_parts, tag_prefix, tag_suffix, hostname)
tags = tag_parts # for old version compatibility
_ = tags # to suppress "unused variable" warning for tags
Thread.current[:record_transformer_record] = record # for old version compatibility
instance_eval(__str_to_eval__)
end
Expand Down
11 changes: 8 additions & 3 deletions lib/fluent/plugin/output.rb
Original file line number Diff line number Diff line change
Expand Up @@ -169,6 +169,12 @@ def initialize
@buffering = true
end
@custom_format = implement?(:custom_format)

@buffer = nil
@secondary = nil
@simple_chunking = nil
@chunk_keys = @chunk_key_time = @chunk_key_tag = nil
@flush_mode = nil
end

def acts_as_secondary(primary)
Expand Down Expand Up @@ -629,8 +635,8 @@ def handle_stream_with_standard_format(tag, es, enqueue: false)
records += 1
end
meta_and_data_bulk = {}
meta_and_data.each_pair do |meta, es|
meta_and_data_bulk[meta] = [es.to_msgpack_stream(time_int: @time_as_integer), es.size]
meta_and_data.each_pair do |meta, m_es|
meta_and_data_bulk[meta] = [m_es.to_msgpack_stream(time_int: @time_as_integer), m_es.size]
end
write_guard do
@buffer.write(meta_and_data_bulk, bulk: true, enqueue: enqueue)
Expand Down Expand Up @@ -700,7 +706,6 @@ def rollback_write(chunk_id)
end

def try_rollback_write
now = Time.now
@dequeued_chunks_mutex.synchronize do
while @dequeued_chunks.first && @dequeued_chunks.first.expired?
info = @dequeued_chunks.shift
Expand Down
2 changes: 1 addition & 1 deletion lib/fluent/plugin/storage_local.rb
Original file line number Diff line number Diff line change
Expand Up @@ -34,7 +34,7 @@ def configure(conf)
@on_memory = true
end
elsif @path
path = @path.dup
# ok
else # @_plugin_id_configured is true
raise NotImplementedError, "implement this feature later with system_config"
## TODO: get process-wide directory for plugin storage, and generate path for this plugin storage instance
Expand Down
2 changes: 1 addition & 1 deletion lib/fluent/plugin_helper/event_emitter.rb
Original file line number Diff line number Diff line change
Expand Up @@ -14,7 +14,6 @@
# limitations under the License.
#

require 'fluent/engine'
require 'fluent/time'

module Fluent
Expand Down Expand Up @@ -49,6 +48,7 @@ def initialize
end

def configure(conf)
require 'fluent/engine'
super

if label_name = conf['@label']
Expand Down
2 changes: 1 addition & 1 deletion lib/fluent/root_agent.rb
Original file line number Diff line number Diff line change
Expand Up @@ -150,7 +150,7 @@ def flush!
log.warn_backtrace
end
end
flushing_threads = []
flushing_threads << t
end
end
flushing_threads.each{|t| t.join }
Expand Down
24 changes: 18 additions & 6 deletions lib/fluent/test/input_test.rb
Original file line number Diff line number Diff line change
Expand Up @@ -99,14 +99,26 @@ def run_should_stop?
false
end

module EmitStreamWrapper
def emit_stream_callee=(method)
@emit_stream_callee = method
end
def emit_stream(tag, es)
@emit_stream_callee.call(tag, es)
end
end

def run(num_waits = 10, &block)
m = method(:emit_stream)
Engine.define_singleton_method(:emit_stream) {|tag,es|
m.call(tag, es)
}
instance.router.define_singleton_method(:emit_stream) {|tag,es|
m.call(tag, es)
}
(class << Engine; self; end).module_eval do
prepend EmitStreamWrapper
end
Engine.emit_stream_callee = m
(class << instance.router; self; end).module_eval do
prepend EmitStreamWrapper
end
instance.router.emit_stream_callee = m

super(num_waits) {
block.call if block

Expand Down
1 change: 0 additions & 1 deletion lib/fluent/test/output_test.rb
Original file line number Diff line number Diff line change
Expand Up @@ -139,7 +139,6 @@ def run(&block)
assert_equal(@expected_buffer, buffer)
end

chunks = []
lines.keys.each do |meta|
chunk = @instance.buffer.generate_chunk(meta)
chunk.append(lines[meta])
Expand Down
16 changes: 8 additions & 8 deletions test/config/test_configurable.rb
Original file line number Diff line number Diff line change
Expand Up @@ -665,14 +665,14 @@ class TestConfigurable < ::Test::Unit::TestCase
checker = lambda { |conf| ConfigurableSpec::Example0.new.configure(conf) }

assert_nothing_raised { checker.call(complete) }
assert_raise(Fluent::ConfigError) { checker.call(complete.reject{|k,v| k == "stringvalue" }) }
assert_raise(Fluent::ConfigError) { checker.call(complete.reject{|k,v| k == "boolvalue" }) }
assert_raise(Fluent::ConfigError) { checker.call(complete.reject{|k,v| k == "integervalue"}) }
assert_raise(Fluent::ConfigError) { checker.call(complete.reject{|k,v| k == "sizevalue" }) }
assert_raise(Fluent::ConfigError) { checker.call(complete.reject{|k,v| k == "timevalue" }) }
assert_raise(Fluent::ConfigError) { checker.call(complete.reject{|k,v| k == "floatvalue" }) }
assert_raise(Fluent::ConfigError) { checker.call(complete.reject{|k,v| k == "hashvalue" }) }
assert_raise(Fluent::ConfigError) { checker.call(complete.reject{|k,v| k == "arrayvalue" }) }
assert_raise(Fluent::ConfigError) { c = complete.dup; c.delete("stringvalue"); checker.call(c) }
assert_raise(Fluent::ConfigError) { c = complete.dup; c.delete("boolvalue"); checker.call(c) }
assert_raise(Fluent::ConfigError) { c = complete.dup; c.delete("integervalue"); checker.call(c) }
assert_raise(Fluent::ConfigError) { c = complete.dup; c.delete("sizevalue"); checker.call(c) }
assert_raise(Fluent::ConfigError) { c = complete.dup; c.delete("timevalue"); checker.call(c) }
assert_raise(Fluent::ConfigError) { c = complete.dup; c.delete("floatvalue"); checker.call(c) }
assert_raise(Fluent::ConfigError) { c = complete.dup; c.delete("hashvalue"); checker.call(c) }
assert_raise(Fluent::ConfigError) { c = complete.dup; c.delete("arrayvalue"); checker.call(c) }
end

test 'generates section with default values for init:true sections' do
Expand Down
4 changes: 2 additions & 2 deletions test/plugin/test_filter_record_transformer.rb
Original file line number Diff line number Diff line change
Expand Up @@ -117,13 +117,13 @@ def emit(config, msgs = [''])
config = %[
enable_ruby yes
<record>
message ${hostname} ${tag_parts.last} ${URI.encode(message)}
message ${hostname} ${tag_parts.last} ${"'" + message + "'"}
</record>
]
msgs = ['1', '2']
es = emit(config, msgs)
es.each_with_index do |(_t, r), i|
assert_equal("#{@hostname} #{@tag_parts[-1]} #{msgs[i]}", r['message'])
assert_equal("#{@hostname} #{@tag_parts[-1]} '#{msgs[i]}'", r['message'])
end
end

Expand Down
18 changes: 14 additions & 4 deletions test/plugin/test_in_http.rb
Original file line number Diff line number Diff line change
Expand Up @@ -251,7 +251,7 @@ def test_with_regexp
body = record.map { |k, v|
v.to_s
}.join(':')
res = post("/#{tag}?time=#{_time.to_s}", body)
res = post("/#{tag}?time=#{_time.to_s}", body, {'Content-Type' => 'application/octet-stream'})
assert_equal "200", res.code
}
end
Expand All @@ -273,7 +273,7 @@ def test_with_csv
d.run do
d.expected_emits.each { |tag, _time, record|
body = record.map { |k, v| v }.to_csv
res = post("/#{tag}?time=#{_time.to_s}", body)
res = post("/#{tag}?time=#{_time.to_s}", body, {'Content-Type' => 'text/comma-separated-values'})
assert_equal "200", res.code
}
end
Expand Down Expand Up @@ -308,7 +308,7 @@ def test_cors_allowed
begin
d.run do
Net::HTTP.start("127.0.0.1", PORT) do |http|
req = Net::HTTP::Post.new("/foo/bar", {"Origin" => "http://foo.com"})
req = Net::HTTP::Post.new("/foo/bar", {"Origin" => "http://foo.com", "Content-Type" => "application/octet-stream"})
res = http.request(req)

acao = res["Access-Control-Allow-Origin"]
Expand All @@ -333,7 +333,7 @@ def test_cors_disallowed
begin
d.run do
Net::HTTP.start("127.0.0.1", PORT) do |http|
req = Net::HTTP::Post.new("/foo/bar", {"Origin" => "http://bar.com"})
req = Net::HTTP::Post.new("/foo/bar", {"Origin" => "http://bar.com", "Content-Type" => "application/octet-stream"})
res = http.request(req)

response_code = res.code
Expand All @@ -352,6 +352,10 @@ def test_cors_disallowed
$test_in_http_content_types = []
$test_in_http_content_types_flag = false
module ContentTypeHook
def initialize(*args)
@io_handler = nil
super
end
def on_headers_complete(headers)
super
if $test_in_http_content_types_flag
Expand Down Expand Up @@ -402,8 +406,14 @@ def post(path, params, header = {})
http = Net::HTTP.new("127.0.0.1", PORT)
req = Net::HTTP::Post.new(path, header)
if params.is_a?(String)
unless header.has_key?('Content-Type')
header['Content-Type'] = 'application/octet-stream'
end
req.body = params
else
unless header.has_key?('Content-Type')
header['Content-Type'] = 'application/x-www-form-urlencoded'
end
req.set_form_data(params)
end
http.request(req)
Expand Down
2 changes: 0 additions & 2 deletions test/plugin/test_output_as_buffered.rb
Original file line number Diff line number Diff line change
Expand Up @@ -272,7 +272,6 @@ def waiting(seconds)
@i.register(:format){|tag,time,record| [tag,time,record].to_json + "\n" }
@i.register(:write){|chunk| chunk.read.split("\n").reject{|l| l.empty? }.each{|data| ary << data } }

tag = "test.tag"
t = event_time()
r = {}
(0...10).each do |i|
Expand Down Expand Up @@ -382,7 +381,6 @@ def waiting(seconds)
@i.register(:format){|tag,time,record| [tag,time,record].to_json + "\n" }
@i.register(:write){|chunk| chunk.read.split("\n").reject{|l| l.empty? }.each{|data| ary << data } }

tag = "test.tag"
t = event_time()
r = {}
(0...10).each do |i|
Expand Down
9 changes: 7 additions & 2 deletions test/plugin/test_output_as_buffered_overflow.rb
Original file line number Diff line number Diff line change
Expand Up @@ -15,6 +15,10 @@ def register(name, &block)
end
end
class DummyAsyncOutput < DummyBareOutput
def initialize
super
@format = @write = nil
end
def format(tag, time, record)
@format ? @format.call(tag, time, record) : [tag, time, record].to_json
end
Expand All @@ -37,7 +41,8 @@ def waiting(seconds)
yield
end
rescue Timeout::Error
STDERR.print *(@i.log.out.logs)
logs = @i.log.out.logs
STDERR.print(*logs)
raise
end
end
Expand Down Expand Up @@ -133,7 +138,7 @@ def waiting(seconds)

assert !@i.buffer.storable?

thread = Thread.new do
Thread.new do
sleep 3
failing = false
end
Expand Down

0 comments on commit 02eb1a6

Please sign in to comment.