// Copyright (c) 1995-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_ses.cpp

// 

//

#include "sf_std.h"

#include "sf_file_cache.h"

#include "sf_memory_man.h"

#ifdef SYMBIAN_F32_ENHANCED_CHANGE_NOTIFICATION	

#include "sf_notifier.h"

#endif //SYMBIAN_F32_ENHANCED_CHANGE_NOTIFICATION	

CSessionFs::CSessionFs()

	       :iSessionFlags((TInt)EFsSessionFlagsAll), 

          iReservedDriveAccess(KReservedDriveAccessArrayGranularity, _FOFF(TReservedDriveAccess, iDriveNumber)),

	       iId(0)

	{

#if defined(_DEBUG) || defined(_DEBUG_RELEASE)

    __e32_atomic_add_ord32(&SessionCount, 1);

#endif

	}

CSessionFs *CSessionFs::NewL()

	{

	return new(ELeave) CSessionFs;

	}

CSessionFs::~CSessionFs()

	{

	__PRINT1(_L("CSessionFs::~CSessionFs() deleting... = 0x%x"),this);

	//take out all the reserved space set by this session

	while(iReservedDriveAccess.Count())

		{

		TReservedDriveAccess& reserved = iReservedDriveAccess[0];

		if(reserved.iReservedSpace)

			{

			TheDrives[reserved.iDriveNumber].SetReservedSpace(TheDrives[reserved.iDriveNumber].ReservedSpace() - reserved.iReservedSpace);

			__ASSERT_DEBUG(TheDrives[reserved.iDriveNumber].ReservedSpace() >= 0,Fault(EReserveSpaceArithmetic));

			}

		iReservedDriveAccess.Remove(0);

		}

	iReservedDriveAccess.Close();

	//	Need to free the requests that we own from the close queue

	while (iCloseRequestCount > 0)

		RequestAllocator::OpenSubFailed(this);

	if (iHandles)

		delete iHandles;

	delete iPath;

	iSessionFlagsLock.Close();

	if(iDisconnectRequest)

		delete(iDisconnectRequest);

#if defined(_DEBUG) || defined(_DEBUG_RELEASE)

    __e32_atomic_add_ord32(&SessionCount, (TUint32) -1);

#endif

	}

void CSessionFs::CreateL()

//

// Create any additional resources.

//

	{

	__PRINT1(_L("CSessionFs::CreateL 0x%x"),this);

	iHandles=CFsObjectIx::NewL();

	TInt r = iSessionFlagsLock.CreateLocal();

	User::LeaveIfError(r);

	RMessage2 m;

	iDisconnectRequest=new(ELeave) CFsDisconnectRequest;

	iDisconnectRequest->Set(m,SessionDisconnectOp,this);

	}

TInt CSessionFs::CurrentDrive()

//

// Return the current drive.

//

	{

	TInt d;

	TInt r=RFs::CharToDrive(Path()[0],d);

	__ASSERT_ALWAYS(r==KErrNone,Fault(ESesPathBadDrive));

	return(d);

	}

TInt CSessionFs::CountResources()

//

// Return the number of resources owned by the session

//

	{

	/* what's this supposed to be doing ??

	TInt count=User::LockedInc(iResourceCount);

	User::LockedDec(iResourceCount);

	return(count);

	*/

	return iResourceCount;	// ... because that's all it does.

	}

void CSessionFs::ResourceCountMarkStart()

//

//	Mark resources at this point

//

	{

	iResourceCountMark = CountResources();

	}

void CSessionFs::ResourceCountMarkEnd(const RMessage2& aMessage)

//

//	End resource count and check same as count start

//

	{

	if (iResourceCountMark!=CountResources())

		{

		_LIT(KCategory,"CSessionFs");

		aMessage.Panic(KCategory,ESesFoundResCountHeaven);

		}

	else

		aMessage.Complete(KErrNone);

	}

void CSessionFs::Disconnect(const RMessage2& aMessage)

	{

	__THRD_PRINT1(_L("CSessionFs::Disconnect() 0x%x"),this);

	iHandles->CloseMainThreadObjects();

	iDisconnectRequest->SetMessage((RMessage2&)aMessage);

	iDisconnectRequest->Dispatch();

	}

