// Copyright (c) 2009 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: Implements a Symbian OS server that exposes the RUsbMassStorage API
// 
// 

#include <e32svr.h>
#include "usbmscfileshared.h"
#include "mscfileserver.h"
#include "mscfilesession.h"
#include "mscfileserversecuritypolicy.h"
#include "mscfilecontroller.h"
#include "debug.h"

/**
 Constructs a USB mass storage Server
 
 @return  a pointer to CMscFileServer object
 */
CMscFileServer* CMscFileServer::NewLC()
	{
	CMscFileServer* r = new (ELeave) CMscFileServer();
	CleanupStack::PushL(r);
	r->ConstructL();
	return r;
	}

/**
 Destructor
 */
CMscFileServer::~CMscFileServer()
	{
	TRACE_FUNC

    delete iController;
	}

/**
 Constructor

 @param aController a USB mass storage controller reference
 */
CMscFileServer::CMscFileServer()
     : CPolicyServer(EPriorityHigh, KMscFileServerPolicy)
	{
	}

void CMscFileServer::ConstructL()
    {
    TRACE_FUNC

    StartL( KMscFileServerName );

    iController = CMscFileController::NewL();
    }
/**
 Create a new session on this server
 
 @param	&aVersion	Version of client
 @return	A pointer to a session object to be used for the client
 */
CSession2* CMscFileServer::NewSessionL(const TVersion &aVersion, const RMessage2& /*aMessage*/) const
	{
	TRACE_FUNC
	TVersion v( KUsbMsSrvMajorVersionNumber,
	            KUsbMsSrvMinorVersionNumber,
	            KUsbMsSrvBuildVersionNumber );

	if ( !User::QueryVersionSupported( v, aVersion ) )
	    {
        User::Leave( KErrNotSupported );
	    }

	CMscFileServer* ncThis = const_cast<CMscFileServer*>(this);
	CMscFileSession* sess = CMscFileSession::NewL(*ncThis);
	return sess;
	}


/**
 Inform the client there has been an error.
 
 @param	aError	The error that has occurred
 */
void CMscFileServer::Error(TInt aError)
	{
	TRACE_STATE(( _L("!! CMscFileServer::Error( %d )"), aError ))

	Message().Complete(aError);
	ReStart();
	}

/**
 Increment the open session count (iSessionCount) by one.
 
 @post	the number of open sessions is incremented by one
 */
void CMscFileServer::IncrementSessionCount()
	{
	TRACE_STATE(( _L(">< CMscFileServer::IncrementSessionCount( %d )"), iSessionCount ))
	__ASSERT_DEBUG(iSessionCount >= 0, User::Panic(KUsbMsSvrPncCat, EUsbMsPanicIllegalIPC));
	
	++iSessionCount;
	}

/**
 Decrement the open session count (iSessionCount) by one.
 
 @post		the number of open sessions is decremented by one
 */
void CMscFileServer::DecrementSessionCount()
	{
	TRACE_STATE(( _L(">< CMscFileServer::DecrementSessionCount( %d )"), iSessionCount ))
	__ASSERT_DEBUG(iSessionCount > 0, User::Panic(KUsbMsSvrPncCat, EUsbMsPanicIllegalIPC));

	--iSessionCount;
	}

void CMscFileServer::ThreadFunctionL()
    {
    TRACE_FUNC_ENTRY

    // Naming the server thread after the server helps to debug panics
    User::LeaveIfError( User::RenameThread( KMscFileServerName ) );
    
    // Construct active scheduler
    CActiveScheduler* activeScheduler = new ( ELeave ) CActiveScheduler;
    CleanupStack::PushL( activeScheduler ) ;

    // Install active scheduler
    // We don't need to check whether an active scheduler is already installed
    // as this is a new thread, so there won't be one
    CActiveScheduler::Install( activeScheduler );

    // Construct our server
    CMscFileServer::NewLC(); // Anonymous

    RProcess::Rendezvous( KErrNone );

    // Start handling requests
    CActiveScheduler::Start();

    //===== thread stopped =====
    TRACE_INFO(( _L( "   MscFileServer thread stopped" ) ))
    CleanupStack::PopAndDestroy( 2, activeScheduler ); // Anonymous CMscFileServer
    
    TRACE_FUNC_EXIT
    }


TInt CMscFileServer::ThreadFunction( TAny* /*aNone*/ )
    {
    TRACE_FUNC_ENTRY
    CTrapCleanup* cleanupStack = CTrapCleanup::New();
    if ( !cleanupStack )
        {
        RThread::Rendezvous( KErrNoMemory );
        }

    TRAPD( err, ThreadFunctionL() )
    if ( err != KErrNone )
        {
        TRACE_ERROR(( _L( "*** Error! Thread leaves w/ %d ***" ), err ))
        RThread::Rendezvous( KErrNoMemory );        
        }

    delete cleanupStack;
    cleanupStack = NULL;

    TRACE_FUNC_EXIT
    return KErrNone;
    }


TInt E32Main()
    {
    return CMscFileServer::ThreadFunction( NULL );
    }