equal
deleted
inserted
replaced
156 // ----------------------------------------------------------------------------- |
156 // ----------------------------------------------------------------------------- |
157 // TMSCallIPAdpt::InitStream |
157 // TMSCallIPAdpt::InitStream |
158 // |
158 // |
159 // ----------------------------------------------------------------------------- |
159 // ----------------------------------------------------------------------------- |
160 // |
160 // |
161 gint TMSCallIPAdpt::InitStreamL(TMSCallType /*callType*/, |
161 gint TMSCallIPAdpt::InitStream(TMSCallType /*callType*/, TMSStreamType strmType, |
162 TMSStreamType strmType, gint strmId, TMSFormatType frmtType, |
162 gint strmId, TMSFormatType frmtType, const RMessage2& message) |
163 const RMessage2& aMessage) |
|
164 { |
163 { |
165 TRACE_PRN_FN_ENT; |
164 TRACE_PRN_FN_ENT; |
166 gint status(TMS_RESULT_SUCCESS); |
165 gint status(TMS_RESULT_SUCCESS); |
167 |
166 |
168 TUint32 fourCC = TOFOURCC(frmtType); |
167 guint32 fourCC = TOFOURCC(frmtType); |
169 if (fourCC == NULL) |
168 if (fourCC == NULL) |
170 { |
169 { |
171 return TMS_RESULT_INVALID_ARGUMENT; |
170 return TMS_RESULT_INVALID_ARGUMENT; |
172 } |
171 } |
173 |
172 |
177 { |
176 { |
178 status = TMS_RESULT_DOES_NOT_EXIST; |
177 status = TMS_RESULT_DOES_NOT_EXIST; |
179 if (strmId == iUplinkStreamId) |
178 if (strmId == iUplinkStreamId) |
180 { |
179 { |
181 SetFormat(iUplinkStreamId, fourCC); |
180 SetFormat(iUplinkStreamId, fourCC); |
182 status = OpenUplinkL(aMessage); |
181 status = OpenUplinkL(message); |
183 NotifyClient(iUplinkStreamId, ECmdUplinkInitComplete, status); |
182 NotifyClient(iUplinkStreamId, ECmdUplinkInitComplete, status); |
184 } |
183 } |
185 break; |
184 break; |
186 } |
185 } |
187 case TMS_STREAM_DOWNLINK: |
186 case TMS_STREAM_DOWNLINK: |
188 { |
187 { |
189 status = TMS_RESULT_DOES_NOT_EXIST; |
188 status = TMS_RESULT_DOES_NOT_EXIST; |
190 if (strmId == iDnlinkStreamId) |
189 if (strmId == iDnlinkStreamId) |
191 { |
190 { |
192 SetFormat(iDnlinkStreamId, fourCC); |
191 SetFormat(iDnlinkStreamId, fourCC); |
193 status = OpenDownlinkL(aMessage); |
192 status = OpenDownlinkL(message); |
194 NotifyClient(iDnlinkStreamId, ECmdDownlinkInitComplete, status); |
193 NotifyClient(iDnlinkStreamId, ECmdDownlinkInitComplete, status); |
195 } |
194 } |
196 break; |
195 break; |
197 } |
196 } |
198 default: |
197 default: |
986 // ----------------------------------------------------------------------------- |
985 // ----------------------------------------------------------------------------- |
987 // TMSCallIPAdpt::OpenDownlinkL |
986 // TMSCallIPAdpt::OpenDownlinkL |
988 // Method for player initialization. |
987 // Method for player initialization. |
989 // ----------------------------------------------------------------------------- |
988 // ----------------------------------------------------------------------------- |
990 // |
989 // |
991 gint TMSCallIPAdpt::OpenDownlinkL(const RMessage2& aMessage) |
990 gint TMSCallIPAdpt::OpenDownlinkL(const RMessage2& message) |
992 { |
991 { |
993 TRACE_PRN_FN_ENT; |
992 TRACE_PRN_FN_ENT; |
994 gint status(TMS_RESULT_SUCCESS); |
993 gint status(TMS_RESULT_SUCCESS); |
995 |
994 |
996 // Clients must have MultimediaDD capability to use this priority/pref. |
995 // Clients must have MultimediaDD capability to use this priority/pref. |
1008 { |
1007 { |
1009 // Open message queue for handling server notifications to the client |
1008 // Open message queue for handling server notifications to the client |
1010 if (iMsgQueueDn.Handle() <= 0) |
1009 if (iMsgQueueDn.Handle() <= 0) |
1011 { |
1010 { |
1012 // Second argument in TMSCallProxy::InitStream |
1011 // Second argument in TMSCallProxy::InitStream |
1013 status = iMsgQueueDn.Open(aMessage, 1); |
1012 status = iMsgQueueDn.Open(message, 1); |
1014 } |
1013 } |
1015 |
1014 |
1016 if (status == TMS_RESULT_SUCCESS) |
1015 if (status == TMS_RESULT_SUCCESS) |
1017 { |
1016 { |
1018 // For transfer data buffer processing |
1017 // For transfer data buffer processing |
1028 // ----------------------------------------------------------------------------- |
1027 // ----------------------------------------------------------------------------- |
1029 // TMSCallIPAdpt::OpenUplinkL |
1028 // TMSCallIPAdpt::OpenUplinkL |
1030 // Method for recorder initialization. |
1029 // Method for recorder initialization. |
1031 // ----------------------------------------------------------------------------- |
1030 // ----------------------------------------------------------------------------- |
1032 // |
1031 // |
1033 gint TMSCallIPAdpt::OpenUplinkL(const RMessage2& aMessage) |
1032 gint TMSCallIPAdpt::OpenUplinkL(const RMessage2& message) |
1034 { |
1033 { |
1035 TRACE_PRN_FN_ENT; |
1034 TRACE_PRN_FN_ENT; |
1036 gint status(TMS_RESULT_SUCCESS); |
1035 gint status(TMS_RESULT_SUCCESS); |
1037 |
1036 |
1038 // Ensure clients have MultimediaDD capability to use this priority/pref |
1037 // Ensure clients have MultimediaDD capability to use this priority/pref |
1048 { |
1047 { |
1049 // Open message queue for handling server notifications to the client |
1048 // Open message queue for handling server notifications to the client |
1050 if (iMsgQueueUp.Handle() <= 0) |
1049 if (iMsgQueueUp.Handle() <= 0) |
1051 { |
1050 { |
1052 // Second argument in TMSCallProxy::InitStream |
1051 // Second argument in TMSCallProxy::InitStream |
1053 status = iMsgQueueUp.Open(aMessage, 1); |
1052 status = iMsgQueueUp.Open(message, 1); |
1054 } |
1053 } |
1055 |
1054 |
1056 if (status == TMS_RESULT_SUCCESS) |
1055 if (status == TMS_RESULT_SUCCESS) |
1057 { |
1056 { |
1058 // For transfer data buffer processing |
1057 // For transfer data buffer processing |
1068 // ----------------------------------------------------------------------------- |
1067 // ----------------------------------------------------------------------------- |
1069 // TMSCallIPAdpt::SetFormat |
1068 // TMSCallIPAdpt::SetFormat |
1070 // |
1069 // |
1071 // ----------------------------------------------------------------------------- |
1070 // ----------------------------------------------------------------------------- |
1072 // |
1071 // |
1073 void TMSCallIPAdpt::SetFormat(const gint strmId, const TUint32 aFormat) |
1072 void TMSCallIPAdpt::SetFormat(const gint strmId, const guint32 aFormat) |
1074 { |
1073 { |
1075 if (strmId == iUplinkStreamId) |
1074 if (strmId == iUplinkStreamId) |
1076 { |
1075 { |
1077 iUpFourCC = aFormat; |
1076 iUpFourCC = aFormat; |
1078 } |
1077 } |
1085 // ----------------------------------------------------------------------------- |
1084 // ----------------------------------------------------------------------------- |
1086 // TMSCallIPAdpt::BufferFilled |
1085 // TMSCallIPAdpt::BufferFilled |
1087 // |
1086 // |
1088 // ----------------------------------------------------------------------------- |
1087 // ----------------------------------------------------------------------------- |
1089 // |
1088 // |
1090 void TMSCallIPAdpt::BufferFilledL(TUint dataSize) |
1089 void TMSCallIPAdpt::BufferFilledL(guint dataSize) |
1091 { |
1090 { |
1092 if (iIPDownlink) |
1091 if (iIPDownlink) |
1093 { |
1092 { |
1094 iIPDownlink->BufferFilled(dataSize); |
1093 iIPDownlink->BufferFilled(dataSize); |
1095 } |
1094 } |
1112 // TMSCallIPAdpt::GetDataXferChunkHndl |
1111 // TMSCallIPAdpt::GetDataXferChunkHndl |
1113 // |
1112 // |
1114 // ----------------------------------------------------------------------------- |
1113 // ----------------------------------------------------------------------------- |
1115 // |
1114 // |
1116 gint TMSCallIPAdpt::GetDataXferChunkHndl(const TMSStreamType strmType, |
1115 gint TMSCallIPAdpt::GetDataXferChunkHndl(const TMSStreamType strmType, |
1117 const TUint32 key, RChunk& chunk) |
1116 const guint32 key, RChunk& chunk) |
1118 { |
1117 { |
1119 TRACE_PRN_FN_ENT; |
1118 TRACE_PRN_FN_ENT; |
1120 |
1119 |
1121 gint status(TMS_RESULT_UNINITIALIZED_OBJECT); |
1120 gint status(TMS_RESULT_UNINITIALIZED_OBJECT); |
1122 switch (strmType) |
1121 switch (strmType) |
1381 |
1380 |
1382 // ----------------------------------------------------------------------------- |
1381 // ----------------------------------------------------------------------------- |
1383 // TMSCallIPAdpt::NotifyClient |
1382 // TMSCallIPAdpt::NotifyClient |
1384 // ----------------------------------------------------------------------------- |
1383 // ----------------------------------------------------------------------------- |
1385 // |
1384 // |
1386 void TMSCallIPAdpt::NotifyClient(const gint strmId, const TInt aCommand, |
1385 void TMSCallIPAdpt::NotifyClient(const gint strmId, const gint aCommand, |
1387 const TInt aStatus, const TInt64 /*aInt64*/) |
1386 const gint aStatus, const gint64 /*aInt64*/) |
1388 { |
1387 { |
1389 iMsgBuffer.iRequest = aCommand; |
1388 iMsgBuffer.iRequest = aCommand; |
1390 iMsgBuffer.iStatus = aStatus; |
1389 iMsgBuffer.iStatus = aStatus; |
1391 |
1390 |
1392 if (strmId == iUplinkStreamId) |
1391 if (strmId == iUplinkStreamId) |