TUint CSessionFs::Reserved(TInt aDriveNumber) const

	{

	TReservedDriveAccess reserved(aDriveNumber);

    TInt idx = iReservedDriveAccess.Find(reserved);

    if(idx == KErrNotFound)

        return 0;

    return iReservedDriveAccess[idx].iReservedSpace;

	}

TInt CSessionFs::SetReserved(const TInt aDriveNumber, const TInt aReservedValue)

	{

	TReservedDriveAccess reserved(aDriveNumber, aReservedValue);

	TInt idx = iReservedDriveAccess.Find(reserved);

	if(idx == KErrNotFound)

		return iReservedDriveAccess.InsertInSignedKeyOrder(reserved);

	iReservedDriveAccess[idx].iReservedSpace = aReservedValue;

	return KErrNone;

	}

TBool CSessionFs::ReservedAccess(TInt aDriveNumber) const

	{

	TReservedDriveAccess reserved(aDriveNumber);

	TInt idx = iReservedDriveAccess.Find(reserved);

	return idx == KErrNotFound ? EFalse : iReservedDriveAccess[idx].iReservedAccess;

	}

void CSessionFs::SetReservedAccess(const TInt aDriveNumber, const TBool aReservedAccess)

	{

	TReservedDriveAccess reserved(aDriveNumber);

    TInt idx = iReservedDriveAccess.Find(reserved);

    if(idx != KErrNotFound)

        iReservedDriveAccess[idx].iReservedAccess = aReservedAccess;

	}

TBool CSessionFs::IsChangeNotify()

	{

	return TestSessionFlags(EFsSessionNotifyChange);

	}

TBool CSessionFs::TestSessionFlags(TUint32 aFlags)

	{

	iSessionFlagsLock.Wait();

	TBool b = (iSessionFlags & aFlags) == aFlags;

	iSessionFlagsLock.Signal();

	return(b);

	}

void CSessionFs::SetSessionFlags(TUint32 aBitsToSet, TUint32 aBitsToClear)

	{

	iSessionFlagsLock.Wait();

	iSessionFlags &= ~aBitsToClear;

	iSessionFlags |= aBitsToSet;

	iSessionFlagsLock.Signal();

	}

void CSessionFs::CloseRequestCountInc()

	{

	iSessionFlagsLock.Wait();

	iCloseRequestCount++;	

	iSessionFlagsLock.Signal();

	}

void CSessionFs::CloseRequestCountDec()

	{

	iSessionFlagsLock.Wait();

	iCloseRequestCount--;

	iSessionFlagsLock.Signal();

	}

//

// Start resource count

//

TInt TFsResourceCountMarkStart::DoRequestL(CFsRequest* aRequest)

	{

	aRequest->Session()->ResourceCountMarkStart();

	return(KErrNone);

	}

TInt TFsResourceCountMarkStart::Initialise(CFsRequest* /*aRequest*/)

	{

	return KErrNone;

	}

//

//  Check for resource heaven

//

TInt TFsResourceCountMarkEnd::DoRequestL(CFsRequest* aRequest)

	{

	aRequest->Session()->ResourceCountMarkEnd(aRequest->Message());

	return(KErrNone);

	}

TInt TFsResourceCountMarkEnd::Initialise(CFsRequest* /*aRequest*/)

	{

	return KErrNone;

	}

//

// Return the number of resources owned by the session

//

TInt TFsResourceCount::DoRequestL(CFsRequest* aRequest)

	{

	TInt resCount=aRequest->Session()->CountResources();

	TPckgC<TInt> pckg(resCount);

	aRequest->WriteL(KMsgPtr0,pckg);

	return(KErrNone);

	}

TInt TFsResourceCount::Initialise(CFsRequest* /*aRequest*/)

	{

	return KErrNone;

	}

//

// Set iNotifyUser

//

