/*
* Copyright (c) 2008-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: 
* TestUtil - client testutils interface implementation
*
*/




/**
 @file 
 @test
 @internalComponent
*/
 
#include "testutilsdpclient.h"
#include "testutilclientserver.h"

static TInt StartTestUtilServer()
	{
	const TUidType serverUid(KNullUid, KNullUid, KServerUid3);
	RProcess server;
	TInt err = server.Create(KTestUtilServerImg, KNullDesC, serverUid);
	if (err != KErrNone)
		{
		return err;
		}
	TRequestStatus stat;
	server.Rendezvous(stat);
	if (stat != KRequestPending)
		{
		server.Kill(0);		// abort startup
		}
	else
		{
		server.Resume();	// logon OK - start the server
		}
	User::WaitForRequest(stat);		// wait for start or death
	// we can't use the 'exit reason' if the server panicked as this
	// is the panic 'reason' and may be '0' which cannot be distinguished
	// from KErrNone
	err = (server.ExitType() == EExitPanic) ? KErrGeneral : stat.Int();
	server.Close();
	return err;
	}

EXPORT_C TInt RTestUtilSession::Connect()
//
// Connect to the server, attempting to start it if necessary
//
	{
	TInt retry=2;
	for (;;)
		{
		TInt err = CreateSession(KTestUtilServerName, TVersion(0, 0, 0), 2);
		if (err != KErrNotFound && err != KErrServerTerminated)
			{
			return err;
			}
		if (--retry==0)
			{
			return err;
			}
		err = StartTestUtilServer();
		if (err != KErrNone && err != KErrAlreadyExists)
			{
			return err;
			}
		}
	}

EXPORT_C TInt RTestUtilSession::Copy(const TDesC& aSourceFile, const TDesC& aDestinationFile)
	{
	return SendReceive(ECopy,TIpcArgs(&aSourceFile, &aDestinationFile));
	}

EXPORT_C TInt RTestUtilSession::Move(const TDesC& aSourceFile, const TDesC& aDestinationFile)
	{
	return SendReceive(EMove,TIpcArgs(&aSourceFile, &aDestinationFile));
	}

EXPORT_C TInt RTestUtilSession::Delete(const TDesC& aFileName)
	{
	return SendReceive(EDelete,TIpcArgs(&aFileName));
	}

EXPORT_C TInt RTestUtilSession::MkDirAll(const TDesC& aFileName)
	{
	return SendReceive(EMkDirAll,TIpcArgs(&aFileName));
	}

EXPORT_C TInt RTestUtilSession::RmDir(const TDesC& aFileName)
	{
	return SendReceive(ERmDir,TIpcArgs(&aFileName));
	}

EXPORT_C TBool RTestUtilSession::FileExistsL(const TDesC& aFileName)
	{
	return FileExistsL(aFileName, 0);
	}

EXPORT_C TBool RTestUtilSession::FileExistsL(const TDesC& aFileName, TInt aMsecTimeout)
	{
	TBool fileExists;
	TPckg<TBool> exists(fileExists);
	User::LeaveIfError(SendReceive(EFileExists,TIpcArgs(&aFileName, aMsecTimeout, &exists)));
	return fileExists;
	}
EXPORT_C TInt RTestUtilSession::FormatDrive(TInt aDrive, TBool aFormatFatTableOnly)
	{
	return SendReceive(EFormat,TIpcArgs(aDrive, aFormatFatTableOnly));
	}
EXPORT_C TInt RTestUtilSession::MountDrive(TInt aDrive)
	{
	return SendReceive(EMount,TIpcArgs(aDrive));
	}
EXPORT_C TInt RTestUtilSession::UnMountDrive(TInt aDrive)
	{
	return SendReceive(EUnMount,TIpcArgs(aDrive));
	}
	
EXPORT_C TInt RTestUtilSession::Lock(const TDesC& aFileName)
	{
	return SendReceive(ELock,TIpcArgs(&aFileName));
	}
	
EXPORT_C TInt RTestUtilSession::Unlock(const TDesC& aFileName)
	{
	return SendReceive(EUnlock,TIpcArgs(&aFileName));
	}

EXPORT_C TInt RTestUtilSession::SetReadOnly(const TDesC& aFileName, TInt aSetReadOnly)
	{
	return SendReceive(ESetReadOnly,TIpcArgs(&aFileName, aSetReadOnly));
	}
EXPORT_C TInt RTestUtilSession::GetFileHandle(const TDesC& aFileName, RFile &aRFile)
	{
	TPckgBuf<TInt> fh;
	TInt fsh = SendReceive(EGetFileHandle, TIpcArgs(&aFileName, &fh));
	if(fsh < 0)
		{
		return fsh;
		}
	return aRFile.AdoptFromServer(fsh, fh());
	}
EXPORT_C void RTestUtilSession::WatchFile(const TDesC& aFileName, TRequestStatus& aStatus)
	{
	aStatus=KRequestPending;
	SendReceive(EWatchFile, TIpcArgs(&aFileName), aStatus);
	}
EXPORT_C void RTestUtilSession::WatchFileCancelL()
	{
	User::LeaveIfError(SendReceive(EWatchFileCancel));
	}
EXPORT_C TInt RTestUtilSession::GetNumFilesL(const TDesC& aDirName)
	{
	TInt numFiles;
	TPckg<TInt> getNum(numFiles);
	
	User::LeaveIfError(SendReceive(EGetNumFiles, TIpcArgs(&aDirName, &getNum)));
	
	return numFiles;
	}

// End of file