// Copyright (c) 2002-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_obj.cpp

// 

//

#include "sf_std.h"

const TInt KObjectIxGranularity=8;		

const TInt KObjectConGranularity=8;

const TInt KObjectConIxGranularity=4;

const TInt KObjectIndexMask=0x7fff;

const TInt KObjectMaxIndex=0x7fff;

const TInt KObjectInstanceShift=16;

const TInt KObjectInstanceMask=0x3fff;

const TInt KObjectUniqueIDShift=16;

const TInt KObjectIxMaxHandles=0x8000;

inline TInt index(TInt aHandle)

	{return(aHandle&KObjectIndexMask);}

inline TInt instance(TInt aHandle)

	{return((aHandle>>KObjectInstanceShift)&KObjectInstanceMask);}

inline TInt instanceLimit(TInt& aCount)

	{return ((aCount&KObjectInstanceMask)==0) ? ((++aCount)&KObjectInstanceMask) : aCount&KObjectInstanceMask;}

inline TInt makeHandle(TInt anIndex,TInt anInstance)

	{return((TInt)((anInstance<<KObjectInstanceShift)|anIndex));}

inline TInt uniqueID(TInt aHandle)

	{return((aHandle>>KObjectUniqueIDShift)&KObjectInstanceMask);}

inline TInt makeFindHandle(TInt anIndex,TInt anUniqueID)

	{return((TInt)((anUniqueID<<KObjectUniqueIDShift)|anIndex));}

CFsObjectConIx* CFsObjectConIx::NewL()

//

// Create an instance of this class.

//

	{

	return new(ELeave) CFsObjectConIx;

	}

CFsObjectConIx::CFsObjectConIx()

//

// Constructor

//

	: iNextUniqueID(1)

	{

	}

CFsObjectConIx::~CFsObjectConIx()

//

// Destructor

//

	{

	if (iCount)

		{

		TInt i=-1;

		while(++i<iCount)

			{

			CFsObjectCon* pS=iContainers[i];

			delete pS;

			}

		}

	delete iContainers;

	}

void CFsObjectConIx::CreateContainerL(CFsObjectCon*& aContainer)

//

// Actually create the container

//

	{

	aContainer=CFsObjectCon::NewL();

	aContainer->iUniqueID=iNextUniqueID;

	if (iCount==iAllocated)

		{

		TInt newAlloc=iAllocated+KObjectConIxGranularity;

		iContainers=(CFsObjectCon**)User::ReAllocL(iContainers, newAlloc*sizeof(CFsObjectCon*));

		iAllocated=newAlloc;

		}

	iContainers[iCount++]=aContainer;

	}

CFsObjectCon* CFsObjectConIx::CreateL()

//

// Create a new container.

//

	{

	CFsObjectCon* pC=NULL;

	TRAPD(r,CreateContainerL(pC))

	if (r!=KErrNone)

		{

		delete pC;

		User::Leave(r);

		}

	iNextUniqueID++;

	return pC;

	}

void CFsObjectConIx::Remove(CFsObjectCon* aCon)

//

// Remove a container from the index.

//

	{

	if (!aCon)

		return;

	CFsObjectCon** pS=iContainers;

	CFsObjectCon** pE=pS+iCount;

	while(pS<pE)

		{

		if (*pS==aCon)

			{

			Mem::Move((TAny*)pS,(TAny*)(pS+1),TInt(pE)-TInt(pS)-sizeof(CFsObjectCon*));

			TInt newAlloc=--iCount;

			newAlloc=(newAlloc+(KObjectConIxGranularity-1))&~(KObjectConIxGranularity-1);

			if (newAlloc!=iAllocated)

				{

				if (newAlloc)

					iContainers=(CFsObjectCon**)User::ReAlloc(iContainers,newAlloc*sizeof(CFsObjectCon*));

				else

					{

					delete iContainers;

					iContainers=NULL;

					}

				iAllocated=newAlloc;

				}

			delete aCon;

			return;

			}

		pS++;

		}

	Fault(EObjRemoveContainerNotFound);

	}

/**

Constructs the object and initializes the reference count to one. 

Once constructed, a reference counting object cannot be deleted until its 

reference count is reduced to zero. 

@see CFsObject::Close

*/

EXPORT_C CFsObject::CFsObject()

	{

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

	__e32_atomic_add_ord32(&ObjectCount, 1);

#endif

//	iContainer=NULL;

//	iName=NULL;

	iAccessCount=1;

	}

/**

Destructor.

Deallocates memory associated with this objects name, if a name 

has been set.

@panic FSERV 104 if the reference count is not zero when

       the destructor is called.

*/

