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

// System includes

// 

//

// Local includes

#include "cnwsswsptrhnddatasupplier.h"

#include "tnwsswsptrhndpanic.h"

// Class signature

#include "cnwsstranslookuptable.h"

CNwssTransLookUpTable::CNwssTransLUTEntry* CNwssTransLookUpTable::CNwssTransLUTEntry::NewL()

	{

	return new(ELeave) CNwssTransLookUpTable::CNwssTransLUTEntry;

	}

CNwssTransLookUpTable::CNwssTransLUTEntry::CNwssTransLUTEntry()

	{

	}

CNwssTransLookUpTable::CNwssTransLUTEntry::~CNwssTransLUTEntry()

	{

	delete iResponseBodyHandler;

	}

CNwssTransLookUpTable* CNwssTransLookUpTable::NewL(TInt aTableSize)

	{

	CNwssTransLookUpTable* me = new(ELeave)CNwssTransLookUpTable();

	CleanupStack::PushL(me);

	me->ConstructL(aTableSize);

	CleanupStack::Pop(me);

	return me;

	}

CNwssTransLookUpTable::CNwssTransLookUpTable()

	{

	}

CNwssTransLookUpTable::~CNwssTransLookUpTable()

	{

	// Flush the look-up table.  Entries which are unused will delete OK since

	// when removed, their iResponseBodyHandler pointer is reset to NULL.

	iEntries.ResetAndDestroy();

	}

CNwssTransLookUpTable::CNwssTransLUTEntry& CNwssTransLookUpTable::NewEntry()

	{

	TInt numTableEntries = iEntries.Count();

#ifdef __UNIT_TESTING__

	if (numTableEntries == 0)

		// dummy return for testing only

		return *(REINTERPRET_CAST(CNwssTransLookUpTable::CNwssTransLUTEntry*, 1));

#endif

	__ASSERT_DEBUG(numTableEntries > 0, User::Invariant());

	CNwssTransLookUpTable::CNwssTransLUTEntry* retVal = NULL;

	if (iNumActiveLUTEntries < numTableEntries)

		retVal = iEntries[iNumActiveLUTEntries++];

#ifdef __UNIT_TESTING__

	else

		// dummy return for testing only

		return *(REINTERPRET_CAST(CNwssTransLookUpTable::CNwssTransLUTEntry*, 1));

#else

	else

		TNwssWspTrHndPanic::Panic(TNwssWspTrHndPanic::ETransLUTOverflow);

#endif

	return *retVal;

	}

CNwssTransLookUpTable::CNwssTransLUTEntry&

CNwssTransLookUpTable::LookUpByTransId(RWSPCOTrans::TTransID aTransId, TBool& aFound)

	{

	// Iterate the look-up-table until we find the entry whose transaction ID matches

	// the supplied value

	aFound = EFalse;

	TInt idx = 0;

	while (!aFound && (idx < iNumActiveLUTEntries))

		{

		if (iEntries[idx]->iStackTransID == aTransId)

			aFound = ETrue;

		else

			++idx;

		}

	if (aFound)

		return *(iEntries[idx]);

	// dummy return

	CNwssTransLookUpTable::CNwssTransLUTEntry* retVal = NULL;

	return *retVal;

	}

CNwssTransLookUpTable::CNwssTransLUTEntry&

CNwssTransLookUpTable::LookUpByCallback(MWspCOMethodCallback& aCallback, TBool& aFound)

	{

	// Locate the item in the table

	aFound = EFalse;

	TInt unused = KErrNotFound;

	CNwssTransLookUpTable::CNwssTransLUTEntry* lutEntry = LookUp(aCallback, unused);

	if (lutEntry)

		{

		aFound = ETrue;

		return *lutEntry;

		}

	// dummy return

	CNwssTransLookUpTable::CNwssTransLUTEntry* retVal = NULL;

	return *retVal;

	}

