/*

* Copyright (c) 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:  Audio stream test component

*

*/

#include "MediaEvent.h"

CMediaEvent* CMediaEvent::NewL(CStifLogger *aLogger,

		TTimeIntervalMicroSeconds32 aDelay , TTimeIntervalMicroSeconds32 aInterval,

		MEventTarget *aTarget , CParameters *aParameters , TInt aPriority)

	{

	CMediaEvent *__self = CMediaEvent::NewLC(aLogger ,

										aDelay , aInterval , aTarget,

										aParameters, aPriority);

	CleanupStack::Pop(__self);

	return __self;

	}

CMediaEvent* CMediaEvent::NewLC(CStifLogger *aLogger,

		TTimeIntervalMicroSeconds32 aDelay , TTimeIntervalMicroSeconds32 aInterval,

		MEventTarget *aTarget, CParameters *aParameters , TInt aPriority)

	{

		CMediaEvent *__self = new(ELeave) CMediaEvent(aLogger , aDelay , aInterval , aTarget , aParameters);

		CleanupStack::PushL(__self);

		__self->ConstructL(aPriority);

		return __self;

	}

CMediaEvent::CMediaEvent (CStifLogger *aLogger,

		TTimeIntervalMicroSeconds32 aDelay, TTimeIntervalMicroSeconds32 aInterval,

		MEventTarget *aTarget , CParameters *aParameters)

	: iLogger(aLogger) ,

		iDelay(aDelay) , iInterval(aInterval) , iEventTarget(aTarget),

		iParameters(aParameters) , iCount(0)

	{}

void CMediaEvent::ConstructL(TInt aPriority=CActive::EPriorityStandard)

	{

	iLogger->Log(_L("Creating event with priority (%d)") , aPriority);

	iPeriodic=CPeriodic::NewL(aPriority);

	iPeriodic->Start(iDelay , iInterval , TCallBack(Tick, this));

	}

CMediaEvent::~CMediaEvent ()

	{

	iPeriodic->Cancel();

	delete iPeriodic;

	delete iParameters;

	iParameters=NULL;

	}

TInt CMediaEvent::Tick(TAny *aObject)

	{

	return (static_cast<CMediaEvent*>(aObject) )->DoTick(); // cast, and call non-static function

	}

TInt CMediaEvent::DoTick()

	{

	iCount++;

	if (! iEventTarget->ExecuteL(iParameters)) {

		iPeriodic->Cancel();

	}

	return 0;

	}

TInt CMediaEvent::GetCount() const

	{

	return iCount;

	}

////////////////////////////

CImmediateMediaEvent* CImmediateMediaEvent::NewL(CStifLogger *aLogger ,

											MEventTarget *aTarget , CParameters *aParameters , TInt aPriority)

	{

		CImmediateMediaEvent *__self = CImmediateMediaEvent::NewLC(aLogger, aTarget, aParameters, aPriority);

		CleanupStack::Pop(__self);

		return __self;

	}

CImmediateMediaEvent* CImmediateMediaEvent::NewLC(CStifLogger *aLogger ,

											MEventTarget *aTarget, CParameters *aParameters , TInt aPriority)

	{

		CImmediateMediaEvent *__self = new(ELeave) CImmediateMediaEvent(aLogger , aTarget , aParameters, aPriority);

		CleanupStack::PushL(__self);

		__self->ConstructL();

		return __self;

	}

CImmediateMediaEvent::CImmediateMediaEvent (CStifLogger *aLogger ,

						MEventTarget *aTarget , CParameters *aParameters, TInt aPriority)

					: CActive(aPriority) , iLogger(aLogger) ,

						iEventTarget(aTarget) , iParameters(aParameters) , iEnabled(ETrue)

	{}

void CImmediateMediaEvent::ConstructL(/*TInt aPriority=CActive::EPriorityStandard*/)

	{

	iLogger->Log(_L("Creating event with priority (%d)") , Priority() );

	//iPeriodic=CPeriodic::NewL(aPriority);

	//iPeriodic->Start(iDelay , iInterval , TCallBack(Tick, this));

	CActiveScheduler::Add(this);

	}

CImmediateMediaEvent::~CImmediateMediaEvent ()

	{

	delete iParameters;

	iParameters=NULL;

	Cancel();

	}

void CImmediateMediaEvent::RunL()

	{

	if (iEnabled)

		{

		iEventTarget->ExecuteL(iParameters);

		}

	}

void CImmediateMediaEvent::DoCancel()

	{

	iEnabled = EFalse;

	}

TBool CImmediateMediaEvent::FireExecute()

	{

	//__ASSERT_ALWAYS(!IsActive(), User::Panic(_L("Error with the "), KErrGeneral));

	if ( IsActive() ) return EFalse;

	iEnabled = ETrue;

	TRequestStatus *status = &iStatus;

	SetActive();

	User::RequestComplete( status , KErrNone);

	return ETrue;

	}