diff options
Diffstat (limited to 'tinyDAV/src/audio/coreaudio/tdav_consumer_coreaudio.c')
| -rw-r--r-- | tinyDAV/src/audio/coreaudio/tdav_consumer_coreaudio.c | 269 |
1 files changed, 269 insertions, 0 deletions
diff --git a/tinyDAV/src/audio/coreaudio/tdav_consumer_coreaudio.c b/tinyDAV/src/audio/coreaudio/tdav_consumer_coreaudio.c new file mode 100644 index 0000000..39fe1a9 --- /dev/null +++ b/tinyDAV/src/audio/coreaudio/tdav_consumer_coreaudio.c @@ -0,0 +1,269 @@ +/*
+* Copyright (C) 2009-2010 Mamadou Diop.
+*
+* Contact: Mamadou Diop <diopmamadou(at)doubango.org>
+*
+* This file is part of Open Source Doubango Framework.
+*
+* DOUBANGO is free software: you can redistribute it and/or modify
+* it under the terms of the GNU General Public License as published by
+* the Free Software Foundation, either version 3 of the License, or
+* (at your option) any later version.
+*
+* DOUBANGO is distributed in the hope that it will be useful,
+* but WITHOUT ANY WARRANTY; without even the implied warranty of
+* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
+* GNU General Public License for more details.
+*
+* You should have received a copy of the GNU General Public License
+* along with DOUBANGO.
+*
+*/
+
+/**@file tdav_consumer_coreaudio.c
+ * @brief Audio Consumer for MacOSX and iOS platforms.
+ *
+ * @authors
+ * - Laurent Etiemble <laurent.etiemble(at)gmail.com>
+ * - Mamadou Diop <diopmamadou(at)doubango(dot)org>
+ *
+ * @date Created: Sat Nov 8 16:54:58 2009 letiemble
+ */
+#include "tinydav/audio/coreaudio/tdav_consumer_coreaudio.h"
+
+
+// http://developer.apple.com/library/mac/#documentation/MusicAudio/Reference/AudioQueueReference/Reference/reference.html
+#if HAVE_COREAUDIO
+
+#include "tsk_thread.h"
+#include "tsk_memory.h"
+#include "tsk_debug.h"
+
+static void __handle_output_buffer(void *userdata, AudioQueueRef queue, AudioQueueBufferRef buffer) {
+ OSStatus ret;
+ void *data;
+ tsk_size_t out_size = 0;
+ tdav_consumer_coreaudio_t* consumer = (tdav_consumer_coreaudio_t*)userdata;
+
+ if (!consumer->started) {
+ return;
+ }
+
+ if((data = tdav_consumer_audio_get(TDAV_CONSUMER_AUDIO(consumer), &out_size))){
+ // If we can get audio to play, then copy in the buffer
+ memcpy(buffer->mAudioData, data, TSK_MIN(consumer->buffer_size, out_size));
+ TSK_FREE(data);
+ } else{
+ // Put silence if there is no audio to play
+ memset(buffer->mAudioData, 0, consumer->buffer_size);
+ }
+
+ // Re-enqueue the buffer
+ ret = AudioQueueEnqueueBuffer(consumer->queue, buffer, 0, NULL);
+}
+
+/* ============ Media Consumer Interface ================= */
+#define tdav_consumer_coreaudio_set tsk_null
+
+int tdav_consumer_coreaudio_prepare(tmedia_consumer_t* self, const tmedia_codec_t* codec)
+{
+ OSStatus ret;
+ tsk_size_t i;
+ tdav_consumer_coreaudio_t* consumer = (tdav_consumer_coreaudio_t*)self;
+
+ if(!consumer || !codec && codec->plugin){
+ TSK_DEBUG_ERROR("Invalid parameter");
+ return -1;
+ }
+
+ TDAV_CONSUMER_AUDIO(consumer)->channels = codec->plugin->audio.channels;
+ TDAV_CONSUMER_AUDIO(consumer)->rate = codec->plugin->rate;
+ /* codec should have ptime */
+
+ // Set audio category
+ UInt32 category = kAudioSessionCategory_PlayAndRecord;
+ AudioSessionSetProperty(kAudioSessionProperty_AudioCategory, sizeof(category), &category);
+
+ // Create the audio stream description
+ AudioStreamBasicDescription *description = &(consumer->description);
+ description->mSampleRate = TDAV_CONSUMER_AUDIO(consumer)->rate;
+ description->mFormatID = kAudioFormatLinearPCM;
+ description->mFormatFlags = kAudioFormatFlagIsSignedInteger | kAudioFormatFlagIsPacked;
+ description->mChannelsPerFrame = TDAV_CONSUMER_AUDIO(consumer)->channels;
+ description->mFramesPerPacket = 1;
+ description->mBitsPerChannel = TDAV_CONSUMER_AUDIO(consumer)->bits_per_sample;
+ description->mBytesPerPacket = description->mBitsPerChannel / 8 * description->mChannelsPerFrame;
+ description->mBytesPerFrame = description->mBytesPerPacket;
+ description->mReserved = 0;
+
+ int packetperbuffer = 1000 / TDAV_CONSUMER_AUDIO(consumer)->ptime;
+ consumer->buffer_size = description->mSampleRate * description->mBytesPerFrame / packetperbuffer;
+
+ // Create the playback audio queue
+ ret = AudioQueueNewOutput(&(consumer->description),
+ __handle_output_buffer,
+ consumer,
+ NULL,
+ NULL,
+ 0,
+ &(consumer->queue));
+
+ for(i = 0; i < CoreAudioPlayBuffers; i++) {
+ // Create the buffer for the queue
+ ret = AudioQueueAllocateBuffer(consumer->queue, consumer->buffer_size, &(consumer->buffers[i]));
+ if (ret) {
+ break;
+ }
+
+ // Clear the data
+ memset(consumer->buffers[i]->mAudioData, 0, consumer->buffer_size);
+ consumer->buffers[i]->mAudioDataByteSize = consumer->buffer_size;
+
+ // Enqueue the buffer
+ ret = AudioQueueEnqueueBuffer(consumer->queue, consumer->buffers[i], 0, NULL);
+ if (ret) {
+ break;
+ }
+ }
+
+ return ret;
+}
+
+int tdav_consumer_coreaudio_start(tmedia_consumer_t* self)
+{
+ OSStatus ret;
+ tdav_consumer_coreaudio_t* consumer = (tdav_consumer_coreaudio_t*)self;
+
+ if(!consumer){
+ TSK_DEBUG_ERROR("Invalid parameter");
+ return -1;
+ }
+
+ if(consumer->started){
+ TSK_DEBUG_WARN("Consumer already started");
+ return 0;
+ }
+
+ consumer->started = tsk_true;
+ ret = AudioQueueStart(consumer->queue, NULL);
+
+ return ret;
+}
+
+int tdav_consumer_coreaudio_consume(tmedia_consumer_t* self, void** buffer, tsk_size_t size, const tsk_object_t* proto_hdr)
+{
+ tdav_consumer_coreaudio_t* consumer = (tdav_consumer_coreaudio_t*)self;
+
+ if(!consumer || !buffer || !*buffer || !size){
+ TSK_DEBUG_ERROR("Invalid parameter");
+ return -1;
+ }
+ // buffer is already decoded
+ return tdav_consumer_audio_put(TDAV_CONSUMER_AUDIO(consumer), buffer, size, proto_hdr);
+}
+
+int tdav_consumer_coreaudio_pause(tmedia_consumer_t* self)
+{
+ OSStatus ret;
+ tdav_consumer_coreaudio_t* consumer = (tdav_consumer_coreaudio_t*)self;
+
+ if(!consumer){
+ TSK_DEBUG_ERROR("Invalid parameter");
+ return -1;
+ }
+
+ ret = AudioQueuePause(consumer->queue);
+
+ return ret;
+}
+
+int tdav_consumer_coreaudio_stop(tmedia_consumer_t* self)
+{
+ OSStatus ret;
+ tdav_consumer_coreaudio_t* consumer = (tdav_consumer_coreaudio_t*)self;
+
+ if(!self){
+ TSK_DEBUG_ERROR("Invalid parameter");
+ return -1;
+ }
+
+ if(!consumer->started){
+ TSK_DEBUG_WARN("Consumer not started");
+ return 0;
+ }
+
+ consumer->started = tsk_false;
+ ret = AudioQueueStop(consumer->queue, false);
+
+ return ret;
+}
+
+//
+// coreaudio consumer object definition
+//
+/* constructor */
+static tsk_object_t* tdav_consumer_coreaudio_ctor(tsk_object_t * self, va_list * app)
+{
+ tdav_consumer_coreaudio_t *consumer = self;
+ if(consumer){
+ /* init base */
+ tdav_consumer_audio_init(TDAV_CONSUMER_AUDIO(consumer));
+ }
+ return self;
+}
+/* destructor */
+static tsk_object_t* tdav_consumer_coreaudio_dtor(tsk_object_t * self)
+{
+ tdav_consumer_coreaudio_t *consumer = self;
+ if(consumer){
+ // Stop the consumer if not done
+ if(consumer->started){
+ tdav_consumer_coreaudio_stop(self);
+ }
+
+ // Free all buffers and dispose the queue
+ if (consumer->queue) {
+ tsk_size_t i;
+
+ for(i=0; i<CoreAudioPlayBuffers; i++){
+ AudioQueueFreeBuffer(consumer->queue, consumer->buffers[i]);
+ }
+
+ AudioQueueDispose(consumer->queue, true);
+ }
+
+ /* deinit base */
+ tdav_consumer_audio_deinit(TDAV_CONSUMER_AUDIO(consumer));
+ }
+
+ return self;
+}
+
+/* object definition */
+static const tsk_object_def_t tdav_consumer_coreaudio_def_s =
+{
+ sizeof(tdav_consumer_coreaudio_t),
+ tdav_consumer_coreaudio_ctor,
+ tdav_consumer_coreaudio_dtor,
+ tdav_consumer_audio_cmp,
+};
+
+/* plugin definition*/
+static const tmedia_consumer_plugin_def_t tdav_consumer_coreaudio_plugin_def_s =
+{
+ &tdav_consumer_coreaudio_def_s,
+
+ tmedia_audio,
+ "Apple CoreAudio consumer",
+
+ tdav_consumer_coreaudio_set,
+ tdav_consumer_coreaudio_prepare,
+ tdav_consumer_coreaudio_start,
+ tdav_consumer_coreaudio_consume,
+ tdav_consumer_coreaudio_pause,
+ tdav_consumer_coreaudio_stop
+};
+
+const tmedia_consumer_plugin_def_t *tdav_consumer_coreaudio_plugin_def_t = &tdav_consumer_coreaudio_plugin_def_s;
+
+#endif /* HAVE_COREAUDIO */
|
