/*

* Copyright (c) 2005 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:    

*

*/

#include "mcemessagesink.h"

#include "mcecommessagesink.h"

#include "mcesession.h"

#include "mceclilogs.h"

#include "mcemediastream.h"

#include "mcemanager.h"

#include "mceclilogs.h"

#include "mcedatareceiver.h"

#include "mcedatasinkobserver.h"

#define _FLAT_DATA static_cast<CMceComMessageSink*>( iFlatData )

#define FLAT_DATA( data ) _FLAT_DATA->data

// ============================ MEMBER FUNCTIONS ===============================

// -----------------------------------------------------------------------------

// CMceMessageSink::NewL

// -----------------------------------------------------------------------------

//

EXPORT_C CMceMessageSink* CMceMessageSink::NewL( CMceManager& aManager )

    {

    MCECLI_DEBUG("CMceMessageSink::NewL, Entry");

    CMceMessageSink* self = CMceMessageSink::NewLC( aManager );

    CleanupStack::Pop( self );

    return self;

    }

// -----------------------------------------------------------------------------

// CMceMessageSinke::NewLC

// -----------------------------------------------------------------------------

//

EXPORT_C CMceMessageSink* CMceMessageSink::NewLC( CMceManager& aManager )

    {

    MCECLI_DEBUG("CMceMessageSink::NewLC, Entry");

    CMceMessageSink* self = new (ELeave) CMceMessageSink();

    CleanupStack::PushL( self );

    self->ConstructL( &aManager );

    return self;

    }

// -----------------------------------------------------------------------------

// CMceMessageSink::~CMceMessageSink

// -----------------------------------------------------------------------------

//

EXPORT_C CMceMessageSink::~CMceMessageSink()

    {

    MCECLI_DEBUG("CMceMessageSink::~CMceMessageSink, Entry");

    delete iReceiver;

    }

// -----------------------------------------------------------------------------

// 

// -----------------------------------------------------------------------------

//

EXPORT_C void CMceMessageSink::EnableL()

    {

    MCECLI_DEBUG("CMceMessageSink::EnableL, Entry");

    iReceiver = CMceDataReceiver::NewL( *this );    

    CMceMediaSink::DoEnableL();

    MCECLI_DEBUG("CMceMessageSink::EnableL, Exit");

    }

// -----------------------------------------------------------------------------

// 

// -----------------------------------------------------------------------------

//

EXPORT_C void CMceMessageSink::DisableL()

    {

    MCECLI_DEBUG("CMceMessageSink::DisableL, Entry");

    delete iReceiver;

    iReceiver = 0;

    CMceMediaSink::DoDisableL();

    MCECLI_DEBUG("CMceMessageSink::DisableL, Exit");

    }

// -----------------------------------------------------------------------------

// Factory method for inner usage

// -----------------------------------------------------------------------------

//

CMceMessageSink* CMceMessageSink::NewL()

    {

    MCECLI_DEBUG("CMceMessageSink::NewL, Entry");

    CMceMessageSink* self = CMceMessageSink::NewLC();

    CleanupStack::Pop( self );

    return self;

    }

// -----------------------------------------------------------------------------

// Factory method for inner usage

// -----------------------------------------------------------------------------

//

CMceMessageSink* CMceMessageSink::NewLC()

    {

    MCECLI_DEBUG("CMceMessageSink::NewLC, Entry");

    CMceMessageSink* self = new (ELeave) CMceMessageSink();

    CleanupStack::PushL( self );

    self->ConstructL( NULL );

    return self;

    }

// -----------------------------------------------------------------------------

// 

// -----------------------------------------------------------------------------

//

void CMceMessageSink::DataReceived( CMceMediaStream& /*aStream*/, CMceMediaSink& /*aSink*/,

    const TDesC8& aData )

    {

    MCECLI_DEBUG("CMceMessageSink::DataReceived, Entry");

    MMceDataSinkObserver* observer =

        iStream->Session()->Manager().DataSinkObserver();

    observer->DataReceived( *iStream, *this, aData );

    }

// -----------------------------------------------------------------------------

// CMceMessageSink::CMceMessageSink

// -----------------------------------------------------------------------------

//

CMceMessageSink::CMceMessageSink()

	: CMceMediaSink()

    { 

    }

// -----------------------------------------------------------------------------

// CMceMessageSink::ConstructL

// -----------------------------------------------------------------------------

//

void CMceMessageSink::ConstructL( CMceManager* /*aManager*/ )

    {    

    MCECLI_DEBUG("CMceMessageSink::ConstructL, Entry");

	CMceComMessageSink *sink = CMceComMessageSink::NewLC();

	CMceMediaSink::ConstructL( sink );

	CleanupStack::Pop(sink);

	//iReceiver = CMceDataReceiver::NewL( *this, iIsexits );

    }