Commit f23e3ff6 authored by Ad Schellevis's avatar Ad Schellevis

(netflow, parse) fix time

parent 905c56f1
...@@ -100,7 +100,7 @@ def parse_flow(recv_stamp): ...@@ -100,7 +100,7 @@ def parse_flow(recv_stamp):
continue continue
if flow.has_field(flowd.FIELD_FLOW_TIMES): if flow.has_field(flowd.FIELD_FLOW_TIMES):
# calculate flow start, end, duration in ms # calculate flow start, end, duration in ms
flow_record['flow_end'] = (flow.recv_sec - flow.flow_finish / 1000.0) flow_record['flow_end'] = (flow.recv_sec - flow.flow_finish / 1000.0 + flow.sys_uptime_ms/1000.0)
flow_record['duration_ms'] = (flow.flow_finish - flow.flow_start) flow_record['duration_ms'] = (flow.flow_finish - flow.flow_start)
flow_record['flow_start'] = flow_record['flow_end'] - flow_record['duration_ms'] / 1000.0 flow_record['flow_start'] = flow_record['flow_end'] - flow_record['duration_ms'] / 1000.0
# handle source data # handle source data
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment