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