/*

* Copyright (c) 2002-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:   Client-Server communication

*

*/

#include <s32mem.h>

#include <e32std.h>

#include <lbspositioninfo.h>

#include <epos_suplterminalconstants.h>

#include <epos_suplterminal.h>

#include <epos_suplterminalparams.h>

#include "epos_suplterminalipc.h"

#include "epos_suplterminalerrors.h"

#include "epos_startsuplserver.h"

#include "epos_suplterminalptrholder.h"

#include "epos_suplterminalqop.h"

#include "epos_suplparameters.h"

#include "epos_csuplsettings.h"

#include "epos_csuplsettingparams.h"

const TUint	KFirstReq 			= 0x1000;

const TInt KMaxBufLength        = 255;

//-----------------------------------------------------------------------------

// RSuplTerminalServer

//-----------------------------------------------------------------------------

// -----------------------------------------------------------------------------

// RSuplTerminalServer::RSuplTerminalServer()

// C++ default constructor can NOT contain any code, that might leave.

// -----------------------------------------------------------------------------

//

EXPORT_C RSuplTerminalServer::RSuplTerminalServer()

  : RSessionBase(), 

    iReserved(NULL)

   	{

	}

// -----------------------------------------------------------------------------

// RSuplTerminalServer::ConstructL

// Symbian 2nd phase constructor can leave.

// -----------------------------------------------------------------------------

//

void RSuplTerminalServer::ConstructL()

	{            

	}

// ---------------------------------------------------------

// RSuplTerminalServer::Destruct

//

// Destruction method for RSuplTerminalServer. 

// ---------------------------------------------------------

//

void RSuplTerminalServer::Destruct()

	{

	}

// ---------------------------------------------------------

// RSuplTerminalServer::Connect

//

// (other items were commented in a header).

// ---------------------------------------------------------

//

EXPORT_C TInt RSuplTerminalServer::Connect()

	{

    __ASSERT_ALWAYS(Handle() == 0, 

    		User::Panic(KSuplClientFault, ESuplServerHandleNotClosed));

	TRAPD(ret, ConstructL());

	if (ret == KErrNone)

		{

		//TInt retry = 200;

		TInt retry = 3;

		for (;;) // FOREVER

			{

			ret = CreateSession(KSuplServerName, Version(), KDefaultMessageSlots);

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

				{

				break;

				}

			if (--retry == 0)

				{

				break;

				}

			ret = StartServer();

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

				{

				break;

				}

			}

		}

	if (ret != KErrNone)

		{

		Destruct();

		}

	return ret;

	}

// ---------------------------------------------------------

// RSuplTerminalServer::Close

//

// (other items were commented in a header).

// ---------------------------------------------------------

//

EXPORT_C void RSuplTerminalServer::Close()

	{

    RSessionBase::Close();

	Destruct();

	}

// ---------------------------------------------------------

// RSuplTerminalServer::Version

//

// (other items were commented in a header).

// ---------------------------------------------------------

//

EXPORT_C TVersion RSuplTerminalServer::Version() const

	{

	return TVersion(

		KSuplMajorVersionNumber,

		KSuplMinorVersionNumber,

		KSuplBuildVersionNumber);

	}

// ---------------------------------------------------------

// RSuplTerminalServer::Connect

//

// (other items were commented in a header).

// ---------------------------------------------------------

//

EXPORT_C TInt RSuplTerminalServer::Connect(TRequestStatus& aStatus)

	{

    __ASSERT_ALWAYS(Handle() == 0, User::Panic(KSuplClientFault, ESuplServerHandleNotClosed));

	TRAPD(ret, ConstructL());

	if (ret == KErrNone)

		{

		TInt retry = 200;

		for (;;) // FOREVER

			{

			ret = CreateSession(KSuplServerName, Version(), KDefaultMessageSlots, EIpcSession_Unsharable, (TSecurityPolicy*)0, &aStatus);

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

				{

				break;

				}

			if (--retry == 0)

				{

				break;

				}

			ret = StartServer();

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

				{

				break;

				}

			}

		}

	if (ret != KErrNone)

		{

		Destruct();

		}

	return ret;

	}	

//-----------------------------------------------------------------------------

// RSuplTerminalSubSession

//-----------------------------------------------------------------------------

// ---------------------------------------------------------

// RSuplTerminalSubSession::RSuplTerminalSubSession

//

// (other items were commented in a header).

// ---------------------------------------------------------

//

EXPORT_C RSuplTerminalSubSession::RSuplTerminalSubSession()

  : RSubSessionBase(), 

    iPtrHolder(NULL),

    iReserved(NULL),

    isTriggeringUsed(EFalse),

    iNotifyRequestCtr(0)

	{

	}

// ---------------------------------------------------------

// RSuplTerminalSubSession::ConstructL

//

// (other items were commented in a header).

// ---------------------------------------------------------

//

