mmserv/tms/tmscallproxy/src/tmscallproxy.cpp
changeset 31 8dfd592727cb
parent 12 5a06f39ad45b
child 46 0ac9a5310753
equal deleted inserted replaced
22:128eb6a32b84 31:8dfd592727cb
   117 //
   117 //
   118 // -----------------------------------------------------------------------------
   118 // -----------------------------------------------------------------------------
   119 //
   119 //
   120 EXPORT_C gint TMSCallProxy::InitStream(const TMSCallType callType,
   120 EXPORT_C gint TMSCallProxy::InitStream(const TMSCallType callType,
   121         const TMSStreamType strmType, gint strmId,
   121         const TMSStreamType strmType, gint strmId,
   122         const TMSFormatType frmtType, RHandleBase* msgQueue)
   122         const TMSFormatType frmtType, RHandleBase* msgQueue,
       
   123         const gint retrytime)
   123     {
   124     {
   124     TRACE_PRN_FN_ENT;
   125     TRACE_PRN_FN_ENT;
   125     gint status(TMS_RESULT_SUCCESS);
   126     gint status(TMS_RESULT_SUCCESS);
   126     TMSCliSrvStreamInitDataStructBufPckg inPckg;
   127     TMSCliSrvStreamInitDataStructBufPckg inPckg;
   127     inPckg().CallType = callType;
   128     inPckg().CallType = callType;
   128     inPckg().StreamType = strmType;
   129     inPckg().StreamType = strmType;
   129     inPckg().StreamId = strmId;
   130     inPckg().StreamId = strmId;
   130     inPckg().FormatType = frmtType;
   131     inPckg().FormatType = frmtType;
       
   132     inPckg().RetryTime = retrytime;
   131     status = RSessionBase::SendReceive(TMS_INIT_STREAM, TIpcArgs(&inPckg,
   133     status = RSessionBase::SendReceive(TMS_INIT_STREAM, TIpcArgs(&inPckg,
   132             *msgQueue));
   134             *msgQueue));
   133     TRACE_PRN_FN_EXT;
   135     TRACE_PRN_FN_EXT;
   134     return TMSRESULT(status);
   136     return TMSRESULT(status);
   135     }
   137     }
   138 // TMSCallProxy::StartStream
   140 // TMSCallProxy::StartStream
   139 //
   141 //
   140 // -----------------------------------------------------------------------------
   142 // -----------------------------------------------------------------------------
   141 //
   143 //
   142 EXPORT_C gint TMSCallProxy::StartStream(const TMSCallType callType,
   144 EXPORT_C gint TMSCallProxy::StartStream(const TMSCallType callType,
   143         const TMSStreamType strmType, gint strmId)
   145         const TMSStreamType strmType, gint strmId, const gint retrytime)
   144     {
   146     {
   145     TRACE_PRN_FN_ENT;
   147     TRACE_PRN_FN_ENT;
   146     gint status(TMS_RESULT_SUCCESS);
   148     gint status(TMS_RESULT_SUCCESS);
   147     TMSCliSrvStreamOpDataStructBufPckg inPckg;
   149     TMSCliSrvStreamOpDataStructBufPckg inPckg;
   148     inPckg().CallType = callType;
   150     inPckg().CallType = callType;
   149     inPckg().StreamType = strmType;
   151     inPckg().StreamType = strmType;
   150     inPckg().StreamId = strmId;
   152     inPckg().StreamId = strmId;
       
   153     inPckg().RetryTime = retrytime;
   151     status = RSessionBase::SendReceive(TMS_START_STREAM, TIpcArgs(&inPckg));
   154     status = RSessionBase::SendReceive(TMS_START_STREAM, TIpcArgs(&inPckg));
   152     TRACE_PRN_FN_EXT;
   155     TRACE_PRN_FN_EXT;
   153     return TMSRESULT(status);
   156     return TMSRESULT(status);
   154     }
   157     }
   155 
   158