Compare commits

...

1 Commits

Author SHA1 Message Date
1988955671 Accumulate delta separately from data timestamp 2013-04-05 17:41:48 -04:00

View File

@@ -132,9 +132,10 @@ def main(argv = None):
data_ts_base = 0 data_ts_base = 0
data_ts_inc = 0 data_ts_inc = 0
data_ts_rate = args.rate data_ts_rate = args.rate
data_ts_delta = 0
def get_data_ts(): def get_data_ts():
if args.delta: if args.delta:
return data_ts_base return data_ts_base + data_ts_delta
else: else:
return data_ts_base + rate_to_period(data_ts_rate, return data_ts_base + rate_to_period(data_ts_rate,
data_ts_inc) data_ts_inc)
@@ -207,12 +208,12 @@ def main(argv = None):
pass pass
continue continue
# If --delta mode, increment data_ts_base by the delta # If --delta mode, increment data_ts_delta by the
# from the file. # delta from the file.
if args.delta: if args.delta:
try: try:
(delta, line) = line.split(None, 1) (delta, line) = line.split(None, 1)
data_ts_base += float(delta) data_ts_delta += float(delta)
except ValueError: except ValueError:
raise ParseError(filename, "can't parse delta") raise ParseError(filename, "can't parse delta")
@@ -247,7 +248,7 @@ def main(argv = None):
timestamp_to_human(clock_ts)) timestamp_to_human(clock_ts))
stream.finalize() stream.finalize()
data_ts_base = data_ts = clock_ts data_ts_base = data_ts = clock_ts
data_ts_inc = 0 data_ts_inc = data_ts_delta = 0
# Don't use this clock time anymore until we update it # Don't use this clock time anymore until we update it
clock_ts = None clock_ts = None