diff -r 826cea16efd9 -r 13a33d82ad98 dvrengine/CommonRecordingEngineClient/src/RCRClient.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/dvrengine/CommonRecordingEngineClient/src/RCRClient.cpp	Wed Sep 01 12:20:37 2010 +0100
@@ -0,0 +1,157 @@
+/*
+* 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 the License "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:    Implementation of CR client's Server*
+*/
+
+
+
+
+// INCLUDE FILES
+#include "RCRClient.h"
+#include <ipvideo/CRTypeDefs.h>
+#include <e32math.h>
+#include <f32file.h>
+
+// CONSTANTS
+const TUint KDefaultMessageSlots( 4 );
+const TUint KNumberOfServerStartupAttempts( 2 );
+
+// LOCAL FUNCTION PROTOTYPES
+static TInt StartServer();
+static TInt CreateServerProcess();
+
+// ============================= LOCAL FUNCTIONS ===============================
+
+// -----------------------------------------------------------------------------
+// StartServer 
+// Returns: Error code
+// -----------------------------------------------------------------------------
+//
+static TInt StartServer()
+    {
+    TFindServer findServer( KCRServerNameExe );
+    TFullName name( KNullDesC );
+    
+    // Server already running?
+    TInt result( findServer.Next( name ) );
+    if ( !result )
+        {
+        return KErrNone;
+        }    
+   
+    // Process
+    result = CreateServerProcess();
+    
+    return result;    
+    }
+
+// -----------------------------------------------------------------------------
+// CreateServerProcess 
+//
+// -----------------------------------------------------------------------------
+//
+static TInt CreateServerProcess()
+    {
+    RProcess server;
+    TInt err( server.Create( KCRServerNameExe , _L( "" ) ) );
+    if ( err )
+        {
+        return err;
+        }
+        
+    // Makes the server eligible for execution.    
+    TRequestStatus reqStatus;
+    server.Rendezvous(reqStatus);
+    
+    server.Resume();
+    
+    User::WaitForRequest(reqStatus);
+    
+    if( reqStatus.Int() != KErrNone )
+        {
+        server.Close();
+        }
+        
+    return reqStatus.Int();
+    }
+
+// ============================ MEMBER FUNCTIONS ===============================
+
+// -----------------------------------------------------------------------------
+// RCRClient::RCRClient
+//
+// -----------------------------------------------------------------------------
+//
+RCRClient::RCRClient() : RSessionBase()
+    {
+    // None
+    }
+
+// -----------------------------------------------------------------------------
+// RCRClient::Connect
+//
+// -----------------------------------------------------------------------------
+// 
+TInt RCRClient::Connect()
+    {
+    TInt ret( KErrNotFound );
+    TInt retry( KNumberOfServerStartupAttempts );
+    do
+        {
+        // Start
+        ret = StartServer();
+        if ( ret != KErrNone && ret != KErrAlreadyExists )
+            {
+            return ret;
+            }
+        
+        // Subsession
+        ret = CreateSession( KCRServerNameExe, Version(), KDefaultMessageSlots );
+        if ( ret != KErrNotFound && ret != KErrServerTerminated )
+            {
+            return ret;
+            }
+
+        retry--;
+        }
+        while( retry >= 0 );
+
+    return ret;
+    }
+
+// -----------------------------------------------------------------------------
+// RCRClient::Close
+// 
+// -----------------------------------------------------------------------------
+//
+void RCRClient::Close()
+    {
+    TIpcArgs args( TIpcArgs::ENothing );
+    SendReceive( ECRServCloseSession, args );
+    RHandleBase::Close();
+    }
+
+// -----------------------------------------------------------------------------
+// RCRClient::Version
+// 
+// -----------------------------------------------------------------------------
+//
+TVersion RCRClient::Version( void ) const
+    {
+    return( TVersion( KCRServMajorVersionNumber, 
+                      KCRServMinorVersionNumber,
+                      KCRServBuildVersionNumber ) );
+    }
+
+// End of File