fix to use NumericTimeParser to parse float time (without error of fl…

…oating point value)
fluent · Nov 11, 2016 · 6a5490c · 6a5490c
1 parent 100e599
commit 6a5490c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/lib/fluent/plugin/in_http.rb b/lib/fluent/plugin/in_http.rb
@@ -137,6 +137,8 @@ def start
       event_loop_attach(@km)
       event_loop_attach(@lsock)
 
+      @float_time_parser = Fluent::NumericTimeParser.new(:float)
+
       # detach_multi_process do
       #   super
       #   @km = KeepaliveManager.new(@keepalive_timeout)
@@ -187,7 +189,7 @@ def on_request(path_info, params)
         end
         time = if param_time = params['time']
                  param_time = param_time.to_f
-                 param_time.zero? ? Fluent::Engine.now : Fluent::EventTime.from_time(Time.at(param_time))
+                 param_time.zero? ? Fluent::Engine.now : @float_time_parser.parse(param_time)
                else
                  record_time.nil? ? Fluent::Engine.now : record_time
                end