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

// f32\sfile\sf_raw.cpp

// 

//

#include "sf_std.h"

#include "sf_file_cache.h"

LOCAL_C CRawDiskCB* GetRawDiskFromHandle(TInt aHandle, CSessionFs* aSession)

//

// Get the rawdisk control block from aHandle

//

	{

	return((CRawDiskCB*)(SessionObjectFromHandle(aHandle,RawDisks->UniqueID(),aSession)));

	}

LOCAL_C void DoFsRawDiskOpenL(TInt& aHandle,CRawDiskCB*& aRawDisk, CFsRequest* aRequest)

//

// Do the bits that can leave

//

	{

	aRawDisk=new(ELeave) CRawDiskCB;

	RawDisks->AddL(aRawDisk,ETrue);

	aRawDisk->InitL(&aRequest->Drive()->CurrentMount(),aRequest->Drive()->IsWriteProtected());

	// modify resource counter after initialisation to ensure correct cleanup in object destruction

	AddDiskAccess(aRequest->Drive()->CurrentMount());

	aHandle=aRequest->Session()->Handles().AddL(aRawDisk,ETrue);

	}

TInt TFsRawDiskOpen::DoRequestL(CFsRequest* aRequest)

//

// Open direct disk access channel

//

	{

	__PRINT(_L("TFsRawDiskOpen::DoRequestL(CFsRequest* aRequest)"));

	TInt r=aRequest->Drive()->CheckMount();

	if (r==KErrNone && aRequest->Drive()->CurrentMount().LockStatus()<0)

		return(KErrInUse);

	if (r!=KErrNone)

		return(r);

	__ASSERT_DEBUG( aRequest->Drive()->CurrentMount().LockStatus()==0,Fault(ESvrRawDiskOpenFailed));

	TInt handle;

	CRawDiskCB* rawDisk=NULL;

	TRAPD(ret,DoFsRawDiskOpenL(handle,rawDisk,aRequest));

	if (ret!=KErrNone)

		{

		if(rawDisk)

			rawDisk->Close();

		return(ret);

		}

	r = rawDisk->Drive().FlushCachedFileInfo();

	if (r != KErrNone)

		return(r);

	// Empty the closed file container

	TClosedFileUtils::Remove();

	TPtrC8 pH((TUint8*)&handle,sizeof(TInt));

	aRequest->WriteL(KMsgPtr3,pH);

	aRequest->Session()->IncResourceCount();

	return(KErrNone);

	}

TInt TFsRawDiskOpen::Initialise(CFsRequest* aRequest)

//	

//

	{

	if (!KCapFsRawDiskOpen.CheckPolicy(aRequest->Message(), __PLATSEC_DIAGNOSTIC_STRING("Raw Disk Open")))

		return KErrPermissionDenied;

	TInt driveNo=aRequest->Message().Int0();

	return ValidateDriveDoSubst(driveNo,aRequest);

	}

TInt TFsRawDiskRead::DoRequestL(CFsRequest* aRequest)

//

// Do Raw Read

//

	{

	__PRINT(_L("TFsRawDiskRead::DoRequestL(CFsRequest* aRequest)"));

	CRawDiskCB* rawDisk=(CRawDiskCB*)aRequest->ScratchValue();

	TInt r=rawDisk->Drive().CheckMount();

	if (r!=KErrNone && r!=KErrInUse)

		return(r);

	if (&rawDisk->Mount()!=&rawDisk->Drive().CurrentMount())

		return(KErrDisMounted);

	TInt64 pos;

	TPtr8 tBuf((TUint8*)&pos,sizeof(TInt64));

	aRequest->ReadL(KMsgPtr2,tBuf);

	if ( pos < 0 )

		return(KErrArgument);

	TInt length=aRequest->Message().Int1();

	const TAny* pDes=aRequest->Message().Ptr0();

	TRACETHREADID(aRequest->Message());

	TRACE7(UTF::EBorder, UTraceModuleFileSys::ECMountCBRawReadL, EF32TraceUidFileSys, 

		aRequest->DriveNumber(), I64LOW(pos), I64HIGH(pos), length, pDes, 0, I64LOW(threadId));

	TRAP(r,rawDisk->Mount().RawReadL(pos,length,pDes,0,aRequest->Message()));

	TRACERET1(UTF::EBorder, UTraceModuleFileSys::ECMountCBRawReadLRet, EF32TraceUidFileSys, r);

	return(r);

	}

