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

 //

 #include "LOGMAIN.H"

 #include "LOGREC.H"

 #include "LOGCOMP.H"

 #include "logservpanic.h"

 #include "LOGQUERY.H"

 #include "LogServDatabaseTransactionInterface.h"

 #include "LogServCacheConfig.h"

 #include "LogCliServShared.h"

 #include "LogServDatabaseChangeInterface.h"

 #include "LogServSqlStrings.h"

 CLogMaintenance::CLogMaintenance(MLogServDatabaseTransactionInterface& aDatabase, TInt aPriority)

 : CLogActive(aPriority), iDatabase(aDatabase)

 	{

 	}

 CLogMaintenance::~CLogMaintenance()

 	{

 	Cancel();

 	delete iRecover;

 	delete iCompact;

 	}

 void CLogMaintenance::ConstructL()

 	{

 	iRecover = new(ELeave)CLogRecover(iDatabase, Priority());

 	iCompact = new(ELeave)CLogCompact(iDatabase, Priority());

 	}

 CLogMaintenance* CLogMaintenance::NewL(MLogServDatabaseTransactionInterface& aDatabase, TInt aPriority)

 	{

 	CLogMaintenance* self = new(ELeave)CLogMaintenance(aDatabase, aPriority);

 	CleanupStack::PushL(self);

 	self->ConstructL();

 	CleanupStack::Pop();

 	return self;

 	}

 void CLogMaintenance::Start(TBool aPurge, TRequestStatus& aStatus)

 	{

 	iState = ELogRecover;

 	iPurge = aPurge;

 	Queue(aStatus);

 	TRequestStatus* status = &iStatus;

 	User::RequestComplete(status, KErrNone);

 	SetActive();

 	}

 TBool CLogMaintenance::DoNextL()

 	{

 	switch(iState)

 		{

 		// Recover the database

 		case ELogRecover:

 			if (iRecover->Start(iStatus))

 				{

 				iState = ELogGetConfig;

 				return ETrue;

 				}

 			// Fall Through

 		// Get the log configuration

 		case ELogGetConfig:

 			if (iPurge)

 				{

 				iConfig = iDatabase.DTICacheConfig().Config();				

 				TRequestStatus* status = &iStatus;

 				User::RequestComplete(status, KErrNone);

 				iState = iConfig.iMaxEventAge == 0 ? ELogCompact : ELogPurgeMainAge;

 				return ETrue;

 				}

 			// Fall through

 		// Purge old events from the log

 		case ELogPurgeMainAge:

 			if (iPurge)

 				{

 				// Get the max age

 				TTime date;

 				date.UniversalTime();

 				date -= TTimeIntervalSeconds(iConfig.iMaxEventAge);

 				ClearLogL(date, iStatus);

 				iState = ELogCompact;

 				return ETrue;

 				}

 		// Compact the database

 		case ELogCompact:

 			iCompact->Start(iStatus);

 			iState = ELogComplete;

 			return ETrue;

 		case ELogComplete:

 			break;

 		default:

 			__ASSERT_DEBUG(EFalse, Panic(ELogNoSuchState7));

 		};

 	return EFalse;

 	}

 void CLogMaintenance::DoRunL()

 	{

 	if (DoNextL())

 		SetActive();

 	}

 void CLogMaintenance::DoCancel()

 	{

 	iRecover->Cancel();

 	iCompact->Cancel();

 	CLogActive::DoCancel();

 	}

 void CLogMaintenance::DoComplete(TInt& aStatus)

 	{

 	// Ignore all errors

 	aStatus = KErrNone;

 	}

 // aDate is expected to be UTC  

 void CLogMaintenance::ClearLogL(const TTime& aDate, TRequestStatus& aStatus)

 	{

 	TBuf<KLogMaxDateLength> date;

 	aDate.FormatL(date, LogUtils::DateFormatForLocale());

     // Get list of events to purge

     TheSql.Format(KLogSqlSelectOldestString, &date);

     RLogDbView view;

     view.PrepareLC(iDatabase.DTIDatabase(), TheSql);

 	if(view.FirstL())

 		{

         static TDbColNo idColNo = 0;

         if(idColNo == 0)

             {

             CDbColSet* cs = view.ColSetL();

             idColNo = cs->ColNo(KLogFieldIdString);

             delete cs;

             }

         iDatabase.DTIBeginWithRollBackProtectionLC();

 		do

 			{

 			view.GetL();

 			const TLogId id = view.ColInt32(idColNo);

 			view.DeleteL();

 			iDatabase.DTIChangeInterface().DCISubmitChangedEventContextL(ELogChangeTypeEventDeleted, id);

 			}

 		while(view.NextL());

 		// Commit changes

 		iDatabase.DTICommitAndCancelRollbackProtectionL();

 		}

 	CleanupStack::PopAndDestroy(&view);

 	// Complete the request

 	TRequestStatus* status = &aStatus;

 	User::RequestComplete(status, KErrNone);

 	}