sl@0: // Copyright (c) 1996-2009 Nokia Corporation and/or its subsidiary(-ies).
sl@0: // All rights reserved.
sl@0: // This component and the accompanying materials are made available
sl@0: // under the terms of "Eclipse Public License v1.0"
sl@0: // which accompanies this distribution, and is available
sl@0: // at the URL "http://www.eclipse.org/legal/epl-v10.html".
sl@0: //
sl@0: // Initial Contributors:
sl@0: // Nokia Corporation - initial contribution.
sl@0: //
sl@0: // Contributors:
sl@0: //
sl@0: // Description:
sl@0: // Object index
sl@0: // 
sl@0: //
sl@0: 
sl@0: #include "WSOBJIX.H"
sl@0: 
sl@0: #include "OBJECT.H"
sl@0: #include "server.h"
sl@0: #include "panics.h"
sl@0: 
sl@0: const TInt KNewObjectInitialCount = 1;
sl@0: 
sl@0: CWsObjectIx::CWsObjectIx() : iObjectArray(8), iNewObjectCount(KNewObjectInitialCount)
sl@0: 	{
sl@0: 	}
sl@0: 
sl@0: CWsObjectIx::~CWsObjectIx()
sl@0: 	{
sl@0: 	TInt count=iObjectArray.Count();
sl@0: 	if (count==0)
sl@0: 		return;
sl@0: 	TWsObject* ptr=&iObjectArray[0];
sl@0: 	const TWsObject* end=ptr+count;
sl@0: 	for (;ptr<end;ptr++)
sl@0: 		{
sl@0: 		CWsObject* obj=ptr->iObject;
sl@0: 		if (obj)
sl@0: 			{
sl@0: 			obj->CloseObject();
sl@0: 			}
sl@0: 		}
sl@0: 	iObjectArray.Reset();
sl@0: 	}
sl@0: 
sl@0: void CWsObjectIx::ConstructL()
sl@0: 	{
sl@0: 	// Insert a dummy object into the first slot to avoid
sl@0: 	// having a null handle
sl@0: 	TWsObject nullObject(NULL,0);
sl@0: 	iObjectArray.AppendL(nullObject);
sl@0: 	}
sl@0: 
sl@0: /** Adds the object to the list.
sl@0: 
sl@0: If there is an empty slot (i.e. a slot that was previously used but has been freed) the
sl@0: object is put in that slot else a new slot is created at the end of the array.
sl@0: 
sl@0: @param anObj The object to add to the list.
sl@0: @return The handle to be used by the client to identify this object.
sl@0: @internalComponent
sl@0: @released
sl@0: */
sl@0: TInt CWsObjectIx::AddL(CWsObject* anObj)
sl@0: 	{
sl@0: 	TWsObject* ptr=&iObjectArray[0];
sl@0: 	const TWsObject* base=ptr;
sl@0: 	TInt index=iObjectArray.Count();
sl@0: 	const TWsObject* end=ptr+index;
sl@0: 	WS_ASSERT_DEBUG(base->iObject==NULL, EWsPanicObjectIndexError);
sl@0: 	
sl@0: 	// Search for an empty slot
sl@0: 	while(++ptr<end)
sl@0: 		{
sl@0: 		if (ptr->iObject==NULL)
sl@0: 			{
sl@0: 			ptr->iObject=anObj;
sl@0: 			index=ptr-base;
sl@0: 			break;
sl@0: 			}
sl@0: 		}
sl@0: 	
sl@0: 	// create a new handle for the object
sl@0: 	TUint handleCount = ((iNewObjectCount<<TWsObject::ECountPosition) + TWsObject::ECountInc) & TWsObject::ECountMask;
sl@0: 	
sl@0: 	if (ptr==end)
sl@0: 		{
sl@0: 		// No available empty slot, so append this object to the queue
sl@0: 		if (index==TWsObject::ECountInc)
sl@0: 			{
sl@0: 			User::LeaveNoMemory();	//Things will go wrong later if we ever have more 64K objects
sl@0: 			}	
sl@0: 		TWsObject newObject(anObj,handleCount);
sl@0: 		iObjectArray.AppendL(newObject);
sl@0: 		ptr=&iObjectArray[index];
sl@0: 		}
sl@0:  
sl@0: 	// assign the object a unique server-side handle (combination of handle count & object type)
sl@0: 	ptr->iHandle = handleCount | anObj->Type();
sl@0: 
sl@0: 	// increment the object counter
sl@0: 	if (++iNewObjectCount==TWsObject::ECountWrapAround)
sl@0: 		iNewObjectCount = KNewObjectInitialCount;
sl@0:  	
sl@0: 	// return to the client their unique handle for the object (combination of handle count & slot number)
sl@0: 	return (handleCount + index);
sl@0: 	}	 
sl@0: 
sl@0: void CWsObjectIx::Tidy()
sl@0: 	{
sl@0: 	TInt count=iObjectArray.Count()-1;
sl@0: 	while(count>0)	// Don't delete object [0]
sl@0: 		{
sl@0: 		if (iObjectArray[count].iObject!=NULL)
sl@0: 			break;
sl@0: 		iObjectArray.Delete(count--);
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CWsObjectIx::Remove(CWsObject* anObj)
sl@0: 	{
sl@0: 	const TWsObject* ptr=FirstObject();
sl@0: 	const TWsObject* end=ptr+iObjectArray.Count();
sl@0: 	WS_ASSERT_DEBUG(ptr->iObject==NULL, EWsPanicObjectIndexError);
sl@0: 	while(++ptr<end)
sl@0: 		{
sl@0: 		if (ptr->iObject==anObj)
sl@0: 			{
sl@0: 			Remove(ptr);
sl@0: 			Tidy();
sl@0: 			return;
sl@0: 			}
sl@0: 		}
sl@0: 	}
sl@0: 
sl@0: void CWsObjectIx::Remove(const TWsObject* aObject)
sl@0: 	{
sl@0: 	WS_ASSERT_DEBUG(aObject->iObject!=NULL, EWsPanicObjectIndexError);
sl@0: 	WS_ASSERT_DEBUG((aObject->iHandle&TWsObject::ETypeMask)==(TUint)aObject->iObject->Type(), EWsPanicObjectIndexError);
sl@0: 	const_cast<TWsObject*>(aObject)->iObject=NULL;
sl@0: 	}
sl@0: 
sl@0: CWsObject* CWsObjectIx::HandleToObject(TInt aHandle) const
sl@0: 	{
sl@0: 	TInt slot=aHandle&TWsObject::ESlotMask;
sl@0: 	if (slot<0 || slot>=iObjectArray.Count())
sl@0: 		return(NULL);
sl@0: 	const TWsObject* object=&iObjectArray[slot];
sl@0: 	if ((object->iHandle&TWsObject::ECountMask)==((TUint)aHandle&TWsObject::ECountMask))
sl@0: 		{
sl@0: 		return object->iObject;
sl@0: 		}
sl@0: 	return(NULL);
sl@0: 	}
sl@0: 
sl@0: const TWsObject* CWsObjectIx::FirstObject() const
sl@0: 	{
sl@0: 	return(&iObjectArray[0]);
sl@0: 	}
sl@0: 
sl@0: TInt CWsObjectIx::At(const CWsObject* anObj)
sl@0: 	{
sl@0: 	const TWsObject* base=FirstObject();
sl@0: 	const TWsObject* ptr=base;
sl@0: 	const TWsObject* end=base+iObjectArray.Count();
sl@0: 	WS_ASSERT_DEBUG(ptr->iObject==NULL, EWsPanicObjectIndexError);
sl@0: 	while(++ptr<end)
sl@0: 		{
sl@0: 		if (ptr->iObject==anObj && (ptr->iHandle&TWsObject::ETypeMask)==(TUint)anObj->Type())
sl@0: 			return(ptr-base);
sl@0: 		}
sl@0: 	return(KErrNotFound);
sl@0: 	}
sl@0: 
sl@0: TInt CWsObjectIx::Count() const
sl@0: 	{
sl@0: 	const TWsObject* ptr=FirstObject();
sl@0: 	const TWsObject* end=ptr+iObjectArray.Count();
sl@0: 	WS_ASSERT_DEBUG(ptr->iObject==NULL, EWsPanicObjectIndexError);
sl@0: 	TInt count=0;
sl@0: 	while(++ptr<end)
sl@0: 		{
sl@0: 		if (ptr->iObject && ptr->iObject->Type()!=WS_HANDLE_CLIENT)
sl@0: 			count++;
sl@0: 		}
sl@0: 	return(count);
sl@0: 	}
sl@0: 
sl@0: TInt CWsObjectIx::Length() const
sl@0: 	{
sl@0: 	return(iObjectArray.Count());
sl@0: 	}