// 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 <e32std.h>

#include <e32std_private.h>

#include "msgservice.h"

#include "rusbhostmsdevice.h"

#include "rusbhostmslogicalunit.h"

#include "debug.h"

TVersion RUsbHostMsLogicalUnit::Version() const

	{

	return(TVersion(KUsbHostMsSrvMajorVersionNumber,

                    KUsbHostMsSrvMinorVersionNumber,

                    KUsbHostMsSrvBuildVersionNumber));

	}

EXPORT_C RUsbHostMsLogicalUnit::RUsbHostMsLogicalUnit()

	{

	// Intentionally left blank

	}

/**

Send a command to initialise the Mass Storage device.

@param aMsg

@param aDevHandleIndex

@param aLun

@return TInt

*/

EXPORT_C TInt RUsbHostMsLogicalUnit::Initialise(const RMessage2& aMsg,

                                                TInt aDevHandleIndex,

												TUint32 aLun)

	{

	__FNLOG("RUsbHostMsLogicalUnit::Initialise");

	TInt r = dev.Open(aMsg, aDevHandleIndex);

	if (r != KErrNone)

		{

		__PRINT1(_L("Session handle can not be opened %d"),r);

		return r;

		}

	r = CreateSubSession(dev, EUsbHostMsRegisterLun, TIpcArgs(aLun));

	if (r != KErrNone)

		{

		__PRINT1(_L("SubSession creation failed %d"),r);

		return r;

		}

	return r;

	}

/**

Send a command to read the Mass Storage device.

@param aPos Position to start reading from

@param aLength Number of Bytes

@param aTrg Buffer to copy data to

@return TInt KErrNone, if the send operation is successful;

	KErrServerTerminated, if the server no longer present; KErrServerBusy, if there are no message slots available;

	KErrNoMemory, if there is insufficient memory available.

*/

EXPORT_C TInt RUsbHostMsLogicalUnit::Read(TInt64 aPos, TInt aLength, TDes8& aTrg)

	{

	__FNLOG("RUsbHostMsLogicalUnit::Read");

	TReadWrite data;

	data.iPos = aPos;

	data.iLen = aLength;

	__PRINT2(_L("pos = 0x%lx, len = x%x"), data.iPos, data.iLen);

	TPckg<TReadWrite> pckg(data);

	/* We handle the message asynchronously in the thread modelled MSC */

	TRequestStatus	status;

	SendReceive(EUsbHostMsRead, TIpcArgs(&pckg, &aTrg), status);

	User::WaitForRequest(status);

    __PRINT2(_L("pos = 0x%lx, len = x%x"), data.iPos, data.iLen);

	return status.Int();

	}

/**

Send a command to write to the Mass Storage device.

@param aPos Position to start reading from

@param aLength Number of Bytes

@param aTrg Buffer to copy data from

@return TInt KErrNone, if the send operation is successful;

	KErrServerTerminated, if the server no longer present; KErrServerBusy, if there are no message slots available;

	KErrNoMemory, if there is insufficient memory available.

available.

*/

EXPORT_C TInt RUsbHostMsLogicalUnit::Write(TInt64 aPos, TInt aLength, const TDesC8& aTrg)

	{

	__FNLOG("RUsbHostMsLogicalUnit::Write");

	TReadWrite data;

	data.iPos = aPos;

	data.iLen = aLength;

	__PRINT2(_L("pos = 0x%lx, len = x%x"), data.iPos, data.iLen);

	TPckg<TReadWrite> pckg(data);

	/* We handle the message asynchronously in the thread modelled MSC */

	TRequestStatus	status;

	SendReceive(EUsbHostMsWrite, TIpcArgs(&aTrg, &pckg), status);

	User::WaitForRequest(status);

	return status.Int();

	}

/**

Send a command to erase an area of the Mass Storage device.

@param aPos Position to start reading from

@param aLength Number of Bytes

@return TInt KErrNone, if the send operation is successful;

	KErrServerTerminated, if the server no longer present; KErrServerBusy, if there are no message slots available;

	KErrNoMemory, if there is insufficient memory available.

available.

*/

