136 // ----------------------------------------------------------------------------- |
136 // ----------------------------------------------------------------------------- |
137 // TMSCallCSAdpt::InitStream |
137 // TMSCallCSAdpt::InitStream |
138 // |
138 // |
139 // ----------------------------------------------------------------------------- |
139 // ----------------------------------------------------------------------------- |
140 // |
140 // |
141 gint TMSCallCSAdpt::InitStreamL(TMSCallType /*callType*/, |
141 gint TMSCallCSAdpt::InitStream(TMSCallType /*callType*/, TMSStreamType strmType, |
142 TMSStreamType strmType, gint strmId, TMSFormatType /*frmtType*/, |
142 gint strmId, TMSFormatType /*frmtType*/, const RMessage2& message) |
143 const RMessage2& aMessage) |
|
144 { |
143 { |
145 TRACE_PRN_FN_ENT; |
144 TRACE_PRN_FN_ENT; |
146 gint status(TMS_RESULT_SUCCESS); |
145 gint status(TMS_RESULT_SUCCESS); |
147 |
146 |
148 switch (strmType) |
147 switch (strmType) |
149 { |
148 { |
150 case TMS_STREAM_UPLINK: |
149 case TMS_STREAM_UPLINK: |
|
150 { |
151 if (strmId == iUplinkStreamId) |
151 if (strmId == iUplinkStreamId) |
152 { |
152 { |
153 // Open message queue handling client-server communication |
153 // Open message queue handling client-server communication |
154 if (iMsgQueueUp.Handle() <= 0) |
154 if (iMsgQueueUp.Handle() <= 0) |
155 { |
155 { |
156 // Third argument in TMSCallProxy::InitStream |
156 // Third argument in TMSCallProxy::InitStream |
157 status = iMsgQueueUp.Open(aMessage, 1); |
157 status = iMsgQueueUp.Open(message, 1); |
158 } |
158 } |
159 if (status == TMS_RESULT_SUCCESS) |
159 if (status == TMS_RESULT_SUCCESS) |
160 { |
160 { |
161 TRAP(status, iCSUplink = TMSCSUplink::NewL(*this)); |
161 TRAP(status, iCSUplink = TMSCSUplink::NewL(*this)); |
162 } |
162 } |
165 else |
165 else |
166 { |
166 { |
167 status = TMS_RESULT_DOES_NOT_EXIST; |
167 status = TMS_RESULT_DOES_NOT_EXIST; |
168 } |
168 } |
169 break; |
169 break; |
|
170 } |
170 case TMS_STREAM_DOWNLINK: |
171 case TMS_STREAM_DOWNLINK: |
|
172 { |
171 if (strmId == iDnlinkStreamId) |
173 if (strmId == iDnlinkStreamId) |
172 { |
174 { |
173 // Open message queue handling client-server communication |
175 // Open message queue handling client-server communication |
174 if (iMsgQueueDn.Handle() <= 0) |
176 if (iMsgQueueDn.Handle() <= 0) |
175 { |
177 { |
176 // Third argument in TMSCallProxy::InitStream |
178 // Third argument in TMSCallProxy::InitStream |
177 status = iMsgQueueDn.Open(aMessage, 1); |
179 status = iMsgQueueDn.Open(message, 1); |
178 } |
180 } |
179 if (status == TMS_RESULT_SUCCESS) |
181 if (status == TMS_RESULT_SUCCESS) |
180 { |
182 { |
181 TRAP(status, iCSDownlink = TMSCSDownlink::NewL(*this)); |
183 TRAP(status, iCSDownlink = TMSCSDownlink::NewL(*this)); |
182 if (status == TMS_RESULT_SUCCESS) |
184 if (status == TMS_RESULT_SUCCESS) |
183 { |
185 { |
184 TRAP(status, iRouting = |
186 TRAP(status, iRouting = |
185 CTelephonyAudioRouting::NewL(*this)); |
187 CTelephonyAudioRouting::NewL(*this)); |
186 if (status == TMS_RESULT_SUCCESS) |
188 if (status == TMS_RESULT_SUCCESS) |
187 { |
189 { |
188 iTarSettings = TMSTarSettings::NewL(); |
190 TRAP(status, iTarSettings = TMSTarSettings::NewL()); |
189 } |
191 } |
190 } |
192 } |
191 } |
193 } |
192 iStrmtype = TMS_STREAM_DOWNLINK; |
194 iStrmtype = TMS_STREAM_DOWNLINK; |
193 } |
195 } |
194 else |
196 else |
195 { |
197 { |
196 status = TMS_RESULT_DOES_NOT_EXIST; |
198 status = TMS_RESULT_DOES_NOT_EXIST; |
197 } |
199 } |
198 break; |
200 break; |
|
201 } |
199 default: |
202 default: |
|
203 { |
200 status = TMS_RESULT_STREAM_TYPE_NOT_SUPPORTED; |
204 status = TMS_RESULT_STREAM_TYPE_NOT_SUPPORTED; |
201 break; |
205 break; |
|
206 } |
202 } |
207 } |
203 |
208 |
204 TRACE_PRN_IF_ERR(status); |
209 TRACE_PRN_IF_ERR(status); |
205 TRACE_PRN_FN_EXT; |
210 TRACE_PRN_FN_EXT; |
206 return status; |
211 return status; |
893 count = numOfItems; |
898 count = numOfItems; |
894 for (guint i = 0; i < numOfItems; i++) |
899 for (guint i = 0; i < numOfItems; i++) |
895 { |
900 { |
896 tmsoutput = TOTMSOUTPUT(availableOutputs[i]); |
901 tmsoutput = TOTMSOUTPUT(availableOutputs[i]); |
897 stream.WriteUint32L(tmsoutput); |
902 stream.WriteUint32L(tmsoutput); |
898 //TRACE_PRN_N1(_L("TMS->CallIPAdpt: outputs: [%d]"), availableOutputs[i]); |
|
899 } |
903 } |
900 |
904 |
901 CleanupStack::PopAndDestroy(&stream); |
905 CleanupStack::PopAndDestroy(&stream); |
902 status = TMS_RESULT_SUCCESS; |
906 status = TMS_RESULT_SUCCESS; |
903 } |
907 } |
912 // ----------------------------------------------------------------------------- |
916 // ----------------------------------------------------------------------------- |
913 // TMSCallCSAdpt::DownlinkInitCompleted |
917 // TMSCallCSAdpt::DownlinkInitCompleted |
914 // |
918 // |
915 // ----------------------------------------------------------------------------- |
919 // ----------------------------------------------------------------------------- |
916 // |
920 // |
917 void TMSCallCSAdpt::DownlinkInitCompleted(TInt status) |
921 void TMSCallCSAdpt::DownlinkInitCompleted(gint status) |
918 { |
922 { |
919 TRACE_PRN_FN_ENT; |
923 TRACE_PRN_FN_ENT; |
920 NotifyClient(iDnlinkStreamId, ECmdDownlinkInitComplete, status, 0); |
924 NotifyClient(iDnlinkStreamId, ECmdDownlinkInitComplete, status, 0); |
921 TRACE_PRN_FN_EXT; |
925 TRACE_PRN_FN_EXT; |
922 } |
926 } |
924 // ----------------------------------------------------------------------------- |
928 // ----------------------------------------------------------------------------- |
925 // TMSCallCSAdpt::UplinkInitCompleted |
929 // TMSCallCSAdpt::UplinkInitCompleted |
926 // |
930 // |
927 // ----------------------------------------------------------------------------- |
931 // ----------------------------------------------------------------------------- |
928 // |
932 // |
929 void TMSCallCSAdpt::UplinkInitCompleted(TInt status) |
933 void TMSCallCSAdpt::UplinkInitCompleted(gint status) |
930 { |
934 { |
931 TRACE_PRN_FN_ENT; |
935 TRACE_PRN_FN_ENT; |
932 NotifyClient(iUplinkStreamId, ECmdUplinkInitComplete, status, 0); |
936 NotifyClient(iUplinkStreamId, ECmdUplinkInitComplete, status, 0); |
933 TRACE_PRN_FN_EXT; |
937 TRACE_PRN_FN_EXT; |
934 } |
938 } |
1027 pckg().iOutput = TOTMSOUTPUT(aTelephonyAudioRouting.Output()); |
1031 pckg().iOutput = TOTMSOUTPUT(aTelephonyAudioRouting.Output()); |
1028 if (iTarSettings) |
1032 if (iTarSettings) |
1029 { |
1033 { |
1030 iTarSettings->SetTar(pckg, ETrue); |
1034 iTarSettings->SetTar(pckg, ETrue); |
1031 } |
1035 } |
1032 //TRACE_PRN_IF_ERR(aError); |
|
1033 TRACE_PRN_FN_EXT; |
1036 TRACE_PRN_FN_EXT; |
1034 } |
1037 } |
1035 |
1038 |
1036 // ----------------------------------------------------------------------------- |
1039 // ----------------------------------------------------------------------------- |
1037 // TMSCallCSAdpt::NotifyClient |
1040 // TMSCallCSAdpt::NotifyClient |
1038 // |
1041 // |
1039 // ----------------------------------------------------------------------------- |
1042 // ----------------------------------------------------------------------------- |
1040 // |
1043 // |
1041 void TMSCallCSAdpt::NotifyClient(const gint strmId, const gint aCommand, |
1044 void TMSCallCSAdpt::NotifyClient(const gint strmId, const gint command, |
1042 const gint aStatus, const gint64 /*aInt64*/) |
1045 const gint status, const gint64 /*int64*/) |
1043 { |
1046 { |
1044 iMsgBuffer.iRequest = aCommand; |
1047 iMsgBuffer.iRequest = command; |
1045 iMsgBuffer.iStatus = aStatus; |
1048 iMsgBuffer.iStatus = status; |
1046 |
1049 |
1047 if (strmId == iUplinkStreamId) |
1050 if (strmId == iUplinkStreamId) |
1048 { |
1051 { |
1049 iMsgQueueUp.Send(iMsgBuffer); |
1052 iMsgQueueUp.Send(iMsgBuffer); |
1050 } |
1053 } |