terminate capture in all instances

This commit is contained in:
Ferdinand Schober
2024-11-03 12:34:47 +01:00
parent bad8c5a81b
commit 6bc00bd84d

View File

@@ -186,8 +186,17 @@ async fn do_capture(
/* create barriers for active clients */ /* create barriers for active clients */
for (handle, pos) in clients { for (handle, pos) in clients {
tokio::select! { tokio::select! {
r = capture.create(handle, to_capture_pos(pos)) => r?, r = capture.create(handle, to_capture_pos(pos)) => match r {
_ = wait_for_termination(request_rx) => return Ok(()), Ok(_) => {},
Err(e) => {
capture.terminate().await?;
return Err(e.into());
},
},
_ = wait_for_termination(request_rx) => {
capture.terminate().await?;
return Ok(());
},
} }
} }