lib/fluent/plugin/parser_netflow_v5.rb in fluent-plugin-netflowipfix-1.0.2 vs lib/fluent/plugin/parser_netflow_v5.rb in fluent-plugin-netflowipfix-1.1.0

@@ -69,11 +69,10 @@
 				super
 			end # def configure
 
 
 
-
       def handle_v5(host, packet, block)
         packet.records.each do |flowset|
           # handle_flowset_data(host, packet, flowset, block, null, null)
 
           record = {
@@ -109,10 +108,10 @@
             record["first_switched"] = format_for_switched(msec_from_boot_to_time(record["first_switched"], packet.uptime, packet.unix_sec, packet.unix_nsec))
             record["last_switched"]  = format_for_switched(msec_from_boot_to_time(record["last_switched"] , packet.uptime, packet.unix_sec, packet.unix_nsec))
           end # unless
 
           time = Time.at(packet.unix_sec, packet.unix_nsec / 1000).to_i # TODO: Fluent::EventTime
-          block.call(time, record)
+          block.call(time, record, host)
         end # do flowset
       end # def handle_v5