// Copyright (c) 2006-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:

//

/**

 @file

 @deprecated since v9.1. Functionality is replaced with commsdat.

*/

#include "NotifyClient.H"

#include "NotifierServ.H"

const TInt KCommsDatServerMaxOuterLoopRetryCount=2;

const TInt KCommsDatServerMaxInnerLoopRetryCount=10;

const TInt KCommsDatServerRetryTimeout=200000;	// 200 msec

//**********************************

//RCommsdatNotifier

//**********************************

EXPORT_C RCommsdatNotifier::RCommsdatNotifier()

	/** Constructor. */

	{}

TInt RCommsdatNotifier::StartNotifierProcess()

	{	

	RProcess server;

	TInt ret=server.Create(KCommsdatNotifierExecutable, KNullDesC);

	if (ret!=KErrNone)

		{

		return ret;	

		}

	TRequestStatus stat;	

	server.Rendezvous(stat);

	server.Resume();

	server.Close();

	User::WaitForRequest(stat);

	return stat.Int();		

	}	

EXPORT_C TInt RCommsdatNotifier::Connect()

	/** Connects to the server.

	*

	* 

	* @return	KErrNone if successful; otherwise, a system-wide error code. */

	{

	TInt ret = CreateSession(COMMSDATNOTIFIER_SERVER_NAME,Version(),-1);

	TInt outerLoopRetryCount = 0;

	while ((ret == KErrNotFound) && (outerLoopRetryCount++ < KCommsDatServerMaxOuterLoopRetryCount))

		{		

		ret=StartNotifierProcess();

		if (ret==KErrNone || ret==KErrAlreadyExists)

			{

			ret = CreateSession(COMMSDATNOTIFIER_SERVER_NAME,Version(),-1);

			TInt innerLoopRetryCount = 0;

			while ((ret == KErrNotFound) && (innerLoopRetryCount++ < KCommsDatServerMaxInnerLoopRetryCount))

				{

				User::After(KCommsDatServerRetryTimeout);

				ret = CreateSession(COMMSDATNOTIFIER_SERVER_NAME,Version(),-1);				

				}

			}

			else

			{

				break; // we can't do anything more

			}

		}      	

	return ret;

	}

EXPORT_C TVersion RCommsdatNotifier::Version() const

	/** Gets the client side version number.

	*

	* @return	The client version number. */

	{

	return(TVersion(KCommsdatNotifierMajorVersionNumber,KCommsdatNotifierMinorVersionNumber,KCommsdatNotifierBuildVersionNumber));

	}

EXPORT_C void RCommsdatNotifier::RequestNotification(TRequestStatus& aStatus)

	{

        SendReceive(ERequestNotify, TIpcArgs(),aStatus);

	}

EXPORT_C void RCommsdatNotifier::CancelNotification()

	{

	SendReceive(ECancelNotify, TIpcArgs());

	}	

EXPORT_C void RCommsdatNotifier::Close()

    {

	RHandleBase::Close();

    }