/*

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

#include <e32std.h>

#include <e32uid.h>

#include "clientutils.h"

#include "fstokenservername.h"

#ifdef SYMBIAN_AUTH_SERVER

#ifdef __WINS__

#include <u32hal.h>

#endif //__WINS__

#include <e32svr.h>

#endif // SYMBIAN_AUTH_SERVER

//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	

//	Tokentype session class for file based certificate store

//	Connects and passes messages to the file store tokentype server

//	Coded specifically for file store token type

//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	

_LIT(KFSTokenServerImg,"fstokenserver");

#ifdef SYMBIAN_AUTH_SERVER

#ifdef __WINS__

_LIT(KFSNewTokenServerImg,"fstokenserver_useauth");

#endif // __WINS__

#endif // SYMBIAN_AUTH_SERVER

RFileStoreClientSession::RFileStoreClientSession()

{}

TInt RFileStoreClientSession::SendRequest(TFSTokenMessages aRequest, const TIpcArgs& aArgs) const

{

	return SendReceive(aRequest, aArgs);

}

void RFileStoreClientSession::SendAsyncRequest(TFSTokenMessages aRequest, const TIpcArgs& aArgs, TRequestStatus* aStatus) const

{

	__ASSERT_ALWAYS(aStatus, FSTokenPanic(EBadArgument));

	if (aStatus)

	{

		*aStatus = KRequestPending;

		SendReceive(aRequest, aArgs, *aStatus);

	}

}

//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	

//	Client-server startup code

//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	//	\\	

static TInt StartServer();	//	Forward declaration

//

// Connect to the server, attempting to start it if necessary

//

#ifdef SYMBIAN_AUTH_SERVER

#ifdef __WINS__

static bool UseAuthServer(void);

#endif // SYMBIAN_AUTH_SERVER

#endif // __WINS__

TInt RFileStoreClientSession::Connect(ETokenEnum aToken)

	{

	// The version is made up of three pieces of information:

	// 1. iMajor - The token we want to talk to

	// 2. iMinor - The protocol version number

	// 3. iBuild - unused

	TVersion version(aToken, KFSProtolVersion, 0);

	TInt retry=2;

	for (;;)

		{

		TInt err = KErrNone;

#ifdef SYMBIAN_AUTH_SERVER

#ifdef __WINS__

		if(UseAuthServer())

			{

			err = CreateSession(KFSNewTokenServerName, version, 1);

			}

		else

#endif // __WINS__

#endif // SYMBIAN_AUTH_SERVER

			{

			err = CreateSession(KFSTokenServerName, version, 1);

			}

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

			return err;

		if (--retry==0)

			return err;

		err=StartServer();

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

			return err;

		}

	}

#ifdef SYMBIAN_AUTH_SERVER

#ifdef __WINS__

/*static*/ bool UseAuthServer(void)

	{

	bool useAuthServer = false;

	TUint32 useAuth = 0;

	// For the emulator allow the constant to be patched via epoc.ini

	UserSvr::HalFunction(EHalGroupEmulator, EEmulatorHalIntProperty,

	(TAny*)"KKeyStoreUseAuthServer", &useAuth); // read emulator property (if present)

	if(useAuth)

		{

		useAuthServer = true;

		}

	return useAuthServer; 

	}

#endif // __WINS__

#endif // SYMBIAN_AUTH_SERVER

TInt StartServer()

	{

	// Server startup is different for WINS in EKA1 mode ONLY (lack of process

	// emulation - we load the library in this instance

	const TUidType serverUid(KNullUid, KNullUid, KUidFSTokenServer);

	RProcess server;

	TInt error = KErrNone;

#ifdef SYMBIAN_AUTH_SERVER

#ifdef __WINS__

	if(UseAuthServer())

		{

		error = server.Create(KFSNewTokenServerImg, KNullDesC, serverUid);

		}

	else

#endif // __WINS__

#endif // SYMBIAN_AUTH_SERVER

		{

		error = server.Create(KFSTokenServerImg, KNullDesC, serverUid);

		}

	if (error != KErrNone)

		{

		return error;

		}

	// Synchronise with the process to make sure it hasn't died straight away

	TRequestStatus stat;

	server.Rendezvous(stat);

	if (stat != KRequestPending)

		{

		// logon failed - server is not yet running, so cannot have terminated

		server.Kill(0);				// Abort startup

		}

	else

		{

		// logon OK - start the server

		server.Resume();

		}

	// Wait to synchronise with server - if it dies in the meantime, it

	// also gets completed

	User::WaitForRequest(stat);	

	// 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

	error = (server.ExitType()==EExitPanic) ? KErrGeneral : stat.Int();

	server.Close();

	return (error);

	}