EXPORT_C TInt RUsbHostMsLogicalUnit::Erase(TInt64 aPos, TInt aLength)

	{

	__FNLOG("RUsbHostMsLogicalUnit::Erase");

	TReadWrite data;

	data.iPos = aPos;

	data.iLen = aLength;

	__PRINT2(_L("pos = 0x%lx, len = x%x"), data.iPos, data.iLen);

	TPckg<TReadWrite> pckg(data);

	/* We handle the message asynchronously in the thread modelled MSC */

	TRequestStatus	status;

	SendReceive(EUsbHostMsErase, TIpcArgs(&pckg), status);

	User::WaitForRequest(status);

	return status.Int();

	}

/**

Send a command to get the nedia's capacity info.

@param aCapsInfo [OUT] A buffer to copy the capacity info to.

@return TInt KErrNone, if the send operation is successful;

KErrServerTerminated, if the server no longer present; KErrServerBusy, if there

are no message slots available; KErrNoMemory, if there is insufficient memory

available.

*/

EXPORT_C TInt RUsbHostMsLogicalUnit::Caps(TCapsInfo& aCapsInfo)

	{

	__FNLOG("RUsbHostMsLogicalUnit::Caps");

    TPckg<TCapsInfo> data(aCapsInfo);

	/* We handle the message asynchronously in the thread modelled MSC */

	TRequestStatus	status;

	SendReceive(EUsbHostMsCapacity, TIpcArgs(&data),status);

	User::WaitForRequest(status);

	return status.Int();

	}

/**

Request notification of media change to the file server

@param aChanged The descriptor pointing to iChanged flag in TDrive to be updated

when error occurs during read or write.

@param aStatus The request status This is set to KErrNone on completion, or KErrCancel when the logical unit is closed;

	KErrServerTerminated, if the server no longer present; KErrServerBusy, if there are no message slots available;

	KErrNoMemory, if there is insufficient memory available.

@return None

*/

EXPORT_C void RUsbHostMsLogicalUnit::NotifyChange(TDes8& aChanged, TRequestStatus &aStatus)

	{

	__FNLOG("RUsbHostMsLogicalUnit::NotifyChange");

	SendReceive(EUsbHostMsNotifyChange, TIpcArgs(&aChanged), aStatus);

	}

/**

Request to suspend the logical unit associated with this drive

*/

EXPORT_C void RUsbHostMsLogicalUnit::SuspendLun()

	{

	__FNLOG("RUsbHostMsLogicalUnit::SuspendLun");

	SendReceive(EUsbHostMsSuspendLun, TIpcArgs(NULL));

	}

/**

Close the sub-session.

@return TInt KErrNone

*/

EXPORT_C TInt RUsbHostMsLogicalUnit::UnInitialise()

	{

	__FNLOG("RUsbHostMsLogicalUnit::UnInitialise");

	CloseSubSession(EUsbHostMsUnRegisterLun);

	dev.Close();

	return KErrNone;

	}

/**

Request that the drive is remounted.

@param aFlags Flags to be passed to the drive

@return EXPORT_C TInt KErrNone, if the send operation is successful;

KErrServerTerminated, if the server no longer present; KErrServerBusy, if there

are no message slots available; KErrNoMemory, if there is insufficient memory

available.

*/

EXPORT_C TInt RUsbHostMsLogicalUnit::ForceRemount(TUint aFlags)

	{

	__FNLOG("RUsbHostMsLogicalUnit::ForceRemount");

	__PRINT1(_L("flags = %d"), aFlags);

	TRequestStatus	status;

	SendReceive(EUsbHostMsForceRemount, TIpcArgs(aFlags), status);

	User::WaitForRequest(status);

	return status.Int();

	}

EXPORT_C void RUsbHostMsLogicalUnit::NotifyChangeCancel()

	{

	__FNLOG("RUsbHostMsLogicalUnit::NotifyChangeCancel");

	SendReceive(EUsbHostMsCancelChangeNotifier, TIpcArgs(NULL));

	}