EXPORT_C void RSuplTerminalSubSession::ConstructL()

	{

    __ASSERT_ALWAYS(iPtrHolder == NULL, 

    		User::Panic(KSuplClientFault, ESuplServerHandleNotClosed));

	iPtrHolder = CSuplSubSessnPtrHolder::NewL(1, 1);

	}

// ---------------------------------------------------------

// RSuplTerminalSubSession::Destruct

//

// (other items were commented in a header).

// ---------------------------------------------------------

//

EXPORT_C void RSuplTerminalSubSession::Destruct()

	{

    delete iPtrHolder;

	iPtrHolder = NULL;

	}

// ---------------------------------------------------------

// RSuplTerminalSubSession::Open

//

// (other items were commented in a header).

// ---------------------------------------------------------

//

EXPORT_C TInt RSuplTerminalSubSession::Open(

					RSuplTerminalServer& aSuplServer, 

					TSuplServiceType aSuplService)

	{

	__ASSERT_ALWAYS(aSuplServer.Handle() != 0,

		User::Panic(KSuplClientFault, ESuplServerBadHandle));

	iSuplService = aSuplService;

	TInt suplVersion;

	switch( aSuplService )

		{

		case ESUPL_1_0:

			{

			suplVersion = 1;

			break;					

			}

		case ESUPL_2_0:

			{

			suplVersion = 2;

			break;					

			}

		default:

			{

			suplVersion = 1;

			break;					

			}

		}

	TIpcArgs args;

    args.Set(0, suplVersion);		

	TRAPD(ret, ConstructL());

	if (ret == KErrNone)

		{

		ret = CreateSubSession(aSuplServer, ESuplTerminalSubssnOpen, args);

		}

	if (ret != KErrNone)

		{

		Destruct();

		}

	return ret;            

	}

// ---------------------------------------------------------

// RSuplTerminalSubSession::RunSession

//

// (other items were commented in a header).

// ---------------------------------------------------------

//

EXPORT_C void RSuplTerminalSubSession::RunSession(

					TRequestStatus& aStatus, 

					TInt aSETCaps, 

					TInt aRequestId, 

					TBool aFirstReq)

    {

	__ASSERT_ALWAYS(SubSessionHandle(), User::Panic(KSuplClientFault, ESuplServerBadHandle));

	if(aRequestId < 0 )  	

		{

		TRequestStatus *status = &aStatus; 

		User::RequestComplete(status,KErrArgument);	

		return;

		}

	if(aSETCaps < 0 )  	

		{

		TRequestStatus *status = &aStatus; 

		User::RequestComplete(status,KErrArgument);	

		return;

		}

    TInt setCaps;

    if (aFirstReq)

        setCaps = aSETCaps | KFirstReq; 

    else

        setCaps = aSETCaps;

	TIpcArgs args;

    args.Set(0, setCaps);		

    args.Set(1, aRequestId);		

	SendReceive(ESuplTerminalSubssnAsyncRunsession, args, aStatus);	

    }

//---------------TDESC METHODS START HERE---------------------------------------

// ---------------------------------------------------------

// RSuplTerminalSubSession::RunSession

//

// (other items were commented in a header).

// ---------------------------------------------------------

//

EXPORT_C void RSuplTerminalSubSession::RunSession(

					TRequestStatus& aStatus, 

					TSuplTerminalQop& aQop, 

					const TDesC& aHslpAddress, 

					TBool aFallBack, 

					TInt aSETCaps, 

					TInt aRequestId, 

					TBool aFirstReq)

    {

    __ASSERT_ALWAYS(SubSessionHandle(), 

    			User::Panic(KSuplClientFault, ESuplServerBadHandle));

    if(aRequestId < 0 )     

        {

        TRequestStatus *status = &aStatus; 

        User::RequestComplete(status,KErrArgument); 

        return;

        }

    if(aSETCaps < 0 )   

        {

        TRequestStatus *status = &aStatus; 

        User::RequestComplete(status,KErrArgument); 

        return;

        }

    if(aHslpAddress.Length() < 0 || aHslpAddress.Length() > KMaxHslpAddressLength )

        {

        TRequestStatus *status = &aStatus; 

        User::RequestComplete(status,KErrArgument);

        return;

        }

    //Check if the passed HSLPAddress exists or not!

    TInt serverExists = CheckIfSlpExists(aHslpAddress);

    if(serverExists != KErrNone)

        {

        TRequestStatus *status = &aStatus; 

        User::RequestComplete(status,serverExists);

        return;

        }

    TReal32 aHorAcc,aVerAcc;

    TInt aDelay,aMaxAge;    

    if((aQop.GetHorizontalAccuracy(aHorAcc)==KErrNotFound)&&

    			(aQop.GetVerticalAccuracy(aVerAcc)==KErrNotFound)&&

    			(aQop.GetDelay(aDelay)==KErrNotFound)&&

    			(aQop.GetMaxLocationAge(aMaxAge)==KErrNotFound))

    	{

        TRequestStatus *status = &aStatus; 

        User::RequestComplete(status,KErrArgument); 

        return;

    	}      

    iSuplParameters.qop = aQop;

    iSuplParameters.HslpAddress = aHslpAddress;

    iSuplParameters.FallBack = aFallBack;

    iPtrHolder->Ptr(0).Set(

        reinterpret_cast<TUint8*>(&iSuplParameters),

        sizeof(iSuplParameters),sizeof(iSuplParameters));

    TInt setCaps;

    if (aFirstReq)

        setCaps = aSETCaps | KFirstReq; 

    else

        setCaps = aSETCaps;

    TIpcArgs args;

    args.Set(0, setCaps);       

    args.Set(1,aRequestId);

    args.Set(2,&iPtrHolder->Ptr(0));

    SendReceive(ESuplTerminalSubssnASyncRunsessionWithServernameQop, args, aStatus);  

    }

