src/audio/symbian/streamplayer.cpp

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