/*
* Copyright (c) 2002 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:  This file is used only if RDRMRightsClient starts the
*                DRM Rights Database server. 
*
*/

// INCLUDE FILES
#include   <e32std.h>
#include    <e32uid.h>
#include <f32file.h>

#ifdef RD_MULTIPLE_DRIVE
#include <DriveInfo.h>
#endif

#include "drmengineclientserver.h"

// EXTERNAL DATA STRUCTURES
// EXTERNAL FUNCTION PROTOTYPES  
// CONSTANTS
#ifdef __WINS__
LOCAL_C const TUint KServerMinHeapSize =  0x1000;  
LOCAL_C const TUint KServerMaxHeapSize = 0x300000; 
_LIT( KRightsServerFile, "RightsServer" );
#else

#ifdef RD_MULTIPLE_DRIVE
_LIT( KRightsServerFile, "%c:\\RightsServer.exe" );
#else
_LIT( KRightsServerFile, "e:\\RightsServer.exe" );
#endif
#endif

// MACROS
// LOCAL CONSTANTS AND MACROS
// MODULE DATA STRUCTURES
// LOCAL FUNCTION PROTOTYPES
LOCAL_C TInt CreateServer( void );

// FORWARD DECLARATIONS

// ============================= LOCAL FUNCTIONS ===============================

// -----------------------------------------------------------------------------
// CreateServer launches the DRM Rights server [process (THUMB/ARMI)|thread (WINS)]. 
// Returns: KErrNone: No errors.
//          <KErrNone: Symbian wide error code.
// -----------------------------------------------------------------------------
//
LOCAL_C TInt CreateServer( void )
    {
    TInt error = KErrNone;
    
        RProcess server;
        
#ifndef RD_MULTIPLE_DRIVE
    
        error = server.Create( KRightsServerFile, 
                               KNullDesC );
    
#else //RD_MULTIPLE_DRIVE
        
        RFs fs;
        TInt driveNumber( -1 );
        TChar driveLetter;
        DriveInfo::GetDefaultDrive( DriveInfo::EDefaultMassStorage, driveNumber );
        
        error = fs.Connect();
        if( error != KErrNone )
            {
            fs.Close();
            return error;
            }
        
        fs.DriveToChar( driveNumber, driveLetter );
        fs.Close();
	
        TFileName rightsServerFile;
        rightsServerFile.Format( KRightsServerFile, (TUint)driveLetter );
    
        error = server.Create( rightsServerFile, 
                               KNullDesC );
    
#endif
        
        if ( !error )
            {
            // Give some time to the process to start.
            User::After( 1000 );
            
        // Kick the server up & running.
        server.Resume();
            
        // Local handle not needed anymore.
        server.Close();
        }
        
    return error;
    }
    
// ============================ MEMBER FUNCTIONS ===============================
    
// ========================== OTHER EXPORTED FUNCTIONS =========================
    
// -----------------------------------------------------------------------------
// DRMServerStarter starts the actual server.
// Returns: KErrNone: All went OK, no errors.
//          <KErrNone: Symbian wide error code.
// -----------------------------------------------------------------------------
//
EXPORT_C TInt DRMServerStarter()
    {
    RSemaphore semaphore;
    TFindServer server( DRMEngine::KServerName );
    TFullName name;
    
    // Check if the server is already running.
    TInt error = server.Next( name );
    
    if ( !error )
        {
        // Yep, it's already running.
        return KErrNone;
        }

    error = semaphore.CreateGlobal( DRMEngine::KDRMSemaphore,   // name
                                    0 ,              // count
                                    EOwnerThread ); // owner
    
    if ( error == KErrAlreadyExists )
        {
        error = semaphore.OpenGlobal( DRMEngine::KDRMSemaphore );
        }
        
    if ( !error )
        {
        error = CreateServer();
        if ( !error )
            {
            // Wait until server has done all its things.
            semaphore.Wait();
            
            // Signal the (possible) next one waiting in line. Server
            // only signals the semaphore once but there might be several
            // clients waiting for this semaphore, in theory.
            semaphore.Signal();
            }
        
        // Semaphore can be destroyed.
        semaphore.Close();
        }
        
    return error; 
    }
//  End of File