void CSessionFs::SetNotifyUser(TBool aNotification)

	{

	if(aNotification)

		{

		SetSessionFlags(EFsSessionNotifyUser, 0);

		}

	else

		{

		SetSessionFlags(0, EFsSessionNotifyUser);

		}

	}

//

// Get iNotifyUser

//

TBool CSessionFs::GetNotifyUser()

	{

	return TestSessionFlags(EFsSessionNotifyUser);

	}

//

// Notify the user of any read or write failure

//

TInt TFsSetNotifyUser::DoRequestL(CFsRequest* aRequest)

	{

	TBool notification=aRequest->Message().Int0();

	aRequest->Session()->SetNotifyUser(notification);

	return(KErrNone);

	}

TInt TFsSetNotifyUser::Initialise(CFsRequest* /*aRequest*/)

	{

	return KErrNone;

	}

//

// Notify the user of any read or write failure

//

TInt TFsGetNotifyUser::DoRequestL(CFsRequest* aRequest)

	{

	TBool notification=aRequest->Session()->GetNotifyUser();

	TPtrC8 pA((TUint8*)&notification,sizeof(TBool));

	aRequest->WriteL(KMsgPtr0,pA);

	return(KErrNone);

	}

TInt TFsGetNotifyUser::Initialise(CFsRequest* /*aRequest*/)

	{

	return KErrNone;

	}

//

// Get the drive name

//

TInt TFsGetDriveName::DoRequestL(CFsRequest* aRequest)

	{

	TInt driveNum=aRequest->Drive()->DriveNumber();

	TFileName driveName;

	if (TheDriveNames[driveNum]==NULL)

		driveName.SetLength(0);

	else

		driveName=(*TheDriveNames[driveNum]);

	aRequest->WriteL(KMsgPtr1,driveName);

	return(KErrNone);

	}

TInt TFsGetDriveName::Initialise(CFsRequest* aRequest)

	{

	TInt r=ValidateDrive(aRequest->Message().Int0(),aRequest);

	return(r);

	}

//

// Set the drive name

//

TInt TFsSetDriveName::DoRequestL(CFsRequest* aRequest)

	{

	TInt driveNum=aRequest->Drive()->DriveNumber();

	TFileName driveName;

	aRequest->ReadL(KMsgPtr1,driveName);

//	Validate name - return KErrBadName if it contains illegal characters such as

//	* ? / | > <

	TNameChecker checker(driveName);

	TText badChar;

	if (checker.IsIllegalName(badChar))

		return(KErrBadName);

	TInt len=((driveName.Length()+31)>>5)<<5; // % 32

	if (TheDriveNames[driveNum]==NULL)

		TheDriveNames[driveNum]=HBufC::New(len);

	else if (TheDriveNames[driveNum]->Des().MaxLength()<len)

		{

		HBufC* temp=TheDriveNames[driveNum]->ReAlloc(len);

		if (temp==NULL)

			return(KErrNoMemory);

		TheDriveNames[driveNum]=temp;

		}

	if (TheDriveNames[driveNum]==NULL || TheDriveNames[driveNum]->Des().MaxLength()<len)

		return(KErrNoMemory);

	*TheDriveNames[driveNum]=driveName;

	return(KErrNone);

	}

TInt TFsSetDriveName::Initialise(CFsRequest* aRequest)

	{

	TInt r=ValidateDrive(aRequest->Message().Int0(),aRequest);

	if (r!=KErrNone)

		return(r);

	if (!KCapFsSetDriveName.CheckPolicy(aRequest->Message(), __PLATSEC_DIAGNOSTIC_STRING("Set Drive Name")))

		return KErrPermissionDenied;

	return KErrNone;

	}

TInt FlushCachedFiles(CSessionFs* aSession)

	{

	TInt retVal = KErrNone;

	aSession->Handles().Lock();

	TInt count = aSession->Handles().Count();

	for (TInt n=0; n<count; n++)

		{

		CObjPromotion* obj = (CObjPromotion*)aSession->Handles()[n];

		if (obj != NULL && obj->UniqueID() == FileShares->UniqueID())

			{

			CFileShare* share = (CFileShare*) obj;

			if (!share->IsCorrectThread())

				continue;

			CFileCB& file=((CFileShare*) obj)->File();

			CFileCache* fileCache = file.FileCache();

			if (fileCache)

				{

				retVal = fileCache->FlushDirty();

				if (retVal == CFsRequest::EReqActionBusy)

					break;

				}

			}

		}

	aSession->Handles().Unlock();

	return retVal;

	}

