+++ /dev/null
-/*******************************************************************\r
- *\r
- * File: Audio_mediaserver.cpp\r
- *\r
- * Author: Peter van Sebille (peter@yipton.net)\r
- *\r
- * Modified/adapted for picodriveN by notaz, 2006\r
- *\r
- * (c) Copyright 2006, notaz\r
- * (c) Copyright 2001, Peter van Sebille\r
- * All Rights Reserved\r
- *\r
- *******************************************************************/\r
-\r
-#include "audio_mediaserver.h"\r
-#include "debug.h"\r
-\r
-//#define DEBUG_UNDERFLOWS\r
-//#undef DEBUGPRINT\r
-//#define DEBUGPRINT(x...)\r
-\r
-\r
-const TInt KUpdatesPerSec = 10;\r
-const TInt KBlockTime = 1000000 / KUpdatesPerSec;\r
-const TInt KMaxLag = 200000; // max sound lag, lower values increase chance of underflow\r
-const TInt KMaxUnderflows = 50; // max underflows/API errors we are going allow in a row (to prevent lockups)\r
-\r
-\r
-/*******************************************\r
- *\r
- * CGameAudioMS\r
- *\r
- *******************************************/\r
-\r
-CGameAudioMS::CGameAudioMS(TInt aRate, TBool aStereo, TInt aWritesPerSec, TInt aVolume)\r
-: iRate(aRate), iStereo(aStereo), iWritesPerSec(aWritesPerSec), iVolume(aVolume)\r
-{\r
-}\r
-\r
-\r
-CGameAudioMS* CGameAudioMS::NewL(TInt aRate, TBool aStereo, TInt aWritesPerSec, TInt aVolume)\r
-{\r
- DEBUGPRINT(_L("CGameAudioMS::NewL(%i, %i, %i, %i)"), aRate, aStereo, aWritesPerSec, aVolume);\r
- CGameAudioMS* self = new(ELeave) CGameAudioMS(aRate, aStereo, aWritesPerSec, aVolume);\r
- CleanupStack::PushL(self);\r
- self->ConstructL();\r
- CleanupStack::Pop(); // self\r
- return self;\r
-}\r
-\r
-\r
-CGameAudioMS::~CGameAudioMS()\r
-{\r
- DEBUGPRINT(_L("CGameAudioMS::~CGameAudioMS()"));\r
- if(iMdaAudioOutputStream) {\r
- iScheduler->Schedule(); // let it finish it's stuff\r
- iMdaAudioOutputStream->Stop();\r
- delete iMdaAudioOutputStream;\r
- }\r
- if(iServer) delete iServer;\r
-\r
- for (TInt i=0; i<KSoundBuffers; i++)\r
- delete iSoundBuffers[i];\r
-\r
- // Polled AS\r
- //if(iScheduler) delete iScheduler;\r
-}\r
-\r
-\r
-void CGameAudioMS::ConstructL()\r
-{\r
- iServer = CMdaServer::NewL();\r
-\r
- // iScheduler = CPolledActiveScheduler::NewL();\r
- iScheduler = CPolledActiveScheduler::Instance();\r
-\r
- switch(iRate) {\r
- case 11025: iMdaAudioDataSettings.iSampleRate = TMdaAudioDataSettings::ESampleRate11025Hz; break;\r
- case 16000: iMdaAudioDataSettings.iSampleRate = TMdaAudioDataSettings::ESampleRate16000Hz; break;\r
- case 22050: iMdaAudioDataSettings.iSampleRate = TMdaAudioDataSettings::ESampleRate22050Hz; break;\r
- case 44100: iMdaAudioDataSettings.iSampleRate = TMdaAudioDataSettings::ESampleRate44100Hz; break;\r
- default: iMdaAudioDataSettings.iSampleRate = TMdaAudioDataSettings::ESampleRate8000Hz; break;\r
- }\r
-\r
- iMdaAudioDataSettings.iChannels = (iStereo) ? TMdaAudioDataSettings::EChannelsStereo : TMdaAudioDataSettings::EChannelsMono;\r
- iMdaAudioDataSettings.iCaps = TMdaAudioDataSettings::ESampleRateFixed | iMdaAudioDataSettings.iSampleRate;\r
- iMdaAudioDataSettings.iFlags = TMdaAudioDataSettings::ENoNetworkRouting;\r
-\r
- iMaxWriteSamples = iRate / iWritesPerSec;\r
- if (iRate % iWritesPerSec)\r
- iMaxWriteSamples++;\r
- int bufferedFrames = iWritesPerSec / KUpdatesPerSec;\r
-\r
- iBufferSize = iMaxWriteSamples * (iStereo ? 4 : 2);\r
- iBufferSize *= bufferedFrames;\r
- for (TInt i=0 ; i<KSoundBuffers ; i++)\r
- {\r
- // it seems .SetLength(max) throws USER:23 panic,\r
- // so make them a bit larger\r
- iSoundBuffers[i] = HBufC8::NewL(iBufferSize+4);\r
- iSoundBuffers[i]->Des().FillZ (iBufferSize+4);\r
- }\r
-\r
- iCurrentBuffer = 0;\r
- iCurrentBufferSize = 0;\r
-\r
- DEBUGPRINT(_L("sound: iMaxWriteSamples: %i, iBufferSize: %i"), iMaxWriteSamples, iBufferSize);\r
-\r
- // here we actually test if we can create and open CMdaAudioOutputStream at all, but really create and use it later.\r
- iMdaAudioOutputStream = CMdaAudioOutputStream::NewL(iListener, iServer);\r
- if (iMdaAudioOutputStream) {\r
- if (iVolume < 0 || iVolume > iMdaAudioOutputStream->MaxVolume())\r
- iVolume = iMdaAudioOutputStream->MaxVolume();\r
- delete iMdaAudioOutputStream;\r
- iMdaAudioOutputStream = 0;\r
- }\r
-}\r
-\r
-// returns a pointer to buffer for next frame,\r
-// to be used when iSoundBuffers are used directly\r
-TInt16 *CGameAudioMS::NextFrameL(TInt aPcmFrames)\r
-{\r
- TInt mul = iStereo ? 4 : 2;\r
- TInt bytes = aPcmFrames * mul;\r
- iCurrentPosition += bytes / 2;\r
- iCurrentBufferSize += bytes;\r
-\r
- if (aPcmFrames > iMaxWriteSamples) {\r
- DEBUGPRINT(_L("too many samples: %i > %i"), aPcmFrames, iMaxWriteSamples);\r
- }\r
-\r
- if (iCurrentBufferSize + iMaxWriteSamples * mul > iBufferSize)\r
- {\r
- //DEBUGPRINT(_L("write on iCurrentBufferSize %i"), iCurrentBufferSize);\r
- WriteBlockL();\r
- }\r
-\r
- iScheduler->Schedule();\r
-\r
- if(iListener.iUnderflowed) {\r
- if(iListener.iUnderflowed > KMaxUnderflows) {\r
- delete iMdaAudioOutputStream;\r
- iMdaAudioOutputStream = 0;\r
- return 0;\r
- }\r
- UnderflowedL(); // not again!\r
- }\r
-\r
- return iCurrentPosition;\r
-}\r
-\r
-void CGameAudioMS::WriteBlockL()\r
-{\r
- iScheduler->Schedule();\r
- // do not write until stream is open\r
- if(!iListener.iIsOpen) WaitForOpenToCompleteL();\r
- //if(!iListener.iHasCopied) WaitForCopyToCompleteL(); // almost never happens anyway and sometimes even deadlocks?\r
- //iListener.iHasCopied = EFalse;\r
- \r
-\r
- if(!iListener.iUnderflowed) {\r
- TInt64 delta;\r
- // don't write if sound is lagging too much\r
- delta = iTime - iMdaAudioOutputStream->Position().Int64();\r
- if (delta > MAKE_TINT64(0, KMaxLag))\r
- // another query sometimes returns very different result\r
- delta = iTime - iMdaAudioOutputStream->Position().Int64();\r
-\r
- if(delta <= MAKE_TINT64(0, KMaxLag)) {\r
- //RDebug::Print(_L("delta: %i"), iTime.Low() - iMdaAudioOutputStream->Position().Int64().Low());\r
- iSoundBuffers[iCurrentBuffer]->Des().SetLength(iCurrentBufferSize);\r
- iMdaAudioOutputStream->WriteL(*iSoundBuffers[iCurrentBuffer]);\r
- iTime += KBlockTime;\r
- } else {\r
- DEBUGPRINT(_L("lag: %i"), I64LOW(delta));\r
- }\r
- }\r
-\r
- if (++iCurrentBuffer == KSoundBuffers)\r
- iCurrentBuffer = 0;\r
- iSoundBuffers[iCurrentBuffer]->Des().SetMax();\r
- iCurrentPosition = (TInt16*) iSoundBuffers[iCurrentBuffer]->Ptr();\r
- iCurrentBufferSize = 0;\r
-}\r
-\r
-void CGameAudioMS::Pause()\r
-{\r
- if(!iMdaAudioOutputStream) return;\r
-\r
- iScheduler->Schedule(); // let it finish it's stuff\r
- iMdaAudioOutputStream->Stop();\r
- delete iMdaAudioOutputStream;\r
- iMdaAudioOutputStream = 0;\r
-}\r
-\r
-// call this before doing any playback!\r
-TInt16 *CGameAudioMS::ResumeL()\r
-{\r
- DEBUGPRINT(_L("CGameAudioMS::Resume()"));\r
- iScheduler->Schedule();\r
-\r
- // we act a bit strange here: simulate buffer underflow, which actually starts audio\r
- iListener.iIsOpen = ETrue;\r
- iListener.iUnderflowed = 1;\r
- iListener.iLastError = 0;\r
- iCurrentBufferSize = 0;\r
- iCurrentPosition = (TInt16*) iSoundBuffers[iCurrentBuffer]->Ptr();\r
- return iCurrentPosition;\r
-}\r
-\r
-// handles underflow condition\r
-void CGameAudioMS::UnderflowedL()\r
-{\r
-#ifdef DEBUG_UNDERFLOWS\r
- DEBUGPRINT(_L("UnderflowedL()"));\r
-#endif\r
-\r
- if (iListener.iLastError != KErrUnderflow)\r
- {\r
- // recreate the stream\r
- //iMdaAudioOutputStream->Stop();\r
- if(iMdaAudioOutputStream) delete iMdaAudioOutputStream;\r
- iMdaAudioOutputStream = CMdaAudioOutputStream::NewL(iListener, iServer);\r
- iMdaAudioOutputStream->Open(&iMdaAudioDataSettings);\r
- iMdaAudioOutputStream->SetAudioPropertiesL(iMdaAudioDataSettings.iSampleRate, iMdaAudioDataSettings.iChannels);\r
- iMdaAudioOutputStream->SetVolume(iVolume); // new in UIQ3\r
-\r
- iListener.iIsOpen = EFalse; // wait for it to open\r
- //iListener.iHasCopied = ETrue; // but don't wait for last copy to complete\r
- // let it open and feed some stuff to make it happy\r
- User::After(0);\r
- iScheduler->Schedule();\r
- iListener.iLastError = 0;\r
- if(!iListener.iIsOpen) WaitForOpenToCompleteL();\r
- } else {\r
- iListener.iLastError = iListener.iUnderflowed = 0;\r
- }\r
- iTime = iMdaAudioOutputStream->Position().Int64();\r
-}\r
-\r
-void CGameAudioMS::WaitForOpenToCompleteL()\r
-{\r
- DEBUGPRINT(_L("CGameAudioMS::WaitForOpenToCompleteL"));\r
- TInt count = 20; // 2 seconds\r
- TInt waitPeriod = 100 * 1000;\r
-\r
- if(!iListener.iIsOpen) {\r
- // it is often enough to do this\r
- User::After(0);\r
- iScheduler->Schedule();\r
- }\r
- while (!iListener.iIsOpen && --count)\r
- {\r
- User::After(waitPeriod);\r
- iScheduler->Schedule();\r
- }\r
- if (!iListener.iIsOpen)\r
- User::LeaveIfError(KErrNotSupported);\r
-}\r
-\r
-TInt CGameAudioMS::ChangeVolume(TInt aUp)\r
-{\r
- //DEBUGPRINT(_L("CGameAudioMS::ChangeVolume(%i)"), aUp);\r
-\r
- if (iMdaAudioOutputStream) {\r
- if (aUp) {\r
- iVolume += 5;\r
- if (iVolume > iMdaAudioOutputStream->MaxVolume())\r
- iVolume = iMdaAudioOutputStream->MaxVolume();\r
- } else {\r
- iVolume -= 5;\r
- if (iVolume < 0) iVolume = 0;\r
- }\r
- iMdaAudioOutputStream->SetVolume(iVolume);\r
- }\r
-\r
- return iVolume;\r
-}\r
-\r
-void TGameAudioEventListener::MaoscOpenComplete(TInt aError)\r
-{\r
-#ifdef DEBUG_UNDERFLOWS\r
- DEBUGPRINT(_L("CGameAudioMS::MaoscOpenComplete, error=%d"), aError);\r
-#endif\r
-\r
- iIsOpen = ETrue;\r
- if(aError) {\r
- iLastError = aError;\r
- iUnderflowed++;\r
- }\r
- else iUnderflowed = 0;\r
-}\r
-\r
-void TGameAudioEventListener::MaoscBufferCopied(TInt aError, const TDesC8& aBuffer)\r
-{\r
- if (aError)\r
- DEBUGPRINT(_L("CGameAudioMS::MaoscBufferCopied, error=%d"), aError);\r
-\r
-// iHasCopied = ETrue;\r
-\r
- if(aError) { // shit!\r
- iLastError = aError;\r
- iUnderflowed++;\r
- }\r
-}\r
-\r
-void TGameAudioEventListener::MaoscPlayComplete(TInt aError)\r
-{\r
-#ifdef DEBUG_UNDERFLOWS\r
- DEBUGPRINT(_L("CGameAudioMS::MaoscPlayComplete: %i"), aError);\r
-#endif\r
- if(aError) {\r
- iLastError = aError;\r
- iUnderflowed++; // never happened to me while testing, but just in case\r
- }\r
-}\r
-\r
notaz.gp2x.de / picodrive.git / blobdiff