omxaudiomixertest.c

Go to the documentation of this file.

#include "omxaudiomixertest.h"
#include "ctype.h"

#define SINK_NAME "OMX.nokia.outputstream.component"
#define BUFFER_COUNT_ACTUAL 2
#define FRAME_SIZE 1152*2*2 // 1152 samples* 2 channels * 2byte/16bits per channel

static void setHeader(OMX_PTR header, OMX_U32 size) {
  OMX_VERSIONTYPE* ver = (OMX_VERSIONTYPE*)((char*)header + sizeof(OMX_U32));
  *((OMX_U32*)header) = size;

  ver->s.nVersionMajor = VERSIONMAJOR;
  ver->s.nVersionMinor = VERSIONMINOR;
  ver->s.nRevision = VERSIONREVISION;
  ver->s.nStep = VERSIONSTEP;
}

/* Application private date: should go in the component field (segs...) */
appPrivateType* appPriv;
int fd = 0,fd1=0;
unsigned int filesize,filesize1;
int flagIsGain[4];
int flagPlaybackOn;
int flagSetupTunnel;
int flagSampleRate;
int flagChannel;
char *input_file[2], *output_file;
static OMX_BOOL bEOS1=OMX_FALSE,bEOS2=OMX_FALSE;

OMX_BUFFERHEADERTYPE *inBuffer[4], *outBuffer[2],*inBufferSink[2];
static OMX_BOOL isPortDisabled[4];
static int iBufferDropped[2];

