// fuser.cpp
// 
// Copyright (c) 2005 - 2010 Accenture. All rights reserved.
// This component and the accompanying materials are made available
// under the terms of the "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:
// Accenture - Initial contribution
//

#include "fuser.h"
#include <f32file.h>


CCommandBase* CCmdFileUser::NewLC()
	{
	CCmdFileUser* self = new(ELeave) CCmdFileUser();
	CleanupStack::PushL(self);
	self->BaseConstructL();
	return self;
	}

CCmdFileUser::~CCmdFileUser()
	{
	iFiles.Close();
	}

CCmdFileUser::CCmdFileUser()
	{
	}

const TDesC& CCmdFileUser::Name() const
	{
	_LIT(KName, "fuser");
	return KName;
	}

void CCmdFileUser::DoRunL()
	{
	const TInt numFiles = iFiles.Count();
	if (numFiles == 0)
		{
		PrintAllUsersL();
		}
	else
		{
		for (TInt i = 0; i < numFiles; ++i)
			{
			PrintUsersL(iFiles[i]);
			}
		}
	}

void CCmdFileUser::PrintAllUsersL()
	{
	TOpenFileScan openFileScanner(FsL());
	CFileList* fileList = NULL;
	FOREVER
		{
		openFileScanner.NextL(fileList);
		if (fileList == NULL)
			{
			break;
			}
		CleanupStack::PushL(fileList);
		const TInt numOpenFiles = fileList->Count();
		for (TInt i = 0; i < numOpenFiles; ++i)
			{
			const TEntry& entry = (*fileList)[i];
			Printf(_L("%S: \r\n"), &entry.iName);
			TThreadId threadId(openFileScanner.ThreadId());
			RThread thread;
			TInt err = thread.Open(threadId);
			if (err)
				{
				Printf(_L("\tError %d opening thread id %u\r\n"), err, (TUint)threadId);
				}
			else
				{
				TFullName name(thread.FullName());
				thread.Close();
				Printf(_L("\t%S (%u)\r\n"), &name, (TUint)threadId);
				}
			}
		CleanupStack::PopAndDestroy(fileList);
		}
	}

void CCmdFileUser::PrintUsersL(const TDesC& aFileName)
	{
	Printf(_L("%S: \r\n"), &aFileName);
	TOpenFileScan openFileScanner(FsL());
	CFileList* fileList = NULL;
	TBool userFound(EFalse);
	FOREVER
		{
		openFileScanner.NextL(fileList);
		if (fileList == NULL)
			{
			break;
			}
		CleanupStack::PushL(fileList);
		const TInt numOpenFiles = fileList->Count();
		for (TInt i = 0; i < numOpenFiles; ++i)
			{
			const TEntry& entry = (*fileList)[i];
			if (entry.iName.MatchF(aFileName.Mid(2)) != KErrNotFound) // Note entry.iName doesn't have a drive letter, hence the Mid(2).
				{
				userFound = ETrue;
				TThreadId threadId(openFileScanner.ThreadId());
				RThread thread;
				TInt err = thread.Open(threadId);
				if (err)
					{
					Printf(_L("\tError %d opening thread id %u\r\n"), err, (TUint)threadId);
					}
				else
					{
					TFullName name(thread.FullName());
					thread.Close();
					Printf(_L("\t%S (%u)\r\n"), &name, (TUint)threadId);
					}
				break;
				}
			}
		CleanupStack::PopAndDestroy(fileList);
		}

	if (!userFound)
		{
		Write(_L("\tNo users"));
		}
	}

void CCmdFileUser::ArgumentsL(RCommandArgumentList& aArguments)
	{
	_LIT(KArgFiles, "file_name");
	aArguments.AppendFileNameL(iFiles, KArgFiles);
	}


#ifdef EXE_BUILD
EXE_BOILER_PLATE(CCmdFileUser)
#endif