omxsymbianoutputstreamtest.c

Go to the documentation of this file.

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <pthread.h>
#include <sys/mman.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <string.h>

#include <OMX_Core.h>
#include <OMX_Component.h>
#include <OMX_Types.h>
#include <OMX_Audio.h>

#include "omxsymbianoutputstreamtest.h"
#include "tsemaphore.h"

/* Application private date: should go in the component field (segs...) */
appPrivateType* appPriv;

int main(int argc, char** argv)
{
    OMX_ERRORTYPE err;
    OMX_HANDLETYPE handle;
    OMX_CALLBACKTYPE callbacks;
    

    OMX_PORT_PARAM_TYPE param;
    OMX_AUDIO_PARAM_PCMMODETYPE omxAudioParamPcmMode;
    OMX_BUFFERHEADERTYPE *omxbuffer1, *omxbuffer2;
    int fd = 0;
    unsigned int filesize;
    int data_read;
    int curr_buff;
    int i;

    callbacks.EventHandler = symbianoutputstreamEventHandler;
    callbacks.EmptyBufferDone = symbianoutputstreamEmptyBufferDone;
    callbacks.FillBufferDone = NULL;

    DEBUG(DEB_LEV_PARAMS, "Starting SymbianOutputStreamTest\n");

      fd = open("C:\\music_stereo_44k.raw", O_RDONLY);
      if(fd < 0)
      {
        DEBUG(DEB_LEV_PARAMS, "Error with file descriptor\n");
        exit(1);
      }

    filesize = getFileSize(fd);
    
    /* Initialize application private data */
    appPriv = malloc(sizeof(appPrivateType));
    pthread_cond_init(&appPriv->condition, NULL);
    pthread_mutex_init(&appPriv->mutex, NULL);
    appPriv->eventSem = malloc(sizeof(tsem_t));
    tsem_init(appPriv->eventSem, 0);
    
    err = OMX_Init();
    
    err = OMX_GetHandle(&handle, "OMX.nokia.outputstream.component", NULL /*appPriv */, &callbacks);
    if(err != OMX_ErrorNone){
        DEBUG(DEB_LEV_ERR, "Component Not Found!!\n");
        exit(1);
    }
    
    err = OMX_GetParameter(handle, OMX_IndexParamAudioInit, &param);
    if(err != OMX_ErrorNone){
        DEBUG(DEB_LEV_ERR, "Error in getting OMX_PORT_PARAM_TYPE parameter\n");
        exit(1);
    }
    param.nPorts = 1;
    err = OMX_SetParameter(handle, OMX_IndexParamAudioInit, &param);
    if(err != OMX_ErrorNone){
      DEBUG(DEB_LEV_ERR, "Error in setting OMX_PORT_PARAM_TYPE parameter\n");
      exit(1);
    }

    /*
    omxAudioPortDefinition.nPortIndex = 0;
    err = OMX_GetParameter(handle, OMX_IndexParamPortDefinition, &omxAudioPortDefinition);
    if(err != OMX_ErrorNone){
        DEBUG(DEB_LEV_ERR, "Error in getting OMX_PORT_PARAM_TYPE parameter\n");
        exit(1);
    }
    */

    omxAudioParamPcmMode.nPortIndex = 0;
    err = OMX_GetParameter(handle, OMX_IndexParamAudioPcm, &omxAudioParamPcmMode);
    DEBUG(DEB_LEV_PARAMS, "Default PCM rate is %i\n", (int)omxAudioParamPcmMode.nSamplingRate);
    omxAudioParamPcmMode.nSamplingRate = 44100;
    err = OMX_SetParameter(handle, OMX_IndexParamAudioPcm, &omxAudioParamPcmMode);
    if(err != OMX_ErrorNone){
      DEBUG(DEB_LEV_ERR, "Error in setting OMX_PORT_PARAM_TYPE parameter\n");
      exit(1);
    }
    DEBUG(DEB_LEV_PARAMS, "Now PCM rate is %i\n", (int)omxAudioParamPcmMode.nSamplingRate);
    
    
    err = OMX_SendCommand(handle, OMX_CommandStateSet, OMX_StateIdle, NULL);
    omxbuffer1 = omxbuffer2 = NULL;
    err = OMX_AllocateBuffer(handle, &omxbuffer1, 0, NULL, BUFFER_SIZE);
    if (err != OMX_ErrorNone) {
      DEBUG(DEB_LEV_ERR, "Error on AllocateBuffer out 1 %i\n", err);
      exit(1);
    }
    
    err = OMX_AllocateBuffer(handle, &omxbuffer2, 0, NULL, BUFFER_SIZE);
    if (err != OMX_ErrorNone) {
      DEBUG(DEB_LEV_ERR, "Error on AllocateBuffer out 2 %i\n", err);
      exit(1);
    }

    tsem_down(appPriv->eventSem);

    err = OMX_SendCommand(handle, OMX_CommandStateSet, OMX_StateExecuting, NULL);

    omxbuffer1->nInputPortIndex = 0;
    omxbuffer2->nInputPortIndex = 0;
    
    /* Wait for commands to complete */
    tsem_down(appPriv->eventSem);
    
    /* Now, toss down one buffer */
    data_read = read(fd, omxbuffer1->pBuffer, BUFFER_SIZE);
    omxbuffer1->nFilledLen = data_read;
    err = OMX_EmptyThisBuffer(handle, omxbuffer1);
    curr_buff = 1;
    
    DEBUG(DEB_LEV_PARAMS, "SymbianOutputStreamTest starting data processing loop\n");

    /* Data processing loop */
    i = filesize/BUFFER_SIZE;
    while(--i){
        /* It's very important to mutual exclude this section.
         * We dont wanna wakeup something which nobody is waiting on...
         */
        pthread_mutex_lock(&appPriv->mutex);

        if(curr_buff == 2){
            data_read = read(fd, omxbuffer1->pBuffer, BUFFER_SIZE);
            if (data_read == 0)
                break;
            // omxbuffer1->nFilledLen = data_read;
            omxbuffer1->nFilledLen = BUFFER_SIZE;
            err = OMX_EmptyThisBuffer(handle, omxbuffer1);
            curr_buff = 1;
        }
        else{
            data_read = read(fd, omxbuffer2->pBuffer, BUFFER_SIZE);
            if (data_read == 0)
                break;
            //omxbuffer2->nFilledLen = data_read;
            omxbuffer2->nFilledLen = BUFFER_SIZE;
            err = OMX_EmptyThisBuffer(handle, omxbuffer2);
            curr_buff = 2;
        }
        
        DEBUG(DEB_LEV_FULL_SEQ, "Waiting for empty buffer to complete...\n");
        pthread_cond_wait(&appPriv->condition, &appPriv->mutex);
        pthread_mutex_unlock(&appPriv->mutex);
        DEBUG(DEB_LEV_FULL_SEQ, "Input buffer processed...\n");
    }
    err = OMX_SendCommand(handle, OMX_CommandStateSet, OMX_StateIdle, NULL);
    tsem_down(appPriv->eventSem);
    
    err = OMX_SendCommand(handle, OMX_CommandStateSet, OMX_StateLoaded, NULL);
    
    err = OMX_FreeBuffer(handle, 0, omxbuffer1);
    err = OMX_FreeBuffer(handle, 0, omxbuffer2);
    
    tsem_down(appPriv->eventSem);
    
    OMX_FreeHandle(handle);

    free(appPriv->eventSem);
    free(appPriv);
    
    return 0;
}

