Function wasapi_audio_thread

native/windows/src/lib.rs:632–755

()

#[cfg(windows)]
unsafe fn wasapi_audio_thread() {
    use windows::Win32::Media::Audio::*;
    use windows::Win32::System::Com::*;
    use windows::core::*;
    use std::sync::atomic::Ordering;

    // Initialize COM on this thread
    let _ = CoInitializeEx(None, COINIT_MULTITHREADED);

    // Create device enumerator and get default output device
    let enumerator: IMMDeviceEnumerator = match CoCreateInstance(
        &MMDeviceEnumerator,
        None,
        CLSCTX_ALL,
    ) {
        Ok(e) => e,
        Err(_) => return,
    };

    let device = match enumerator.GetDefaultAudioEndpoint(eRender, eConsole) {
        Ok(d) => d,
        Err(_) => return,
    };

    let audio_client: IAudioClient = match device.Activate(CLSCTX_ALL, None) {
        Ok(c) => c,
        Err(_) => return,
    };

    // Get mix format
    let mix_format_ptr = match audio_client.GetMixFormat() {
        Ok(f) => f,
        Err(_) => return,
    };
    let mix_format = &*mix_format_ptr;
    let sample_rate = mix_format.nSamplesPerSec;
    let channels = mix_format.nChannels as usize;

    // Initialize in shared mode with 20ms buffer
    let buffer_duration = 200_000; // 20ms in 100-nanosecond units
    if audio_client.Initialize(
        AUDCLNT_SHAREMODE_SHARED,
        0,
        buffer_duration,
        0,
        mix_format_ptr,
        None,
    ).is_err() {
        return;
    }

    let buffer_size = match audio_client.GetBufferSize() {
        Ok(s) => s as usize,
        Err(_) => return,
    };

    let render_client: IAudioRenderClient = match audio_client.GetService() {
        Ok(r) => r,