--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/videoscheduler/SchedulerClient/src/RCseSchedulerClient.cpp	Wed Sep 01 12:20:37 2010 +0100
@@ -0,0 +1,200 @@
+/*
+* Copyright (c) 2006 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 CseScheduler client's Server*
+*/
+
+
+
+// INCLUDE FILES
+#include <ipvideo/RCseSchedulerClient.h>            // Header for this class
+#include "CseDebug.h"                       // Debug macros
+#include <ipvideo/CseSchedulerClientServerCommon.h> // Common defines for client and server
+#include <e32math.h>
+#include <f32file.h>
+
+// EXTERNAL DATA STRUCTURES
+// None
+
+// EXTERNAL FUNCTION PROTOTYPES  
+// None
+
+// CONSTANTS
+const TUint KSchedulingDefaultMessageSlots( 4 );
+const TUint KSchedulingNumberOfServerStartupAttempts( 2 );
+
+// MACROS
+// None
+
+// LOCAL CONSTANTS AND MACROS
+// None
+
+// MODULE DATA STRUCTURES
+// None
+
+// LOCAL FUNCTION PROTOTYPES
+// LOCAL FUNCTION PROTOTYPES
+static TInt StartServer();
+static TInt CreateServerProcess();
+
+// FORWARD DECLARATIONS
+// None
+
+// ============================= LOCAL FUNCTIONS ===============================
+// -----------------------------------------------------------------------------
+// StartServer 
+// Returns: Error code
+// -----------------------------------------------------------------------------
+//
+static TInt StartServer()
+    {
+    CSELOGSTRING_HIGH_LEVEL(">>>RCseSchedulerClient::StartServer");
+    TFindServer findServer( KCseSchedulerServerName );
+    TFullName name;
+    
+    // Server already running?    
+    if ( !findServer.Next( name ) )
+        {
+        return KErrNone;
+        }
+        
+    TInt result( CreateServerProcess() );
+    
+    CSELOGSTRING2_HIGH_LEVEL("<<<RCseSchedulerClient::StartServer: %d", result);
+    return result;
+    }
+
+// -----------------------------------------------------------------------------
+// CreateServerProcess 
+//
+// -----------------------------------------------------------------------------
+//
+static TInt CreateServerProcess()
+    {
+    CSELOGSTRING_HIGH_LEVEL(">>>RCseSchedulerClient::CreateServerProcess");
+    RProcess server;
+    TInt result( server.Create( KCseSchedulerServerFileName , _L( "" ) ) );
+
+    if ( result )
+        {
+        return  result;
+        }
+
+    // Makes the server eligible for execution.    
+    TRequestStatus reqStatus;
+    server.Rendezvous(reqStatus);
+    
+    server.Resume();
+    
+    User::WaitForRequest(reqStatus);
+    
+    if( reqStatus.Int() != KErrNone )
+        {
+        server.Close();
+        }
+    
+    CSELOGSTRING2_HIGH_LEVEL("<<<RCseSchedulerClient::CreateServerProcess: %d", reqStatus.Int());
+    return reqStatus.Int();
+    }
+
+// ============================ MEMBER FUNCTIONS ===============================
+
+// -----------------------------------------------------------------------------
+// RCseSchedulerClient::RCseSchedulerClient
+//
+// -----------------------------------------------------------------------------
+//
+RCseSchedulerClient::RCseSchedulerClient() : RSessionBase()
+    {
+    CSELOGSTRING_HIGH_LEVEL(">>>RCseSchedulerClient::RCseSchedulerClient");
+    // None
+    CSELOGSTRING_HIGH_LEVEL("<<<RCseSchedulerClient::RCseSchedulerClient");
+    }
+
+// -----------------------------------------------------------------------------
+// RCseSchedulerClient::~RCseSchedulerClient
+//
+// -----------------------------------------------------------------------------
+//
+RCseSchedulerClient::~RCseSchedulerClient()
+    {
+    CSELOGSTRING_HIGH_LEVEL(">>>RCseSchedulerClient::~RCseSchedulerClient");
+    CSELOGSTRING_HIGH_LEVEL("<<<RCseSchedulerClient::~RCseSchedulerClient");
+    }
+
+// -----------------------------------------------------------------------------
+// RCseSchedulerClient::Connect
+//
+// -----------------------------------------------------------------------------
+// 
+TInt RCseSchedulerClient::Connect()
+    {
+    CSELOGSTRING_HIGH_LEVEL(">>>RCseSchedulerClient::Connect");
+    TInt ret( KErrNotFound );
+    TInt retry( KSchedulingNumberOfServerStartupAttempts );
+    do
+        {
+        // Start
+        ret = StartServer();
+        if ( ret!=KErrNone && ret!=KErrAlreadyExists )
+            {
+            return ret;
+            }
+        
+        // Subsession
+        ret = CreateSession( KCseSchedulerServerName, Version(), KSchedulingDefaultMessageSlots );
+        if ( ret != KErrNotFound && ret != KErrServerTerminated )
+            {
+            return ret;
+            }
+
+        retry--;
+        }
+    while( retry >= 0 );
+
+    CSELOGSTRING_HIGH_LEVEL("<<<RCseSchedulerClient::Connect");
+    return ret;
+    }
+    
+// -----------------------------------------------------------------------------
+// RCseSchedulerClient::Close
+// 
+// -----------------------------------------------------------------------------
+//
+void RCseSchedulerClient::Close()
+    {
+    CSELOGSTRING_HIGH_LEVEL(">>>RCseSchedulerClient::Close");
+
+    TIpcArgs args( TIpcArgs::ENothing );
+    SendReceive( ECseServCloseSession, args );
+     
+    RHandleBase::Close();
+
+    CSELOGSTRING_HIGH_LEVEL("<<<RCseSchedulerClient::Connect");
+    }
+
+// -----------------------------------------------------------------------------
+// RCseSchedulerClient::Version
+// 
+// -----------------------------------------------------------------------------
+//
+TVersion RCseSchedulerClient::Version( void ) const
+    {
+    CSELOGSTRING_HIGH_LEVEL(">>>RCseSchedulerClient::Version");
+
+    return( TVersion( KCseServMajorVersionNumber, 
+                      KCseServMinorVersionNumber,
+                      KCseServBuildVersionNumber ) );
+    }
+
+// End of File