EXPORT_C  CFsObject::~CFsObject()

	{

	__PRINT1(_L("CFsObject::~CFsObject() 0x%x"),this);

	__ASSERT_ALWAYS(Dec()==0,Fault(EObjDestructorAccessCount));	

	__ASSERT_ALWAYS(!iContainer,Fault(EObjDestructorContainer));

	if(iName)

		User::Free(iName);

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

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

#endif

	}

/**

Opens this reference counting object.

The default behaviour increments the reference count by one. 

Where a derived class implements its own version of this function, it must 

either use the protected member function Inc() to increment the reference 

count or make a base call to this function.

@return KErrNone, or another system-wide error code.

*/

EXPORT_C TInt CFsObject::Open()

	{

	TInt count=Inc();

	(void)count;

	__THRD_PRINT2(_L("CFsObject::Open() object=0x%x count=%d"),this,count);

	__ASSERT_DEBUG(count>=1,Fault(EFsObjectOpen));

	return KErrNone;

	}

/**

Removes an assigned container object then deletes this reference

counting object.

*/

void CFsObject::DoClose()

	{

	__THRD_PRINT(_L("CFsObject::DoClose()"));

	if(iContainer)

		{

		iContainer->Remove(this,ETrue);

		iContainer=NULL;

		}

	delete(this);

	}

/**

Closes this reference counting object.

The default behaviour decrements the reference count by one. If this becomes 

zero, then the function calls DoClose on this reference counting object.

Where a derived class implements its own version of this function, it can 

use the protected member functions Dec() & DoClose() or make a base call to 

this function.

@see CFsObject::DoClose

*/

EXPORT_C void CFsObject::Close()

	{

	__THRD_PRINT(_L("CFsObject::Close()"));

	if(Dec()==1)

		DoClose();

	}

/**

Determine if this object is within the correct drive thread context 

for file based operations.

The default behaviour is to return True.

A derived class implementation is required.

@return ETrue

*/

EXPORT_C TBool CFsObject::IsCorrectThread()

	{

	return(ETrue);

	}

/**

Sets or clears this reference counting object's name.

To set the name, the specified descriptor must contain the name to be set. 

Once the name has been successfully set, then the specified source descriptor 

can be discarded.

To clear an existing name, specify a NULL argument.

@param aName A pointer to the descriptor containing the name to be set, or 

             NULL if an existing name is to be cleared.

@return KErrNone if the function is successful;

        KErrNoMemory if there is insufficient memory available.

@panic USER 11 if the length of aName is greater than KMaxName

       for a 16-bit descriptor.

@panic USER 23 if the length of aName is greater than KMaxName

       for an 8-bit descriptor.

*/

EXPORT_C TInt CFsObject::SetName(const TDesC *aName)

	{

	User::Free(iName);

	iName=NULL;

	if (aName!=NULL)

		{

		iName=aName->Alloc();

		if (iName==NULL)

			return(KErrNoMemory);

		}

	return(KErrNone);

	}

/**

Gets the name of this reference counting object.

The default behaviour provided by this function depends on whether a name 

has been explicitly set into the object:

If a name has previously been set, then the function returns that name.

If a name has not been set, then the function returns NULL.

@return A modifiable buffer descriptor with a defined maximum length containing 

        the name of this reference counting object or a TName with no contents.

*/

EXPORT_C TName CFsObject::Name() const

	{

	if (iName)

		return(*iName);

	TName empty;

	return empty;

	}

/**

Gets the Unique ID of the assigned object container to this object.

@return A unique number for file system container objects.

*/

TInt CFsObject::UniqueID() const {return(iContainer->UniqueID());}

CFsObjectIx* CFsObjectIx::NewL()

//

// Create an instance of this class.

//

	{

	CFsObjectIx* pO=new(ELeave) CFsObjectIx;

	TInt r=pO->iLock.CreateLocal();

	if(r!=KErrNone)

		{

		delete(pO);

		User::Leave(r);

		}

	return(pO);

	}

CFsObjectIx::CFsObjectIx()

//

// Constructor

//

	: iNextInstance(1)

	{

//	iAllocated=0;

//	iNumEntries=0;

//	iHighWaterMark=0;

//	iObjects=NULL;

	}

/**

    Close all objects that were created in the main file server thread.

    For sync. drives all objects must be closed in the main file server thread, because

    they are created in this thread, as soon as all synch. requests are processed there.

*/