TInt TFsRawDiskRead::Initialise(CFsRequest* aRequest)

//

//

//

	{

	if (!KCapFsRawDiskRead.CheckPolicy(aRequest->Message(), __PLATSEC_DIAGNOSTIC_STRING("Raw Disk Read")))

		return KErrPermissionDenied;

	CRawDiskCB* rawDisk=GetRawDiskFromHandle(aRequest->Message().Int3(),aRequest->Session());

	if(!rawDisk)

		return(KErrBadHandle);

	aRequest->SetDrive(&rawDisk->Drive());

	aRequest->SetScratchValue((TUint)rawDisk);

	return KErrNone;

	}

TInt TFsRawDiskWrite::DoRequestL(CFsRequest* aRequest)

//

// Do Raw write

//

	{

	__PRINT(_L("TFsRawDiskWrite::DoRequestL(CFsRequest* aRequest)"));

	CRawDiskCB* rawDisk=(CRawDiskCB*)aRequest->ScratchValue();

	TInt r=rawDisk->Drive().CheckMount();

	if (r!=KErrNone && r!=KErrInUse)

		return(r);

	if (&rawDisk->Mount()!=&rawDisk->Drive().CurrentMount())

		return(KErrDisMounted);

	TInt64 pos;

	TPtr8 tBuf((TUint8*)&pos,sizeof(TInt64));

	aRequest->ReadL(KMsgPtr2,tBuf);

	if ( pos < 0 )

		return(KErrArgument);

	TInt length=aRequest->Message().Int1();

	const TAny* pDes=aRequest->Message().Ptr0();

	TRACETHREADID(aRequest->Message());

	TRACE7(UTF::EBorder, UTraceModuleFileSys::ECMountCBRawWriteL, EF32TraceUidFileSys, 

		aRequest->DriveNumber(), I64LOW(pos), I64HIGH(pos), length, pDes, 0, I64LOW(threadId));

	TRAP(r,rawDisk->Mount().RawWriteL(pos,length,pDes,0,aRequest->Message()));

	TRACERET1(UTF::EBorder, UTraceModuleFileSys::ECMountCBRawWriteLRet, EF32TraceUidFileSys, r);

	rawDisk->SetChanged();

	return(r);

	}

TInt TFsRawDiskWrite::Initialise(CFsRequest* aRequest)

//

//

//

	{

	if (!KCapFsRawDiskWrite.CheckPolicy(aRequest->Message(), __PLATSEC_DIAGNOSTIC_STRING("Raw Disk Write")))

		return KErrPermissionDenied;

	CRawDiskCB* rawDisk=GetRawDiskFromHandle(aRequest->Message().Int3(),aRequest->Session());

	if(!rawDisk)

		return(KErrBadHandle);

	if(rawDisk->IsWriteProtected())

		return(KErrAccessDenied);

	aRequest->SetDrive(&rawDisk->Drive());

	aRequest->SetScratchValue((TUint)rawDisk);

	return KErrNone;

	}

CRawDiskCB::CRawDiskCB()

//

// Constructor

//

	{

	}

CRawDiskCB::~CRawDiskCB()

//

// Destructor

//

	{

	if(iMount)

		{

		__ASSERT_DEBUG(iMount->LockStatus()>0,Fault(ERawDiskBadAccessCount));

		RemoveDiskAccess(*iMount);

		if(IsChanged())

			iMount->Drive().SetChanged(ETrue);

		iMount->Close();

		}

	}

void CRawDiskCB::InitL(CMountCB* aMount,TBool aIsWriteProtected)

//

// Initialise

//

	{

	DoInitL(aMount->Drive().DriveNumber());

	iMount=aMount;

	if(aIsWriteProtected)

		SetWriteProtected();

	User::LeaveIfError(iMount->Open());

	}