/*

* Copyright (c) 2009 Nokia Corporation and/or its subsidiary(-ies).

* All rights reserved.

* This component and the accompanying materials are made available

* under the terms of "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 "TrkTcbCliSession.h"

#include "TrkTcbClientDefs.h"

// System includes

// User includes

#include "TrkTcbCmdCodes.h"

#include "TrkTcbClientUtils.h"

// Type definitions

// Constants

const TInt KNumberOfServerStartupAttempts = 2;

// Enumerations

//

// RTrkTcbCliSession (source)

//

//

// RTrkTcbCliSession::RTrkTcbCliSession

//

// Constructor

//

RTrkTcbCliSession::RTrkTcbCliSession()

{

}

//

//RTrkTcbCliSession::Connect()

//

// Connects the client process to the TrkTcb server, starting the server 

// if it is not already running.

// return KErrNone if successful, otherwise one of the system-wide errors.

//

TInt RTrkTcbCliSession::Connect()

{

	TInt startupAttempts = KNumberOfServerStartupAttempts;

	for(;;)

	{

		TInt ret = CreateSession(TrkTcbClientDefs::ServerAndThreadName(), TrkTcbClientDefs::Version(), KTrkTcbServerAsynchronousSlotCount);

		if (ret != KErrNotFound && ret != KErrServerTerminated)

		{

			return ret;

		}

		if	(startupAttempts-- == 0)

		{

			return ret;

		}

		ret = TrkTcbClientUtils::StartTrkTcbServer();

		if	(ret != KErrNone && ret != KErrAlreadyExists)

		{

			return ret;

		}

	}

}

//

// RTrkTcbCliSession::Version()

//

// Provides the version number of the TrkTcb server.

// @return The version number. 

//

TVersion RTrkTcbCliSession::Version() const

{

	return TrkTcbClientDefs::Version();

}

//

// RTrkTcbCliSession::OpenFile()

//

// Opens the specified file in the specified mode.

// @return KErrNone - if succesful

//		   Negative - if failed.

//

TInt RTrkTcbCliSession::OpenFile(const TDesC& aFilePath, TUint aMode, TTime& aModifiedTime)

{

	TPckg<TTime> package(aModifiedTime);

	TInt length = aFilePath.Length();

	TIpcArgs args(length, &aFilePath, aMode, &package);

	return SendReceive(ETrkTcbCmdCodeOpenFile, args);

}

//

// RTrkTcbCliSession::ReadFile()

//

// Reads data from the already opened file.

// @return KErrNone - if succesful

//		   Negative - if failed.

//

TInt RTrkTcbCliSession::ReadFile(TUint16 aLength, TDes8& aFileData)

{

	TIpcArgs args(aLength, &aFileData);

	return SendReceive(ETrkTcbCmdCodeReadFile, args);

}

//

// RTrkTcbCliSession::WriteFile()

//

// Writes data into the already opened file.

// @return KErrNone - if succesful

//		   Negative - if failed.

//

TInt RTrkTcbCliSession::WriteFile(const TDesC8& aFileData)

{

	TIpcArgs args(aFileData.Length(), &aFileData);

	return SendReceive(ETrkTcbCmdCodeWriteFile, args);

}

//

// RTrkTcbCliSession::CloseFile()

//

// Closes data into the already opened file.

// @return KErrNone - if succesful

//		   Negative - if failed.

//

TInt RTrkTcbCliSession::CloseFile(const TTime& aTime)

{

	TPckg<TTime> package(aTime);

	TIpcArgs args(&package);

	return SendReceive(ETrkTcbCmdCodeCloseFile, args);

}

//

// RTrkTcbCliSession::PositionFile()

//

// Changes the current postion in the already opened file

// @return KErrNone - if succesful

//		   Negative - if failed.

//

TInt RTrkTcbCliSession::PositionFile(TSeek aSeek, TInt& aOffset)

{

	TPckg<TSeek>  package(aSeek);

	TIpcArgs args(&package, aOffset);

	return SendReceive(ETrkTcbCmdCodePositionFile, args);

}

//

// RTrkTcbCliSession::ShutDownServer()

//

// Closes the server.

// @return KErrNone - if succesful

//		   Negative - if failed.

//

TInt RTrkTcbCliSession::ShutDownServer()

{

	TIpcArgs args;

	return SendReceive(ETrkTcbCmdCodeShutDownServer, args);

}