//-------------------2ND METHOD(SYNCHRONOUS)--------------------------

// ---------------------------------------------------------

// RSuplTerminalSubSession::RunSession

//

// (other items were commented in a header).

// ---------------------------------------------------------

//

EXPORT_C TInt RSuplTerminalSubSession::RunSession(

					TSuplTerminalQop& aQop, 

					const TDesC& aHslpAddress, 

					TBool aFallBack, 

					TInt aSETCaps, 

					TInt aRequestId, 

					TBool aFirstReq)

    {

    __ASSERT_ALWAYS(SubSessionHandle(), 

    		User::Panic(KSuplClientFault, ESuplServerBadHandle));

    if(aRequestId < 0 )     

        {

        return KErrArgument;

        }

    if(aSETCaps < 0 )   

        {

        return KErrArgument;

        }

    if(aHslpAddress.Length() < 0 || aHslpAddress.Length() > KMaxHslpAddressLength )

        {

        return KErrArgument;

        }

    //Check if the passed HSLPAddress exists or not!

    TInt serverExists = CheckIfSlpExists(aHslpAddress);

    if(serverExists != KErrNone)

        {

        return serverExists;

        }

    TReal32 aHorAcc,aVerAcc;

    TInt aDelay,aMaxAge;    

    if((aQop.GetHorizontalAccuracy(aHorAcc)==KErrNotFound)

    			&&(aQop.GetVerticalAccuracy(aVerAcc)==KErrNotFound)

    			&&(aQop.GetDelay(aDelay)==KErrNotFound)

    			&&(aQop.GetMaxLocationAge(aMaxAge)==KErrNotFound))

	    {

	    return KErrArgument;

	    }

    iSuplParameters.qop = aQop;

    iSuplParameters.HslpAddress = aHslpAddress;

    iSuplParameters.FallBack = aFallBack;

    iPtrHolder->Ptr(0).Set(

        reinterpret_cast<TUint8*>(&iSuplParameters),

        sizeof(iSuplParameters),sizeof(iSuplParameters));

    TInt setCaps;

    if (aFirstReq)

        setCaps = aSETCaps | KFirstReq; 

    else

        setCaps = aSETCaps;

    TIpcArgs args;

    args.Set(0, setCaps);       

    args.Set(1,aRequestId);

    args.Set(2,&iPtrHolder->Ptr(0));

    return SendReceive(ESuplTerminalSubssnSyncRunsessionWithServernameQop, args);  

    }

//------------------------------ASYNC WITHOUT QOP--------------------------------------------------------------

// ---------------------------------------------------------

// RSuplTerminalSubSession::RunSession

//

// (other items were commented in a header).

// ---------------------------------------------------------

//

EXPORT_C void RSuplTerminalSubSession::RunSession(

					TRequestStatus& aStatus, 

					const TDesC& aHslpAddress, 

					TBool aFallBack, 

					TInt aSETCaps, 

					TInt aRequestId, 

					TBool aFirstReq)

    {

    __ASSERT_ALWAYS(SubSessionHandle(), User::Panic(KSuplClientFault, ESuplServerBadHandle));

    if(aRequestId < 0 )     

        {

        TRequestStatus *status = &aStatus; 

        User::RequestComplete(status,KErrArgument); 

        return;

        }

    if(aSETCaps < 0 )   

        {

        TRequestStatus *status = &aStatus; 

        User::RequestComplete(status,KErrArgument); 

        return;

        }

    if(aHslpAddress.Length() < 0 || aHslpAddress.Length() > KMaxHslpAddressLength )

        {

        TRequestStatus *status = &aStatus; 

        User::RequestComplete(status,KErrArgument);

        return;

        }

    //Check if the passed HSLPAddress exists or not!

    TInt serverExists = CheckIfSlpExists(aHslpAddress);

    if(serverExists != KErrNone)

        {