/*
* Copyright (c) 2004-2007 Nokia Corporation and/or its subsidiary(-ies).
* All rights reserved.
* This component and the accompanying materials are made available
* under the terms of "Eclipse Public License v1.0"
* which accompanies this distribution, and is available
* at the URL "http://www.eclipse.org/legal/epl-v10.html".
*
* Initial Contributors:
* Nokia Corporation - initial contribution.
*
* Contributors:
*
* Description: Downlink (playback) datapath
*
*/
// INCLUDE FILES
#include <mmf/common/mmfcontroller.h>
#include "mccdldatapath.h"
#include "mccsubcontrollerlogs.h"
// EXTERNAL DATA STRUCTURES
// EXTERNAL FUNCTION PROTOTYPES
// CONSTANTS
// MACROS
// LOCAL CONSTANTS AND MACROS
// MODULE DATA STRUCTURES
// LOCAL FUNCTION PROTOTYPES
// FORWARD DECLARATIONS
// ============================= LOCAL FUNCTIONS ===============================
// ============================ MEMBER FUNCTIONS ===============================
// -----------------------------------------------------------------------------
// CMccDlDataPath::CMccDlDataPath
// C++ default constructor can NOT contain any code, that
// might leave.
// -----------------------------------------------------------------------------
CMccDlDataPath::CMccDlDataPath(
MAsyncEventHandler* aEventHandler,
MMccResources* aMccResources,
TMediaId aMediaId ) :
CMccDataPathBase( aEventHandler, aMccResources, aMediaId )
{
}
// -----------------------------------------------------------------------------
// CMccDlDataPath::ConstructL
// Symbian 2nd phase constructor can leave.
// -----------------------------------------------------------------------------
void CMccDlDataPath::ConstructL()
{
__SUBCONTROLLER( "CMccDlDataPath::ConstructL" )
__ASSERT_ALWAYS( iEventHandler, User::Leave( KErrArgument ) );
__ASSERT_ALWAYS( iMccResources, User::Leave( KErrArgument ) );
__SUBCONTROLLER( "CMccDlDataPath::ConstructL, exit" )
}
// -----------------------------------------------------------------------------
// CMccDlDataPath::NewL
// Static constructor.
// -----------------------------------------------------------------------------
CMccDlDataPath* CMccDlDataPath::NewL(
MAsyncEventHandler* aEventHandler,
MMccResources* aMccResources,
TMediaId aMediaId )
{
__ASSERT_ALWAYS ( aEventHandler, User::Leave(KErrArgument) );
CMccDlDataPath* self = new ( ELeave ) CMccDlDataPath( aEventHandler,
aMccResources,
aMediaId );
CleanupStack::PushL( self );
self->ConstructL();
CleanupStack::Pop( self );
return self;
}
// -----------------------------------------------------------------------------
// CMccDlDataPath::~CMccDlDataPath
// Destructor
// -----------------------------------------------------------------------------
CMccDlDataPath::~CMccDlDataPath()
{
__SUBCONTROLLER( "CMccDlDataPath::~CMccDlDataPath" )
__SUBCONTROLLER( "CMccDlDataPath::~CMccDlDataPath, exit" )
}
// -----------------------------------------------------------------------------
// CMccDlDataPath::PrimeL
// Primes the datapath
// -----------------------------------------------------------------------------
void CMccDlDataPath::PrimeL( TUint32 aEndpointId )
{
__SUBCONTROLLER( "CMccDlDataPath::PrimeL" )
__ASSERT_ALWAYS( iDataPathCreated, User::Leave( KErrNotReady ) );
__ASSERT_ALWAYS( iDataSource, User::Leave( KErrGeneral ) );
__ASSERT_ALWAYS( iDataSink, User::Leave( KErrGeneral ) );
if ( !iSourceBuffer )
{
TBool bufferReference;
iSourceBuffer =
iDataSource->CreateSourceBufferL( iMediaId, bufferReference );
__ASSERT_ALWAYS( iSourceBuffer, User::Leave( KErrGeneral ) );
__ASSERT_ALWAYS( bufferReference, User::Leave( KErrGeneral ) );
}
if ( ControlSource( aEndpointId ) )
{
__SUBCONTROLLER( "CMccDlDataPath::PrimeL, control source" )
SetStateL( EPrimed );
iDataSource->NegotiateSourceL( *iDataSink );
iDataSource->SourcePrimeL();
}
if ( ControlSink( aEndpointId ) )
{
__SUBCONTROLLER( "CMccDlDataPath::PrimeL, control sink" )
iDataSink->SinkPrimeL();
}
CreateCompleteCallBackL();
__SUBCONTROLLER( "CMccDlDataPath::PrimeL, exit" )
}
// -----------------------------------------------------------------------------
// CMccDlDataPath::PauseL
// Pauses the downlink streaming
// -----------------------------------------------------------------------------
void CMccDlDataPath::PauseL( TUint32 aEndpointId )
{
__SUBCONTROLLER( "CMccDlDataPath::PauseL" )
__ASSERT_ALWAYS( iDataPathCreated, User::Leave( KErrNotReady ) );
__ASSERT_ALWAYS( iDataSource, User::Leave( KErrGeneral ) );
__ASSERT_ALWAYS( iDataSink, User::Leave( KErrGeneral ) );
if ( ControlSource( aEndpointId ) )
{
__SUBCONTROLLER( "CMccDlDataPath::PauseL, control source" )
SetStateL( EPaused );
iDataSource->SourcePauseL();
}
if ( ControlSink( aEndpointId ) )
{
__SUBCONTROLLER( "CMccDlDataPath::PauseL, control sink" )
if ( IsMmfEndpoint( iAssociatedSink ) )
{
__SUBCONTROLLER( "CMccDlDataPath::PauseL, stop mmf sink" )
// Resource has to be freed
iDataSink->SinkStopL();
}
else
{
iDataSink->SinkPauseL();
}
}
if ( State() == EPaused )
{
iSourceBuffer = NULL;
// Cancel the whole path
Cancel();
ChangeDataPathTransferState( ECanceled );
}
__SUBCONTROLLER( "CMccDlDataPath::PauseL, exit" )
}
// -----------------------------------------------------------------------------
// CMccDlDataPath::PlayL
// Starts the downlink playing
// -----------------------------------------------------------------------------
void CMccDlDataPath::PlayL( TUint32 aEndpointId )
{
__SUBCONTROLLER( "CMccDlDataPath::PlayL" )
__ASSERT_ALWAYS( iDataPathCreated, User::Leave( KErrNotReady ) );
__ASSERT_ALWAYS( iDataSource, User::Leave( KErrGeneral ) );
__ASSERT_ALWAYS( iDataSink, User::Leave( KErrGeneral ) );
__ASSERT_ALWAYS( iSourceBuffer, User::Leave( KErrGeneral ) );
iDataPathCompletedErrorCode = KErrNone;
if ( ControlSource( aEndpointId ) )
{
__SUBCONTROLLER( "CMccDlDataPath::PlayL, control source" )
SetStateL( EStreaming );
iDataSource->SourcePlayL();
}
if ( ControlSink( aEndpointId ) )
{
__SUBCONTROLLER( "CMccDlDataPath::PlayL, control sink" )
iDataSink->SinkPlayL();
}
if ( State() == EStreaming && ChangeDataPathTransferState( ENeedSourceData ) )
{
ActivateSourceBuffer();
}
__SUBCONTROLLER( "CMccDlDataPath::PlayL, exit" )
}
// -----------------------------------------------------------------------------
// CMccDlDataPath::BufferEmptiedL
// From MDataSource
// -----------------------------------------------------------------------------
void CMccDlDataPath::BufferEmptiedL( CMMFBuffer* aBuffer )
{
// This is the buffer returned by DevSound when it has emptied it
// Check the buffer that it is not NULL and it is supported.
IsBufferSupportedL( aBuffer );
if( EStreaming == State() )
{
__ASSERT_ALWAYS( aBuffer == iSourceBuffer, User::Leave( KErrArgument ) );
iSourceBuffer->SetStatus( EAvailable );
ChangeDataPathTransferState( ENeedSourceData );
}
else
{
// We're not streaming currently, can leave
User::Leave( KErrNotReady );
}
}
// -----------------------------------------------------------------------------
// CMccDlDataPath::BufferFilledL
// From MDataSink
// -----------------------------------------------------------------------------
void CMccDlDataPath::BufferFilledL( CMMFBuffer* aBuffer )
{
if( EStreaming == State() )
{
// There is a leave if aBuffer is NULL
// the ownership of the aBuffer is in source, so source
// must not give a NULL aBuffer
IsBufferSupportedL( aBuffer );
if ( !aBuffer->BufferSize() /*|| aBuffer->LastBuffer()*/ )
{
__ASSERT_ALWAYS( iSourceBuffer, User::Leave( KErrArgument ) );
// Just in-case we are terminating on BufferSize == 0 or play window
iSourceBuffer->SetStatus( EAvailable );
ChangeDataPathTransferState( ENeedSourceData, ETrue );
}
else
{
if( iSourceBuffer != aBuffer )
{
// Buffer has been changed by the source
iSourceBuffer = aBuffer;
}
ChangeDataPathTransferState( ESendDataToSink );
}
}
else
{
// We're not streaming so we can leave
User::Leave( KErrNotReady );
}
}
// -----------------------------------------------------------------------------
// CMccDlDataPath::FillSourceBufferL
// Fill the source buffer
// -----------------------------------------------------------------------------
void CMccDlDataPath::FillSourceBufferL()
{
__ASSERT_ALWAYS( iSourceBuffer, User::Leave( KErrNotReady ) );
iSourceBuffer->SetStatus( EBeingFilled );
iSourceBuffer->SetLastBuffer( EFalse );
ChangeDataPathTransferState( EWaitSource );
iDataSource->FillBufferL( iSourceBuffer, this, iMediaId );
}
// -----------------------------------------------------------------------------
// CMccDlDataPath::EmptySinkBufferL
// Empty the sink buffer
// -----------------------------------------------------------------------------
void CMccDlDataPath::EmptySinkBufferL()
{
__ASSERT_ALWAYS( iSourceBuffer, User::Leave( KErrNotReady ) );
ChangeDataPathTransferState( EWaitSink );
iSourceBuffer->SetStatus( EFull );
TRAPD( error, iDataSink->EmptyBufferL( iSourceBuffer, this, iMediaId ) );
if ( KErrEof == error || KErrOverflow == error || KErrUnderflow == error )
{
iDataPathCompletedErrorCode = error;
ChangeDataPathTransferState( EEndOfData );
}
else
{
User::LeaveIfError( error );
}
}
// -----------------------------------------------------------------------------
// CMccDlDataPath::DoEndOfDataL
// Worker function for data ending
// -----------------------------------------------------------------------------
void CMccDlDataPath::DoEndOfDataL()
{
if ( KUidMmfAudioOutput != iDataSink->DataSinkType() )
{
if ( KErrNone == iDataPathCompletedErrorCode )
{
iDataPathCompletedErrorCode = KErrCompletion;
}
}
SignalDataPathCompleteL(iDataPathCompletedErrorCode);
SetStateL( EStopped );
}
// -----------------------------------------------------------------------------
// CMccDlDataPath::Stop
// Stop the datapath
// -----------------------------------------------------------------------------
void CMccDlDataPath::StopL( TUint32 aEndpointId )
{
__SUBCONTROLLER( "CMccDlDataPath::StopL" )
__ASSERT_ALWAYS( iDataPathCreated, User::Leave( KErrNotReady ) );
iDataPathCompletedErrorCode = KErrNone;
if ( ControlSource( aEndpointId ) )
{
__SUBCONTROLLER( "CMccDlDataPath::StopL, control source" )
SetStateL( EStopped );
iDataSource->SourceStopL();
}
if ( ControlSink( aEndpointId ) )
{
__SUBCONTROLLER( "CMccDlDataPath::StopL, control sink" )
iDataSink->SinkStopL();
}
if ( State() == EStopped )
{
iSourceBuffer = NULL;
// Stop the whole path
Cancel();
ChangeDataPathTransferState( ECanceled );
}
__SUBCONTROLLER( "CMccDlDataPath::StopL, exit" )
}
// -----------------------------------------------------------------------------
// CMccDlDataPath::NegotiateL
// Negotiate the source and sink
// -----------------------------------------------------------------------------
void CMccDlDataPath::NegotiateL( MDataSource& aDataSource )
{
__SUBCONTROLLER( "CMccDlDataPath::NegotiateL" )
__ASSERT_ALWAYS( iDataSink, User::Leave( KErrNotReady ) );
__ASSERT_ALWAYS( &aDataSource, User::Leave( KErrArgument ) );
// NegotiateSourceL will do a re-entry so we need to have iDataSource set
// for that call to succeed.
iDataSource = &aDataSource;
iDataSource->NegotiateSourceL( *iDataSink );
iDataSource = NULL;
this->AddDataSourceL( &aDataSource );
__SUBCONTROLLER( "CMccDlDataPath::NegotiateL exit" )
}
// -----------------------------------------------------------------------------
// CMccDlDataPath::LoadL
// -----------------------------------------------------------------------------
void CMccDlDataPath::LoadL( MDataSource& aDataSource )
{
__SUBCONTROLLER( "CMccDlDataPath::LoadL" )
__ASSERT_ALWAYS( iDataSink, User::Leave( KErrNotReady ) );
iDataSink->NegotiateL( aDataSource );
__SUBCONTROLLER( "CMccDlDataPath::LoadL exit" )
}
// -----------------------------------------------------------------------------
// CMccDlDataPath::ResumeL
// Resumes pause audio streaming
// -----------------------------------------------------------------------------
void CMccDlDataPath::ResumeL( TUint32 aEndpointId )
{
__SUBCONTROLLER( "CMccDlDataPath::ResumeL" )
__ASSERT_ALWAYS( iDataPathCreated, User::Leave( KErrNotReady ) );
iDataPathCompletedErrorCode = KErrNone;
if ( ControlSource( aEndpointId ) )
{
__SUBCONTROLLER( "CMccDlDataPath::ResumeL, control source" )
SetStateL( EStreaming );
iDataSource->SourcePlayL();
}
if ( ControlSink( aEndpointId ) )
{
__SUBCONTROLLER( "CMccDlDataPath::ResumeL, control sink" )
if ( IsMmfEndpoint( iAssociatedSink ) )
{
__SUBCONTROLLER( "CMccDlDataPath::ResumeL, prime mmf sink" )
// Resource was freed at pause, initialize it again
iDataSink->SinkPrimeL();
}
iDataSink->SinkPlayL();
}
if ( State() == EStreaming && ChangeDataPathTransferState( ENeedSourceData ) )
{
iSourceBuffer = NULL;
TBool bufferReference;
iSourceBuffer =
iDataSource->CreateSourceBufferL( iMediaId, bufferReference );
__ASSERT_ALWAYS( iSourceBuffer, User::Leave( KErrGeneral ) );
__ASSERT_ALWAYS( bufferReference, User::Leave( KErrGeneral ) );
ActivateSourceBuffer();
}
__SUBCONTROLLER( "CMccDlDataPath::ResumeL, exit" )
}
// -----------------------------------------------------------------------------
// CMccDlDataPath::ActivateSourceBuffer
// Sets source buffer available
// -----------------------------------------------------------------------------
void CMccDlDataPath::ActivateSourceBuffer()
{
if ( iSourceBuffer )
{
iSourceBuffer->SetStatus( EAvailable );
}
}
// ========================== OTHER EXPORTED FUNCTIONS =========================
// End of File