dsps.cpp

Go to the documentation of this file.

/**
 * @file
 * @ingroup ixlib
 * @brief Sample stream control.
 *
 * Originally `D:\rnd\prj\ix\win95\dsp\dsps.cpp`, address range
 * 445190-445f5f: compiler-generated initializers, then ten stream-control
 * functions. Built /Od /Oi like the rest of ix.
 *
 * A stream is a ring buffer fed by the streamer thread and played through a
 * voice slot allocated after the regular voices: voice[voice_count + index].
 */
#include <signal.h>
#include "ix.h"
#include <stdlib.h>
 
int      nStreamCount;           /* 0x00598130 */
int      nAllocatedStreams;      /* 0x00598134 */
IxStream streams[2];             /* 0x00598138 */
 
/* Function start: 0x4451B5 */   /* source lines 26, 27, 28, 32 */
void ix_dsps_alloc(int stream, unsigned int size, int freq, int bps, int channels)
{
    IxVoice *v;
 
    if (stream < 0 || stream >= nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 26);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    if ((streams[stream].flags & IX_STREAM_ALLOCATED) != 0) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 27);
        ix_log_printf("stream already allocated!");
        exit(-1);
    }
    if ((streams[stream].flags & IX_STREAM_PLAYING) != 0) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 28);
        ix_log_printf("stream still playing!");
        exit(-1);
    }
    streams[stream].buffer = new unsigned char[size];
    if (streams[stream].buffer == 0) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 32);
        ix_log_printf("failed to allocate stream buffer");
        exit(-1);
    }
    streams[stream].size = size;
    streams[stream].writePos = 0;
    streams[stream].playPos = streams[stream].writePos;
    streams[stream].pending = streams[stream].playPos;
    InitializeCriticalSection(&streams[stream].cs);
 
    v = &aVoices[nVoiceCount + stream];
    v->flags = IX_VOICE_FLAG4 | 1;
    if (bps == 16) {
        v->flags |= IX_VOICE_16BIT;
    } else {
        /* Eight-bit samples use the default format flags. */
    }
    if (channels == 2) {
        v->flags |= IX_VOICE_STEREO;
    } else {
        /* Mono samples use the default format flags. */
    }
    v->cursor = streams[stream].buffer;
    v->start = v->cursor;
    v->end = v->cursor + size;
    v->volume = 0x7fff;
    v->leftGain = v->volume;
    v->rightGain = v->volume;
    v->leftGainHi = (unsigned short)v->volume >> 8;
    v->rightGainHi = (unsigned short)v->volume >> 8;
    v->field_10 = 0;
    v->rate = (freq << 8) / IX_MIXER_BASE_RATE;
    nAllocatedStreams = nAllocatedStreams + 1;
    streams[stream].flags |= IX_STREAM_ALLOCATED;
}
 
/* Function start: 0x44546B */   /* source lines 62, 63 */
void ix_dsps_free(int stream)
{
    if (stream < 0 || stream >= nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 62);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    if ((streams[stream].flags & IX_STREAM_ALLOCATED) == 0) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 63);
        ix_log_printf("stream is not allocated!");
        exit(-1);
    }
    if ((streams[stream].flags & IX_STREAM_PLAYING) != 0)
        ix_dsps_stop(stream);
    DeleteCriticalSection(&streams[stream].cs);
    delete[] streams[stream].buffer;
    nAllocatedStreams = nAllocatedStreams - 1;
    streams[stream].flags &= ~IX_STREAM_ALLOCATED;
}
 
/* Function start: 0x445582 */   /* source lines 77, 78, 79 */
void ix_dsps_prepare(int stream)
{
    if (stream < 0 || stream >= nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 77);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    if ((streams[stream].flags & IX_STREAM_ALLOCATED) == 0) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 78);
        ix_log_printf("stream is not ready!");
        exit(-1);
    }
    if ((streams[stream].flags & IX_STREAM_PLAYING) != 0) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 79);
        ix_log_printf("stream is playing!");
        exit(-1);
    }
    streams[stream].playPos = 0;
    streams[stream].pending = streams[stream].playPos;
    streams[stream].writePos = streams[stream].pending;
    aVoices[nVoiceCount + stream].cursor =
        streams[stream].buffer;
}
 
/* Function start: 0x4456D8 */   /* source lines 87, 88, 89 */
void ix_dsps_play(int stream)
{
    IxVoice *v;
 
    if (stream < 0 || stream >= nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 87);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    if ((streams[stream].flags & IX_STREAM_ALLOCATED) == 0) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 88);
        ix_log_printf("stream is not ready!");
        exit(-1);
    }
    if ((streams[stream].flags & IX_STREAM_PLAYING) != 0) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 89);
        ix_log_printf("stream is already playing!");
        exit(-1);
    }
    v = &aVoices[nVoiceCount + stream];
    v->cursor = streams[stream].playPos
              + streams[stream].buffer;
    v->flags |= IX_VOICE_ACTIVE;
    streams[stream].flags |= IX_STREAM_PLAYING;
}
 
