Compare commits
1 Commits
nilmtools-
...
nilmtools-
Author | SHA1 | Date | |
---|---|---|---|
1988955671 |
@@ -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
|
||||||
|
Reference in New Issue
Block a user