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

Merge pull request #231 from bobtfish/fix_source_host

Browse source 
Fix @source_host when it comes from json_event
This commit is contained in:
Jordan Sissel 2012-12-27 15:51:24 -08:00
commit 9bf5efdfcc
1 changed files with 7 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

10
lib/logstash/event.rb
View file

@ -16,6 +16,7 @@ class LogStash::Event
@cancelled = false @cancelled = false
@data = { @data = {
"@source_host" => false,
"@source" => "unknown", "@source" => "unknown",
"@tags" => [], "@tags" => [],
"@fields" => {}, "@fields" => {},
@ -91,16 +92,19 @@ class LogStash::Event
public public
def source; @data["@source"]; end # def source def source; @data["@source"]; end # def source
def source=(val) def source=(val)
uri = URI.parse(val) rescue nil uri = URI.parse(val) rescue nil
val = uri if uri val = uri if uri
if val.is_a?(URI) if val.is_a?(URI)
@data["@source"] = val.to_s @data["@source"] = val.to_s
@data["@source_host"] = val.host maybe_new_source_host = val.host
@data["@source_path"] = val.path @data["@source_path"] = val.path
else else
@data["@source"] = val @data["@source"] = val
@data["@source_host"] = val maybe_new_source_host = val
end
if !@data["@source_host"]
@data["@source_host"] = maybe_new_source_host
end end
end # def source= end # def source=