int main(int argc, char** argv) {

  OMX_CALLBACKTYPE callbacks;
  OMX_CALLBACKTYPE audiosinkcallbacks; 
  OMX_PORT_PARAM_TYPE sParam;
  OMX_U32 data_read,j;
  OMX_PARAM_PORTDEFINITIONTYPE sPortDef;
  OMX_AUDIO_CONFIG_VOLUMETYPE sVolume;
  OMX_AUDIO_PARAM_PCMMODETYPE sPcmModeType;
  int gain[4];
  int i=0;
  OMX_U32 srate=0,nchannel=0;
  OMX_ERRORTYPE err;

  callbacks.EventHandler = audiomixerEventHandler;
  callbacks.EmptyBufferDone = audiomixerEmptyBufferDone;
  callbacks.FillBufferDone = audiomixerFillBufferDone;

  audiosinkcallbacks.EventHandler    = audiosinkEventHandler;
  audiosinkcallbacks.EmptyBufferDone = audiosinkEmptyBufferDone;
  audiosinkcallbacks.FillBufferDone  = NULL;

  gain[0]=gain[1]=gain[2]=gain[3]=50;

  flagIsGain[0] = 1;
  flagIsGain[1] = 1;
  flagIsGain[2] = 1;
  flagIsGain[3] = 1;
  flagPlaybackOn = 1;
  flagSetupTunnel = 1;
  srate = 44100;
  nchannel = 2;

  if (flagSetupTunnel) 
  {
      flagPlaybackOn = 1;
  }

  fd = open("C:\\spede_44k.raw", O_RDONLY);
  if(fd < 0){
    perror("Error opening input file 1\n");
    exit(1);
  }

  fd1 = open("C:\\vesku_44k.raw", O_RDONLY);
  if(fd1 < 0){
    perror("Error opening input file 2\n");
    exit(1);
  }

  filesize = getFileSize(fd);
  filesize1 = getFileSize(fd1);

  /* 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);
  appPriv->eofSem = malloc(sizeof(tsem_t));
  tsem_init(appPriv->eofSem, 0);
  
  if (flagPlaybackOn) {
    appPriv->sinkEventSem = malloc(sizeof(tsem_t));
    tsem_init(appPriv->sinkEventSem, 0);
  }
  iBufferDropped[0] = 0;
  iBufferDropped[1] = 0;

  err = OMX_Init();
  if(err != OMX_ErrorNone) {
    DEBUG(DEB_LEV_ERR, "OMX_Init() failed\n");
    exit(1);
  }

  err = OMX_GetHandle(&appPriv->handle, "OMX.st.audio.mixer", NULL , &callbacks);
  if(err != OMX_ErrorNone) {
    DEBUG(DEB_LEV_ERR, "Audio Mixer OMX_GetHandle failed\n");
    exit(1);
  }
  if (flagPlaybackOn) {
    err = OMX_GetHandle(&appPriv->audiosinkhandle, SINK_NAME, NULL , &audiosinkcallbacks);
    if(err != OMX_ErrorNone){
      DEBUG(DEB_LEV_ERR, "No sink found. Exiting...\n");
      exit(1);
    }
  }

  /*Max 4 input stream*/
  for(j=0;j<4;j++) {
    isPortDisabled[i] = OMX_FALSE;
    if((gain[j] >= 0) && (gain[j] <100)) {
      sVolume.nPortIndex = j;
      err = OMX_GetConfig(appPriv->handle, OMX_IndexConfigAudioVolume, &sVolume);
      if(err!=OMX_ErrorNone) {
        DEBUG(DEB_LEV_ERR,"Error %08x In OMX_GetConfig 0 \n",err);
      }
      sVolume.sVolume.nValue = gain[j];
      DEBUG(DEFAULT_MESSAGES, "Setting Gain[%i] %d \n",(int)j, gain[j]);
      err = OMX_SetConfig(appPriv->handle, OMX_IndexConfigAudioVolume, &sVolume);
      if(err!=OMX_ErrorNone) {
        DEBUG(DEB_LEV_ERR,"Error %08x In OMX_SetConfig 0 \n",err);
      }
    }
  }

  /*Set sample rate and channel no to alsa sink if specified*/
  if(srate && nchannel && flagPlaybackOn) {
    DEBUG(DEFAULT_MESSAGES, "Sample Rate=%d,NChannel=%d\n",(int)srate,(int)nchannel);
    sPcmModeType.nPortIndex=0;
    setHeader(&sPcmModeType, sizeof(OMX_AUDIO_PARAM_PCMMODETYPE));
    err = OMX_GetParameter(appPriv->audiosinkhandle, OMX_IndexParamAudioPcm, &sPcmModeType);

    sPcmModeType.nChannels = nchannel;
    sPcmModeType.nSamplingRate = srate;
    err = OMX_SetParameter(appPriv->audiosinkhandle, OMX_IndexParamAudioPcm, &sPcmModeType);
    if(err!=OMX_ErrorNone) {
      DEBUG(DEB_LEV_ERR,"Error %08x In OMX_SetParameter 0 \n",err);
    }
  }

  if (flagSetupTunnel) {
    err = OMX_SetupTunnel(appPriv->handle, 4, appPriv->audiosinkhandle, 0);
    if(err != OMX_ErrorNone) {
      DEBUG(DEB_LEV_ERR, "Set up Tunnel Failed\n");
      exit(1);
    }
    DEBUG(DEFAULT_MESSAGES, "Set up Tunnel Completed\n");
  }

  setHeader(&sParam, sizeof(OMX_PORT_PARAM_TYPE));
  err = OMX_GetParameter(appPriv->handle, OMX_IndexParamAudioInit, &sParam);
  if(err != OMX_ErrorNone){
    DEBUG(DEB_LEV_ERR, "Error in getting OMX_PORT_PARAM_TYPE parameter\n");
    exit(1);
  }
  DEBUG(DEFAULT_MESSAGES, "Audio Mixer has %d ports\n",(int)sParam.nPorts);

  setHeader(&sPortDef, sizeof(OMX_PARAM_PORTDEFINITIONTYPE));
  sPortDef.nPortIndex = 0;
  err = OMX_GetParameter(appPriv->handle, OMX_IndexParamPortDefinition, &sPortDef);

  sPortDef.nBufferCountActual = 2;
  err = OMX_SetParameter(appPriv->handle, OMX_IndexParamPortDefinition, &sPortDef);
  if(err != OMX_ErrorNone){
    DEBUG(DEB_LEV_ERR, "Error in getting OMX_PORT_PARAM_TYPE parameter\n");
    exit(1);
  }
  sPortDef.nPortIndex = 1;
  err = OMX_GetParameter(appPriv->handle, OMX_IndexParamPortDefinition, &sPortDef);

  sPortDef.nBufferCountActual = 2;
  err = OMX_SetParameter(appPriv->handle, OMX_IndexParamPortDefinition, &sPortDef);
  if(err != OMX_ErrorNone){
    DEBUG(DEB_LEV_ERR, "Error in getting OMX_PORT_PARAM_TYPE parameter\n");
    exit(1);
  }

  /*Disable 2 out of 4 ports*/
  isPortDisabled[2] = OMX_TRUE;
  isPortDisabled[3] = OMX_TRUE;
  err = OMX_SendCommand(appPriv->handle, OMX_CommandPortDisable, 2, NULL);
  err = OMX_SendCommand(appPriv->handle, OMX_CommandPortDisable, 3, NULL);
  tsem_down(appPriv->eventSem);
  tsem_down(appPriv->eventSem);


  err = OMX_SendCommand(appPriv->handle, OMX_CommandStateSet, OMX_StateIdle, NULL);
  if (flagPlaybackOn) {
    err = OMX_SendCommand(appPriv->audiosinkhandle, OMX_CommandStateSet, OMX_StateIdle, NULL);
  }

  inBuffer[0] = inBuffer[1] = inBuffer[2] = inBuffer[3]= outBuffer[0] = outBuffer[1] = NULL;

  for(j=0;j<BUFFER_COUNT_ACTUAL;j++) {
    err = OMX_AllocateBuffer(appPriv->handle, &inBuffer[j], 0, NULL, BUFFER_IN_SIZE);
    if (err != OMX_ErrorNone) {
      DEBUG(DEB_LEV_ERR, "Error on AllocateBuffer in %i %i\n",(int)j, err);
      exit(1);
    }
    err = OMX_AllocateBuffer(appPriv->handle, &inBuffer[j+ 2], 1, NULL, BUFFER_IN_SIZE);
    if (err != OMX_ErrorNone) {
      DEBUG(DEB_LEV_ERR, "Error on AllocateBuffer in %i %i\n",(int)j+2, err);
      exit(1);
    }
  }

  if (flagPlaybackOn) {
    tsem_down(appPriv->sinkEventSem);
    DEBUG(DEB_LEV_SIMPLE_SEQ,"audio sink state idle\n");
  }
  tsem_down(appPriv->eventSem);

  err = OMX_SendCommand(appPriv->handle, OMX_CommandStateSet, OMX_StateExecuting, NULL);

  /* Wait for commands to complete */
  tsem_down(appPriv->eventSem);

  if (flagPlaybackOn) {
    DEBUG(DEB_LEV_SIMPLE_SEQ,"sending audio sink state executing\n");
    err = OMX_SendCommand(appPriv->audiosinkhandle, OMX_CommandStateSet, OMX_StateExecuting, NULL);
    if(err != OMX_ErrorNone) {
      DEBUG(DEB_LEV_ERR,"audio sink state executing failed\n");
      exit(1);
    }
    DEBUG(DEB_LEV_SIMPLE_SEQ,"waiting for  audio sink state executing\n");
    tsem_down(appPriv->sinkEventSem);
    DEBUG(DEB_LEV_SIMPLE_SEQ, "audio sink state executing successful\n");
  }
  DEBUG(DEB_LEV_PARAMS, "Had buffers at:\n0x%08x\n0x%08x\n0x%08x\n0x%08x\n", 
                (int)inBuffer[0]->pBuffer, (int)inBuffer[1]->pBuffer, (int)outBuffer[0]->pBuffer, (int)outBuffer[1]->pBuffer);
  DEBUG(DEB_LEV_PARAMS, "After switch to executing\n");
  
  for(j=0;j<BUFFER_COUNT_ACTUAL;j++) {
    data_read = read(fd, inBuffer[j]->pBuffer, FRAME_SIZE);
    inBuffer[0]->nFilledLen = data_read;
    filesize -= data_read;

    data_read = read(fd1, inBuffer[j+2]->pBuffer, FRAME_SIZE);
    inBuffer[2]->nFilledLen = data_read;
    filesize1 -= data_read;
  }

  for(j=0;j<BUFFER_COUNT_ACTUAL*2;j++) {
    DEBUG(DEB_LEV_PARAMS, "Empty %i  buffer %x\n",(int)j, (int)inBuffer[j]);
    err = OMX_EmptyThisBuffer(appPriv->handle, inBuffer[j]);
  }

  DEBUG(DEFAULT_MESSAGES, "Waiting for EOS\n");
  if(isPortDisabled[0] == OMX_FALSE) {
    tsem_down(appPriv->eofSem);
    DEBUG(DEFAULT_MESSAGES, "Received EOS 1\n");
  }
  if(isPortDisabled[1] == OMX_FALSE) {
    tsem_down(appPriv->eofSem);
    DEBUG(DEFAULT_MESSAGES, "Received EOS 2\n");
  }

  err = OMX_SendCommand(appPriv->handle, OMX_CommandStateSet, OMX_StateIdle, NULL);
  if (flagPlaybackOn) {
    err = OMX_SendCommand(appPriv->audiosinkhandle, OMX_CommandStateSet, OMX_StateIdle, NULL);
  }

  printf("waiting for sink to idle callback\n");

  if (flagPlaybackOn) {
    tsem_down(appPriv->sinkEventSem);
  }
  /* Wait for commands to complete */

  printf("waiting for decoder to idle callback\n");

  tsem_down(appPriv->eventSem);

  err = OMX_SendCommand(appPriv->handle, OMX_CommandStateSet, OMX_StateLoaded, NULL);
  if (flagPlaybackOn) {
    err = OMX_SendCommand(appPriv->audiosinkhandle, OMX_CommandStateSet, OMX_StateLoaded, NULL);
  }

  for(j=0;j<BUFFER_COUNT_ACTUAL;j++) {
    if(isPortDisabled[0] == OMX_FALSE) {
      err = OMX_FreeBuffer(appPriv->handle, 0, inBuffer[j]);
    }
    if(isPortDisabled[1] == OMX_FALSE) {
      err = OMX_FreeBuffer(appPriv->handle, 1, inBuffer[j+2]);
    }
  }

 printf("waiting for sink to loaded callback\n");

  if (flagPlaybackOn) {
    tsem_down(appPriv->sinkEventSem);
  }
  
  printf("waiting for decoder to loaded callback\n");

  /* Wait for commands to complete */
  tsem_down(appPriv->eventSem);
  
  OMX_FreeHandle(appPriv->handle);

  free(appPriv->eventSem);
  free(appPriv);
  if (flagPlaybackOn) {
    free(appPriv->sinkEventSem);
    appPriv->sinkEventSem = NULL;
  }

  close(fd);
  close(fd1);
  free(input_file[0]);
  free(input_file[1]);

  /* exit(0); */

  return 0;
}

