|
@@ -27,6 +27,7 @@ class Probe:
|
|
|
return None
|
|
return None
|
|
|
|
|
|
|
|
# Parse streams
|
|
# Parse streams
|
|
|
|
|
+ prefix = None
|
|
|
stream = None
|
|
stream = None
|
|
|
for line in data.splitlines():
|
|
for line in data.splitlines():
|
|
|
if line == "[STREAM]":
|
|
if line == "[STREAM]":
|
|
@@ -34,9 +35,15 @@ class Probe:
|
|
|
elif line == "[/STREAM]":
|
|
elif line == "[/STREAM]":
|
|
|
streams.append(stream)
|
|
streams.append(stream)
|
|
|
steam = None
|
|
steam = None
|
|
|
|
|
+ if line == "[SIDE_DATA]":
|
|
|
|
|
+ prefix = 'SIDE_DATA'
|
|
|
|
|
+ elif line == "[/SIDE_DATA]":
|
|
|
|
|
+ prefix = None
|
|
|
elif stream is not None:
|
|
elif stream is not None:
|
|
|
try:
|
|
try:
|
|
|
(key, val) = line.split('=', 1)
|
|
(key, val) = line.split('=', 1)
|
|
|
|
|
+ if prefix is not None:
|
|
|
|
|
+ key = f"{prefix}:{key}"
|
|
|
except ValueError:
|
|
except ValueError:
|
|
|
self.logger.error(f"Skipping unexpected stream data ({path}): {line}")
|
|
self.logger.error(f"Skipping unexpected stream data ({path}): {line}")
|
|
|
continue
|
|
continue
|