// 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 "cusbmassstoragecontroller.h"

#include "massstoragedebug.h"

#include "usbmsserversecuritypolicy.h"

/**

 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)

	{

    __PRINT(_L("CUsbMassStorageServer::CUsbMassStorageServer\n"));   

	}

/**

 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

	{

	TVersion v(KUsbMsSrvMajorVersionNumber,KUsbMsSrvMinorVersionNumber,KUsbMsSrvBuildVersionNumber);

	__PRINT(_L("CUsbMassStorageServer::NewSessionL\n"));

	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)

	{

	__PRINT1(_L("CUsbMassStorageServer::Error [aError=%d]\n"), 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()

	{

	__PRINT1(_L("CUsbMassStorageServer::IncrementSessionCount %d\n"), iSessionCount);

	__ASSERT_DEBUG(iSessionCount >= 0, User::Panic(KUsbMsSvrPncCat, EUsbMsPanicIllegalIPC));

	++iSessionCount;

	__PRINT(_L("CUsbMassStorageServer::IncrementSessionCount\n"));

	}

/**

 Decrement the open session count (iSessionCount) by one.

 @post		the number of open sessions is decremented by one

 */

void CUsbMassStorageServer::DecrementSessionCount()

	{

	__PRINT1(_L("CUsbMassStorageServer::DecrementSessionCount %d\n"), iSessionCount);

	__ASSERT_DEBUG(iSessionCount > 0, User::Panic(KUsbMsSvrPncCat, EUsbMsPanicIllegalIPC));

	--iSessionCount;

	}