sl@0: // Copyright (c) 2003-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: // mmfswaudioinputpriv.h
sl@0: // 
sl@0: //
sl@0: 
sl@0: #ifndef SWAUDIOINPUTPRIV_H
sl@0: #define SWAUDIOINPUTPRIV_H
sl@0: 
sl@0: #include <e32def.h>
sl@0: #include "mmfswaudioinput.h"
sl@0: #include <d32soundsc.h>
sl@0: #include <e32base.h>
sl@0: #include <e32std.h>
sl@0: 
sl@0: #define KNumRecorders (2) // 2 for double buffering, 4 quadruple etc
sl@0: 
sl@0: enum TPanicCodes
sl@0:     {
sl@0:     KPanicBadTotalQueueLength=1,    // once constructed, total queue length should be KNumRecorders
sl@0:     KPanicBadTotalQueueLength2,     // during construction or delation, total queue length should be <= KNumRecorders
sl@0:     KPanicBadBusyQueueLength,       // Busy queue should never exceed length of 1
sl@0:     EPanicBusyRecorderNotActive,    // If in the busy queue, should be active
sl@0:     EPanicNonBusyRecorderActive,    // opposite
sl@0:     };
sl@0: 
sl@0: //Total Number of sample rates
sl@0: class CChannelAndSampleRateConverter;  // forward dec
sl@0: 
sl@0: class TRecordSharedChunkBufConfig : public TSharedChunkBufConfigBase
sl@0: 	{
sl@0: public:
sl@0: 	TInt iBufferOffsetList[3];
sl@0: 	};
sl@0: 
sl@0: NONSHARABLE_CLASS(CAudioInput) : public CBase, 
sl@0: 					public MAudioInput,
sl@0: 					public MAIParamInterface
sl@0: 	{
sl@0: 	NONSHARABLE_CLASS( CRecorder ) : public CActive
sl@0: 		{
sl@0: 	public:
sl@0: 		CRecorder(CAudioInput& aParent, TInt aIndex);
sl@0: 		~CRecorder();
sl@0: 		void Cancel();
sl@0: 		
sl@0: 		void RecordData();
sl@0: 		TInt Index() const;
sl@0: 		void ReleaseBuffer(TBool aDoAnyway=EFalse);
sl@0: 		TBool IsBusy() const;
sl@0: 		TBool BufferHeld() const;
sl@0: 		TInt Length() const; 
sl@0: 		TInt Offset() const;
sl@0: 		TInt StatusOrOffset() const;
sl@0: 		
sl@0: 		TSglQueLink iLink; // used to form queues. Treat as private.
sl@0: 		
sl@0: 		// from CActive
sl@0: 		void RunL();
sl@0: 		void DoCancel(); 
sl@0: 	private:
sl@0: 		CAudioInput& iParent;
sl@0: 		const TInt iIndex;
sl@0: 		TInt iLength;
sl@0: 		TBool iBufferHeld;
sl@0: 		};
sl@0: 
sl@0: private:
sl@0: 	class TFormatData
sl@0: 		{
sl@0: 	public:
sl@0: 		inline TFormatData():
sl@0: 			iSampleRate(8000), iRequestedChannels(1) // default
sl@0: 			{
sl@0: 			}
sl@0: 	public:
sl@0: 		TInt iSampleRate;
sl@0: 		TInt iActualRate;
sl@0: 		TInt iRequestedChannels;
sl@0: 		TInt iActualChannels;			
sl@0: 		};
sl@0: 	
sl@0: public:
sl@0: 	static CAudioInput* NewL(MAudioInputObserver& aObserver);
sl@0: 	~CAudioInput();
sl@0: 	
sl@0: 	// from MAudioInput
sl@0: 	void Release();
sl@0: 	TInt Initialize(const TAudioInputParams& aParams);
sl@0: 	void Close();
sl@0: 	TInt Start();
sl@0: 	void BufferAck();
sl@0: 	TInt Pause();
sl@0: 	TInt Resume();
sl@0: 	TInt Flush();
sl@0: 	void Stop();
sl@0: 	TAny* Interface(TUid aInterfaceUid);
sl@0: 	
sl@0: 	// from MAIParamInterface
sl@0: 	TInt SetGain(TInt aGain);
sl@0: 	TInt GetBufferSizes(TInt& aMinSize, TInt& aMaxSize);
sl@0: 	TInt GetSupportedSampleRates(RArray<TInt>& aSupportedSampleRates);
sl@0: 	
sl@0: 	RSoundSc& RecordSoundDevice();
sl@0: 	void BufferArrives(CRecorder* aRecorder);
sl@0: 	void BufferError(CRecorder* aRecorder, TInt aError);
sl@0: 	TInt SetFormat(const TAudioInputParams& aFormat);
sl@0: 	TInt NegotiateFormat(const TAudioInputParams& aFormat, TFormatData &aFormatData);
sl@0: 	TInt GetSupportedSampleRates(RArray<TInt>& aSupportedSampleRates, RSoundSc& aSoundDevice);
sl@0: 
sl@0: private:
sl@0: 	CAudioInput(MAudioInputObserver& aObserver);
sl@0: 	void ConstructL();
sl@0: 	void Cancel();
sl@0: 
sl@0: 	static TInt Callback(TAny* aPtr);
sl@0: 	void AsyncCallbackL();
sl@0:     void RequestCallback();
sl@0: 	
sl@0: 	void CancelRecorders();
sl@0:     void CancelPendingRecorders();
sl@0:     void CancelBusyRecorder();
sl@0: 	void InternalStop();
sl@0: 	void InternalFlush();
sl@0: 	void RecordAllIdle();
sl@0: 	
sl@0: 	void UseBuffer(CRecorder* aRecorder);
sl@0: 	void HandleBufferAck();
sl@0: 	
sl@0: 	void CheckFullInvariant();
sl@0: 	void CheckInvariant(TBool aKnownConstructed=ETrue);
sl@0: 	
sl@0: #ifdef _DEBUG
sl@0:     void CheckActiveRecorders();
sl@0:     void CheckActiveRecorders(TSglQue<CRecorder>& aQueue, TBool aExpected, TInt aPanicCode);
sl@0: #endif
sl@0: 
sl@0: 	static TInt QLength(TSglQue<CRecorder>& aQueue);
sl@0: 	CRecorder* QPop(TSglQue<CRecorder>& aQueue);
sl@0: 	TBool QPop(CRecorder*& aRecorder, TSglQue<CRecorder>& aQueue);
sl@0: 	
sl@0: 	inline TInt BufferLength() const { return iBufferLength; } // TODO required?
sl@0: 		
sl@0: private:
sl@0: 	MAudioInputObserver& iObserver;
sl@0: 	
sl@0: 	enum TState
sl@0: 		{
sl@0: 		EStateCreated2,
sl@0: 		EStateInitialized2,
sl@0: 		EStateRecordWait2,
sl@0: 		EStateRecordWaitAck2,
sl@0: 		};
sl@0: 	
sl@0: 	enum TRunningState // when in RecordWait2 or RecordWaitAck2
sl@0: 	    {
sl@0: 	    ERStateRunning,        // recording
sl@0: 	    ERStatePaused,         // paused state
sl@0: 	    ERStateFinishing,      // look to do InputFinished() on next tick
sl@0: 	    ERStateFinished,       // InputFinished() sent
sl@0: 	    ERStateFailed,         // InputError() sent 
sl@0: 	    };
sl@0: 		
sl@0: 	TState iState;
sl@0: 	TRunningState iRState;
sl@0: 	TRecordSharedChunkBufConfig iRecordBufferConfig;
sl@0: 	RSoundSc iRecordSoundDevice;
sl@0: 	RChunk iChunk;
sl@0: 	CRecorder* iRecorders[KNumRecorders];
sl@0: 	CAsyncCallBack* iAsyncCallBack;
sl@0: 	TInt iBufferLength;	// this is the length of buffers we request
sl@0:     CChannelAndSampleRateConverter* iConverter;
sl@0:     TPtrC8 iBufPtr;     // this is usually the descriptor sent to the observer
sl@0:     RBuf8 iConvBuff;    // extra buffer from when we use a converter
sl@0:     
sl@0:     TSglQue<CRecorder> iIdleQueue;        // just sitting there
sl@0:     TSglQue<CRecorder> iRecordingQueue;   // record operation outstanding
sl@0:     TSglQue<CRecorder> iPendingQueue;     // buffer has been recorded, waiting to be processed
sl@0:     TSglQue<CRecorder> iBusyQueue;        // mid InputAvailable()/BufferAck() cycle. Length <= 1
sl@0: 	};
sl@0: 
sl@0: inline TBool CAudioInput::QPop(CRecorder*& aRecorder, TSglQue<CRecorder>& aQueue)
sl@0: // overload of QPop(), since "while (recorder = QPop(...))" etc gives warnings
sl@0: // This allows "while (QPop(recorder, ...))" instead
sl@0: 	{
sl@0: 	CRecorder* recorder = QPop(aQueue);
sl@0: 	if (recorder)
sl@0: 		{
sl@0: 		aRecorder = recorder;
sl@0: 		return ETrue;
sl@0: 		}
sl@0: 	return EFalse;
sl@0: 	}
sl@0: 
sl@0: #endif // SWAUDIOINPUTPRIV_H
sl@0: