--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/commsconfig/commsdatabaseshim/commdbshim/Notifier/src/NotifyClient.CPP	Thu Dec 17 09:22:25 2009 +0200
@@ -0,0 +1,110 @@
+// 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();
+    }