/*
* 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 "contentiteratordata.h"

using namespace ContentAccess;

CContentIteratorData* CContentIteratorData::NewL(const TDesC& aSearchPath, TBool aRecursive, const TDesC8& aMimeType)
	{
	CContentIteratorData* self = new (ELeave) CContentIteratorData();
	CleanupStack::PushL(self);
	self->ConstructL(aSearchPath, aRecursive, aMimeType);
	CleanupStack::Pop(self);
	return self;
	}
	
CContentIteratorData::CContentIteratorData()
	{
	}
	
CContentIteratorData::~CContentIteratorData()
	{
	// release semaphore 
	iThreadSemaphore.Signal();
	
	iDataLockSemaphore.Close();
	iThreadSemaphore.Close();
	}

void CContentIteratorData::ConstructL(const TDesC& aSearchPath, TBool aRecursive, const TDesC8& aMimeType)
	{
	// Remember search parameters, the CContentIterator::ThreadEntry() 
	// will ask for these later
	iPath.Copy(aSearchPath);
	iRecursive = aRecursive;
	iMimeType.Copy(aMimeType);
	
	
	// Create semaphores
	User::LeaveIfError(iDataLockSemaphore.CreateLocal(1, EOwnerProcess));	
	User::LeaveIfError(iThreadSemaphore.CreateLocal(1, EOwnerProcess));
	
	// Grab semaphore so CContentIterator::ThreadEntry function can't enter the loop yet
	iThreadSemaphore.Wait();
	}

				
void CContentIteratorData::Lock()
	{
	iDataLockSemaphore.Wait();
	}

void CContentIteratorData::Unlock()
	{
	iDataLockSemaphore.Signal();
	}
		
void CContentIteratorData::CompleteClientRequest(TInt aError)
	{
	RThread clientThread;
	clientThread.Open(iClientThreadId);
	clientThread.RequestComplete(iClientRequest, aError);
	clientThread.Close();
	}
	
	
void CContentIteratorData::SetClientRequest(TThreadId& aClientThreadId, TRequestStatus& aStatus)
	{
	// Remember the thread and TRequestStatus that must be completed later
	iClientThreadId = aClientThreadId;
	iClientRequest = &aStatus;
	}
	
void CContentIteratorData::RunThreadFunction(TFileIteratorOperation aFunction)
	{
	// Unblock the CContentIterator::ThreadEntry() function and allow it to run
	iFunction = aFunction;
	iThreadSemaphore.Signal();
	}

TFileIteratorOperation CContentIteratorData::ThreadWait()
	{
	// Called by CContentIterator::ThreadEntry() to block execution until RunThreadFunction() is called
	iThreadSemaphore.Wait();
	return iFunction;
	}

		
void CContentIteratorData::SetData(const TDesC& aPath, const TDesC& aUniqueId, const TDesC& aName, const TDesC8& aMimeType)
	{
	// Set the results found in the search
	iPath.Copy(aPath);
	iMimeType.Copy(aMimeType);
	iUniqueId.Copy(aUniqueId);
	iName.Copy(aName);
	}

const TDesC& CContentIteratorData::Path() const
	{
	return iPath; 
	}

const TDesC8& CContentIteratorData::MimeType() const
	{
	return iMimeType; 
	}
	
const TDesC& CContentIteratorData::UniqueId() const
	{
	return iUniqueId;
	}

const TDesC& CContentIteratorData::Name() const
	{
	return iName;
	}
	
TBool CContentIteratorData::IsRecursive() const
	{
	return iRecursive;	
	}