// Copyright (c) 2007-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:
//

/**
 @file
 @internalComponent
*/

#include "renderertimer.h"
#include "rendererrelay.h"
#include "rendererutil.h"

/** C++ constructor */
CRendererTimer::CRendererTimer(CRendererRelay& aRenderer) 
: CTimer(EPriorityHigh), iRenderer(aRenderer)
	{
	CActiveScheduler::Add(this);
	}

/** Two-phased constructor. */
CRendererTimer* CRendererTimer::NewL(CRendererRelay& aRenderer)
	{
	CRendererTimer* self = new (ELeave) CRendererTimer(aRenderer);
	CleanupStack::PushL(self);
	self->ConstructL(); // this call CTimer::ConstructL
	CleanupStack::Pop(self);
	return self;
	}

/** Destructor */
CRendererTimer::~CRendererTimer()
	{
	// cancel is called by CTimer destructor
	}

/** Start the renderer timer */
void CRendererTimer::Start(TTimeIntervalMicroSeconds32 aDelay)
	{
	DEBUGPRINT2(_L("CRendererTimer::Start entered with aDelay=%d"), aDelay.Int());

	__ASSERT_DEBUG(iRenderer.UpdateSubmitted() == EFalse, User::Panic(_L("CRT::Start"), KErrArgument));
	__ASSERT_DEBUG(IsActive() == EFalse, User::Panic(_L("CRT::Start"), KErrCorrupt));

	HighRes(aDelay);
	}

/** Handle completion */
void CRendererTimer::RunL()
	{
	DEBUGPRINT2(_L("CRendererTimer::RunL entered with status=%d"), iStatus.Int());

	if (iStatus == KErrNone)
		{
		iRenderer.RendererTimerExpired();
		}
	}


/** Two-phased constructor. */
CThreadUndertaker* CThreadUndertaker::NewL(RThread& aSubThread)
	{
	CThreadUndertaker* self;
	self = new (ELeave) CThreadUndertaker(aSubThread);
	return self;
	}

/** Constructor for the class. */
CThreadUndertaker::CThreadUndertaker(RThread& aSubThread) 
: CActive(CActive::EPriorityIdle), iSubThread(aSubThread)
	{
	CActiveScheduler::Add(this);

	iStatus = KRequestPending;
	SetActive();

	//Logon to the thread so we will receive signals
	iSubThread.Logon(iStatus);
	}

/** Destructor for this class. */
CThreadUndertaker::~CThreadUndertaker()
	{
	Cancel();
	}

/** This function is triggered when the thread being monitored terminates. */
void CThreadUndertaker::RunL()
	{
	// If the thread being monitored panic, panic this thread.
	TInt reason = iSubThread.ExitReason();
	TExitCategoryName category = iSubThread.ExitCategory();
	User::Panic(category, reason);
	}

/** Stop monitoring the thread for panics. */
void CThreadUndertaker::DoCancel()
	{
	iSubThread.LogonCancel(iStatus);
	}