diff options
Diffstat (limited to 'branches/1.0/tinyDAV/src/audio/coreaudio/tdav_consumer_coreaudio.c')
| -rw-r--r-- | branches/1.0/tinyDAV/src/audio/coreaudio/tdav_consumer_coreaudio.c | 269 |
1 files changed, 0 insertions, 269 deletions
diff --git a/branches/1.0/tinyDAV/src/audio/coreaudio/tdav_consumer_coreaudio.c b/branches/1.0/tinyDAV/src/audio/coreaudio/tdav_consumer_coreaudio.c deleted file mode 100644 index 39fe1a9..0000000 --- a/branches/1.0/tinyDAV/src/audio/coreaudio/tdav_consumer_coreaudio.c +++ /dev/null @@ -1,269 +0,0 @@ -/*
-* 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 */
|