void CFsObjectIx::CloseMainThreadObjects()

	{

	__ASSERT_DEBUG(FsThreadManager::IsMainThread(),Fault(EObjectIxMainThread));

	__PRINT(_L("CFsObjectIx::CloseThreadObjects()"));

	Lock();

	// We have to be very careful here. Calling Close() on the objects in the array

	// may result in other entries being removed from the array before we delete

	// them here, and may result in the array being ReAlloc()ed, corrupting the removed

	// entries, hence we must check the iHighWaterMark value each time round the loop.

	TInt i=-1;

	while(++i<iHighWaterMark)

		{

		SFsObjectIxRec* pS=iObjects+i;

		CFsObject *pO=pS->obj;

		if (pO && pO->IsCorrectThread())

			{

			// invalidate entry before closing it

			pS->obj=NULL;

			pO->Close();	

			}

		}

	Unlock();

	}

CFsObjectIx::~CFsObjectIx()

//

// Destructor

// Assumes that no need to lock

//

	{

	__PRINT1(_L("CFsObjectIx::~CFsObjectIx() 0x%x"),this);

	// We have to be very careful here. Calling Close() on the objects in the array

	// may result in other entries being removed from the array before we delete

	// them here, and may result in the array being ReAlloc()ed, corrupting the removed

	// entries, hence we must check the iHighWaterMark value each time round the loop.

	TInt i=-1;

	while(++i<iHighWaterMark)

		{

		SFsObjectIxRec* pS=iObjects+i;

		CFsObject *pO=pS->obj;

		if (pO)

			{

			// invalidate entry before closing it

			pS->obj=NULL;

			pO->Close();	

			}

		}

	delete iObjects;

	iLock.Close();

	}

TInt CFsObjectIx::AddL(CFsObject* anObj,TBool aLock)

//

// Add a new object to the index.

//

	{

	if(aLock)

		Lock();

	SFsObjectIxRec *pS=iObjects;

	SFsObjectIxRec *pE=pS+iHighWaterMark;

	TInt i=0;

	TInt inc=0;

	while(pS<pE && pS->obj)

		pS++, i++;

	if (pS==pE)

		inc=1;

	if (pS==pE && iAllocated==iHighWaterMark)

		{

		// no slots free, so reallocate array

		if (iHighWaterMark==KObjectIxMaxHandles)

			{

			if(aLock)

				Unlock();

			User::LeaveNoMemory();

			}

		TInt newAlloc=iAllocated + KObjectIxGranularity;

		SFsObjectIxRec* pA=(SFsObjectIxRec*)User::ReAlloc(iObjects, newAlloc*sizeof(SFsObjectIxRec));

		if(!pA)

			{

			if(aLock)

				Unlock();

			User::Leave(KErrNoMemory);

			}

		iObjects=pA;

		iAllocated=newAlloc;

		i=iHighWaterMark;

		pS=pA+i;

		}

	pS->obj=anObj;

	pS->uniqueID=(TUint16)anObj->UniqueID();

	pS->instance=(TUint16)instanceLimit(iNextInstance);

	iNextInstance++;

	iHighWaterMark+=inc;

	++iNumEntries;

	TInt h=makeHandle(i,pS->instance);

	if(aLock)

		Unlock();

	return(h);

	}

void CFsObjectIx::Remove(TInt aHandle,TBool aLock)

//

// Remove an object from the index.

//

	{

	if(aLock)

		Lock();

	TInt i=index(aHandle);

	__ASSERT_ALWAYS(i<iHighWaterMark,Fault(EObjRemoveBadHandle));

	SFsObjectIxRec* pR=iObjects+i;

	CFsObject *pO=pR->obj;

	if (!pO || pR->instance!=instance(aHandle) || pR->uniqueID!=pO->UniqueID())

		Fault(EObjRemoveBadHandle);

	pR->obj=NULL;

	--iNumEntries;

	if (i==iHighWaterMark-1)

		{

		do

			{

			i--;

			pR--;

			} while(i>=0 && !pR->obj);

		TInt newAlloc=(i+KObjectIxGranularity)&~(KObjectIxGranularity-1);

		if (newAlloc!=iAllocated)

			{

			if (newAlloc)

				iObjects=(SFsObjectIxRec*)User::ReAlloc(iObjects,newAlloc*sizeof(SFsObjectIxRec));

			else

				{

				delete iObjects;

				iObjects=NULL;

				}

			iAllocated=newAlloc;

			}

		iHighWaterMark=i+1;

		}

	if(aLock)

		Unlock();

	pO->Close();

	}

CFsObject *CFsObjectIx::At(TInt aHandle,TInt aUniqueID,TBool aLock)

//

// Return the object from its handle.

//

	{

	if(aLock)

		Lock();

	TInt i=index(aHandle);

	if (i>=iHighWaterMark)

		{

		if(aLock)

			Unlock();

		return NULL;

		}

	SFsObjectIxRec *pS=iObjects+i;

	if (pS->instance!=instance(aHandle) || pS->uniqueID!=aUniqueID)

		{

		if(aLock)

			Unlock();

		return NULL;

		}