mixer.cpp

Go to the documentation of this file.

/*
 *  ix / D:\rnd\prj\ix\win95\dsp\mixer.cpp
 *
 *  Original address range: 0x00445F60 - 0x004467C4   (4 functions)
 *  Range is exact: recovered from this module's own assert __FILE__ anchors in
 *  the shipped debug build (see docs/ORDER.md).
 *
 *  Implement in ADDRESS ORDER -- MSVC emits functions in source order, so the
 *  list below is the original source order of this file.
 */
#include "ix.h"
#include <dsound.h>
#include <stdlib.h>
#include <string.h>
 
#pragma function(memset)
 
#define IX_MIXER_FILE "D:\\rnd\\prj\\ix\\win95\\dsp\\mixer.cpp"
 
extern HANDLE g_hMixerTask; /* 0x005c4ec0 */
extern HWND g_4_hDspWnd; /* 0x005c4ec4 */
extern HANDLE g_2_hMixerRouseEvent; /* 0x005c4ec8 */
extern unsigned int g_dwMixerScratchSize; /* 0x005c4ed4 */
extern unsigned int g_3_dwMixWriteOffset; /* 0x005c4ecc */
extern LPDIRECTSOUND g_1_pDirectSound; /* 0x005c4ed0 */
extern unsigned int g_5_dwSoundOptions; /* 0x005c4ed8 */
extern LPDIRECTSOUNDBUFFER g_1_pPrimarySoundBuffer; /* 0x005c52ec */
extern unsigned int g_6_dwDsoundTick; /* 0x005c52e8 */
extern LPDIRECTSOUNDBUFFER g_pMixerBuffer; /* 0x005c4ee0 */
 
BOOL CALLBACK ix_dsp_open_driver(LPGUID guid, LPSTR description,
                                 LPSTR module, LPVOID context);
 
