/*

 * Copyright (c) 2009 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: Handles new position timer implementation 

 *

 */

#include "prefetchlevelupdatetimer.h"

#include <mdaaudiosampleplayer.h>

#include <mdaaudiosampleplayer.h>

#include <videoplayer2.h>

#include <e32math.h>

extern "C"

{

	#include "xaadaptationmmf.h"

}

#define RET_ERR_IF_ERR(s) if (s!=KErrNone) return s;

#define RET_IF_ERR(s) if (s!=KErrNone) return;

CPrefetchLevelUpdateTimer::CPrefetchLevelUpdateTimer(	CMdaAudioPlayerUtility* aAudioPlayer,

        												CVideoPlayerUtility2* aVideoPlayer) :

				    										CActive(CActive::EPriorityStandard), 

															iAudioPlayer(aAudioPlayer),

															iVideoPlayer(aVideoPlayer),

															iNotifyIncrement(10),

															iLastIncrement(0)

{

	CActiveScheduler::Add(this);

}

CPrefetchLevelUpdateTimer::~CPrefetchLevelUpdateTimer()

{

	Cancel();

    iTimer.Close();

}

CPrefetchLevelUpdateTimer* CPrefetchLevelUpdateTimer::NewL(	CMdaAudioPlayerUtility* aAudioPlayer,

        														CVideoPlayerUtility2* aVideoPlayer)

{

	CPrefetchLevelUpdateTimer* self = new (ELeave) CPrefetchLevelUpdateTimer(aAudioPlayer,aVideoPlayer);

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    return self;

}

void CPrefetchLevelUpdateTimer::ConstructL()

{

	User::LeaveIfError(iTimer.CreateLocal());

}

void CPrefetchLevelUpdateTimer::SetContext(TAny* aCtx)

{

	iCtx = aCtx;

}

void CPrefetchLevelUpdateTimer::SetCallbackEventMask(XAuint32 aMask)

{

	iCallbackEventMask = aMask;

}

void CPrefetchLevelUpdateTimer::SetPrefetchLevelUpdatePeriod(XAmillisecond aPos)

{

    iUpdatePeriod = TTimeIntervalMicroSeconds32(aPos * 1000);

}

void CPrefetchLevelUpdateTimer::SetUpdateIncrement(XApermille inc)

{

	if(0<=inc && inc<=1000)

	{

		iNotifyIncrement = inc / 10;

	}

}

void CPrefetchLevelUpdateTimer::UseAudioPlayer()

{

	iPlayerToUse = static_cast<CBase*> (iAudioPlayer);

}

void CPrefetchLevelUpdateTimer::UseVideoPlayer()

{

	iPlayerToUse = static_cast<CBase*> (iVideoPlayer);

}

void CPrefetchLevelUpdateTimer::ResetPlayer()

{

    iPlayerToUse = NULL;

}

void CPrefetchLevelUpdateTimer::Start()

{

    if (IsActive())

    {

	    Cancel();

	}

	SendFillLevelChangeEvent(); //send a fill level change event (0%) right away 

	iLastIncrement = 0;

	iStatus = KRequestPending;

	iTimer.After(iStatus, iUpdatePeriod);

	SetActive();

}

void CPrefetchLevelUpdateTimer::Stop()

{

    if (IsActive())

    {

		SendFillLevelChangeEvent(); //send a fill level change event (100%)

	}

	Cancel();

	iLastIncrement = 0;

}

void CPrefetchLevelUpdateTimer::RunL()

{

    if ((iStatus == KErrNone) && iPlayerToUse)

	{

		TInt progress = 0;

		if(GetLoadingProgress(progress) == KErrNone)

		{

			if(progress==100)

			{

				Stop();

			}

			else if(progress >= (iLastIncrement + iNotifyIncrement))

			{

				SendFillLevelChangeEvent();

				iLastIncrement = progress - (progress % iNotifyIncrement);

			}

		}

	}

	iStatus = KRequestPending;

    iTimer.After(iStatus, iUpdatePeriod);

    SetActive();

}

void CPrefetchLevelUpdateTimer::DoCancel()

{

    iTimer.Cancel();

}

TInt CPrefetchLevelUpdateTimer::RunError(TInt aError)

{

    return aError;

}

TInt CPrefetchLevelUpdateTimer::GetLoadingProgress(TInt& progress)

{

    TInt err(KErrNone);

    if (iPlayerToUse && (iPlayerToUse == iAudioPlayer))

    {

		//TRAP(err, iAudioPlayer->GetAudioLoadingProgressL(progress));

        //always retrun 100 for audio

        progress = 100;

    }

    else if (iPlayerToUse && (iPlayerToUse == iVideoPlayer))

    {

        TRAP(err, iVideoPlayer->GetVideoLoadingProgressL(progress));

    }

    else

	{

		err = KErrNotFound;

    }

    return err;

}

void CPrefetchLevelUpdateTimer::SendFillLevelChangeEvent()

{

	if(iCallbackEventMask & XA_PREFETCHEVENT_FILLLEVELCHANGE)

	{		

		//use callback to send progress

		XAAdaptEvent xaevent =

		{

			XA_PREFETCHITFEVENTS, XA_PREFETCHEVENT_FILLLEVELCHANGE, 0, 0

		};

		XAAdaptationBase_SendAdaptEvents((XAAdaptationBaseCtx*) iCtx, &xaevent);

	}

}