CoreAudio AudioQueue停止问题

Question

我正在制作一个基于CoreAudio的FLAC播放器，并且遇到了AudioQueues的调皮问题。 我初始化我这样的东西（用下划线开头的变量是实例变量）：在44.1千赫

_flacDecoder = FLAC__stream_decoder_new(); 

    AudioStreamBasicDescription asbd = { 
     .mFormatID = kAudioFormatLinearPCM, 
     .mFormatFlags = kAudioFormatFlagIsSignedInteger | kAudioFormatFlagIsPacked, 
     .mSampleRate = 44100, 
     .mChannelsPerFrame = 2, 
     .mBitsPerChannel = 16, 
     .mBytesPerPacket = 4, 
     .mFramesPerPacket = 1, 
     .mBytesPerFrame = 4, 
     .mReserved = 0 
    }; 

    AudioQueueNewOutput(&asbd, HandleOutputBuffer, (__bridge void *)(self), CFRunLoopGetCurrent(), kCFRunLoopDefaultMode, 0, &_audioQueue); 

    for (int i = 0; i < kNumberBuffers; ++i) { 
     AudioQueueAllocateBuffer(_audioQueue, 0x10000, &_audioQueueBuffers[i]); 
    } 

    AudioQueueSetParameter(_audioQueue, kAudioQueueParam_Volume, 1.0); 

16位立体声PCM，非常基本的设置。 kNumberBuffers是3，每个缓冲区是0x10000字节。 我填充缓存与这些回调：

static void HandleOutputBuffer(void *inUserData, AudioQueueRef inAQ, AudioQueueBufferRef inBuffer){ 

    FLACPlayer * self = (__bridge FLACPlayer*)inUserData; 

    UInt32 largestBlockSizeInBytes = self->_currentStreamInfo.max_blocksize * self->_currentStreamInfo.channels * self->_currentStreamInfo.bits_per_sample/8; 

    inBuffer->mAudioDataByteSize = 0; 
    self->_buffer = inBuffer; 

    while(inBuffer->mAudioDataByteSize <= inBuffer->mAudioDataBytesCapacity - largestBlockSizeInBytes){ 
     FLAC__bool result = FLAC__stream_decoder_process_single(self->_flacDecoder); 
     assert(result); 

     if(FLAC__stream_decoder_get_state(self->_flacDecoder) == FLAC__STREAM_DECODER_END_OF_STREAM){ 
      AudioQueueStop(self->_audioQueue, false); 
      break; 
     } 
    } 

    AudioQueueEnqueueBuffer(inAQ, inBuffer, 0, NULL); 
} 

static FLAC__StreamDecoderWriteStatus flacDecoderWriteCallback(const FLAC__StreamDecoder *decoder, const FLAC__Frame *frame, const FLAC__int32 * const buffer[], void *client_data){ 

    FLACPlayer * self = (__bridge FLACPlayer *)client_data; 

    assert(frame->header.bits_per_sample == 16); // TODO 

    int16_t * bufferWritePosition = (int16_t*)((uint8_t*)self->_buffer->mAudioData + self->_buffer->mAudioDataByteSize); 
    for(int i = 0; i < frame->header.blocksize; i++){ 
     for(int j = 0; j < frame->header.channels; j++){ 
      *bufferWritePosition = (int16_t)buffer[j][i]; 
      bufferWritePosition++; 
     } 
    } 

    int totalFramePayloadInBytes = frame->header.channels * frame->header.blocksize * frame->header.bits_per_sample/8; 
    self->_buffer->mAudioDataByteSize += totalFramePayloadInBytes; 

    return FLAC__STREAM_DECODER_WRITE_STATUS_CONTINUE; 
} 

static void flacDecoderMetadataCallback(const FLAC__StreamDecoder *decoder, const FLAC__StreamMetadata *metadata, void *client_data){ 

    FLACPlayer * self = (__bridge FLACPlayer*) client_data; 

    if(metadata->type == FLAC__METADATA_TYPE_STREAMINFO){ 
     self->_currentStreamInfo = metadata->data.stream_info; 
    } 
} 

基本上当队列请求一个新的缓冲区，我填的是缓冲区中的FLAC__stream_decoder，那么我入队了。就像其他人一样。当libFLAC告诉我我已经到达文件末尾时，我告诉AudioQueue异步停止，直到它消耗了所有缓冲区的内容为止。然而，播放完毕之前，播放停止了一小会儿。如果我删除此行：

AudioQueueStop(self->_audioQueue, false); 

一切工作正常;音频播放端到端，虽然我的队列一直运行直到时间结束。如果我把上面一行是：

AudioQueueStop(self->_audioQueue, true); 

然后回放立即停止/同步，因为你会从苹果公司的文档中获得：

如果传递真实，停止立即发生（即， 同步）。如果通过false，函数将立即返回 ，但音频队列不会停止，直到播放队列缓冲区 或记录（即异步停止）。音频队列 根据需要调用回调，直到队列实际停止。

我的问题是： - 我做错了什么？ - 如何才能播放我的音频直到结束，并正确关闭队列？

Answer 1

当然，这个东西几个小时后挣扎，我已经找到了解决方案分钟张贴这个问题后... 的问题是，AudioQueue不关心缓冲区调用AudioQueueStop后排队（ ...，假）。所以现在我喂这样的队列，一切正常般的魅力：

static void HandleOutputBuffer(void *inUserData, AudioQueueRef inAQ, AudioQueueBufferRef inBuffer){ 

    FLACPlayer * self = (__bridge FLACPlayer*)inUserData; 

    UInt32 largestBlockSizeInBytes = self->_currentStreamInfo.max_blocksize * self->_currentStreamInfo.channels * self->_currentStreamInfo.bits_per_sample/8; 

    inBuffer->mAudioDataByteSize = 0; 
    self->_buffer = inBuffer; 

    bool shouldStop = false; 

    while(inBuffer->mAudioDataByteSize <= inBuffer->mAudioDataBytesCapacity - largestBlockSizeInBytes){ 
     FLAC__bool result = FLAC__stream_decoder_process_single(self->_flacDecoder); 
     assert(result); 

     if(FLAC__stream_decoder_get_state(self->_flacDecoder) == FLAC__STREAM_DECODER_END_OF_STREAM){ 
      shouldStop = true; 
      break; 
     } 
    } 

    AudioQueueEnqueueBuffer(inAQ, inBuffer, 0, NULL); 
    if(shouldStop){ 
     AudioQueueStop(self->_audioQueue, false); 
    } 
}