github-mirrors/logstash
1
0
Fork 0
mirror of https://github.com/elastic/logstash.git synced 2025-04-24 14:47:19 -04:00
Code Issues Projects Releases Packages Wiki Activity

LOGSTASH-309: work around a jruby bug and use native java.io for writing to fifos

Browse source
This commit is contained in:
Pete Fritchman 2012-01-01 02:43:32 -05:00
parent 9326b494f0
commit 96376a97b0
1 changed files with 9 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

12
lib/logstash/outputs/file.rb
View file

@ -46,9 +46,9 @@ class LogStash::Outputs::File < LogStash::Outputs::Base
# TODO(sissel): Check if we should close files not recently used.
if @message_format
fd.puts(event.sprintf(@message_format))
fd.write(event.sprintf(@message_format) + "\n")
else
fd.puts(event.to_json)
fd.write(event.to_json + "\n")
end
fd.flush
end # def receive
@ -65,6 +65,12 @@ class LogStash::Outputs::File < LogStash::Outputs::Base
FileUtils.mkdir_p(dir)
end
@files[path] = File.new(path, "a")
# work around a bug opening fifos (bug JRUBY-6280)
stat = File.stat(path) rescue nil
if stat and stat.ftype == "fifo"
@files[path] = java.io.FileWriter.new(java.io.File.new(path))
else
@files[path] = File.new(path, "a")
end
end
end # class LogStash::Outputs::Gelf