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 < 0 || aNew > KMaxVolume)
  90                 return;
  91
  92         iVolume = aNew;
  93         iState |= EVolumeChange;
  94 }
  95
  96 void CStreamPlayer::Open()
  97 {
  98         TMdaAudioDataSettings audioSettings;
  99         audioSettings.Query();
 100         audioSettings.iSampleRate = iRate;
 101         audioSettings.iChannels = iChannels;
 102         audioSettings.iVolume = 0;
 103
 104         iState &= ~EStopped;
 105         iStream->Open(&audioSettings);
 106 }
 107
 108 void CStreamPlayer::Stop()
 109 {
 110         if(iState & (EStarted | EInited))
 111         {
 112                 Close();
 113                 iState |= EStopped;
 114         }
 115 }
 116
 117 void CStreamPlayer::Start()
 118 {
 119         iState |= EStarted;
 120         if(iState & EInited)
 121         {
 122                 Request();
 123         }
 124         else if(iState & EStopped)
 125         {
 126                 Open();
 127         }
 128 }
 129
 130 void CStreamPlayer::Close()
 131 {
 132         iState &= ~EInited;
 133         iStream->Stop();
 134         iState &= ~EStarted;
 135 }
 136
 137 void CStreamPlayer::Request()
 138 {
 139         if(iState & EVolumeChange)
 140         {
 141                 const TReal newVol = iVolume;
 142                 const TReal newMax = KMaxVolume;
 143                 const int maxVol = iStream->MaxVolume();
 144                 const TReal max = static_cast<TReal>(maxVol);
 145                 const TReal newvolume = (newVol * max) / newMax;
 146                 const int vol = static_cast<TReal>(newvolume);
 147                 iStream->SetVolume(vol);
 148                 iState &= ~EVolumeChange;
 149         }
 150
 151         if(iState & EStarted)
 152         {
 153                 iPtr.Set(iProvider.Data());
 154         }
 155         if(iPtr.Length() == 0)
 156         {
 157                 iPtr.Set(iSilence);
 158         }
 159         TRAPD(err, iStream->WriteL(iPtr));
 160         if(err != KErrNone)
 161         {
 162                 iObs.Complete(MStreamObs::EWrite, err);
 163         }
 164 }
 165
 166 void CStreamPlayer::MaoscOpenComplete(int aError)
 167 {
 168         if(aError == KErrNone)
 169         {
 170                 iStream->SetDataTypeL(iType);
 171                 iStream->SetAudioPropertiesL(iRate, iChannels);
 172                 iStream->SetPriority(EPriorityNormal, EMdaPriorityPreferenceTime);
 173
 174                 iState |= EInited;
 175
 176                 SetVolume(Volume());
 177
 178                 if(iState & EStarted)
 179                 {
 180                         Request();
 181                 }
 182         }
 183         if(!(iState & EDied))
 184                 iObs.Complete(MStreamObs::EInit, aError);
 185 }
 186
 187 void CStreamPlayer::MaoscBufferCopied(int aError, const TDesC8& /*aBuffer*/)
 188 {
 189         if(aError == KErrNone)
 190         {
 191                 if(iState & EInited)
 192                         Request();
 193                 else
 194                         iStream->Stop();
 195         }
 196         else if(!(iState & EDied))
 197                 iObs.Complete(MStreamObs::EPlay, aError);
 198 }
 199
 200 void CStreamPlayer::MaoscPlayComplete(int aError)
 201 {
 202         iState &= ~EStarted;
 203         if(!(iState & EDied))
 204                 iObs.Complete(MStreamObs::EClose, aError);
 205 }