/* Callbacks implementation */
OMX_ERRORTYPE audiomixerEventHandler(
  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_IN OMX_PTR pEventData) {

  DEBUG(DEB_LEV_SIMPLE_SEQ, "Hi there, I am in the %s callback\n", __func__);
  if(eEvent == OMX_EventCmdComplete) {
    if (Data1 == OMX_CommandStateSet) {
      DEBUG(DEB_LEV_SIMPLE_SEQ, "Volume Component State changed in ");
      switch ((int)Data2) {
      case OMX_StateInvalid:
        DEBUG(DEB_LEV_SIMPLE_SEQ, "OMX_StateInvalid\n");
        break;
      case OMX_StateLoaded:
        DEBUG(DEB_LEV_SIMPLE_SEQ, "OMX_StateLoaded\n");
        break;
      case OMX_StateIdle:
        DEBUG(DEB_LEV_SIMPLE_SEQ, "OMX_StateIdle\n");
        break;
      case OMX_StateExecuting:
        DEBUG(DEB_LEV_SIMPLE_SEQ, "OMX_StateExecuting\n");
        break;
      case OMX_StatePause:
        DEBUG(DEB_LEV_SIMPLE_SEQ, "OMX_StatePause\n");
        break;
      case OMX_StateWaitForResources:
        DEBUG(DEB_LEV_SIMPLE_SEQ, "OMX_StateWaitForResources\n");
        break;
      }
      tsem_up(appPriv->eventSem);
    } else  if (Data1 == OMX_CommandPortEnable){
      tsem_up(appPriv->eventSem);
    } else if (Data1 == OMX_CommandPortDisable){
      tsem_up(appPriv->eventSem);
    } 
  } else if(eEvent == OMX_EventBufferFlag) {
    if((int)Data2 == OMX_BUFFERFLAG_EOS) {
      tsem_up(appPriv->eofSem);
    }
  } else {
    DEBUG(DEB_LEV_SIMPLE_SEQ, "Param1 is %i\n", (int)Data1);
    DEBUG(DEB_LEV_SIMPLE_SEQ, "Param2 is %i\n", (int)Data2);
  }

  return OMX_ErrorNone;
}

