/*
* 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