dsps.cpp

Go to the documentation of this file.

/*
 *  ix / D:\rnd\prj\ix\win95\dsp\dsps.cpp
 *
 *  Original address range: 0x004451B5 - 0x00445F5F   (10 functions)
 *  Range is exact: recovered from this module's own assert __FILE__ anchors.
 *  Built /Od /Oi like the rest of ix -- do not optimise this file.
 *
 *  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 "ix.h"
#include <dos.h>
#include <stdlib.h>
 
int      g_3_nStreamCount; /* 0x005c5750 */
int      g_nStreamsTaken; /* 0x005c5754 */
IxStream g_1_streams[2]; /* 0x005c5758 */
 
/* The stream operations further down.  With the stream table's
 * initializer, their named parameters give this unit retail's symbol-key
 * numbering. */
void ix_dsps_prepare(int stream);
void ix_dsps_play(int stream);
void ix_dsps_stop(int stream);
void ix_dsps_set_volume(int stream, unsigned short volume);
int ix_dsps_get_buffer_free(int stream);
void ix_dsps_unlock(int stream);
 
/* Function start: 0x48AA15 */   /* 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 >= g_3_nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 26);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    if ((g_1_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 ((g_1_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);
    }
    g_1_streams[stream].buffer = new unsigned char[size];
    if (g_1_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);
    }
    g_1_streams[stream].size = size;
    g_1_streams[stream].writePos = 0;
    g_1_streams[stream].playPos = g_1_streams[stream].writePos;
    g_1_streams[stream].pending = g_1_streams[stream].playPos;
    InitializeCriticalSection(&g_1_streams[stream].cs);
 
    v = &g_2_voices[g_nVoiceCapacity + stream];
    v->flags = IX_VOICE_FLAG4 | 1;
    if (bps == 16)
        v->flags |= IX_VOICE_16BIT;
    else
        ;
    if (channels == 2)
        v->flags |= IX_VOICE_STEREO;
    else
        ;
    v->cursor = g_1_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 char)((unsigned short)v->volume >> 8);
    v->rightGainHi = (unsigned char)((unsigned short)v->volume >> 8);
    v->field_10 = 0;
    v->rate = (short)((freq << 8) / IX_MIXER_BASE_RATE);
    g_nStreamsTaken = g_nStreamsTaken + 1;
    g_1_streams[stream].flags |= IX_STREAM_ALLOCATED;
}
 
void ix_dsps_stop(int stream);
 
/* Function start: 0x48ACCB */   /* source lines 62, 63 */
void ix_dsps_free(int stream)
{
    if (stream < 0 || stream >= g_3_nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 62);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    if ((g_1_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 ((g_1_streams[stream].flags & IX_STREAM_PLAYING) != 0)
        ix_dsps_stop(stream);
    DeleteCriticalSection(&g_1_streams[stream].cs);
    delete[] g_1_streams[stream].buffer;
    g_nStreamsTaken = g_nStreamsTaken - 1;
    g_1_streams[stream].flags &= ~IX_STREAM_ALLOCATED;
}
 
/* Function start: 0x48ADE2 */   /* source lines 77, 78, 79 */
void ix_dsps_prepare(int stream)
{
    if (stream < 0 || stream >= g_3_nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 77);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    if ((g_1_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 ((g_1_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);
    }
    g_1_streams[stream].playPos = 0;
    g_1_streams[stream].pending = g_1_streams[stream].playPos;
    g_1_streams[stream].writePos = g_1_streams[stream].pending;
    g_2_voices[g_nVoiceCapacity + stream].cursor =
        g_1_streams[stream].buffer;
}
 
/* Function start: 0x48AF38 */   /* source lines 87, 88, 89 */
void ix_dsps_play(int stream)
{
    IxVoice *v;
 
    if (stream < 0 || stream >= g_3_nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 87);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    if ((g_1_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 ((g_1_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 = &g_2_voices[g_nVoiceCapacity + stream];
    v->cursor = g_1_streams[stream].playPos
              + g_1_streams[stream].buffer;
    v->flags |= IX_VOICE_ACTIVE;
    g_1_streams[stream].flags |= IX_STREAM_PLAYING;
}
 
/* Function start: 0x48B068 */   /* source lines 99, 100, 101 */
void ix_dsps_stop(int stream)
{
    if (stream < 0 || stream >= g_3_nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 99);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    if ((g_1_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 ((g_1_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);
    }
    g_2_voices[g_nVoiceCapacity + stream].flags &= ~IX_VOICE_ACTIVE;
    g_1_streams[stream].flags &= ~IX_STREAM_PLAYING;
}
 
void ix_dsps_lock(int stream, unsigned int requestedBytes,
                  unsigned char **buffer, unsigned int *lockedBytes);
unsigned int ix_dsps_get_flags(int stream);
void ix_dsps_unlock(int stream);
 
/* Function start: 0x48B166 */   /* source lines 109, 110 */
void ix_dsps_set_volume(int stream, unsigned short vol)
{
    IxVoice *v;
 
    if (stream < 0 || stream >= g_3_nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 109);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    if ((g_1_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 = &g_2_voices[g_nVoiceCapacity + stream];
    v->volume =
        (unsigned short)(((int)(vol & 0xffff) * 0x7fff) / 0xffff);
    v->leftGain = v->volume;
    v->rightGain = v->volume;
    v->leftGainHi = (unsigned char)((unsigned short)v->volume >> 8);
    v->rightGainHi = (unsigned char)((unsigned short)v->volume >> 8);
}
 
/* Function start: 0x48B26B */   /* source line 122 */
unsigned int ix_dsps_get_flags(int stream)
{
    if (stream < 0 || stream >= g_3_nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 122);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    return g_1_streams[stream].flags;
}
 
/* Function start: 0x48B2CF */   /* source lines 128, 129 */
int ix_dsps_get_buffer_free(int stream)
{
    int consumed;
    unsigned int played;
 
    if (stream < 0 || stream >= g_3_nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 128);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    if ((g_1_streams[stream].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);
    }
    consumed = 0;
    EnterCriticalSection(&g_1_streams[stream].cs);
    played = g_2_voices[g_nVoiceCapacity + stream].cursor
           - g_1_streams[stream].buffer;
    if ((int)g_1_streams[stream].pending < 0) {
        g_1_streams[stream].pending = 0;
        g_1_streams[stream].playPos = played;
        LeaveCriticalSection(&g_1_streams[stream].cs);
        return g_1_streams[stream].size;
    }
    if (g_1_streams[stream].playPos < played) {
        consumed = played - g_1_streams[stream].playPos;
        g_1_streams[stream].pending =
            (int)g_1_streams[stream].pending - consumed;
    }
    else if (g_1_streams[stream].playPos != played) {
        consumed = (g_1_streams[stream].size
                   - g_1_streams[stream].playPos) + played;
        g_1_streams[stream].pending =
            (int)g_1_streams[stream].pending - consumed;
    }
    g_1_streams[stream].playPos = played;
    LeaveCriticalSection(&g_1_streams[stream].cs);
    return g_1_streams[stream].size - g_1_streams[stream].pending;
}
 
/* Function start: 0x48B53B */   /* 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 >= g_3_nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 169);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    s = &g_1_streams[stream];
    if ((g_1_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 ((g_1_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;
    g_1_streams[stream].flags |= IX_STREAM_LOCKED;
}
 
/* Function start: 0x48B69C */   /* source lines 188, 191, 192 */
void ix_dsps_unlock(int stream)
{
    IxStream *s;
 
    if (stream < 0 || stream >= g_3_nStreamCount) {
        ix_log_printf("Fatal [%s - %d]:\n", IX_DSPS_FILE, 188);
        ix_log_printf("invalid stream index");
        exit(-1);
    }
    s = &g_1_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;
}