// 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 Session of a Symbian OS server for the RUsbMassStorage API

 // 

 //

 /**

  @file

  @internalTechnology

 */

 #include "cusbmassstoragesession.h"

 #include "cusbmassstoragecontroller.h"

 #include "cusbmassstorageserver.h"

 #include "usbmsshared.h"

 /**

  Construct a Symbian OS session object.

  @param	aServer		Service the session will be a member of

  @param	aMessage	The message from the client.

  @return	A new CUsbMassStorageSession object

  */

 CUsbMassStorageSession* CUsbMassStorageSession::NewL(CUsbMassStorageServer& aServer)

 	{

 	CUsbMassStorageSession* r = new (ELeave) CUsbMassStorageSession(aServer);

 	CleanupStack::PushL(r);

 	r->ConstructL();

 	CleanupStack::Pop();

 	return r;

 	}

 /**

  Constructor.

  @param	aServer	Service the session will be a member of

  */

 CUsbMassStorageSession::CUsbMassStorageSession(CUsbMassStorageServer& aServer)

 	: iUsbMsServer(aServer)

 	{

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

 	}

 /**

  2nd Phase Construction.

  */

 void CUsbMassStorageSession::ConstructL()

 	{

 	iUsbMsServer.IncrementSessionCount();

     if (iUsbMsServer.SessionCount() > 1)

         {

         __PRINT1(_L("\tiSessionCount: %d\n"), iUsbMsServer.SessionCount());

         // Only one session is allowed

         User::Leave(KErrInUse);

         }        

  	}

 /**

  Destructor.

  */

 CUsbMassStorageSession::~CUsbMassStorageSession()

 	{

 	iUsbMsServer.DecrementSessionCount();

 	}

 /**

  Called when a message is received from the client.

  @param	aMessage	Message received from the client

  */

 void CUsbMassStorageSession::ServiceL(const RMessage2& aMessage)

 	{

 	DispatchMessageL(aMessage);

 	}

 /**

  Handles the request (in the form of a the message) received from the client

  @internalTechnology

  @param	aMessage	The received message

  */

 void CUsbMassStorageSession::DispatchMessageL(const RMessage2& aMessage)

 	{

 	TInt ret = KErrNone;

 	switch (aMessage.Function())

 		{

 	case EUsbMsStart:

 		ret = Start(aMessage);

 		break;

 	case EUsbMsStop:

 		ret = Stop();

 		break;

 	case EUsbMsShutdown:

 		ret = Shutdown();

 		break;

 	default:

 		aMessage.Panic(KUsbMsCliPncCat, EUsbMsPanicIllegalIPC);

 		break;

 		}

 	aMessage.Complete(ret);

 	}

 /**

  Client request to start the device.

  @return	Any error that occurred or KErrNone

  */

 TInt CUsbMassStorageSession::Start(const RMessage2& aMessage)

 	{

 	__PRINT(_L("CUsbMassStorageSession::Start\n"));

 	TMassStorageConfig msConfig;

 	TRAPD(err, GetMsConfigL(aMessage, msConfig));

 	if (err != KErrNone)

 		{

 		__PRINT(_L("Failed to get mass storage configuration data\n"));

 		return err;

 		}

 	return iUsbMsServer.Controller().Start(msConfig);

 	}

 /**

  Client request to stop the device.

  @return	Any error that occurred or KErrNone

  */

 TInt CUsbMassStorageSession::Stop()

     {

     __PRINT(_L("CUsbMassStorageSession::Stop\n"));

     TInt err = iUsbMsServer.Controller().Stop();

 	return err;

 	}

 /**

  Client request to shut down the server

  @return KErrNone

  */

 TInt CUsbMassStorageSession::Shutdown()

     {

     __PRINT(_L("CUsbMassStorageSession::Shutdown\n"));

     CActiveScheduler::Stop();

 	return KErrNone;

 	}

  /**

   Get mass storage configuration data from the received message

   */

  void CUsbMassStorageSession::GetMsConfigL(const RMessage2& aMessage, TMassStorageConfig& aMsStorage)

  	{

  	aMessage.ReadL(0,aMsStorage.iVendorId);

  	aMessage.ReadL(1,aMsStorage.iProductId);

  	aMessage.ReadL(2,aMsStorage.iProductRev);

  	}