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 |