When the device in use by a stream changes but the stream is pause, reinitialize the stream next time it is started

Author: padenot

src/backend/mod.rs

@@ -4579,6 +4579,7 @@ struct AudioUnitStream<'ctx> {
     stopped: AtomicBool,
     draining: AtomicBool,
     reinit_pending: AtomicBool,
+    delayed_reinit: AtomicBool,
     destroy_pending: AtomicBool,
     // Latency requested by the user.
     latency_frames: u32,
@@ -4626,6 +4627,7 @@ impl<'ctx> AudioUnitStream<'ctx> {
             stopped: AtomicBool::new(true),
             draining: AtomicBool::new(false),
             reinit_pending: AtomicBool::new(false),
+            delayed_reinit: AtomicBool::new(false),
             destroy_pending: AtomicBool::new(false),
             latency_frames,
             output_device_latency_frames: AtomicU32::new(0),
@@ -4685,7 +4687,8 @@ impl<'ctx> AudioUnitStream<'ctx> {
         }
 
         if self.stopped.load(Ordering::SeqCst) {
-            // Something stopped the stream, we must not reinit.
+            // Something stopped the stream, reinit on next start
+            self.delayed_reinit.store(true, Ordering::SeqCst);
             return Ok(());
         }
 
@@ -4877,6 +4880,12 @@ impl<'ctx> StreamOps for AudioUnitStream<'ctx> {
         self.stopped.store(false, Ordering::SeqCst);
         self.draining.store(false, Ordering::SeqCst);
 
+        if self.delayed_reinit.load(Ordering::SeqCst) {
+            // Need reinitialization: device was changed when paused
+            let result = self.queue.clone().run_sync(|| self.reinit()).unwrap();
+            result?;
+        }
+
         // Execute start in serial queue to avoid racing with destroy or reinit.
         let result = self
             .queue