void CNwssTransLookUpTable::RemoveEntry(MWspCOMethodCallback& aCallback)

	{

	// Locate the item in the table

	TInt idx = KErrNotFound;

	CNwssTransLookUpTable::CNwssTransLUTEntry* lutEntry = LookUp(aCallback, idx);

	if (lutEntry)

		{

		iEntries.Remove(idx);

		--iNumActiveLUTEntries;

		// Reset the entry, so it can be recycled

		lutEntry->iCallback = NULL;

		delete lutEntry->iResponseBodyHandler;

		lutEntry->iResponseBodyHandler = NULL;

		lutEntry->iStackTrans = RWSPCOTrans();

		lutEntry->iStackTransID = 0;

		lutEntry->iAborted = EFalse;

		// Move the removed entry to the end of the table, to ensure the table remains

		// of constant size.  Note, this append will not leave, since the table size

		// was preallocated in ConstructL.

#if defined (_DEBUG) && defined(__UNIT_TESTING__)

		TInt err =

#endif

			iEntries.Append(lutEntry);

#ifdef __UNIT_TESTING__

		__ASSERT_DEBUG(err == KErrNone, 

					TNwssWspTrHndPanic::Panic(TNwssWspTrHndPanic::ETransLUTOverflow));

#endif

		}

	}

TBool CNwssTransLookUpTable::IsEmpty() const

	{

	return iNumActiveLUTEntries == 0;

	}

CNwssTransLookUpTable::CNwssTransLUTEntry& CNwssTransLookUpTable::Head(TBool& aFound)

	{

	// Are there any entries

	aFound = iNumActiveLUTEntries > 0;

	// Return the first entry

	if (aFound)

		return *(iEntries[0]);

	// dummy return

	CNwssTransLookUpTable::CNwssTransLUTEntry* retVal = NULL;

	return *retVal;

	}

void CNwssTransLookUpTable::ConstructL(TInt aTableSize)

	{

	CNwssTransLookUpTable::CNwssTransLUTEntry* entry;

	// Pre-allocate the look-up table

	for (TInt ii = 0; ii < aTableSize; ++ii)

		{

		entry = CNwssTransLookUpTable::CNwssTransLUTEntry::NewL();

		CleanupStack::PushL(entry);

		User::LeaveIfError(	iEntries.Append(entry) );

		CleanupStack::Pop(entry);

		}

	}

void CNwssTransLookUpTable::ResizeTableL(TInt aNewSize)

	{

	// Bail out now if the size doesn't change!

	const TInt oldSize = iEntries.Count();

	if (aNewSize == oldSize)

		return;

	CNwssTransLookUpTable::CNwssTransLUTEntry* entry = NULL;

	if (aNewSize > oldSize)

		{

		// Table is being enlarged - pre-allocate new entries

		for (TInt ii = 0; ii < (aNewSize - oldSize); ++ii)

			{

			entry = CNwssTransLookUpTable::CNwssTransLUTEntry::NewL();

			CleanupStack::PushL(entry);

			User::LeaveIfError(	iEntries.Append(entry) );

			CleanupStack::Pop(entry);

			}

		// High-water mark doesn't change in this situation

		}

	else

		{

		// Table is being shrunk - remove surplus entries

		for (TInt ii = oldSize - 1; ii >= aNewSize; --ii)

			{

			delete iEntries[ii];

			iEntries.Remove(ii);

			}

		// Adjust high-water mark

		if (iNumActiveLUTEntries > aNewSize)

			iNumActiveLUTEntries = aNewSize;

		}

	}

CNwssTransLookUpTable::CNwssTransLUTEntry*

CNwssTransLookUpTable::LookUp(MWspCOMethodCallback& aCallback, TInt& aIndex)

	{

	// Iterate the look-up-table until we find the entry whose transaction callback

	// matches the supplied value

	TBool found = EFalse;

	aIndex = 0;

	CNwssTransLookUpTable::CNwssTransLUTEntry* lutEntry = NULL;

	while (!found && (aIndex < iNumActiveLUTEntries))

		{

		lutEntry = iEntries[aIndex];

		if (lutEntry->iCallback == &aCallback)

			found = ETrue;

		else

			++aIndex;

		}

	if (!found)

		{

		aIndex = KErrNotFound;

		lutEntry = NULL;

		}

	return lutEntry;

	}