ref: df4476ab77a8e48cc15f8316a914e734f6ce4434
dir: /src/ft2_audio.c/
// for finding memory leaks in debug mode with Visual Studio
#if defined _DEBUG && defined _MSC_VER
#include <crtdbg.h>
#endif
#include <stdio.h>
#include <stdint.h>
#include <math.h>
#include "ft2_header.h"
#include "ft2_config.h"
#include "scopes/ft2_scopes.h"
#include "ft2_video.h"
#include "ft2_gui.h"
#include "ft2_midi.h"
#include "ft2_wav_renderer.h"
#include "ft2_tables.h"
#include "ft2_structs.h"
#include "mixer/ft2_mix.h"
#include "mixer/ft2_center_mix.h"
#include "mixer/ft2_silence_mix.h"
// hide POSIX warnings
#ifdef _MSC_VER
#pragma warning(disable: 4996)
#endif
#define INITIAL_DITHER_SEED 0x12345000
static int32_t smpShiftValue;
static uint32_t oldAudioFreq, tickTimeLenInt, randSeed = INITIAL_DITHER_SEED;
static uint64_t tickTimeLenFrac;
static double dAudioNormalizeMul, dSqrtPanningTable[256+1], dPrngStateL, dPrngStateR;
static voice_t voice[MAX_CHANNELS * 2];
// globalized
audio_t audio;
pattSyncData_t *pattSyncEntry;
chSyncData_t *chSyncEntry;
chSync_t chSync;
pattSync_t pattSync;
volatile bool pattQueueClearing, chQueueClearing;
void resetCachedMixerVars(void)
{
channel_t *ch = channel;
for (int32_t i = 0; i < MAX_CHANNELS; i++, ch++)
ch->oldFinalPeriod = -1;
voice_t *v = voice;
for (int32_t i = 0; i < MAX_CHANNELS*2; i++, v++)
v->oldDelta = 0;
}
void stopVoice(int32_t i)
{
voice_t *v;
v = &voice[i];
memset(v, 0, sizeof (voice_t));
v->panning = 128;
// clear "fade out" voice too
v = &voice[MAX_CHANNELS + i];
memset(v, 0, sizeof (voice_t));
v->panning = 128;
}
bool setNewAudioSettings(void) // only call this from the main input/video thread
{
pauseAudio();
if (!setupAudio(CONFIG_HIDE_ERRORS))
{
// set back old known working settings
config.audioFreq = audio.lastWorkingAudioFreq;
config.specialFlags &= ~(BITDEPTH_16 + BITDEPTH_32 + BUFFSIZE_512 + BUFFSIZE_1024 + BUFFSIZE_2048);
config.specialFlags |= audio.lastWorkingAudioBits;
if (audio.lastWorkingAudioDeviceName != NULL)
{
if (audio.currOutputDevice != NULL)
{
free(audio.currOutputDevice);
audio.currOutputDevice = NULL;
}
audio.currOutputDevice = strdup(audio.lastWorkingAudioDeviceName);
}
// also update config audio radio buttons if we're on that screen at the moment
if (ui.configScreenShown && editor.currConfigScreen == CONFIG_SCREEN_AUDIO)
setConfigAudioRadioButtonStates();
// if it didn't work to use the old settings again, then something is seriously wrong...
if (!setupAudio(CONFIG_HIDE_ERRORS))
okBox(0, "System message", "Couldn't find a working audio mode... You'll get no sound / replayer timer!");
resumeAudio();
return false;
}
resumeAudio();
setWavRenderFrequency(audio.freq);
setWavRenderBitDepth((config.specialFlags & BITDEPTH_32) ? 32 : 16);
return true;
}
// amp = 1..32, masterVol = 0..256
void setAudioAmp(int16_t amp, int16_t masterVol, bool bitDepth32Flag)
{
amp = CLAMP(amp, 1, 32);
masterVol = CLAMP(masterVol, 0, 256);
double dAmp = (amp * masterVol) / (32.0 * 256.0);
if (!bitDepth32Flag)
dAmp *= 32768.0;
dAudioNormalizeMul = dAmp;
}
void decreaseMasterVol(void)
{
if (config.masterVol >= 16)
config.masterVol -= 16;
else
config.masterVol = 0;
setAudioAmp(config.boostLevel, config.masterVol, !!(config.specialFlags & BITDEPTH_32));
// if Config -> Audio is open, update master volume scrollbar
if (ui.configScreenShown && editor.currConfigScreen == CONFIG_SCREEN_AUDIO)
drawScrollBar(SB_MASTERVOL_SCROLL);
}
void increaseMasterVol(void)
{
if (config.masterVol < (256-16))
config.masterVol += 16;
else
config.masterVol = 256;
setAudioAmp(config.boostLevel, config.masterVol, !!(config.specialFlags & BITDEPTH_32));
// if Config -> Audio is open, update master volume scrollbar
if (ui.configScreenShown && editor.currConfigScreen == CONFIG_SCREEN_AUDIO)
drawScrollBar(SB_MASTERVOL_SCROLL);
}
void setNewAudioFreq(uint32_t freq) // for song-to-WAV rendering
{
if (freq == 0)
return;
oldAudioFreq = audio.freq;
audio.freq = freq;
const bool mustRecalcTables = audio.freq != oldAudioFreq;
if (mustRecalcTables)
calcReplayerVars(audio.freq);
}
void setBackOldAudioFreq(void) // for song-to-WAV rendering
{
const bool mustRecalcTables = audio.freq != oldAudioFreq;
audio.freq = oldAudioFreq;
if (mustRecalcTables)
calcReplayerVars(audio.freq);
}
void setMixerBPM(int32_t bpm)
{
if (bpm < MIN_BPM || bpm > MAX_BPM)
return;
int32_t i = bpm - MIN_BPM;
audio.samplesPerTickInt = audio.samplesPerTickIntTab[i];
audio.samplesPerTickFrac = audio.samplesPerTickFracTab[i];
// for audio/video sync timestamp
tickTimeLenInt = audio.tickTimeIntTab[i];
tickTimeLenFrac = audio.tickTimeFracTab[i];
}
void audioSetVolRamp(bool volRamp)
{
lockMixerCallback();
audio.volumeRampingFlag = volRamp;
unlockMixerCallback();
}
void audioSetInterpolationType(uint8_t interpolationType)
{
lockMixerCallback();
audio.interpolationType = interpolationType;
// set sinc polyphase LUT pointers
if (config.interpolation == INTERPOLATION_SINC8)
{
fKaiserSinc = fKaiserSinc_8;
fDownSample1 = fDownSample1_8;
fDownSample2 = fDownSample2_8;
}
else if (config.interpolation == INTERPOLATION_SINC16)
{
fKaiserSinc = fKaiserSinc_16;
fDownSample1 = fDownSample1_16;
fDownSample2 = fDownSample2_16;
}
unlockMixerCallback();
}
void calcPanningTable(void)
{
// same formula as FT2's panning table (with 0.0 .. 1.0 scale)
for (int32_t i = 0; i <= 256; i++)
dSqrtPanningTable[i] = sqrt(i / 256.0);
}
static void voiceUpdateVolumes(int32_t i, uint8_t status)
{
voice_t *v = &voice[i];
v->fTargetVolumeL = (float)(v->dVolume * dSqrtPanningTable[256-v->panning]);
v->fTargetVolumeR = (float)(v->dVolume * dSqrtPanningTable[ v->panning]);
if (!audio.volumeRampingFlag)
{
// volume ramping is disabled, set volume directly
v->fCurrVolumeL = v->fTargetVolumeL;
v->fCurrVolumeR = v->fTargetVolumeR;
v->volumeRampLength = 0;
return;
}
// now we need to handle volume ramping
const bool voiceSampleTrigger = !!(status & IS_Trigger);
if (voiceSampleTrigger)
{
// sample is about to start, ramp out/in at the same time
if (v->fCurrVolumeL > 0.0f || v->fCurrVolumeR > 0.0f)
{
// setup fadeout voice
voice_t *f = &voice[MAX_CHANNELS+i];
*f = *v; // store current voice in respective fadeout ramp voice
const float fVolumeLDiff = 0.0f - f->fCurrVolumeL;
const float fVolumeRDiff = 0.0f - f->fCurrVolumeR;
f->volumeRampLength = audio.quickVolRampSamples; // 5ms
const float fVolumeRampLength = (float)(int32_t)f->volumeRampLength;
f->fVolumeLDelta = fVolumeLDiff / fVolumeRampLength;
f->fVolumeRDelta = fVolumeRDiff / fVolumeRampLength;
f->isFadeOutVoice = true;
}
// make current voice fade in from zero when it starts
v->fCurrVolumeL = v->fCurrVolumeR = 0.0f;
}
if (!voiceSampleTrigger && v->fTargetVolumeL == v->fCurrVolumeL && v->fTargetVolumeR == v->fCurrVolumeR)
{
v->volumeRampLength = 0; // no ramp needed for now
}
else
{
const float fVolumeLDiff = v->fTargetVolumeL - v->fCurrVolumeL;
const float fVolumeRDiff = v->fTargetVolumeR - v->fCurrVolumeR;
// IS_QuickVol = 5ms, otherwise the duration of a tick
v->volumeRampLength = (status & IS_QuickVol) ? audio.quickVolRampSamples : audio.samplesPerTickInt;
const float fVolumeRampLength = (float)(int32_t)v->volumeRampLength;
v->fVolumeLDelta = fVolumeLDiff / fVolumeRampLength;
v->fVolumeRDelta = fVolumeRDiff / fVolumeRampLength;
}
}
static void voiceTrigger(int32_t ch, sample_t *s, int32_t position)
{
voice_t *v = &voice[ch];
int32_t length = s->length;
int32_t loopStart = s->loopStart;
int32_t loopLength = s->loopLength;
int32_t loopEnd = s->loopStart + s->loopLength;
uint8_t loopType = GET_LOOPTYPE(s->flags);
bool sample16Bit = !!(s->flags & SAMPLE_16BIT);
if (s->dataPtr == NULL || length < 1)
{
v->active = false; // shut down voice (illegal parameters)
return;
}
if (loopLength < 1) // disable loop if loopLength is below 1
loopType = 0;
if (sample16Bit)
{
v->base16 = (const int16_t *)s->dataPtr;
v->revBase16 = &v->base16[loopStart + loopEnd]; // for pingpong loops
v->leftEdgeTaps16 = s->leftEdgeTapSamples16 + SINC_MAX_LEFT_TAPS;
}
else
{
v->base8 = s->dataPtr;
v->revBase8 = &v->base8[loopStart + loopEnd]; // for pingpong loops
v->leftEdgeTaps8 = s->leftEdgeTapSamples8 + SINC_MAX_LEFT_TAPS;
}
v->hasLooped = false; // for sinc interpolation special case
v->samplingBackwards = false;
v->loopType = loopType;
v->sampleEnd = (loopType == LOOP_OFF) ? length : loopEnd;
v->loopStart = loopStart;
v->loopLength = loopLength;
v->position = position;
v->positionFrac = 0;
// if position overflows, shut down voice (f.ex. through 9xx command)
if (v->position >= v->sampleEnd)
{
v->active = false;
return;
}
v->mixFuncOffset = ((int32_t)sample16Bit * 12) + (audio.interpolationType * 3) + loopType;
v->active = true;
}
void resetRampVolumes(void)
{
voice_t *v = voice;
for (int32_t i = 0; i < song.numChannels; i++, v++)
{
v->fCurrVolumeL = v->fTargetVolumeL;
v->fCurrVolumeR = v->fTargetVolumeR;
v->volumeRampLength = 0;
}
}
void updateVoices(void)
{
channel_t *ch = channel;
voice_t *v = voice;
for (int32_t i = 0; i < song.numChannels; i++, ch++, v++)
{
const uint8_t status = ch->tmpStatus = ch->status; // (tmpStatus is used for audio/video sync queue)
if (status == 0)
continue;
ch->status = 0;
if (status & IS_Vol)
{
v->dVolume = ch->dFinalVol;
// set scope volume
const int32_t scopeVolume = (int32_t)((SCOPE_HEIGHT * ch->dFinalVol) + 0.5); // rounded
v->scopeVolume = (uint8_t)scopeVolume;
}
if (status & IS_Pan)
v->panning = ch->finalPan;
if (status & (IS_Vol + IS_Pan))
voiceUpdateVolumes(i, status);
if (status & IS_Period)
{
// use cached values when possible
if (ch->finalPeriod != ch->oldFinalPeriod)
{
ch->oldFinalPeriod = ch->finalPeriod;
if (ch->finalPeriod == 0) // in FT2, period 0 -> delta 0
{
v->scopeDelta = 0;
v->oldDelta = 0;
v->fSincLUT = fKaiserSinc;
}
else
{
const double dHz = dPeriod2Hz(ch->finalPeriod);
const uintCPUWord_t delta = v->oldDelta = (intCPUWord_t)((dHz * audio.dHz2MixDeltaMul) + 0.5); // Hz -> fixed-point delta (rounded)
// decide which polyphase sinc LUT to use according to resampling ratio
if (delta <= (uintCPUWord_t)(1.1875 * MIXER_FRAC_SCALE))
v->fSincLUT = fKaiserSinc;
else if (delta <= (uintCPUWord_t)(1.5 * MIXER_FRAC_SCALE))
v->fSincLUT = fDownSample1;
else
v->fSincLUT = fDownSample2;
// set scope delta
const double dHz2ScopeDeltaMul = SCOPE_FRAC_SCALE / (double)SCOPE_HZ;
v->scopeDelta = (intCPUWord_t)((dHz * dHz2ScopeDeltaMul) + 0.5); // Hz -> fixed-point delta (rounded)
}
}
v->delta = v->oldDelta;
}
if (status & IS_Trigger)
voiceTrigger(i, ch->smpPtr, ch->smpStartPos);
}
}
void resetAudioDither(void)
{
randSeed = INITIAL_DITHER_SEED;
dPrngStateL = 0.0;
dPrngStateR = 0.0;
}
static inline int32_t random32(void)
{
// LCG 32-bit random
randSeed *= 134775813;
randSeed++;
return (int32_t)randSeed;
}
static void sendSamples16BitDitherStereo(uint8_t *stream, uint32_t sampleBlockLength)
{
int32_t out32;
double dOut, dPrng;
int16_t *streamPointer16 = (int16_t *)stream;
for (uint32_t i = 0; i < sampleBlockLength; i++)
{
// left channel - 1-bit triangular dithering
dPrng = random32() * (0.5 / INT32_MAX); // -0.5 .. 0.5
dOut = (double)audio.fMixBufferL[i] * dAudioNormalizeMul;
dOut = (dOut + dPrng) - dPrngStateL;
dPrngStateL = dPrng;
out32 = (int32_t)dOut;
CLAMP16(out32);
*streamPointer16++ = (int16_t)out32;
// right channel - 1-bit triangular dithering
dPrng = random32() * (0.5 / INT32_MAX); // -0.5 .. 0.5
dOut = (double)audio.fMixBufferR[i] * dAudioNormalizeMul;
dOut = (dOut + dPrng) - dPrngStateR;
dPrngStateR = dPrng;
out32 = (int32_t)dOut;
CLAMP16(out32);
*streamPointer16++ = (int16_t)out32;
// clear what we read from the mixing buffer
audio.fMixBufferL[i] = 0.0f;
audio.fMixBufferR[i] = 0.0f;
}
}
static void sendSamples32BitStereo(uint8_t *stream, uint32_t sampleBlockLength)
{
double dOut;
float *fStreamPointer32 = (float *)stream;
for (uint32_t i = 0; i < sampleBlockLength; i++)
{
// left channel
dOut = (double)audio.fMixBufferL[i] * dAudioNormalizeMul;
dOut = CLAMP(dOut, -1.0, 1.0);
*fStreamPointer32++ = (float)dOut;
// right channel
dOut = (double)audio.fMixBufferR[i] * dAudioNormalizeMul;
dOut = CLAMP(dOut, -1.0, 1.0);
*fStreamPointer32++ = (float)dOut;
// clear what we read from the mixing buffer
audio.fMixBufferL[i] = 0.0f;
audio.fMixBufferR[i] = 0.0f;
}
}
static void doChannelMixing(int32_t bufferPosition, int32_t samplesToMix)
{
voice_t *v = voice; // normal voices
voice_t *r = &voice[MAX_CHANNELS]; // volume ramp fadeout-voices
for (int32_t i = 0; i < song.numChannels; i++, v++, r++)
{
if (v->active)
{
bool centerMixFlag;
const bool volRampFlag = (v->volumeRampLength > 0);
if (volRampFlag)
{
centerMixFlag = (v->fTargetVolumeL == v->fTargetVolumeR) && (v->fVolumeLDelta == v->fVolumeRDelta);
}
else // no volume ramping active
{
if (v->fCurrVolumeL == 0.0f && v->fCurrVolumeR == 0.0f)
{
silenceMixRoutine(v, samplesToMix);
continue;
}
centerMixFlag = (v->fCurrVolumeL == v->fCurrVolumeR);
}
mixFuncTab[((int32_t)centerMixFlag * (3*4*2*2)) + ((int32_t)volRampFlag * (3*4*2)) + v->mixFuncOffset](v, bufferPosition, samplesToMix);
}
if (r->active) // volume ramp fadeout-voice
{
const bool centerMixFlag = (r->fTargetVolumeL == r->fTargetVolumeR) && (r->fVolumeLDelta == r->fVolumeRDelta);
mixFuncTab[((int32_t)centerMixFlag * (3*4*2*2)) + (3*4*2) + r->mixFuncOffset](r, bufferPosition, samplesToMix);
}
}
}
// used for song-to-WAV renderer
void mixReplayerTickToBuffer(uint32_t samplesToMix, uint8_t *stream, uint8_t bitDepth)
{
doChannelMixing(0, samplesToMix);
// normalize mix buffer and send to audio stream
if (bitDepth == 16)
sendSamples16BitDitherStereo(stream, samplesToMix);
else
sendSamples32BitStereo(stream, samplesToMix);
}
int32_t pattQueueReadSize(void)
{
while (pattQueueClearing);
if (pattSync.writePos > pattSync.readPos)
return pattSync.writePos - pattSync.readPos;
else if (pattSync.writePos < pattSync.readPos)
return pattSync.writePos - pattSync.readPos + SYNC_QUEUE_LEN + 1;
else
return 0;
}
int32_t pattQueueWriteSize(void)
{
int32_t size;
if (pattSync.writePos > pattSync.readPos)
{
size = pattSync.readPos - pattSync.writePos + SYNC_QUEUE_LEN;
}
else if (pattSync.writePos < pattSync.readPos)
{
pattQueueClearing = true;
/* Buffer is full, reset the read/write pos. This is actually really nasty since
** read/write are two different threads, but because of timestamp validation it
** shouldn't be that dangerous.
** It will also create a small visual stutter while the buffer is getting filled,
** though that is barely noticable on normal buffer sizes, and it takes a minute
** or two at max BPM between each time (when queue size is default, 4095)
*/
pattSync.data[0].timestamp = 0;
pattSync.readPos = 0;
pattSync.writePos = 0;
size = SYNC_QUEUE_LEN;
pattQueueClearing = false;
}
else
{
size = SYNC_QUEUE_LEN;
}
return size;
}
bool pattQueuePush(pattSyncData_t t)
{
if (!pattQueueWriteSize())
return false;
assert(pattSync.writePos <= SYNC_QUEUE_LEN);
pattSync.data[pattSync.writePos] = t;
pattSync.writePos = (pattSync.writePos + 1) & SYNC_QUEUE_LEN;
return true;
}
bool pattQueuePop(void)
{
if (!pattQueueReadSize())
return false;
pattSync.readPos = (pattSync.readPos + 1) & SYNC_QUEUE_LEN;
assert(pattSync.readPos <= SYNC_QUEUE_LEN);
return true;
}
pattSyncData_t *pattQueuePeek(void)
{
if (!pattQueueReadSize())
return NULL;
assert(pattSync.readPos <= SYNC_QUEUE_LEN);
return &pattSync.data[pattSync.readPos];
}
uint64_t getPattQueueTimestamp(void)
{
if (!pattQueueReadSize())
return 0;
assert(pattSync.readPos <= SYNC_QUEUE_LEN);
return pattSync.data[pattSync.readPos].timestamp;
}
int32_t chQueueReadSize(void)
{
while (chQueueClearing);
if (chSync.writePos > chSync.readPos)
return chSync.writePos - chSync.readPos;
else if (chSync.writePos < chSync.readPos)
return chSync.writePos - chSync.readPos + SYNC_QUEUE_LEN + 1;
else
return 0;
}
int32_t chQueueWriteSize(void)
{
int32_t size;
if (chSync.writePos > chSync.readPos)
{
size = chSync.readPos - chSync.writePos + SYNC_QUEUE_LEN;
}
else if (chSync.writePos < chSync.readPos)
{
chQueueClearing = true;
/* Buffer is full, reset the read/write pos. This is actually really nasty since
** read/write are two different threads, but because of timestamp validation it
** shouldn't be that dangerous.
** It will also create a small visual stutter while the buffer is getting filled,
** though that is barely noticable on normal buffer sizes, and it takes several
** minutes between each time (when queue size is default, 16384)
*/
chSync.data[0].timestamp = 0;
chSync.readPos = 0;
chSync.writePos = 0;
size = SYNC_QUEUE_LEN;
chQueueClearing = false;
}
else
{
size = SYNC_QUEUE_LEN;
}
return size;
}
bool chQueuePush(chSyncData_t t)
{
if (!chQueueWriteSize())
return false;
assert(chSync.writePos <= SYNC_QUEUE_LEN);
chSync.data[chSync.writePos] = t;
chSync.writePos = (chSync.writePos + 1) & SYNC_QUEUE_LEN;
return true;
}
bool chQueuePop(void)
{
if (!chQueueReadSize())
return false;
chSync.readPos = (chSync.readPos + 1) & SYNC_QUEUE_LEN;
assert(chSync.readPos <= SYNC_QUEUE_LEN);
return true;
}
chSyncData_t *chQueuePeek(void)
{
if (!chQueueReadSize())
return NULL;
assert(chSync.readPos <= SYNC_QUEUE_LEN);
return &chSync.data[chSync.readPos];
}
uint64_t getChQueueTimestamp(void)
{
if (!chQueueReadSize())
return 0;
assert(chSync.readPos <= SYNC_QUEUE_LEN);
return chSync.data[chSync.readPos].timestamp;
}
void lockAudio(void)
{
if (audio.dev != 0)
SDL_LockAudioDevice(audio.dev);
audio.locked = true;
}
void unlockAudio(void)
{
if (audio.dev != 0)
SDL_UnlockAudioDevice(audio.dev);
audio.locked = false;
}
void resetSyncQueues(void)
{
pattSync.data[0].timestamp = 0;
pattSync.readPos = 0;
pattSync.writePos = 0;
chSync.data[0].timestamp = 0;
chSync.writePos = 0;
chSync.readPos = 0;
}
void lockMixerCallback(void) // lock audio + clear voices/scopes (for short operations)
{
if (!audio.locked)
lockAudio();
audio.resetSyncTickTimeFlag = true;
stopVoices(); // VERY important! prevents potential crashes by purging pointers
// scopes, mixer and replayer are guaranteed to not be active at this point
resetSyncQueues();
}
void unlockMixerCallback(void)
{
stopVoices(); // VERY important! prevents potential crashes by purging pointers
if (audio.locked)
unlockAudio();
}
void pauseAudio(void) // lock audio + clear voices/scopes + render silence (for long operations)
{
if (audioPaused)
{
stopVoices(); // VERY important! prevents potential crashes by purging pointers
return;
}
if (audio.dev > 0)
SDL_PauseAudioDevice(audio.dev, true);
audio.resetSyncTickTimeFlag = true;
stopVoices(); // VERY important! prevents potential crashes by purging pointers
// scopes, mixer and replayer are guaranteed to not be active at this point
resetSyncQueues();
audioPaused = true;
}
void resumeAudio(void) // unlock audio
{
if (!audioPaused)
return;
if (audio.dev > 0)
SDL_PauseAudioDevice(audio.dev, false);
audioPaused = false;
}
static void fillVisualsSyncBuffer(void)
{
pattSyncData_t pattSyncData;
chSyncData_t chSyncData;
if (audio.resetSyncTickTimeFlag)
{
audio.resetSyncTickTimeFlag = false;
audio.tickTime64 = SDL_GetPerformanceCounter() + audio.audLatencyPerfValInt;
audio.tickTime64Frac = audio.audLatencyPerfValFrac;
}
if (songPlaying)
{
// push pattern variables to sync queue
pattSyncData.tick = song.curReplayerTick;
pattSyncData.row = song.curReplayerRow;
pattSyncData.pattNum = song.curReplayerPattNum;
pattSyncData.songPos = song.curReplayerSongPos;
pattSyncData.BPM = (uint8_t)song.BPM;
pattSyncData.speed = (uint8_t)song.speed;
pattSyncData.globalVolume = (uint8_t)song.globalVolume;
pattSyncData.timestamp = audio.tickTime64;
pattQueuePush(pattSyncData);
}
// push channel variables to sync queue
syncedChannel_t *c = chSyncData.channels;
channel_t *s = channel;
voice_t *v = voice;
for (int32_t i = 0; i < song.numChannels; i++, c++, s++, v++)
{
c->scopeVolume = v->scopeVolume;
c->scopeDelta = v->scopeDelta;
c->instrNum = s->instrNum;
c->smpNum = s->smpNum;
c->status = s->tmpStatus;
c->smpStartPos = s->smpStartPos;
c->pianoNoteNum = 255; // no piano key
if (songPlaying && (c->status & IS_Period) && !s->keyOff)
{
const int32_t note = getPianoKey(s->finalPeriod, s->finetune, s->relativeNote);
if (note >= 0 && note <= 95)
c->pianoNoteNum = (uint8_t)note;
}
}
chSyncData.timestamp = audio.tickTime64;
chQueuePush(chSyncData);
audio.tickTime64 += tickTimeLenInt;
audio.tickTime64Frac += tickTimeLenFrac;
if (audio.tickTime64Frac >= TICK_TIME_FRAC_SCALE)
{
audio.tickTime64Frac &= TICK_TIME_FRAC_MASK;
audio.tickTime64++;
}
}
static void SDLCALL audioCallback(void *userdata, Uint8 *stream, int len)
{
if (editor.wavIsRendering)
return;
len >>= smpShiftValue; // bytes -> samples
if (len <= 0)
return;
int32_t bufferPosition = 0;
uint32_t samplesLeft = len;
while (samplesLeft > 0)
{
if (audio.tickSampleCounter == 0) // new replayer tick
{
replayerBusy = true;
if (audio.volumeRampingFlag)
resetRampVolumes();
tickReplayer();
updateVoices();
fillVisualsSyncBuffer();
audio.tickSampleCounter = audio.samplesPerTickInt;
audio.tickSampleCounterFrac += audio.samplesPerTickFrac;
if (audio.tickSampleCounterFrac >= BPM_FRAC_SCALE)
{
audio.tickSampleCounterFrac &= BPM_FRAC_MASK;
audio.tickSampleCounter++;
}
replayerBusy = false;
}
uint32_t samplesToMix = samplesLeft;
if (samplesToMix > audio.tickSampleCounter)
samplesToMix = audio.tickSampleCounter;
doChannelMixing(bufferPosition, samplesToMix);
bufferPosition += samplesToMix;
audio.tickSampleCounter -= samplesToMix;
samplesLeft -= samplesToMix;
}
if (config.specialFlags & BITDEPTH_16)
sendSamples16BitDitherStereo(stream, len);
else
sendSamples32BitStereo(stream, len);
(void)userdata;
}
static bool setupAudioBuffers(void)
{
const int32_t maxAudioFreq = MAX(MAX_AUDIO_FREQ, MAX_WAV_RENDER_FREQ);
int32_t maxSamplesPerTick = (int32_t)ceil(maxAudioFreq / (MIN_BPM / 2.5)) + 1;
audio.fMixBufferL = (float *)calloc(maxSamplesPerTick, sizeof (float));
audio.fMixBufferR = (float *)calloc(maxSamplesPerTick, sizeof (float));
if (audio.fMixBufferL == NULL || audio.fMixBufferR == NULL)
return false;
return true;
}
static void freeAudioBuffers(void)
{
if (audio.fMixBufferL != NULL)
{
free(audio.fMixBufferL);
audio.fMixBufferL = NULL;
}
if (audio.fMixBufferR != NULL)
{
free(audio.fMixBufferR);
audio.fMixBufferR = NULL;
}
}
static void calcAudioLatencyVars(int32_t audioBufferSize, int32_t audioFreq)
{
double dInt;
if (audioFreq == 0)
return;
const double dAudioLatencySecs = audioBufferSize / (double)audioFreq;
double dFrac = modf(dAudioLatencySecs * editor.dPerfFreq, &dInt);
audio.audLatencyPerfValInt = (uint32_t)dInt;
audio.audLatencyPerfValFrac = (uint64_t)((dFrac * TICK_TIME_FRAC_SCALE) + 0.5); // rounded
audio.dAudioLatencyMs = dAudioLatencySecs * 1000.0;
}
static void setLastWorkingAudioDevName(void)
{
if (audio.lastWorkingAudioDeviceName != NULL)
{
free(audio.lastWorkingAudioDeviceName);
audio.lastWorkingAudioDeviceName = NULL;
}
if (audio.currOutputDevice != NULL)
audio.lastWorkingAudioDeviceName = strdup(audio.currOutputDevice);
}
bool setupAudio(bool showErrorMsg)
{
SDL_AudioSpec want, have;
closeAudio();
if (config.audioFreq < MIN_AUDIO_FREQ || config.audioFreq > MAX_AUDIO_FREQ)
config.audioFreq = DEFAULT_AUDIO_FREQ;
// get audio buffer size from config special flags
uint16_t configAudioBufSize = 1024;
if (config.specialFlags & BUFFSIZE_512)
configAudioBufSize = 512;
else if (config.specialFlags & BUFFSIZE_2048)
configAudioBufSize = 2048;
audio.wantFreq = config.audioFreq;
audio.wantSamples = configAudioBufSize;
// set up audio device
memset(&want, 0, sizeof (want));
want.freq = config.audioFreq;
want.format = (config.specialFlags & BITDEPTH_32) ? AUDIO_F32 : AUDIO_S16;
want.channels = 2;
want.callback = audioCallback;
want.samples = configAudioBufSize;
audio.dev = SDL_OpenAudioDevice(audio.currOutputDevice, 0, &want, &have, SDL_AUDIO_ALLOW_ANY_CHANGE);
if (audio.dev == 0)
{
if (showErrorMsg)
showErrorMsgBox("Couldn't open audio device:\n\"%s\"\n\nDo you have an audio device enabled and plugged in?", SDL_GetError());
return false;
}
// test if the received audio format is compatible
if (have.format != AUDIO_S16 && have.format != AUDIO_F32)
{
if (showErrorMsg)
showErrorMsgBox("Couldn't open audio device:\nThis program only supports 16-bit or 32-bit float audio streams. Sorry!");
closeAudio();
return false;
}
// test if the received audio stream is compatible
if (have.channels != 2)
{
if (showErrorMsg)
showErrorMsgBox("Couldn't open audio device:\nThis program only supports stereo audio streams. Sorry!");
closeAudio();
return false;
}
#if CPU_64BIT
if (have.freq != 44100 && have.freq != 48000 && have.freq != 96000)
#else // 32-bit CPUs only support .16fp resampling precision. Not sensible with high rates.
if (have.freq != 44100 && have.freq != 48000)
#endif
{
if (showErrorMsg)
showErrorMsgBox("Couldn't open audio device:\nThis program doesn't support an audio output rate of %dHz. Sorry!", have.freq);
closeAudio();
return false;
}
if (!setupAudioBuffers())
{
if (showErrorMsg)
showErrorMsgBox("Not enough memory!");
closeAudio();
return false;
}
// set new bit depth flag
int8_t newBitDepth = 16;
config.specialFlags &= ~BITDEPTH_32;
config.specialFlags |= BITDEPTH_16;
if (have.format == AUDIO_F32)
{
newBitDepth = 24;
config.specialFlags &= ~BITDEPTH_16;
config.specialFlags |= BITDEPTH_32;
}
audio.haveFreq = have.freq;
audio.haveSamples = have.samples;
config.audioFreq = audio.freq = have.freq;
calcAudioLatencyVars(have.samples, have.freq);
smpShiftValue = (newBitDepth == 16) ? 2 : 3;
// make a copy of the new known working audio settings
audio.lastWorkingAudioFreq = config.audioFreq;
audio.lastWorkingAudioBits = config.specialFlags & (BITDEPTH_16 + BITDEPTH_32 + BUFFSIZE_512 + BUFFSIZE_1024 + BUFFSIZE_2048);
setLastWorkingAudioDevName();
// update config audio radio buttons if we're on that screen at the moment
if (ui.configScreenShown && editor.currConfigScreen == CONFIG_SCREEN_AUDIO)
showConfigScreen();
updateWavRendererSettings();
setAudioAmp(config.boostLevel, config.masterVol, !!(config.specialFlags & BITDEPTH_32));
// don't call stopVoices() in this routine
for (int32_t i = 0; i < MAX_CHANNELS; i++)
stopVoice(i);
stopAllScopes();
// zero tick sample counter so that it will instantly initiate a tick
audio.tickSampleCounterFrac = audio.tickSampleCounter = 0;
calcReplayerVars(audio.freq);
if (song.BPM == 0)
song.BPM = 125;
setMixerBPM(song.BPM); // this is important
audio.resetSyncTickTimeFlag = true;
setWavRenderFrequency(audio.freq);
setWavRenderBitDepth((config.specialFlags & BITDEPTH_32) ? 32 : 16);
return true;
}
void closeAudio(void)
{
if (audio.dev > 0)
{
SDL_PauseAudioDevice(audio.dev, true);
SDL_CloseAudioDevice(audio.dev);
audio.dev = 0;
}
freeAudioBuffers();
}