/* Callbacks implementation */
OMX_ERRORTYPE symbianoutputstreamEventHandler(
    OMX_OUT OMX_HANDLETYPE hComponent,
    OMX_OUT OMX_PTR pAppData,
    OMX_OUT OMX_EVENTTYPE eEvent,
    OMX_OUT OMX_U32 Data1,
    OMX_OUT OMX_U32 Data2,
    OMX_OUT OMX_PTR pEventData)
{
    DEBUG(DEB_LEV_SIMPLE_SEQ, "Hi there, I am in the %s callback\n", __func__);
    DEBUG(DEB_LEV_SIMPLE_SEQ, "Param1 is %i\n", (int)Data1);
    DEBUG(DEB_LEV_SIMPLE_SEQ, "Param2 is %i\n", (int)Data2);
    tsem_up(appPriv->eventSem);
    return OMX_ErrorNone;
}

OMX_ERRORTYPE symbianoutputstreamEmptyBufferDone(
    OMX_OUT OMX_HANDLETYPE hComponent,
    OMX_OUT OMX_PTR pAppData,
    OMX_OUT OMX_BUFFERHEADERTYPE* pBuffer)
{
    pthread_mutex_lock(&appPriv->mutex);
    DEBUG(DEB_LEV_FULL_SEQ, "Notification for amoty buffer done %08X\n", (int)pBuffer);
    DEBUG(DEB_LEV_FULL_SEQ, "Waking up condition in %s", __func__);
    pthread_cond_signal(&appPriv->condition);
    pthread_mutex_unlock(&appPriv->mutex);
    return OMX_ErrorNone;
}

OMX_ERRORTYPE symbianoutputstreamFillBufferDone(
    OMX_OUT OMX_HANDLETYPE hComponent,
    OMX_OUT OMX_PTR pAppData,
    OMX_OUT OMX_BUFFERHEADERTYPE* pBuffer)
{
    DEBUG(DEB_LEV_FULL_SEQ, "%s: Hmm... shouldn't be here...\n", __func__);
    return OMX_ErrorNotImplemented;
}

static int getFileSize(int fd)
{
    struct stat input_file_stat;
    int err;
    
    /* Obtain input file length */
    err = fstat(fd, &input_file_stat);
    if(err){
        DEBUG(DEB_LEV_ERR, "fstat failed");
        exit(-1);
    }
    return input_file_stat.st_size;
}

---

Generated for OpenMAX Bellagio rel. 0.3.5-svn by  1.5.1