mmserv/tms/tmsimpl/src/tmsclientsinkbodyimpl.cpp
branchRCL_3
changeset 13 f5c5c82a163e
parent 3 4f62049db6ac
child 18 2eb3b066cc7d
equal deleted inserted replaced
11:03a293c97d5c 13:f5c5c82a163e
    93     // TODO send stream attributes here
    93     // TODO send stream attributes here
    94     gint ret(TMS_RESULT_SUCCESS);
    94     gint ret(TMS_RESULT_SUCCESS);
    95 
    95 
    96     if (iProxy)
    96     if (iProxy)
    97         {
    97         {
    98         ret = iProxy->BufferEmptied(TMS_CALL_IP,
    98         //TODO: must use strm_id instead of 1
    99                                     TMS_STREAM_UPLINK,
    99         ret = iProxy->BufferEmptied(TMS_CALL_IP, TMS_STREAM_UPLINK, 1,
   100                                     1, //TODO: must use strm_id
   100 		        *buffer);
   101                                     *buffer);
       
   102         }
   101         }
   103     else
   102     else
   104         {
   103         {
   105         ret = TMS_RESULT_UNINITIALIZED_OBJECT;
   104         ret = TMS_RESULT_UNINITIALIZED_OBJECT;
   106         }
   105         }
   118         gpointer queuehandler)
   117         gpointer queuehandler)
   119     {
   118     {
   120     iProxy = aProxy;
   119     iProxy = aProxy;
   121     if (queuehandler)
   120     if (queuehandler)
   122         {
   121         {
   123         ((TMSQueueHandler*) queuehandler)->AddObserver(*this, TMS_SINK_CLIENT);
   122         static_cast<TMSQueueHandler*>(queuehandler)->AddObserver(*this,
       
   123                 TMS_SINK_CLIENT);
   124         }
   124         }
   125     }
   125     }
   126 
   126 
   127 void TMSClientSinkBodyImpl::QueueEvent(TInt aEventType, TInt /*aError*/,
   127 void TMSClientSinkBodyImpl::QueueEvent(TInt aEventType, TInt /*aError*/,
   128         void* user_data)
   128         void* user_data)
   130     if (iObserver)
   130     if (iObserver)
   131         {
   131         {
   132         switch (aEventType)
   132         switch (aEventType)
   133             {
   133             {
   134             case TMS_EVENT_SINK_PROCESS_BUFFER:
   134             case TMS_EVENT_SINK_PROCESS_BUFFER:
   135                 iObserver->ProcessBuffer(((TMSBuffer*) user_data));
   135                 iObserver->ProcessBuffer(static_cast<TMSBuffer*>(user_data));
   136                 break;
   136                 break;
   137             default:
   137             default:
   138                 break;
   138                 break;
   139             }
   139             }
   140         }
   140         }