|
3975
|
1 #include "streamplayer.h"
|
|
|
2 #include<mda/common/audio.h>
|
|
|
3
|
|
|
4
|
|
|
5
|
|
|
6 const TInt KMaxVolume(256);
|
|
|
7
|
|
|
8 LOCAL_C TInt GetSampleRate(TInt aRate)
|
|
|
9 {
|
|
|
10 switch(aRate)
|
|
|
11 {
|
|
|
12 case 8000: return TMdaAudioDataSettings::ESampleRate8000Hz;
|
|
|
13 case 11025: return TMdaAudioDataSettings::ESampleRate11025Hz;
|
|
|
14 case 12000: return TMdaAudioDataSettings::ESampleRate12000Hz;
|
|
|
15 case 16000: return TMdaAudioDataSettings::ESampleRate16000Hz;
|
|
|
16 case 22050: return TMdaAudioDataSettings::ESampleRate22050Hz;
|
|
|
17 case 24000: return TMdaAudioDataSettings::ESampleRate24000Hz;
|
|
|
18 case 32000: return TMdaAudioDataSettings::ESampleRate32000Hz;
|
|
|
19 case 44100: return TMdaAudioDataSettings::ESampleRate44100Hz;
|
|
|
20 case 48000: return TMdaAudioDataSettings::ESampleRate48000Hz;
|
|
|
21 case 96000: return TMdaAudioDataSettings::ESampleRate96000Hz;
|
|
|
22 case 64000: return TMdaAudioDataSettings::ESampleRate64000Hz;
|
|
|
23 }
|
|
|
24 return KErrNotFound;
|
|
|
25 }
|
|
|
26
|
|
|
27 LOCAL_C TInt GetChannels(TInt aChannels)
|
|
|
28 {
|
|
|
29 switch(aChannels)
|
|
|
30 {
|
|
|
31 case 1: return TMdaAudioDataSettings::EChannelsMono;
|
|
|
32 case 2: return TMdaAudioDataSettings::EChannelsStereo;
|
|
|
33 }
|
|
|
34 return KErrNotFound;
|
|
|
35 }
|
|
|
36
|
|
|
37 TInt CStreamPlayer::ClosestSupportedRate(TInt aRate)
|
|
|
38 {
|
|
|
39 if(aRate > 96000)
|
|
|
40 return 96000;
|
|
|
41 TInt rate = aRate;
|
|
|
42 while(GetSampleRate(rate) == KErrNotFound)
|
|
|
43 {
|
|
|
44 ++rate;
|
|
|
45 }
|
|
|
46 return rate;
|
|
|
47 }
|
|
|
48
|
|
|
49 CStreamPlayer::CStreamPlayer(MStreamProvider& aProvider, MStreamObs& aObs) :
|
|
|
50 iProvider(aProvider), iObs(aObs), iVolume(KMaxVolume)
|
|
|
51 {
|
|
|
52 }
|
|
|
53
|
|
|
54 CStreamPlayer::~CStreamPlayer()
|
|
|
55 {
|
|
|
56 iState |= EDied;
|
|
|
57 if(iState & EInited)
|
|
|
58 Close();
|
|
|
59 User::After(100000); //wait buffer to be flushed
|
|
|
60 ASSERT(iPtr.Length() == 0);
|
|
|
61 delete iStream;
|
|
|
62 }
|
|
|
63
|
|
|
64
|
|
|
65 void CStreamPlayer::ConstructL()
|
|
|
66 {
|
|
|
67 iStream = CMdaAudioOutputStream::NewL(*this, EMdaPriorityMax);
|
|
|
68 iSilence.SetMax();
|
|
|
69 iSilence.FillZ();
|
|
|
70 }
|
|
|
71
|
|
|
72
|
|
|
73 TInt CStreamPlayer::OpenStream(TInt aRate, TInt aChannels, TUint32 aType)
|
|
|
74 {
|
|
|
75 Close();
|
|
|
76
|
|
|
77 iType = aType;
|
|
|
78
|
|
|
79 iRate = GetSampleRate(aRate);
|
|
|
80 if(iRate == KErrNotFound)
|
|
|
81 return KErrNotSupported;
|
|
|
82
|
|
|
83 iChannels = GetChannels(aChannels);
|
|
|
84 if(iChannels == KErrNotFound)
|
|
|
85 return KErrNotSupported;
|
|
|
86
|
|
|
87 Open();
|
|
|
88
|
|
|
89 return KErrNone;
|
|
|
90 }
|
|
|
91
|
|
|
92
|
|
|
93 TInt CStreamPlayer::MaxVolume() const
|
|
|
94 {
|
|
|
95 return KMaxVolume;
|
|
|
96 }
|
|
|
97
|
|
|
98 void CStreamPlayer::SetVolume(TInt aNew)
|
|
|
99 {
|
|
|
100
|
|
|
101 const TInt maxi = MaxVolume();
|
|
|
102 if(aNew > maxi)
|
|
|
103 return;
|
|
|
104 if(aNew < 0)
|
|
|
105 return;
|
|
|
106
|
|
|
107 iVolume = aNew;
|
|
|
108
|
|
|
109 iState |= EVolumeChange;
|
|
|
110 }
|
|
|
111
|
|
|
112 TInt CStreamPlayer::Volume() const
|
|
|
113 {
|
|
|
114 return iVolume;
|
|
|
115 }
|
|
|
116
|
|
|
117 void CStreamPlayer::Open()
|
|
|
118 {
|
|
|
119 TMdaAudioDataSettings audioSettings;
|
|
|
120 audioSettings.Query();
|
|
|
121 audioSettings.iCaps = TMdaAudioDataSettings::ERealTime |
|
|
|
122 TMdaAudioDataSettings::ESampleRateFixed;
|
|
|
123 audioSettings.iSampleRate = iRate;
|
|
|
124 audioSettings.iChannels = iChannels;
|
|
|
125 audioSettings.iFlags = TMdaAudioDataSettings::ENoNetworkRouting;
|
|
|
126 audioSettings.iVolume = 0;
|
|
|
127
|
|
|
128 iState &= ~EStopped;
|
|
|
129 iStream->Open(&audioSettings);
|
|
|
130 }
|
|
|
131
|
|
|
132 void CStreamPlayer::Stop()
|
|
|
133 {
|
|
|
134 if(iState & (EStarted | EInited))
|
|
|
135 {
|
|
|
136 Close();
|
|
|
137 iState |= EStopped;
|
|
|
138 }
|
|
|
139 }
|
|
|
140
|
|
|
141 void CStreamPlayer::Start()
|
|
|
142 {
|
|
|
143 if(iPtr.Length() == 0)
|
|
|
144 {
|
|
|
145 iState |= EStarted;
|
|
|
146 if(iState & EInited)
|
|
|
147 {
|
|
|
148 Request();
|
|
|
149 }
|
|
|
150 else if(iState & EStopped)
|
|
|
151 {
|
|
|
152 Open();
|
|
|
153 }
|
|
|
154 }
|
|
|
155 }
|
|
|
156
|
|
|
157 void CStreamPlayer::Close()
|
|
|
158 {
|
|
|
159 iState &= ~EInited;
|
|
|
160 iStream->Stop();
|
|
|
161 iState &= ~EStarted;
|
|
|
162 }
|
|
|
163
|
|
|
164 void CStreamPlayer::Request()
|
|
|
165 {
|
|
|
166 if(iState & EInited)
|
|
|
167 {
|
|
|
168 iPtr.Set(KNullDesC8);
|
|
|
169
|
|
|
170 if(iState & EVolumeChange)
|
|
|
171 {
|
|
|
172 const TReal newVol = iVolume;
|
|
|
173 const TReal newMax = MaxVolume();
|
|
|
174 const TInt maxVol = iStream->MaxVolume();
|
|
|
175 const TReal max = static_cast<TReal>(maxVol);
|
|
|
176 const TReal newvolume = (newVol * max) / newMax;
|
|
|
177 const TInt vol = static_cast<TReal>(newvolume);
|
|
|
178 iStream->SetVolume(vol);
|
|
|
179 iState &= ~EVolumeChange;
|
|
|
180 }
|
|
|
181
|
|
|
182 if(iState & EStarted)
|
|
|
183 {
|
|
|
184 iPtr.Set(iProvider.Data());
|
|
|
185 }
|
|
|
186 if(iPtr.Length() == 0)
|
|
|
187 {
|
|
|
188 iPtr.Set(iSilence);
|
|
|
189 }
|
|
|
190 TRAPD(err, iStream->WriteL(iPtr));
|
|
|
191 if(err != KErrNone)
|
|
|
192 {
|
|
|
193 iObs.Complete(MStreamObs::EWrite, err);
|
|
|
194 }
|
|
|
195 /* else
|
|
|
196 {
|
|
|
197 iProvider.Written(iPtr.Length());
|
|
|
198 }*/
|
|
|
199 }
|
|
|
200 }
|
|
|
201
|
|
|
202
|
|
|
203 void CStreamPlayer::SetCapsL()
|
|
|
204 {
|
|
|
205 iStream->SetDataTypeL(iType);
|
|
|
206 iStream->SetAudioPropertiesL(iRate, iChannels);
|
|
|
207 }
|
|
|
208
|
|
|
209 void CStreamPlayer::MaoscOpenComplete(TInt aError)
|
|
|
210 {
|
|
|
211 if(aError == KErrNone)
|
|
|
212 {
|
|
|
213 TRAPD(err, SetCapsL());
|
|
|
214 if(err == KErrNone)
|
|
|
215 {
|
|
|
216 iStream->SetPriority(EPriorityNormal, EMdaPriorityPreferenceTime);
|
|
|
217 iState |= EInited;
|
|
|
218
|
|
|
219
|
|
|
220 SetVolume(Volume());
|
|
|
221
|
|
|
222 if(iState & EStarted)
|
|
|
223 {
|
|
|
224 Request();
|
|
|
225 }
|
|
|
226
|
|
|
227 }
|
|
|
228 aError = err;
|
|
|
229 }
|
|
|
230 if(!(iState & EDied))
|
|
|
231 iObs.Complete(MStreamObs::EInit, aError);
|
|
|
232 }
|
|
|
233
|
|
|
234 void CStreamPlayer::MaoscBufferCopied(TInt aError, const TDesC8& /*aBuffer*/)
|
|
|
235 {
|
|
|
236 iPtr.Set(KNullDesC8);
|
|
|
237 if(aError == KErrNone)
|
|
|
238 {
|
|
|
239 if(iState & EInited)
|
|
|
240 Request();
|
|
|
241 else
|
|
|
242 iStream->Stop();
|
|
|
243 }
|
|
|
244 else if(!(iState & EDied))
|
|
|
245 iObs.Complete(MStreamObs::EPlay, aError);
|
|
|
246 }
|
|
|
247
|
|
|
248 void CStreamPlayer::MaoscPlayComplete(TInt aError)
|
|
|
249 {
|
|
|
250 iPtr.Set(KNullDesC8);
|
|
|
251 iState &= ~EStarted;
|
|
|
252 if(!(iState & EDied))
|
|
|
253 iObs.Complete(MStreamObs::EClose, aError);
|
|
|
254 }
|
|
|
255
|
|
|
256 TBool CStreamPlayer::Playing() const
|
|
|
257 {
|
|
|
258 return (iState & EInited) && (iState & EStarted);
|
|
|
259 }
|
|
|
260
|
|
|
261 TBool CStreamPlayer::Closed() const
|
|
|
262 {
|
|
|
263 return !(iState & EInited) && !(iState & EDied);
|
|
|
264 }
|
|
|
265
|
|
|
266 /*
|
|
|
267 void CStreamPlayer::Request()
|
|
|
268 {
|
|
|
269 SetActive();
|
|
|
270 TRequestStatus* s = &iStatus;
|
|
|
271 User::RequestComplete(s, KErrNone);
|
|
|
272 }
|
|
|
273 // iTimer.After(0);
|
|
|
274 */
|
|
|
275
|
|
|
276
|
|
|
277
|
|
|
278
|
|
|
279
|
