// 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 "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:

// Object index

// 

//

#include "WSOBJIX.H"

#include "OBJECT.H"

#include "server.h"

#include "panics.h"

const TInt KNewObjectInitialCount = 1;

CWsObjectIx::CWsObjectIx() : iObjectArray(8), iNewObjectCount(KNewObjectInitialCount)

	{

	}

CWsObjectIx::~CWsObjectIx()

	{

	TInt count=iObjectArray.Count();

	if (count==0)

		return;

	TWsObject* ptr=&iObjectArray[0];

	const TWsObject* end=ptr+count;

	for (;ptr<end;ptr++)

		{

		CWsObject* obj=ptr->iObject;

		if (obj)

			{

			obj->CloseObject();

			}

		}

	iObjectArray.Reset();

	}

void CWsObjectIx::ConstructL()

	{

	// Insert a dummy object into the first slot to avoid

	// having a null handle

	TWsObject nullObject(NULL,0);

	iObjectArray.AppendL(nullObject);

	}

/** Adds the object to the list.

If there is an empty slot (i.e. a slot that was previously used but has been freed) the

object is put in that slot else a new slot is created at the end of the array.

@param anObj The object to add to the list.

@return The handle to be used by the client to identify this object.

@internalComponent

@released

*/

TInt CWsObjectIx::AddL(CWsObject* anObj)

	{

	TWsObject* ptr=&iObjectArray[0];

	const TWsObject* base=ptr;

	TInt index=iObjectArray.Count();

	const TWsObject* end=ptr+index;

	WS_ASSERT_DEBUG(base->iObject==NULL, EWsPanicObjectIndexError);

	// Search for an empty slot

	while(++ptr<end)

		{

		if (ptr->iObject==NULL)

			{

			ptr->iObject=anObj;

			index=ptr-base;

			break;

			}

		}

	// create a new handle for the object

	TUint handleCount = ((iNewObjectCount<<TWsObject::ECountPosition) + TWsObject::ECountInc) & TWsObject::ECountMask;

	if (ptr==end)

		{

		// No available empty slot, so append this object to the queue

		if (index==TWsObject::ECountInc)

			{

			User::LeaveNoMemory();	//Things will go wrong later if we ever have more 64K objects

			}	

		TWsObject newObject(anObj,handleCount);

		iObjectArray.AppendL(newObject);

		ptr=&iObjectArray[index];

		}

	// assign the object a unique server-side handle (combination of handle count & object type)

	ptr->iHandle = handleCount | anObj->Type();

	// increment the object counter

	if (++iNewObjectCount==TWsObject::ECountWrapAround)

		iNewObjectCount = KNewObjectInitialCount;

	// return to the client their unique handle for the object (combination of handle count & slot number)

	return (handleCount + index);

	}	 

void CWsObjectIx::Tidy()

	{

	TInt count=iObjectArray.Count()-1;

	while(count>0)	// Don't delete object [0]

		{

		if (iObjectArray[count].iObject!=NULL)

			break;

		iObjectArray.Delete(count--);

		}

	}

void CWsObjectIx::Remove(CWsObject* anObj)

	{

	const TWsObject* ptr=FirstObject();

	const TWsObject* end=ptr+iObjectArray.Count();

	WS_ASSERT_DEBUG(ptr->iObject==NULL, EWsPanicObjectIndexError);

	while(++ptr<end)

		{

		if (ptr->iObject==anObj)

			{

			Remove(ptr);

			Tidy();

			return;

			}

		}

	}

void CWsObjectIx::Remove(const TWsObject* aObject)

	{

	WS_ASSERT_DEBUG(aObject->iObject!=NULL, EWsPanicObjectIndexError);

	WS_ASSERT_DEBUG((aObject->iHandle&TWsObject::ETypeMask)==(TUint)aObject->iObject->Type(), EWsPanicObjectIndexError);

	const_cast<TWsObject*>(aObject)->iObject=NULL;

	}

CWsObject* CWsObjectIx::HandleToObject(TInt aHandle) const

	{

	TInt slot=aHandle&TWsObject::ESlotMask;

	if (slot<0 || slot>=iObjectArray.Count())

		return(NULL);

	const TWsObject* object=&iObjectArray[slot];

	if ((object->iHandle&TWsObject::ECountMask)==((TUint)aHandle&TWsObject::ECountMask))

		{

		return object->iObject;

		}

	return(NULL);

	}

const TWsObject* CWsObjectIx::FirstObject() const

	{

	return(&iObjectArray[0]);

	}

TInt CWsObjectIx::At(const CWsObject* anObj)

	{

	const TWsObject* base=FirstObject();

	const TWsObject* ptr=base;

	const TWsObject* end=base+iObjectArray.Count();

	WS_ASSERT_DEBUG(ptr->iObject==NULL, EWsPanicObjectIndexError);

	while(++ptr<end)

		{

		if (ptr->iObject==anObj && (ptr->iHandle&TWsObject::ETypeMask)==(TUint)anObj->Type())

			return(ptr-base);

		}

	return(KErrNotFound);

	}

TInt CWsObjectIx::Count() const

	{

	const TWsObject* ptr=FirstObject();

	const TWsObject* end=ptr+iObjectArray.Count();

	WS_ASSERT_DEBUG(ptr->iObject==NULL, EWsPanicObjectIndexError);

	TInt count=0;

	while(++ptr<end)

		{

		if (ptr->iObject && ptr->iObject->Type()!=WS_HANDLE_CLIENT)

			count++;

		}

	return(count);

	}

TInt CWsObjectIx::Length() const

	{

	return(iObjectArray.Count());

	}