OMX_ERRORTYPE audiomixerEmptyBufferDone(
  OMX_OUT OMX_HANDLETYPE hComponent,
  OMX_OUT OMX_PTR pAppData,
  OMX_OUT OMX_BUFFERHEADERTYPE* pBuffer) {

      int data_read;
      OMX_ERRORTYPE err = OMX_ErrorNone;
  

  DEBUG(DEB_LEV_FULL_SEQ, "Hi there, I am in the %s callback.\n", __func__);
  if(pBuffer->nInputPortIndex==0) {
    
    if(isPortDisabled[0] == OMX_FALSE) {
      data_read = read(fd, pBuffer->pBuffer, FRAME_SIZE);
      pBuffer->nFilledLen = data_read;
      pBuffer->nOffset = 0;
      filesize -= data_read;
      DEBUG(DEB_LEV_SIMPLE_SEQ, "Sending from file 1 data read=%d\n",data_read);
      if (data_read <= 0) {
        DEBUG(DEB_LEV_SIMPLE_SEQ, "In the %s no more input data available\n", __func__);
        ++iBufferDropped[0];
        if(iBufferDropped[0]==2) {
          DEBUG(DEB_LEV_SIMPLE_SEQ, "In %s Dropping Empty This buffer to Audio Mixer Stream 1\n", __func__);
          tsem_up(appPriv->eofSem);
          return OMX_ErrorNone;
        } else if(iBufferDropped[0]>2) { 
          DEBUG(DEB_LEV_SIMPLE_SEQ, "In %s Dropping Empty This buffer to Audio Mixer Stream 1\n", __func__);
          return OMX_ErrorNone;
        }
        pBuffer->nFilledLen=0;
        pBuffer->nFlags = OMX_BUFFERFLAG_EOS;
        bEOS1=OMX_TRUE;
        DEBUG(DEB_LEV_SIMPLE_SEQ, "In %s Sending EOS for Stream 1\n", __func__);
        err = OMX_EmptyThisBuffer(hComponent, pBuffer);
        return OMX_ErrorNone;
      }
    } else {
      ++iBufferDropped[0];
      return OMX_ErrorNone;
    }
  } else if(pBuffer->nInputPortIndex==1) {
    
    if(isPortDisabled[1] == OMX_FALSE) {
      data_read = read(fd1, pBuffer->pBuffer, FRAME_SIZE);
      pBuffer->nFilledLen = data_read;
      pBuffer->nOffset = 0;
      filesize1 -= data_read;
      DEBUG(DEB_LEV_SIMPLE_SEQ, "Sending from file 2 data read=%d\n",data_read);
      if (data_read <= 0) {
        DEBUG(DEB_LEV_SIMPLE_SEQ, "In the %s no more input data available\n", __func__);
        ++iBufferDropped[1];
        if(iBufferDropped[1]==2) {
          DEBUG(DEB_LEV_SIMPLE_SEQ, "In %s Dropping Empty This buffer to Audio Mixer Stream 2\n", __func__);
          tsem_up(appPriv->eofSem);
          return OMX_ErrorNone;
        } else if(iBufferDropped[1]>2) { 
          DEBUG(DEB_LEV_SIMPLE_SEQ, "In %s Dropping Empty This buffer to Audio Mixer Stream 2\n", __func__);
          return OMX_ErrorNone;
        }
        pBuffer->nFilledLen=0;
        pBuffer->nFlags = OMX_BUFFERFLAG_EOS;
        bEOS2=OMX_TRUE;
        DEBUG(DEB_LEV_SIMPLE_SEQ, "In %s Sending EOS for Stream 2\n", __func__);
        err = OMX_EmptyThisBuffer(hComponent, pBuffer);
        return OMX_ErrorNone;
      }
    }else {
      ++iBufferDropped[1];
      return OMX_ErrorNone;
    }
  }
  if(!bEOS1 || !bEOS2 ) {
    DEBUG(DEB_LEV_FULL_SEQ, "Empty buffer %x\n", (int)pBuffer);
    err = OMX_EmptyThisBuffer(hComponent, pBuffer);
  }else {
    DEBUG(DEB_LEV_FULL_SEQ, "In %s Dropping Empty This buffer to Audio Mixer\n", __func__);
  }

  return err;
}

