// Copyright (c) 2008-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:
//

/**
 @file
 @internalTechnology
*/

#include <e32base.h>

#include "msctypes.h"
#include "shared.h"
#include "msgservice.h"
#include "cusbhostmslogicalunit.h"
#include "cusbhostmsdevice.h"
#include "cusbhostmsserver.h"
#include "usbmshostpanic.h"
#include "cusbhostmsdevicethread.h"
#include "cusbhostmssession.h"
#include "msdebug.h"
#include "debug.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 CUsbHostMsSession object
 */
CUsbHostMsSession* CUsbHostMsSession::NewL(CUsbHostMsServer& aServer)
	{
    __MSFNSLOG
	CUsbHostMsSession* r = new (ELeave) CUsbHostMsSession(aServer);
	CleanupStack::PushL(r);
	r->ConstructL();
	CleanupStack::Pop();
	return r;
	}

/**
 Constructor.

	param	aServer	Service the session will be a member of
 */
CUsbHostMsSession::CUsbHostMsSession(CUsbHostMsServer& aServer)
	: iUsbHostMsServer(aServer)
	{
    __MSFNLOG
	}


/**
 2nd Phase Construction.
 */
void CUsbHostMsSession::ConstructL()
	{
    __MSFNLOG
	iUsbHostMsServer.IncrementSessionCount();
    __HOSTPRINT1(_L("\tiSessionCount: %d\n"), iUsbHostMsServer.SessionCount());
	}


/**
 Destructor.
 */
CUsbHostMsSession::~CUsbHostMsSession()
	{
    __MSFNLOG

	iUsbHostMsServer.DecrementSessionCount();
	iThread.Close();
    __HOSTPRINT1(_L("\tClosed a session -> iSessionCount: %d\n"), iUsbHostMsServer.SessionCount());
	}

/**
 Called when a message is received from the client.

	param	aMessage	Message received from the client
 */
void CUsbHostMsSession::ServiceL(const RMessage2& aMessage)
	{
    __MSFNLOG
	DispatchMessageL(aMessage);
	}


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

	param	aMessage	The received message
 */
void CUsbHostMsSession::DispatchMessageL(const RMessage2& aMessage)
	{
    __MSFNLOG
	TInt r = KErrNone;
	switch (aMessage.Function())
		{
	case EUsbHostMsRegisterInterface:
		TRAP(r, CreateDeviceThreadL(aMessage));
		if(r != KErrNone)
			{
			aMessage.Complete(r);
			return;
			}
		break;
	case EUsbHostMsUnRegisterInterface:
		iCleanupInProgress = ETrue;
		break;
	/* If it is a cleanup then we need to delete the iDeviceThread */
	case EUsbHostMsFinalCleanup:	
		delete iDeviceThread;
		iDeviceThread = NULL;
		iThread.Kill(KErrNone);
		aMessage.Complete(KErrNone);
		return;
	default:
		break;
		}

	if (iDeviceThread == NULL || iCleanupInProgress ) 
		{
		aMessage.Complete(KErrBadHandle);
		return;
		}


	r = iDeviceThread->QueueMsg(aMessage);
	if (r != KErrNone)
		{
		aMessage.Complete(r);
		return;
		}

	if (iClientStatus && *iClientStatus == KRequestPending)
		{
		__HOSTPRINT(_L("Signaling device thread to handle message"));
		iThread.RequestComplete(iClientStatus, KErrNone);
		}
	}


void CUsbHostMsSession::CreateDeviceThreadL(const RMessage2& aMessage)
	{
    __MSFNLOG
	THostMassStorageConfig msDeviceConfig;
	TPtr8 ptr((TUint8*)&msDeviceConfig,sizeof(THostMassStorageConfig));

	aMessage.ReadL(0, ptr);
	__HOSTPRINT1(_L("EUsbHostMsRegisterInterface Token=%d "), msDeviceConfig.iInterfaceToken);

    TBuf<32> nameBuf;
	nameBuf.Format(_L("Host Ms Thread%8x"), msDeviceConfig.iInterfaceToken);
	iDeviceThread = CUsbHostMsDeviceThread::NewL(*this, msDeviceConfig.iInterfaceToken);

	RHeap* h = (RHeap*)&User::Allocator();
	TInt maxsize = h->MaxLength();	// loader heap max size = file server heap max size
	const TUint KHeapMinSize = 2048;

	TInt r = iThread.Create(nameBuf, CUsbHostMsDeviceThread::Entry, KDefaultStackSize, KHeapMinSize, maxsize, iDeviceThread);
	if(r != KErrNone)
		{
		delete iDeviceThread;
        iDeviceThread = NULL;
		User::Leave(r);
		}
	iThread.SetPriority(EPriorityAbsoluteBackgroundNormal);
	TRequestStatus status;
	iThread.Rendezvous(status);
	iThread.Resume();
	User::WaitForRequest(status);
	if(status != KErrNone)
		{
		delete iDeviceThread;
        iDeviceThread = NULL;
		iThread.Kill(KErrNone);
		User::Leave(status.Int());
		}
	}



void CUsbHostMsSession::MessageRequest(TRequestStatus& aStatus)
    {
    __MSFNLOG
    iClientStatus = &aStatus;
    *iClientStatus = KRequestPending;
    }