/*

 * 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);

 	}