OMX_ERRORTYPE audiomixerFillBufferDone(
  OMX_OUT OMX_HANDLETYPE hComponent,
  OMX_OUT OMX_PTR pAppData,
  OMX_OUT OMX_BUFFERHEADERTYPE* pBuffer) {

  OMX_ERRORTYPE err;
  int i;  

  DEBUG(DEB_LEV_FULL_SEQ, "Hi there, I am in the %s callback. Got buflen %i for buffer at 0x%08x\n",
                          __func__, (int)pBuffer->nFilledLen, (int)pBuffer);

  /* Output data to standard output */
  if(pBuffer != NULL) {
    if (pBuffer->nFilledLen == 0) {
      DEBUG(DEB_LEV_ERR, "Ouch! In %s: no data in the output buffer!\n", __func__);
      return OMX_ErrorNone;
    } else if (flagPlaybackOn) {
      if(inBufferSink[0]->pBuffer == pBuffer->pBuffer) {
        inBufferSink[0]->nFilledLen = pBuffer->nFilledLen;
        err = OMX_EmptyThisBuffer(appPriv->audiosinkhandle, inBufferSink[0]);
      } else {
        inBufferSink[1]->nFilledLen = pBuffer->nFilledLen;
        err = OMX_EmptyThisBuffer(appPriv->audiosinkhandle, inBufferSink[1]);
      }
      if(err != OMX_ErrorNone) {
        DEBUG(DEB_LEV_ERR, "In %s Error %08x Calling EmptyThisBuffer\n", __func__,err);
      }
    } else {
      for(i=0;i<pBuffer->nFilledLen;i++) {
        putchar(*(char*)(pBuffer->pBuffer + i));
      }
      pBuffer->nFilledLen = 0;
      /* Reschedule the fill buffer request */
      if(!bEOS1 || !bEOS2) {
        err = OMX_FillThisBuffer(hComponent, pBuffer);
      } else {
        DEBUG(DEB_LEV_FULL_SEQ, "In %s Dropping Fill This buffer to Audio Mixer\n", __func__);
      }
    }
  } else {
    DEBUG(DEB_LEV_ERR, "Ouch! In %s: had NULL buffer to output...\n", __func__);
  }
  
  return OMX_ErrorNone;
}