/* Function start: 0x445808 */   /* source lines 99, 100, 101 */
void ix_dsps_stop(int stream)
{
    if (stream < 0 || stream >= nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 99);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    if ((streams[stream].flags & IX_STREAM_ALLOCATED) == 0) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 100);
        ix_log_printf("stream is not ready!");
        exit(-1);
    }
    if ((streams[stream].flags & IX_STREAM_PLAYING) == 0) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 101);
        ix_log_printf("stream isnt playing!");
        exit(-1);
    }
    aVoices[nVoiceCount + stream].flags &= ~IX_VOICE_ACTIVE;
    streams[stream].flags &= ~IX_STREAM_PLAYING;
}
 
/* Function start: 0x445906 */   /* source lines 109, 110 */
void ix_dsps_set_volume(int stream, unsigned short vol)
{
    IxVoice *v;
 
    if (stream < 0 || stream >= nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 109);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    if ((streams[stream].flags & IX_STREAM_ALLOCATED) == 0) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 110);
        ix_log_printf("stream is not ready!");
        exit(-1);
    }
    v = &aVoices[nVoiceCount + stream];
    v->volume =
        (unsigned short)(((int)(vol & 0xffff) * 0x7fff) / 0xffff);
    v->leftGain = v->volume;
    v->rightGain = v->volume;
    v->leftGainHi = (unsigned short)v->volume >> 8;
    v->rightGainHi = (unsigned short)v->volume >> 8;
}
 
/* Function start: 0x445A0B */   /* source line 122 */
unsigned int ix_dsps_get_flags(int stream)
{
    if (stream < 0 || stream >= nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 122);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    return streams[stream].flags;
}
 
/* Function start: 0x445A6F */   /* source lines 128, 129 */
int ix_dsps_get_buffer_free(int streamIndex)
{
    if (streamIndex < 0 || streamIndex >= nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 128);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    if ((streams[streamIndex].flags & IX_STREAM_ALLOCATED) == 0) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 129);
        ix_log_printf("stream is not ready!");
        exit(-1);
    }
    unsigned int consumedBytes = 0;
    EnterCriticalSection(&streams[streamIndex].cs);
    unsigned int bufferPosition =
        aVoices[nVoiceCount + streamIndex].cursor - streams[streamIndex].buffer;
    if (streams[streamIndex].pending < 0) {
        streams[streamIndex].pending = 0;
        streams[streamIndex].playPos = bufferPosition;
        LeaveCriticalSection(&streams[streamIndex].cs);
        return streams[streamIndex].size;
    }
    if (streams[streamIndex].playPos < bufferPosition) {
        consumedBytes = bufferPosition - streams[streamIndex].playPos;
        streams[streamIndex].pending -= consumedBytes;
    } else if (streams[streamIndex].playPos != bufferPosition) {
        consumedBytes = (streams[streamIndex].size
                         - streams[streamIndex].playPos) + bufferPosition;
        streams[streamIndex].pending -= consumedBytes;
    }
    streams[streamIndex].playPos = bufferPosition;
    LeaveCriticalSection(&streams[streamIndex].cs);
    return streams[streamIndex].size - streams[streamIndex].pending;
}
 
/* Function start: 0x00445CDB */   /* source lines 169, 172, 173 */
void ix_dsps_lock(int stream, unsigned int requestedBytes,
                  unsigned char **buffer, unsigned int *lockedBytes)
{
    IxStream *s;
 
    if (stream < 0 || stream >= nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 169);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    s = &streams[stream];
    if ((streams[stream].flags & IX_STREAM_ALLOCATED) == 0) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 172);
        ix_log_printf("stream is not ready!");
        exit(-1);
    }
    if ((streams[stream].flags & IX_STREAM_LOCKED) != 0) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 173);
        ix_log_printf("stream is already locked!");
        exit(-1);
    }
    s->lockPtr = s->buffer + s->writePos;
    if (s->writePos + requestedBytes > s->size)
        requestedBytes = s->size - s->writePos;
    s->lockLen = requestedBytes;
    *buffer = s->lockPtr;
    *lockedBytes = s->lockLen;
    streams[stream].flags |= IX_STREAM_LOCKED;
}
 
/* Function start: 0x00445E3C */   /* source lines 188, 191, 192 */
void ix_dsps_unlock(int stream)
{
    IxStream *s;
 
    if (stream < 0 || stream >= nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 188);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    s = &streams[stream];
    if ((s->flags & IX_STREAM_ALLOCATED) == 0) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 191);
        ix_log_printf("stream is not ready!");
        exit(-1);
    }
    if ((s->flags & IX_STREAM_LOCKED) == 0) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 192);
        ix_log_printf("stream isn't locked!");
        exit(-1);
    }
    s->writePos += s->lockLen;
    if (s->writePos >= s->size)
        s->writePos = s->writePos - s->size;
    s->pending += s->lockLen;
    s->flags &= ~IX_STREAM_LOCKED;
}