// 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;
	}