/* Function start: 0x48B7C0 */   /* source lines 46, 50, 60, 63, 81, 84, 96 */
DWORD WINAPI ix_mixer_thread_proc(void *parameter)
{
    DSCAPS dsCaps;
    PCMWAVEFORMAT format;
    DSBUFFERDESC description;
    HRESULT result;
    DSBCAPS bufCaps;
 
    g_5_dwSoundOptions |= 4;
    SetThreadPriority(GetCurrentThread(), THREAD_PRIORITY_TIME_CRITICAL);
    DirectSoundEnumerateA(ix_dsp_open_driver, 0);
    if ((g_5_dwSoundOptions & 0x10) == 0 &&
        g_1_pDirectSound == 0) {
        ix_log_printf("Warning [%s - %d]:\n", IX_MIXER_FILE, 46);
        ix_log_printf("Failed to find write primary driver, using secondary buffer");
        g_5_dwSoundOptions |= 0x10;
        DirectSoundEnumerateA(ix_dsp_open_driver, 0);
    }
    if (g_1_pDirectSound == 0) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_MIXER_FILE, 50);
        ix_log_printf("Failed to init directsound");
        exit(-1);
    }
 
    memset(&dsCaps, 0, 0x60);
    dsCaps.dwSize = 0x60;
    g_1_pDirectSound->GetCaps(&dsCaps);
    if ((g_5_dwSoundOptions & 0x10) == 0 &&
        (dsCaps.dwFlags &
         (DSCAPS_PRIMARY16BIT | DSCAPS_PRIMARYSTEREO)) !=
        (DSCAPS_PRIMARY16BIT | DSCAPS_PRIMARYSTEREO)) {
        ix_log_printf("Warning [%s - %d]:\n", IX_MIXER_FILE, 60);
        ix_log_printf("sound driver doesn't support our primary buffer format, using secondary buffer");
        g_5_dwSoundOptions |= 0x10;
        DirectSoundEnumerateA(ix_dsp_open_driver, 0);
        if (g_1_pDirectSound == 0) {
            ix_log_printf("Fatal [%s - %d]:\n", IX_MIXER_FILE, 63);
            ix_log_printf("Failed to init directsound");
            exit(-1);
        }
    }
 
    memset(&format, 0, 0x10);
    format.wf.wFormatTag = WAVE_FORMAT_PCM;
    format.wf.nChannels = 2;
    format.wf.nSamplesPerSec = 22050;
    format.wf.nBlockAlign = 4;
    format.wf.nAvgBytesPerSec = 88200;
    format.wBitsPerSample = 16;
 
    memset(&description, 0, 0x14);
    description.dwSize = 0x14;
    description.dwFlags = DSBCAPS_PRIMARYBUFFER | DSBCAPS_CTRLVOLUME;
    result = g_1_pDirectSound->CreateSoundBuffer(
        &description, &g_1_pPrimarySoundBuffer, 0);
    if (result != DS_OK) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_MIXER_FILE, 81);
        ix_log_printf("Failed to create primary buffer");
        exit(-1);
    }
 
    result = g_1_pPrimarySoundBuffer->SetFormat(
        (LPWAVEFORMATEX)&format);
    if (result != DS_OK) {
        ix_log_printf("Warning [%s - %d]:\n", IX_MIXER_FILE, 84);
        ix_log_printf("Failed to SetFormat, %s",
                      ix_dsp_result_to_text(result));
    }
    if ((g_5_dwSoundOptions & 0x10) != 0) {
        memset(&description, 0, 0x14);
        description.dwSize = 0x14;
        description.dwFlags = DSBCAPS_CTRLVOLUME;
        description.dwBufferBytes = 0x8000;
        description.lpwfxFormat = (LPWAVEFORMATEX)&format;
        result = g_1_pDirectSound->CreateSoundBuffer(
            &description, &g_pMixerBuffer, 0);
        if (result != DS_OK) {
            ix_log_printf("Warning [%s - %d]:\n", IX_MIXER_FILE, 96);
            ix_log_printf("Failed to CreateSoundBuffer, %s",
                          ix_dsp_result_to_text(result));
            return (DWORD)-1;
        }
        g_dwMixerScratchSize = 0x8000;
        ix_log_printf("secondary buffer, size = %d\n",
                      g_dwMixerScratchSize);
    } else {
        memset(&bufCaps, 0, 0x14);
        bufCaps.dwSize = 0x14;
        g_1_pPrimarySoundBuffer->GetCaps(&bufCaps);
        g_pMixerBuffer = g_1_pPrimarySoundBuffer;
        g_dwMixerScratchSize = bufCaps.dwBufferBytes;
        ix_log_printf("primary buffer, size = %d\n",
                      g_dwMixerScratchSize);
    }
 
    g_1_pPrimarySoundBuffer->SetVolume(
        10000 - (g_nMasterVolume * 10000) / 0xffff);
    while ((g_5_dwSoundOptions & 4) != 0) {
        ix_mixer_service();
        if ((g_5_dwSoundOptions & 4) != 0) {
            WaitForSingleObject(g_2_hMixerRouseEvent, 1000);
            ResetEvent(g_2_hMixerRouseEvent);
            g_pMixerBuffer->Restore();
        }
    }
 
    if (g_pMixerBuffer == g_1_pPrimarySoundBuffer) {
        g_1_pPrimarySoundBuffer = 0;
    } else if (g_1_pPrimarySoundBuffer != 0) {
        g_1_pPrimarySoundBuffer->Release();
        g_1_pPrimarySoundBuffer = 0;
    }
    if (g_pMixerBuffer != 0) {
        g_pMixerBuffer->Release();
        g_pMixerBuffer = 0;
    }
    if (g_1_pDirectSound != 0) {
        g_1_pDirectSound->Release();
        g_1_pDirectSound = 0;
    }
    return 0;
}
 
