correct decoder termination on ingest stream, fix #582

This commit is contained in:
jb-alvarado 2024-04-10 16:04:53 +02:00
parent 6dcbeb6e85
commit 496cd44c42

View File

@ -109,7 +109,7 @@ fn ingest_to_hls_server(
info!("Switch from {} to live ingest", config.processing.mode); info!("Switch from {} to live ingest", config.processing.mode);
if let Err(e) = proc_control.stop(Encoder) { if let Err(e) = proc_control.stop(Decoder) {
error!("{e}"); error!("{e}");
} }
} }
@ -238,11 +238,11 @@ pub fn write_hls(
.stderr(Stdio::piped()) .stderr(Stdio::piped())
.spawn() .spawn()
{ {
Ok(proc) => proc,
Err(e) => { Err(e) => {
error!("couldn't spawn ffmpeg process: {e}"); error!("couldn't spawn ffmpeg process: {e}");
panic!("couldn't spawn ffmpeg process: {e}") panic!("couldn't spawn ffmpeg process: {e}")
} }
Ok(proc) => proc,
}; };
let enc_err = BufReader::new(dec_proc.stderr.take().unwrap()); let enc_err = BufReader::new(dec_proc.stderr.take().unwrap());