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

//

// System includes

#include <logwrap.h>

// User includes

#include "SCHLOG.h"

//Constants

const TInt KLogEventQueueGranularity = 3;

CSchLogManager::CSchLogManager()

:	CActive(EPriorityLow)

	{

	CActiveScheduler::Add(this);

	}

CSchLogManager::~CSchLogManager()

	{

	Cancel();

  	if(iPendingLogEvents)

  		{

  		iPendingLogEvents->ResetAndDestroy();

  		delete iPendingLogEvents;

  		}

	delete iLogEvent;

	if(iLogWrapper)

 		delete iLogWrapper;

	}

void CSchLogManager::ConstructL(RFs& aFileSession)

	{

	iFileSession = &aFileSession;

	iLogWrapper = NULL;

	iLogEvent = CLogEvent::NewL();

	iLogEvent->SetEventType(KLogTaskSchedulerEventTypeUid);

	iPendingLogEvents = new(ELeave) CArrayPtrFlat<CLogEvent>(KLogEventQueueGranularity);

	}

CSchLogManager* CSchLogManager::NewL(RFs& aFileSession)

	{

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

	CleanupStack::PushL(self);

	self->ConstructL(aFileSession);

	CleanupStack::Pop(self);

	return self;

	}

/*

Creates a new log engine entry of type KLogTaskSchedulerEventTypeUid

with aError as its entry.

*/

void CSchLogManager::LogError(TInt aError)

	{

	// Add error code as a descriptor

	TBuf<10> errorCodeAsDescriptor;

	errorCodeAsDescriptor.Num(aError);

	iLogEvent->SetNumber(errorCodeAsDescriptor);

	// Add to log or queue

  	if (!IsActive())

    	{

		iStatus=KRequestPending;

		TRAPD(error, GetLogWrapperL()->Log().AddEvent(*iLogEvent, iStatus));

		if (error != KErrNone)

			return; 

		SetActive();

		}

	else

		{

		// add the request to the queue, it will be processed asap

		CLogEvent* event = 0;

		TRAPD(error, event = CLogEvent::NewL());

		if (KErrNone != error)

			{

			return; // event is discarded!

			}

		//coverity[cleanup_stack]

		/* NewL() and AppendL() are enclosed in TRAP and handled. 

		* So no need of pushing the variable event onto the cleanup stack

		*/

		// add to the queue

		TRAP(error, iPendingLogEvents->AppendL(event));

		if (KErrNone != error)

			{

			delete event; // event is discarded!

			return;

			}

		}	

	}

/*

Creates a new log engine entry of type KLogTaskSchedulerEventTypeUid 

and subject aSubject with aError as its entry.

*/

void CSchLogManager::LogError(const TDesC& aSubject, TInt aError)

	{

	//AddSubject

	iLogEvent->SetSubject(aSubject);

	LogError(aError);

	}

void CSchLogManager::RunL()

  	{

    if (iPendingLogEvents->Count()>0)

        {

        CLogEvent* nextEventPtr = iPendingLogEvents->At(0);

        iLogEvent->CopyL(*nextEventPtr);

		iStatus=KRequestPending;

		//If error occur trap it and ignore, so that log manager can continue 

        TRAPD(error, GetLogWrapperL()->Log().AddEvent(*iLogEvent, iStatus));

       	//Following code is only to ignore build warnings        

        if (error == KErrNone)

				error = KErrNone;

        SetActive();

        // delete the ongoing CLogEvent we just copied

        delete nextEventPtr;

        //remove the pointer from the queue

        iPendingLogEvents->Delete(0);

        }

  	}

void CSchLogManager::DoCancel()

  	{

    if(iLogWrapper)

        iLogWrapper->Log().Cancel();

   	}

/*

Creates a new CLogWrapper and initialise iLogWrapper if it doesn't exist otherwise 

return iLogWrapper

*/

CLogWrapper* CSchLogManager::GetLogWrapperL()

	{

	if(iLogWrapper)

		return iLogWrapper;

	iLogWrapper = CLogWrapper::NewL(*iFileSession, CActive::EPriorityStandard);

	return iLogWrapper;

	}