TInt TFsFlushDirtyData::DoRequestL(CFsRequest* aRequest)

//

//

//

	{

	__CHECK_DRIVETHREAD(aRequest->DriveNumber());

	// Flush all dirty data

	TInt r = FlushCachedFiles(aRequest->Session());

	if (r == CFsRequest::EReqActionBusy)

		return r;

	return KErrNone;

	}

TInt TFsFlushDirtyData::Initialise(CFsRequest* /*aRequest*/)

//

//

//

	{

	return(KErrNone);

	}

// Iterate though all file shares owned by this session and cancel any async requests

TInt CancelAsyncRequests(CSessionFs* aSession)

	{

	TInt retVal = KErrNone;

	aSession->Handles().Lock();

	TInt count = aSession->Handles().Count();

	for (TInt n=0; n<count; n++)

		{

		CObjPromotion* obj = (CObjPromotion*)aSession->Handles()[n];

		if (obj != NULL && obj->UniqueID() == FileShares->UniqueID())

			{

			CFileShare* share = (CFileShare*) obj;

			if (!share->IsCorrectThread())

				continue;

			CFileCB& file=((CFileShare*) obj)->File();

			file.CancelAsyncReadRequest(share, NULL);

			}

		}

	aSession->Handles().Unlock();

	return retVal;

	}

TInt TFsCancelSession::DoRequestL(CFsRequest* aRequest)

	{

	__CHECK_DRIVETHREAD(aRequest->DriveNumber());

	// Cancel any outstanding requests

	CDriveThread* pT=NULL;

	TInt r=FsThreadManager::GetDriveThread(aRequest->DriveNumber(), &pT);

	if(r==KErrNone)

		pT->CompleteSessionRequests(aRequest->Session(),KErrCancel);

	// We must also cancel any ASYNC requests belonging to this session BEFORE 

	// ~CSessionFs() is called to avoid a KERN-EXEC 44 (EBadMessageHandle)

	CancelAsyncRequests(aRequest->Session());

	return(r);

	}

TInt TFsCancelSession::Initialise(CFsRequest* /*aRequest*/)

	{

	return(KErrNone);

	}

TInt TFsSessionDisconnect::DoRequestL(CFsRequest* aRequest)

	{

	__PRINT(_L("TFsSessionDisconnect::DoRequestL()"));

	__ASSERT_DEBUG(FsThreadManager::IsDisconnectThread(),Fault(ESessionDisconnectThread1));

	CDisconnectThread* pT=FsThreadManager::GetDisconnectThread();

	// Complete requests on all plugins

	CFsInternalRequest* pR=pT->GetRequest();

	FsPluginManager::CompleteSessionRequests(aRequest->Session(), KErrCancel, pR);

	// ...and on all drives

	for(TInt i=0;i<KMaxDrives;++i)

		{

		FsThreadManager::LockDrive(i);

		if(!FsThreadManager::IsDriveAvailable(i,EFalse)||FsThreadManager::IsDriveSync(i,EFalse))

			{

			FsThreadManager::UnlockDrive(i);

			continue;

			}

		pR->Set(CancelSessionOp,aRequest->Session());

		pR->SetDriveNumber(i);

		pR->Status()=KRequestPending;

		pR->Dispatch();

		FsThreadManager::UnlockDrive(i);

		User::WaitForRequest(pR->Status());

		// check request completed or cancelled (by file system dismount which completes requests with KErrNotReady)

		__ASSERT_ALWAYS(pR->Status().Int()==KErrNone||pR->Status().Int()==KErrNotReady,Fault(ESessionDisconnectThread2));

		__THRD_PRINT2(_L("cancel session requests on drive %d r=%d"),i,pR->Status().Int());