/* Function start: 0x48BC5C */   /* source line(s) 150;157;161;176;186;196: Failed to Lock, %s | Failed to Unlock, %s | Failed to Play, %s | Failed to get current pos */
int ix_mixer_service(void)
{
    DWORD delay;
    DWORD initialBytes;
    HRESULT hr;
    void *initialBuffer;
 
    delay = 0x42;
    hr = g_pMixerBuffer->Lock(
        0, 0x2df0, &initialBuffer, &initialBytes, 0, 0, 0);
    if (hr != DS_OK) {
        ix_log_printf("Warning [%s - %d]:\n", IX_MIXER_FILE, 150);
        ix_log_printf("Failed to Lock, %s", ix_dsp_result_to_text(hr));
        return -1;
    }
    EnterCriticalSection(&g_7_csMixer);
    ix_dspv_mix(initialBuffer, initialBytes);
    LeaveCriticalSection(&g_7_csMixer);
    hr = g_pMixerBuffer->Unlock(initialBuffer, initialBytes, 0, 0);
    if (hr != DS_OK) {
        ix_log_printf("Warning [%s - %d]:\n", IX_MIXER_FILE, 157);
        ix_log_printf("Failed to Unlock, %s", ix_dsp_result_to_text(hr));
        return -1;
    }
    hr = g_pMixerBuffer->Play(0, 0, DSBPLAY_LOOPING);
    if (hr != DS_OK) {
        ix_log_printf("Warning [%s - %d]:\n", IX_MIXER_FILE, 161);
        ix_log_printf("Failed to Play, %s", ix_dsp_result_to_text(hr));
        return -1;
    }
 
    g_3_dwMixWriteOffset = 0x2df0;
    while ((g_5_dwSoundOptions & 4) != 0) {
        DWORD writePosition;
        HRESULT hr;
        DWORD bufferHeadLen;
        int bufferedBytes;
        void *bufferTail;
        DWORD lockBytes;
        void *bufferHead;
        DWORD playCursor;
        DWORD bufferTailLen;
 
        Sleep(delay);
        g_6_dwDsoundTick++;
        hr = g_pMixerBuffer->GetCurrentPosition(
            &playCursor, &writePosition);
        if (hr != DS_OK) {
            ix_log_printf("Warning [%s - %d]:\n", IX_MIXER_FILE, 176);
            ix_log_printf("Failed to get current position, %s",
                          ix_dsp_result_to_text(hr));
            return -1;
        }
        if (playCursor > g_3_dwMixWriteOffset)
            playCursor -= g_dwMixerScratchSize;
        bufferedBytes = g_3_dwMixWriteOffset - playCursor;
        delay = (unsigned int)(bufferedBytes * 0x42) / 0x16f8;
 
        lockBytes = 0x16f8;
        hr = g_pMixerBuffer->Lock(
            g_3_dwMixWriteOffset, lockBytes,
            &bufferHead, &bufferHeadLen, &bufferTail, &bufferTailLen, 0);
        if (hr != DS_OK) {
            ix_log_printf("Warning [%s - %d]:\n", IX_MIXER_FILE, 186);
            ix_log_printf("Failed to Lock, %s", ix_dsp_result_to_text(hr));
            return -1;
        }
        EnterCriticalSection(&g_7_csMixer);
        ix_dspv_mix(bufferHead, bufferHeadLen);
        if (bufferTail != 0)
            ix_dspv_mix(bufferTail, bufferTailLen);
        LeaveCriticalSection(&g_7_csMixer);
        hr = g_pMixerBuffer->Unlock(
            bufferHead, bufferHeadLen, bufferTail, bufferTailLen);
        if (hr != DS_OK) {
            ix_log_printf("Warning [%s - %d]:\n", IX_MIXER_FILE, 196);
            ix_log_printf("Failed to Unlock, %s", ix_dsp_result_to_text(hr));
            return -1;
        }
        g_3_dwMixWriteOffset += bufferHeadLen;
        if (bufferTail != 0) {
            g_3_dwMixWriteOffset = bufferTailLen;
        } else {
            if (g_3_dwMixWriteOffset >= g_dwMixerScratchSize)
                g_3_dwMixWriteOffset = 0;
        }
    }
    return 0;
}