/*

* 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 the License "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 "cafpanic.h"

#include "contentIterator.h"

#include "FileContentIterator.h"

#include "contentiteratordata.h"

using ContentAccess::CContentIterator;

using ContentAccess::TVirtualPathPtr;

_LIT(KIteratorThread,"ContentIterator");

EXPORT_C CContentIterator* CContentIterator::NewL(const TDesC& aPath, TBool aRecursive, const TDesC8& aMimeType) 

	{  

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

	CleanupStack::PushL(self);

	self->ConstructL(aPath, aRecursive, aMimeType);

	CleanupStack::Pop();

	return self;

	}

CContentIterator::CContentIterator() : CActive(EPriorityStandard)

	{

	}

CContentIterator::~CContentIterator()

	{

	// tell thread to cancel and shutdown

	Cancel();

	// close thread handle

	iWorkerThread.Close();

	delete info; 

	}

void CContentIterator::ConstructL(const TDesC& aPath, TBool aRecursive, const TDesC8& aMimeType)

	{	

	// This data buffer will be shared between the client and the worker thread

	info = CContentIteratorData::NewL(aPath,aRecursive,aMimeType);

	// create the thread, need a big heap and stack for recursively searching through directories

	User::LeaveIfError(iWorkerThread.Create(KIteratorThread(),CContentIterator::ThreadEntry,32768, KMinHeapSize, 131072, (void *) info , EOwnerProcess));

	// add ourselves to active scheduler

	CActiveScheduler::Add(this);

	// Set up notification in case the thread panics etc

	iStatus = KRequestPending;

	iWorkerThread.Logon(iStatus);

	SetActive();

	// start the thread

	iWorkerThread.Resume();

	}

void CContentIterator::DoCancel()

	{

	// Wait until thread finishes whatever it's doing

	info->Lock();

	// Signal for the thread to close

	info->RunThreadFunction(EIteratorShutdownThread);

	}

void CContentIterator::RunL()

	{

	// Thread must have completed

	if(iWorkerThread.ExitType() == EExitPanic)

		{

		// Thread panicd, better panic our thread

		User::Panic(KCafPanicString, ECafPanicContentIteratorThreadPanic);

		}

	}

EXPORT_C TVirtualPathPtr CContentIterator::VirtualPath()

	{

	// Wait until thread finishes whatever it's doing

	info->Lock(); 

	iFileName.Copy(info->Path());	

	iUniqueId.Copy(info->UniqueId());	

	info->Unlock(); 

	return TVirtualPathPtr(iFileName, iUniqueId);

	}

EXPORT_C const TDesC&  CContentIterator::Name()

	{

	// Wait until thread finishes whatever it's doing

	info->Lock(); 

	iName.Copy(info->Name());	

	info->Unlock(); 

	return iName;

	}

EXPORT_C const TDesC8& CContentIterator::MimeType()

	{

	// Wait until thread finishes whatever it's doing

	info->Lock(); 

	iMimeType.Copy(info->MimeType());

	info->Unlock(); 

	return iMimeType;

	}

EXPORT_C void CContentIterator::Next(TRequestStatus &aStatus)

	{

	// Wait until thread finishes whatever it's doing

	info->Lock(); 

	// Remember which thread and TRequestStatus to notify

	TThreadId id = RThread().Id();

	info->SetClientRequest(id, aStatus);

	// Tell it to find the next iteration

	info->RunThreadFunction(EIteratorFindNextContentObject); 

	}

TInt CContentIterator::ThreadEntry(TAny* aAny) 

	{

	TBool exitNow = EFalse;

	TInt err;

	CFileContentIterator* iterator = NULL;

	RThread clientThread;

	CContentIteratorData* info = reinterpret_cast <CContentIteratorData *> (aAny);

	// create a trap handler

	CTrapCleanup* cleanup = CTrapCleanup::New();

	while(!exitNow)

		{

		// Thread will wait here until signaled by other CContentIterator functions

		switch(info->ThreadWait())

			{

		// Client thread has asked us to shutdown, exit loop

		case EIteratorShutdownThread:

			exitNow = ETrue;

			break;

		// Client thread is asking us to find the next object	

		case EIteratorFindNextContentObject:

			if(!iterator)

				{

				TRAP(err, iterator = CFileContentIterator::NewL(info->Path(), info->IsRecursive(), info->MimeType()));

				info->SetData(KNullDesC(), KNullDesC(), KNullDesC(), KNullDesC8());

				}

			else

				{

				err = iterator->Next();

				}

			if(err == KErrNone)

				{

				// If a content object was found, write the value back 

				// into the other thread while the info is still locked

				info->SetData(iterator->FileName(),iterator->UniqueId(), iterator->Name(), iterator->MimeType());

				}

			// Complete the clients asynchronous request

			info->CompleteClientRequest(err);

			break;

		default:

			User::Panic(KCafPanicString, ECafPanicContentIteratorUnknownRequest);

			break;

			};

		// Allow the client to post a new request

		info->Unlock(); 

		}

	delete iterator;

	delete cleanup;

	return KErrNone;

	}