src/audio/symbian/streamplayer.cpp

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