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

/**
 @file
 @internalTechnology
*/

#include <e32svr.h>
#include "usbmsshared.h"
#include "cusbmassstorageserver.h"
#include "cusbmassstoragesession.h"
#include "drivemanager.h"
#include "cusbmassstoragecontroller.h"
#include "smassstorage.h"
#include "usbmsserversecuritypolicy.h"

#include "OstTraceDefinitions.h"
#ifdef OST_TRACE_COMPILER_IN_USE
#include "cusbmassstorageserverTraces.h"
#endif

/**
 Constructs a USB mass storage Server

 @return  a pointer to CUsbMassStorageServer object
 */
CUsbMassStorageServer* CUsbMassStorageServer::NewLC(CUsbMassStorageController& aController)
    {
    CUsbMassStorageServer* r = new (ELeave) CUsbMassStorageServer(aController);
    CleanupStack::PushL(r);
    r->StartL(KUsbMsServerName);
    return r;
    }

/**
 Destructor
 */
CUsbMassStorageServer::~CUsbMassStorageServer()
    {
    // Intentionally left blank
    }


/**
 Constructor

 @param aController a USB mass storage controller reference
 */
CUsbMassStorageServer::CUsbMassStorageServer(CUsbMassStorageController& aController)
     : CPolicyServer(EPriorityHigh,KUsbMsServerPolicy)
    , iController(aController)
    {
    OstTraceFunctionEntry0(CUSBMASSSTORAGESERVER_100);
    }

/**
 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* CUsbMassStorageServer::NewSessionL(const TVersion &aVersion, const RMessage2& /*aMessage*/) const
    {
    OstTraceFunctionEntry0(CUSBMASSSTORAGESERVER_110);
    TVersion v(KUsbMsSrvMajorVersionNumber,KUsbMsSrvMinorVersionNumber,KUsbMsSrvBuildVersionNumber);
    if (!User::QueryVersionSupported(v, aVersion))
        User::Leave(KErrNotSupported);

    CUsbMassStorageServer* ncThis = const_cast<CUsbMassStorageServer*>(this);
    CUsbMassStorageSession* sess = CUsbMassStorageSession::NewL(*ncThis);
    return sess;
    }


/**
 Inform the client there has been an error.

 @param aError  The error that has occurred
 */
void CUsbMassStorageServer::Error(TInt aError)
    {
    OstTrace1(TRACE_SMASSSTORAGE_FS, CUSBMASSSTORAGESERVER_120,
              "aError=%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 CUsbMassStorageServer::IncrementSessionCount()
    {
    OstTrace1(TRACE_SMASSSTORAGE_FS, CUSBMASSSTORAGESERVER_130,
              "SessionCount=%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 CUsbMassStorageServer::DecrementSessionCount()
    {
    OstTrace1(TRACE_SMASSSTORAGE_FS, CUSBMASSSTORAGESERVER_140,
              "SessionCount=%d", iSessionCount);
    __ASSERT_DEBUG(iSessionCount > 0, User::Panic(KUsbMsSvrPncCat, EUsbMsPanicIllegalIPC));
    --iSessionCount;
    }