mmserv/tms/tmsimpl/src/tmsqueuehandler.cpp
branchRCL_3
changeset 7 3d8c721bf319
parent 3 4f62049db6ac
child 9 f5c5c82a163e
equal deleted inserted replaced
6:e35735ece90c 7:3d8c721bf319
   249                 {
   249                 {
   250                 gint index = FindVolEffectInList();
   250                 gint index = FindVolEffectInList();
   251                 if (index != KErrNotFound)
   251                 if (index != KErrNotFound)
   252                     {
   252                     {
   253                     iObserversList[index]->QueueEvent(
   253                     iObserversList[index]->QueueEvent(
   254                             TMS_EVENT_EFFECT_VOL_CHANGED, msgBuf.iStatus, NULL);
   254                             TMS_EVENT_EFFECT_VOL_CHANGED, msgBuf.iStatus,
       
   255                             NULL);
   255                     }
   256                     }
   256                 }
   257                 }
   257                 break;
   258                 break;
   258             default:
   259             default:
   259                 break;
   260                 break;
   287         if (iTMSGlobalContext->CallProxy)
   288         if (iTMSGlobalContext->CallProxy)
   288             {
   289             {
   289             hndl = (iTMSGlobalContext->CallProxy)->GetDataXferChunkHandle(
   290             hndl = (iTMSGlobalContext->CallProxy)->GetDataXferChunkHandle(
   290                     iTMSGlobalContext->CallType,
   291                     iTMSGlobalContext->CallType,
   291                     iTMSGlobalContext->StreamType,
   292                     iTMSGlobalContext->StreamType,
   292                     iTMSGlobalContext->StreamId,
   293                     iTMSGlobalContext->StreamId, key);
   293                     key);
       
   294             err = iChunk.SetReturnedHandle(hndl);
   294             err = iChunk.SetReturnedHandle(hndl);
   295             }
   295             }
   296         }
   296         }
   297 
   297 
   298     if (err == TMS_RESULT_SUCCESS)
   298     if (err == TMS_RESULT_SUCCESS)
   306         iBuffer->SetDataSize(aBufLen);
   306         iBuffer->SetDataSize(aBufLen);
   307 
   307 
   308         gint index = iClientList.Find(TMS_SOURCE_CLIENT);
   308         gint index = iClientList.Find(TMS_SOURCE_CLIENT);
   309         if (index != KErrNotFound)
   309         if (index != KErrNotFound)
   310             {
   310             {
   311             iObserversList[index]->QueueEvent(
   311             iObserversList[index]->QueueEvent(TMS_EVENT_SOURCE_FILL_BUFFER,
   312                     TMS_EVENT_SOURCE_FILL_BUFFER, aStatus, iBuffer);
   312                     aStatus, iBuffer);
   313             }
   313             }
   314         else
   314         else
   315             {
   315             {
   316             err = TMS_RESULT_DOES_NOT_EXIST;
   316             err = TMS_RESULT_DOES_NOT_EXIST;
   317             }
   317             }
   346         if (iTMSGlobalContext->CallProxy)
   346         if (iTMSGlobalContext->CallProxy)
   347             {
   347             {
   348             hndl = (iTMSGlobalContext->CallProxy)->GetDataXferChunkHandle(
   348             hndl = (iTMSGlobalContext->CallProxy)->GetDataXferChunkHandle(
   349                     iTMSGlobalContext->CallType,
   349                     iTMSGlobalContext->CallType,
   350                     iTMSGlobalContext->StreamType,
   350                     iTMSGlobalContext->StreamType,
   351                     iTMSGlobalContext->StreamId,
   351                     iTMSGlobalContext->StreamId, key);
   352                     key);
       
   353             err = iChunk.SetReturnedHandle(hndl);
   352             err = iChunk.SetReturnedHandle(hndl);
   354             }
   353             }
   355         // TODO handle error here
   354         // TODO handle error here
   356         delete iBuffer;
   355         delete iBuffer;
   357         iBuffer = NULL;
   356         iBuffer = NULL;
   367             }
   366             }
   368         iBuffer->SetDataSize(aBufLen);
   367         iBuffer->SetDataSize(aBufLen);
   369         gint index = iClientList.Find(TMS_SINK_CLIENT);
   368         gint index = iClientList.Find(TMS_SINK_CLIENT);
   370         if (index != KErrNotFound)
   369         if (index != KErrNotFound)
   371             {
   370             {
   372             iObserversList[index]->QueueEvent(
   371             iObserversList[index]->QueueEvent(TMS_EVENT_SINK_PROCESS_BUFFER,
   373                     TMS_EVENT_SINK_PROCESS_BUFFER, aStatus, iBuffer);
   372                     aStatus, iBuffer);
   374             }
   373             }
   375         else
   374         else
   376             {
   375             {
   377             err = TMS_RESULT_DOES_NOT_EXIST;
   376             err = TMS_RESULT_DOES_NOT_EXIST;
   378             }
   377             }