Function alsa_audio_thread

native/linux/src/lib.rs:860–909

()

#[cfg(target_os = "linux")]
fn alsa_audio_thread() {
    use alsa::pcm::*;
    use alsa::{Direction, ValueOr};
    use std::sync::atomic::Ordering;

    let pcm = match PCM::new("default", Direction::Playback, false) {
        Ok(p) => p,
        Err(_) => return,
    };

    let sample_rate = 44100u32;
    let channels = 2u32;
    let period_size = 1024;

    {
        let hwp = HwParams::any(&pcm).unwrap();
        let _ = hwp.set_channels(channels);
        let _ = hwp.set_rate(sample_rate, ValueOr::Nearest);
        let _ = hwp.set_format(Format::float());
        let _ = hwp.set_access(Access::RWInterleaved);
        let _ = hwp.set_period_size(period_size, ValueOr::Nearest);
        let _ = hwp.set_buffer_size(period_size * 4);
        let _ = pcm.hw_params(&hwp);
    }

    let _ = pcm.prepare();

    let frames = period_size as usize;
    let mut mix_buf = vec![0.0f32; frames * channels as usize];

    while AUDIO_RUNNING.load(Ordering::SeqCst) {
        for s in mix_buf.iter_mut() { *s = 0.0; }

        unsafe {
            ENGINE.get_mut().map(|eng| {
                eng.audio.mix_output(&mut mix_buf);
            });
        }

        let io = pcm.io_f32().unwrap();
        match io.writei(&mix_buf) {
            Ok(_) => {}
            Err(e) => {
                let _ = pcm.try_recover(e, true);
            }
        }
    }

    let _ = pcm.drain();
}

#[no_mangle]
pub extern "C" fn bloom_load_sound(path_ptr: *const u8) -> f64 {