servius/helvum
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/helvum synced 2026-03-15 03:26:10 +08:00
Code Issues Packages Projects Releases Wiki Activity

pipewire connection: restart the outer loop

Browse Source
This commit is contained in:
Tom Wagner
2023-09-27 10:53:36 +00:00
committed by Denis Drakhnia
parent 94323510aa
commit 7d6aae70c5
1 changed files with 6 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
src/pipewire_connection/mod.rs
View File

@@ -67,23 +67,14 @@ pub(super) fn thread_main(
let core = match context.connect(None) { let core = match context.connect(None) {
Ok(core) => Rc::new(core), Ok(core) => Rc::new(core),
Err(_) => { Err(_) => {
// If connection is failed, try to connect every 200ms // If connection is failed, try to connect again in 200ms
let interval = Some(Duration::from_millis(200)); let interval = Some(Duration::from_millis(200));
let core = Rc::new(RefCell::new(None)); let timer = mainloop.add_timer(clone!(@strong mainloop => move |_| {
let timer = mainloop.add_timer(
clone!(@strong mainloop, @strong context, @strong core => move |_| {
if let Ok(x) = context.connect(None) {
core.replace(Some(x));
mainloop.quit(); mainloop.quit();
} }));
}),
);
timer timer.update_timer(interval, None).into_result().unwrap();
.update_timer(interval, interval)
.into_result()
.unwrap();
let receiver = pw_receiver.attach(&mainloop, { let receiver = pw_receiver.attach(&mainloop, {
clone!(@strong mainloop, @strong is_stopped => move |msg| clone!(@strong mainloop, @strong is_stopped => move |msg|
@@ -98,11 +89,7 @@ pub(super) fn thread_main(
mainloop.run(); mainloop.run();
pw_receiver = receiver.deattach(); pw_receiver = receiver.deattach();
if is_stopped.get() { continue;
break;
}
Rc::new(core.take().unwrap())
} }
}; };