OMX_ERRORTYPE audiosinkEventHandler(
  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__);
  if (Data1 == OMX_CommandStateSet) {
    DEBUG(DEB_LEV_SIMPLE_SEQ, "Audio Sink State changed in ");
    switch ((int)Data2) {
    case OMX_StateInvalid:
      DEBUG(DEB_LEV_SIMPLE_SEQ, "OMX_StateInvalid\n");
      break;
    case OMX_StateLoaded:
      DEBUG(DEB_LEV_SIMPLE_SEQ, "OMX_StateLoaded\n");
      break;
    case OMX_StateIdle:
      DEBUG(DEB_LEV_SIMPLE_SEQ, "OMX_StateIdle\n");
      break;
    case OMX_StateExecuting:
      DEBUG(DEB_LEV_SIMPLE_SEQ, "OMX_StateExecuting\n");
      break;
    case OMX_StatePause:
      DEBUG(DEB_LEV_SIMPLE_SEQ, "OMX_StatePause\n");
      break;
    case OMX_StateWaitForResources:
      DEBUG(DEB_LEV_SIMPLE_SEQ, "OMX_StateWaitForResources\n");
      break;
    }
    tsem_up(appPriv->sinkEventSem);
  } else if (Data1 == OMX_CommandPortEnable){
    DEBUG(DEB_LEV_SIMPLE_SEQ, "In %s Received Port Enable  Event\n",__func__);
    tsem_up(appPriv->sinkEventSem);
  } else if (Data1 == OMX_CommandPortDisable){
    DEBUG(DEB_LEV_SIMPLE_SEQ, "In %s Received Port Disable Event\n",__func__);
    tsem_up(appPriv->sinkEventSem);
  } else {
    DEBUG(DEB_LEV_SIMPLE_SEQ, "Param1 is %i\n", (int)Data1);
    DEBUG(DEB_LEV_SIMPLE_SEQ, "Param2 is %i\n", (int)Data2);
  }
  
  return OMX_ErrorNone;
}

