Mirrors/blakeblackshear.frigate
1
0
Fork 0
mirror of https://github.com/blakeblackshear/frigate.git synced 2024-11-21 19:07:46 +01:00
Code Issues Projects Releases Wiki Activity

add duration to cache

Browse Source
This commit is contained in:
Blake Blackshear 2021-11-19 16:56:00 -06:00
parent a748b70da1
commit 173eaabddf
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
frigate/record.py
View File

@ -129,7 +129,7 @@ class RecordingMaintainer(threading.Thread):
continue continue
if cache_path in self.end_time_cache: if cache_path in self.end_time_cache:
end_time = self.end_time_cache[cache_path] end_time, duration = self.end_time_cache[cache_path]
else: else:
ffprobe_cmd = [ ffprobe_cmd = [
"ffprobe", "ffprobe",
@ -144,9 +144,8 @@ class RecordingMaintainer(threading.Thread):
p = sp.run(ffprobe_cmd, capture_output=True) p = sp.run(ffprobe_cmd, capture_output=True)
if p.returncode == 0: if p.returncode == 0:
duration = float(p.stdout.decode().strip()) duration = float(p.stdout.decode().strip())
self.end_time_cache[ end_time = start_time + datetime.timedelta(seconds=duration)
cache_path self.end_time_cache[cache_path] = (end_time, duration)
] = end_time = start_time + datetime.timedelta(seconds=duration)
else: else:
logger.warning(f"Discarding a corrupt recording segment: {f}") logger.warning(f"Discarding a corrupt recording segment: {f}")
Path(cache_path).unlink(missing_ok=True) Path(cache_path).unlink(missing_ok=True)