/*

* Copyright (c) 2008 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 for Events Handler Server

*

*/

#include "evthandlerclientserver.h"

#include "evthandlerclient.h"

#include "evthandlerserverconsts.h"

#include "evtdebug.h"

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

// StartServer()

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

//

static TInt StartServer()

/*

 * Start the server process. Simultaneous launching

 * of two such processes should be detected when the second one attempts to

 * create the server object, failing with KErrAlreadyExists.

 */

	{

	EVTUIDEBUG("+ StartServer()");

	const TUidType serverUid( KNullUid, KNullUid, KServerUid3);

	RProcess server;

	TInt r = server.Create( KEvtHandlerServerImg, KNullDesC, serverUid );

	if (r != KErrNone)

		return r;

	TRequestStatus stat;

	server.Rendezvous(stat);

	if (stat != KRequestPending)

		server.Kill( 0 );		// abort startup

	else

		server.Resume();	// logon OK - start the server

	User::WaitForRequest( stat );		// wait for start or death

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

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

	server.Close();

	EVTUIDEBUG("- StartServer()");

	return r;

	}

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

// REvtHandlerSession::Connect()

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

//

EXPORT_C TInt REvtHandlerSession::Connect()

/*

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

 */

	{

	EVTUIDEBUG("+ REvtHandlerSession::Connect()");

	TInt retry = 2;

	for (;;)

		{

		TInt r = CreateSession( KEvtHandlerServerName, TVersion( 0, 0, 0), 1 );

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

			return r;

		if ( --retry == 0 )

			return r;

		r = StartServer();

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

			return r;

		}

	}

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

// REvtHandlerSession::SendEventId()

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

//

EXPORT_C TInt REvtHandlerSession::SendEventId( const TDesC& aMessage, const TInt aAccuracy )

	{

	EVTUIDEBUG("+ REvtHandlerSession::SendEventId()");

	if ( aMessage.Length() > KMaxEvtHandlerMessage )

		return KErrArgument;

	return SendReceive( ESendEventId, TIpcArgs( &aMessage, aAccuracy )  );

	}