INNER CODE UNIT · Rust

Some

Rikorose/DeepFilterNet · ladspa/src/lib.rs:364

            if let Some((handle, done)) = self._dbus.take() {
                done.notify(1);
                for _ in 0..20 {
                    sleep(Duration::from_millis(5));
                    if handle.is_finished() {
                        match handle.join() {
                            Ok(_) => log::debug!("{} | dbus thread joined", self.id),
                            Err(e) => log::error!("{} | dbus thread error: {:?}", self.id, e),
                        }
                        break;
                    }
                    log::error!("{} | Joining dbus thread timed out.", self.id);
                }
            }
        }
    }
    fn run<'a>(&mut self, sample_count: usize, ports: &[&'a PortConnection<'a>]) {
        let t0 = Instant::now();

View source record →