/*

* Copyright (c) 2010 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:  Positioning Indicator Helper Client-Server communication

*

*/

#include "posindicatorhelperserver.h"

#include "posindicatorhelpererrors.h"

#include "posindicatorserverconst.h"

#include <s32mem.h>

#include <e32std.h>

const TInt KDefaultMessageSlots = 255; //max

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

// RPosIndicatorHelperServer::RPosIndicatorHelperServer()

// Default constructor

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

// 

 RPosIndicatorHelperServer :: RPosIndicatorHelperServer():RSessionBase(),iReserved(NULL)

    {

     FUNC("+ RPosIndicatorHelperServer::RPosIndicatorHelperServer");

     FUNC("- RPosIndicatorHelperServer::RPosIndicatorHelperServer");

    }

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

// RPosIndicatorHelperServer::Connect

//

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

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

//

 TInt RPosIndicatorHelperServer::Connect()

	{

     FUNC("+ RPosIndicatorHelperServer::Connect");

 	__ASSERT_ALWAYS(Handle() == 0, User::Panic(KPosIndHelperClientPanicCategory, EPosIndicatorHelperServerHandleNotClosed));

	TInt ret = CreateSession(KPosIndHelperSrvName, Version(), KDefaultMessageSlots);

	if( ret == KErrNotFound )

	    {

#if defined(__WINSCW__)

	    StartLbsRootProcess();

#endif

	    RProcess posIndHelperServerProcess;

	    ret = posIndHelperServerProcess.Create(KPosIndHelperSrvName, KNullDesC);

	    if( ret != KErrNone )

	        {

	        posIndHelperServerProcess.Close();

	        return KErrNotFound;

	        }

	    TRequestStatus status;

	    posIndHelperServerProcess.Rendezvous(status);

	    if( status != KRequestPending )

	        {

	        User::WaitForRequest(status);

	        posIndHelperServerProcess.Kill(KErrNone);

	        posIndHelperServerProcess.Close();

	        return status.Int();

	        }

	    else

	        {

	        posIndHelperServerProcess.Resume();		        

	        }

	    User::WaitForRequest(status);

	    posIndHelperServerProcess.Close();

	    if( status != KErrNone )

	        {

	        return (status.Int());

	        }

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

	    }

	return ret;

  }

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

// RPosIndicatorHelperServer::Close

//

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

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

//

 void RPosIndicatorHelperServer::Close()

	{

    FUNC("+ RPosIndicatorHelperServer::Close");

	RSessionBase::Close();

    FUNC("- RPosIndicatorHelperServer::Close");

	}

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

// RPosIndicatorHelperServer::Version

//

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

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

//

 TVersion RPosIndicatorHelperServer::Version() const

	{	

    FUNC("+ RPosIndicatorHelperServer::Version");

	return TVersion(KMajorVersionNumber,

					KMinorVersionNumber,

					KBuildVersionNumber);

	}

#if defined(__WINSCW__)

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

// RPosIndicatorHelperServer::Version

//

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

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

//

TInt RPosIndicatorHelperServer::StartLbsRootProcess()

    {

    FUNC("+ RPosIndicatorHelperServer::StartLbsRootProcess");

    RProcess lbsrootProcess;

    TInt ret = lbsrootProcess.Create(_L("lbsroot"), KNullDesC);

    if( ret != KErrNone )

        {

        lbsrootProcess.Close();

        return KErrNotFound;

        }

    TRequestStatus status;

    lbsrootProcess.Rendezvous(status);

    if( status != KRequestPending )

        {

        User::WaitForRequest(status);

        lbsrootProcess.Kill(KErrNone);

        lbsrootProcess.Close();

        return KErrNotFound;

        }

    else

        {

        lbsrootProcess.Resume();             

        }

    User::WaitForRequest(status);

    lbsrootProcess.Close();

    if( status != KErrNone )

        {

        return (status.Int());

        }

    return ret;

    }

#endif