OMX_ERRORTYPE audiosinkEmptyBufferDone(
  OMX_OUT OMX_HANDLETYPE hComponent,
  OMX_OUT OMX_PTR pAppData,
  OMX_OUT OMX_BUFFERHEADERTYPE* pBuffer)
{
  OMX_ERRORTYPE err;
  static int alsaSinkBufferDropped=0;
  DEBUG(DEB_LEV_FULL_SEQ, "Hi there, I am in the %s callback.\n", __func__);

  DEBUG(DEB_LEV_PARAMS, "Empty buffer %x\n", (int)pBuffer);
  if(!bEOS1 || !bEOS2) {
    if(outBuffer[0]->pBuffer == pBuffer->pBuffer) {
      outBuffer[0]->nFilledLen=0;
      err = OMX_FillThisBuffer(appPriv->handle, outBuffer[0]);
    } else {
      outBuffer[1]->nFilledLen=0;
      err = OMX_FillThisBuffer(appPriv->handle, outBuffer[1]);
    }
    if(err != OMX_ErrorNone) {
      DEBUG(DEB_LEV_ERR, "In %s Error %08x Calling FillThisBuffer\n", __func__,err);
    }
  } else {
    DEBUG(DEFAULT_MESSAGES,"In %s EOS reached\n",__func__);
    alsaSinkBufferDropped++;
    tsem_up(appPriv->eofSem);
  }

  return OMX_ErrorNone;
}

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