Add ffmpeg stderr logging to diagnose audio pipeline issues

- Capture both rtl_fm and ffmpeg stderr to separate log files
- Log ffmpeg errors at stream request and during timeouts
- Helps identify if ffmpeg is the source of zero-byte streaming

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
Smittix
2026-01-15 16:51:16 +00:00
parent b27a532bce
commit a3fd6881df
+38 -9
View File
@@ -439,9 +439,10 @@ def _start_audio_stream(frequency: float, modulation: str):
try: try:
# Use shell pipe for reliable streaming (Python subprocess piping can be unreliable) # Use shell pipe for reliable streaming (Python subprocess piping can be unreliable)
# Log stderr to a temp file so we can see any errors from rtl_fm # Log stderr to temp files so we can see any errors from rtl_fm and ffmpeg
stderr_log = '/tmp/rtl_fm_stderr.log' rtl_stderr_log = '/tmp/rtl_fm_stderr.log'
shell_cmd = f"{' '.join(sdr_cmd)} 2>{stderr_log} | {' '.join(encoder_cmd)}" ffmpeg_stderr_log = '/tmp/ffmpeg_stderr.log'
shell_cmd = f"{' '.join(sdr_cmd)} 2>{rtl_stderr_log} | {' '.join(encoder_cmd)} 2>{ffmpeg_stderr_log}"
logger.info(f"Starting audio pipeline: {shell_cmd}") logger.info(f"Starting audio pipeline: {shell_cmd}")
audio_rtl_process = None # Not used in shell mode audio_rtl_process = None # Not used in shell mode
@@ -458,24 +459,37 @@ def _start_audio_stream(frequency: float, modulation: str):
time.sleep(0.3) time.sleep(0.3)
if audio_process.poll() is not None: if audio_process.poll() is not None:
# Read rtl_fm stderr from temp file # Read stderr from temp files
rtl_stderr = '' rtl_stderr = ''
ffmpeg_stderr = ''
try: try:
with open(stderr_log, 'r') as f: with open(rtl_stderr_log, 'r') as f:
rtl_stderr = f.read().strip() rtl_stderr = f.read().strip()
except: except:
pass pass
logger.error(f"Audio pipeline exited immediately. rtl_fm stderr: {rtl_stderr}") try:
with open(ffmpeg_stderr_log, 'r') as f:
ffmpeg_stderr = f.read().strip()
except:
pass
logger.error(f"Audio pipeline exited immediately. rtl_fm stderr: {rtl_stderr}, ffmpeg stderr: {ffmpeg_stderr}")
return return
# Also check for rtl_fm errors even if process is still running # Also check for errors even if process is still running
try: try:
with open(stderr_log, 'r') as f: with open(rtl_stderr_log, 'r') as f:
rtl_stderr = f.read().strip() rtl_stderr = f.read().strip()
if rtl_stderr: if rtl_stderr:
logger.warning(f"rtl_fm stderr: {rtl_stderr}") logger.warning(f"rtl_fm stderr: {rtl_stderr}")
except: except:
pass pass
try:
with open(ffmpeg_stderr_log, 'r') as f:
ffmpeg_stderr = f.read().strip()
if ffmpeg_stderr:
logger.warning(f"ffmpeg stderr: {ffmpeg_stderr}")
except:
pass
audio_running = True audio_running = True
audio_frequency = frequency audio_frequency = frequency
@@ -893,7 +907,7 @@ def stream_audio() -> Response:
poll_result = audio_process.poll() poll_result = audio_process.poll()
logger.info(f"Audio process poll result: {poll_result} (None means running)") logger.info(f"Audio process poll result: {poll_result} (None means running)")
# Check for rtl_fm errors # Check for rtl_fm and ffmpeg errors
try: try:
with open('/tmp/rtl_fm_stderr.log', 'r') as f: with open('/tmp/rtl_fm_stderr.log', 'r') as f:
rtl_stderr = f.read().strip() rtl_stderr = f.read().strip()
@@ -901,6 +915,13 @@ def stream_audio() -> Response:
logger.warning(f"rtl_fm stderr (at stream request): {rtl_stderr}") logger.warning(f"rtl_fm stderr (at stream request): {rtl_stderr}")
except: except:
pass pass
try:
with open('/tmp/ffmpeg_stderr.log', 'r') as f:
ffmpeg_stderr = f.read().strip()
if ffmpeg_stderr:
logger.warning(f"ffmpeg stderr (at stream request): {ffmpeg_stderr}")
except:
pass
def generate(): def generate():
bytes_sent = 0 bytes_sent = 0
@@ -923,6 +944,14 @@ def stream_audio() -> Response:
break break
else: else:
logger.warning(f"Audio stream: select timeout after {bytes_sent} bytes, iterations={iterations}, poll={audio_process.poll()}") logger.warning(f"Audio stream: select timeout after {bytes_sent} bytes, iterations={iterations}, poll={audio_process.poll()}")
# Check for errors on timeout
try:
with open('/tmp/ffmpeg_stderr.log', 'r') as f:
ffmpeg_err = f.read().strip()
if ffmpeg_err:
logger.warning(f"ffmpeg stderr (timeout): {ffmpeg_err}")
except:
pass
# Timeout - check if process died # Timeout - check if process died
if audio_process.poll() is not None: if audio_process.poll() is not None:
logger.warning(f"Audio process died during streaming after {bytes_sent} bytes") logger.warning(f"Audio process died during streaming after {bytes_sent} bytes")