--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/contentpublishingsrv/contentharvester/contentharvesterclient/src/contentharvesterclient.cpp	Thu Dec 17 08:54:17 2009 +0200
@@ -0,0 +1,147 @@
+/*
+* Copyright (c) 2007 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:  
+ *
+*/
+
+#include "contentharvesterclient.h"
+#include "contentharvesterglobals.h"
+
+// Number of message slots to reserve for this client server session.
+const TUint KDefaultMessageSlots( 5);
+
+// Function prototypes
+static TInt StartServer();
+static TInt CreateServerProcess();
+
+// ======== MEMBER FUNCTIONS ========
+
+// -----------------------------------------------------------------------------
+// RContentHarvesterClient::RContentHarvesterClient
+// C++ default constructor can NOT contain any code, that
+// might leave.
+// -----------------------------------------------------------------------------
+//
+EXPORT_C RContentHarvesterClient::RContentHarvesterClient()
+:RSessionBase()
+    {
+    // No implementation required
+    }
+
+// -----------------------------------------------------------------------------
+// RContentHarvesterClient::Connect
+// Connect to Content Harvester Server session. 
+// exist
+// -----------------------------------------------------------------------------
+//
+EXPORT_C TInt RContentHarvesterClient::Connect()
+    {
+    TInt error = ::StartServer();
+
+    if ( error == KErrNone )
+        {
+        error = CreateSession( KContentHarvesterName,
+                Version(),
+                KDefaultMessageSlots );
+        }
+    return error;
+    }
+
+// -----------------------------------------------------------------------------
+// RContentHarvesterClient::Update
+// Client requests to trigger update process
+// -----------------------------------------------------------------------------
+
+EXPORT_C TInt RContentHarvesterClient::Update()
+    {
+    return SendReceive( EContentHarvesterUpdate );
+    }
+
+// -----------------------------------------------------------------------------
+// RContentHarvesterClient::Stop
+// Client requests to trigger stop process
+// -----------------------------------------------------------------------------
+
+EXPORT_C TInt RContentHarvesterClient::Stop()
+    {
+    return SendReceive( EContentHarvesterStop );
+    }
+
+// -----------------------------------------------------------------------------
+// RContentHarvesterClient::Version
+// Version information.
+// -----------------------------------------------------------------------------
+//
+TVersion RContentHarvesterClient::Version() const
+    {
+    return (TVersion( KContentHarvesterMajorVersionNumber,
+        KContentHarvesterMinorVersionNumber,
+        KContentHarvesterBuildVersionNumber ) );
+    }
+
+// -----------------------------------------------------------------------------
+// StartServer
+// Static method to start the server.
+// -----------------------------------------------------------------------------
+//
+static TInt StartServer()
+    {
+    TInt result;
+
+    TFindServer findServer( KContentHarvesterName );
+    TFullName name;
+
+    result = findServer.Next( name );
+    if ( result != KErrNone )
+        {
+        // Server not running
+        result = CreateServerProcess( );
+        }
+    return result;
+    }
+
+// -----------------------------------------------------------------------------
+// CreateServerProcess
+// Static method to create the server process.
+// -----------------------------------------------------------------------------
+//
+static TInt CreateServerProcess()
+    {
+    const TUidType serverUid( KNullUid, KNullUid, KServerUid3);
+    RProcess server;
+    TInt result;
+    result = server.Create( KContentHarvesterFilename, KNullDesC, serverUid );
+    if ( result == KErrNone )
+        {
+        TRequestStatus stat = KRequestPending;
+        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
+        result = (server.ExitType( ) == EExitPanic ) ? KErrGeneral
+            : stat.Int( );
+        }
+    server.Close( );
+    return result;
+    }