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) |
|
124 { |
123 { |
125 TRACE_PRN_FN_ENT; |
124 TRACE_PRN_FN_ENT; |
126 gint status(TMS_RESULT_SUCCESS); |
125 gint status(TMS_RESULT_SUCCESS); |
127 TMSCliSrvStreamInitDataStructBufPckg inPckg; |
126 TMSCliSrvStreamInitDataStructBufPckg inPckg; |
128 inPckg().CallType = callType; |
127 inPckg().CallType = callType; |
129 inPckg().StreamType = strmType; |
128 inPckg().StreamType = strmType; |
130 inPckg().StreamId = strmId; |
129 inPckg().StreamId = strmId; |
131 inPckg().FormatType = frmtType; |
130 inPckg().FormatType = frmtType; |
132 inPckg().RetryTime = retrytime; |
|
133 status = RSessionBase::SendReceive(TMS_INIT_STREAM, TIpcArgs(&inPckg, |
131 status = RSessionBase::SendReceive(TMS_INIT_STREAM, TIpcArgs(&inPckg, |
134 *msgQueue)); |
132 *msgQueue)); |
135 TRACE_PRN_FN_EXT; |
133 TRACE_PRN_FN_EXT; |
136 return TMSRESULT(status); |
134 return TMSRESULT(status); |
137 } |
135 } |
140 // TMSCallProxy::StartStream |
138 // TMSCallProxy::StartStream |
141 // |
139 // |
142 // ----------------------------------------------------------------------------- |
140 // ----------------------------------------------------------------------------- |
143 // |
141 // |
144 EXPORT_C gint TMSCallProxy::StartStream(const TMSCallType callType, |
142 EXPORT_C gint TMSCallProxy::StartStream(const TMSCallType callType, |
145 const TMSStreamType strmType, gint strmId, const gint retrytime) |
143 const TMSStreamType strmType, gint strmId) |
146 { |
144 { |
147 TRACE_PRN_FN_ENT; |
145 TRACE_PRN_FN_ENT; |
148 gint status(TMS_RESULT_SUCCESS); |
146 gint status(TMS_RESULT_SUCCESS); |
149 TMSCliSrvStreamOpDataStructBufPckg inPckg; |
147 TMSCliSrvStreamOpDataStructBufPckg inPckg; |
150 inPckg().CallType = callType; |
148 inPckg().CallType = callType; |
151 inPckg().StreamType = strmType; |
149 inPckg().StreamType = strmType; |
152 inPckg().StreamId = strmId; |
150 inPckg().StreamId = strmId; |
153 inPckg().RetryTime = retrytime; |
|
154 status = RSessionBase::SendReceive(TMS_START_STREAM, TIpcArgs(&inPckg)); |
151 status = RSessionBase::SendReceive(TMS_START_STREAM, TIpcArgs(&inPckg)); |
155 TRACE_PRN_FN_EXT; |
152 TRACE_PRN_FN_EXT; |
156 return TMSRESULT(status); |
153 return TMSRESULT(status); |
157 } |
154 } |
158 |
155 |