6502/CLK
1
0
Fork 0
mirror of https://github.com/TomHarte/CLK.git synced 2024-12-23 20:29:42 +00:00
Code Issues Projects Releases Wiki Activity

As an initial step, ensured latency doesn't pile up endlessly.

Browse Source
This commit is contained in:
Thomas Harte 2018-05-15 21:12:43 -04:00
parent 7c2721d54d
commit f7decd80b6
1 changed files with 18 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

38
OSBindings/Mac/Clock Signal/Audio/CSAudioQueue.m
View File

@ -27,9 +27,9 @@ static NSLock *CSAudioQueueDeallocLock;
@implementation CSAudioQueue {
AudioQueueRef _audioQueue;
AudioQueueBufferRef _storedBuffers[NumberOfStoredAudioQueueBuffer];
NSLock *_storedBuffersLock;
CSWeakAudioQueuePointer *_weakPointer;
int _enqueuedBuffers;
}
#pragma mark - AudioQueue callbacks
@ -39,16 +39,19 @@ static NSLock *CSAudioQueueDeallocLock;
*/
- (BOOL)audioQueue:(AudioQueueRef)theAudioQueue didCallbackWithBuffer:(AudioQueueBufferRef)buffer {
[_storedBuffersLock lock];
for(int c = 0; c < NumberOfStoredAudioQueueBuffer; c++) {
if(!_storedBuffers[c] || buffer->mAudioDataBytesCapacity > _storedBuffers[c]->mAudioDataBytesCapacity) {
if(_storedBuffers[c]) AudioQueueFreeBuffer(_audioQueue, _storedBuffers[c]);
_storedBuffers[c] = buffer;
[_storedBuffersLock unlock];
return YES;
}
--_enqueuedBuffers;
// If that leaves nothing in the queue, re-enqueue whatever just came back in order to keep the
// queue going. AudioQueues seem to stop playing and never restart no matter how much encouragement
// if exhausted.
if(!_enqueuedBuffers) {
AudioQueueEnqueueBuffer(theAudioQueue, buffer, 0, NULL);
++_enqueuedBuffers;
} else {
AudioQueueFreeBuffer(_audioQueue, buffer);
}
[_storedBuffersLock unlock];
AudioQueueFreeBuffer(_audioQueue, buffer);
return YES;
}
@ -158,18 +161,12 @@ static void audioOutputCallback(
size_t bufferBytes = lengthInSamples * sizeof(int16_t);
[_storedBuffersLock lock];
for(int c = 0; c < NumberOfStoredAudioQueueBuffer; c++) {
if(_storedBuffers[c] && _storedBuffers[c]->mAudioDataBytesCapacity >= bufferBytes) {
memcpy(_storedBuffers[c]->mAudioData, buffer, bufferBytes);
_storedBuffers[c]->mAudioDataByteSize = (UInt32)bufferBytes;
AudioQueueEnqueueBuffer(_audioQueue, _storedBuffers[c], 0, NULL);
_storedBuffers[c] = NULL;
[_storedBuffersLock unlock];
return;
}
// Don't enqueue more than 4 buffers ahead of now, to ensure not too much latency accrues.
if(_enqueuedBuffers > 4) {
[_storedBuffersLock unlock];
return;
}
[_storedBuffersLock unlock];
++_enqueuedBuffers;
AudioQueueBufferRef newBuffer;
AudioQueueAllocateBuffer(_audioQueue, (UInt32)bufferBytes * 2, &newBuffer);
@ -177,6 +174,7 @@ static void audioOutputCallback(
newBuffer->mAudioDataByteSize = (UInt32)bufferBytes;
AudioQueueEnqueueBuffer(_audioQueue, newBuffer, 0, NULL);
[_storedBuffersLock unlock];
}
#pragma mark - Sampling Rate getters