// Copyright (c) 2007-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:
// This file provides the implementation for the thread entry.
// @internalComponent
// @prototype
// 
//

#include "e32base.h"				// defines CleanupStack

#include "netupsthreadentry.h"
#include "netupsdatabaseentry.h"
#include "netupsprocessentry.h"
#include "netupssubsession.h"
#include "netupsthreadmonitor.h"
#include "netupspolicycheckrequestqueue.h"
#include "netupsassert.h"

#include <ups/upsclient.h>

#include <comms-infras/commsdebugutility.h> 		// defines the comms debug logging utility

namespace NetUps
{
__FLOG_STMT(_LIT8(KNetUpsSubsys, 	"esock");)   
__FLOG_STMT(_LIT8(KNetUpsComponent, "NetUps");) /*esockloader*/

CThreadEntry* CThreadEntry::NewL(CDatabaseEntry& aDatabaseEntry, CProcessEntry& aProcessEntry, const TThreadId& aThreadId, UserPromptService::RUpsSession& aUpsSession)
	{
	CThreadEntry* self = new (ELeave) CThreadEntry(aThreadId);

	CleanupStack::PushL(self);
	self->ConstructL(aDatabaseEntry, aProcessEntry, aUpsSession);
	CleanupStack::Pop(self);

	return self;
	}

CThreadEntry::CThreadEntry(const TThreadId& aThreadId) :  iIsDead(EFalse), iThreadId(aThreadId), iThreadMonitor(NULL)
	{
	}
	
void CThreadEntry::ConstructL(CDatabaseEntry& aDatabaseEntry, CProcessEntry& aProcessEntry, UserPromptService::RUpsSession& aUpsSession)
	{
	__FLOG_OPEN(KNetUpsSubsys, KNetUpsComponent);

	iSubSession 	= CSubSession::NewL(aUpsSession, aDatabaseEntry, aProcessEntry, *this);
	iQueue 			= CPolicyCheckRequestQueue::NewL(*iSubSession); 
	iThreadMonitor 	= CThreadMonitor::NewL(aDatabaseEntry, aProcessEntry, *this);

	__FLOG_6(_L("CThreadEntry %08x:\tConstructL(), iIsDead = %d, thread id = %d, iThreadMonitor = %08x, iSubSession = %08x, iQueue = %08x"), this, iIsDead, iThreadId.Id(), iThreadMonitor, iSubSession, iQueue);	
	}

CThreadEntry::~CThreadEntry() 
	{
	__FLOG_1(_L("CThreadEntry %08x:\t~CThreadEntry()"), this);

	for (TInt i = iConnectionEntry.Count() - 1; i >=0; --i )
		{
		delete iConnectionEntry[i];
		}	
	iConnectionEntry.Reset();
	iConnectionEntry.Close();

	delete	iThreadMonitor;
	delete	iSubSession;
	delete  iQueue;

	__FLOG_CLOSE;	
	}

TBool CThreadEntry::FindConnectionEntry(const Messages::TNodeId& aCommsId, TInt32& aIndex)
	{
	TBool found = EFalse;
	for (TInt i = iConnectionEntry.Count() - 1; i >=0; --i)
		{
		if (iConnectionEntry[i]->CommsId() == aCommsId)
			{
			aIndex = i;
			found = ETrue;
			break;
			}
		}
		
	return found;	
	}

void CThreadEntry::AddCommsIdL(const Messages::TNodeId& aCommsId)
	{
	//__FLOG_2(_L("CThreadEntry %08x:\t AddCommsIdL(), aCommsId = %d"), this, aCommsId.Printable());
	__FLOG_1(_L("CThreadEntry %08x:\tAddCommsIdL()"), this);

	TInt32 index = 0;
	TBool found = FindConnectionEntry(aCommsId, index);
		
	if (found == EFalse)
		{
		CConnectionEntry* connectionEntry = CConnectionEntry::NewL(aCommsId, (TInt) 0);
		CleanupStack::PushL(connectionEntry);
		iConnectionEntry.AppendL(connectionEntry);
		CleanupStack::Pop(connectionEntry);
		}		
	}

TBool CThreadEntry::RemoveCommsId(const Messages::TNodeId& aCommsId)
	{
	//__FLOG_2(_L("CThreadEntry %08x:\tRemoveCommsId(), aCommsId %08x"), this, aCommsId);
	__FLOG_1(_L("CThreadEntry %08x:\tRemoveCommsId()"), this);

	TInt32 index = 0;
	TBool found = FindConnectionEntry(aCommsId, index);

	TBool commsIdRemoved = EFalse;
	if (found && (iConnectionEntry[index]->Count() == 0))
		{
		delete iConnectionEntry[index];
		iConnectionEntry[index] = 0;
		iConnectionEntry.Remove(index);			
		commsIdRemoved = ETrue;
		}

	return commsIdRemoved;
	}

void CThreadEntry::IncrementConnectionCount(const Messages::TNodeId& aCommsId)
	{
	//__FLOG_2(_L("CThreadEntry %08x:\t IncrementConnectionCount(), aCommsId = %d"), this, aCommsId.Printable());
	__FLOG_1(_L("CThreadEntry %08x:\t IncrementConnectionCount()"), this);

	TInt32 index = 0;
	TBool found = FindConnectionEntry(aCommsId, index);
		
	if (found == EFalse)
		{
		User::Panic(KNetUpsPanic, KPanicInvalidLogic);					
		}	
	else
		{
		iConnectionEntry[index]->IncrementCount();	
		}
	}

void CThreadEntry::IncrementConnectionCountL(const Messages::TNodeId& aCommsId)
	{
	//__FLOG_2(_L("CThreadEntry %08x:\t IncrementConnectionCount(), aCommsId = %d"), this, aCommsId.Printable());
	__FLOG_1(_L("CThreadEntry %08x:\tIncrementConnectionCountL()"), this);

	TInt32 index = 0;
	TBool found = FindConnectionEntry(aCommsId, index);
		
	if (found == EFalse)
		{
		CConnectionEntry* connectionEntry = CConnectionEntry::NewL(aCommsId, (TInt) 1);
		CleanupStack::PushL(connectionEntry);
		iConnectionEntry.AppendL(connectionEntry);
		CleanupStack::Pop(connectionEntry);
		}
	else
		{
		iConnectionEntry[index]->IncrementCount();
		}		
	}

void CThreadEntry::DecrementConnectionCount(const Messages::TNodeId& aCommsId)
	{
	//__FLOG_2(_L("CThreadEntry %08x:\t DecrementConnectionCount(), aCommsId = %d"), this, aCommsId.Printable());
	__FLOG_1(_L("CThreadEntry %08x:\tDecrementConnectionCount()"), this);

	TInt32 index = 0;
	TBool found = FindConnectionEntry(aCommsId, index);

	if (found == EFalse)
		{
		User::Panic(KNetUpsPanic, KPanicInvalidLogic);
		}
	else
		{
		iConnectionEntry[index]->DecrementCount();
		if (iConnectionEntry[index]->Count() == 0)
			{
			delete iConnectionEntry[index];
			iConnectionEntry[index] = 0;
			iConnectionEntry.Remove(index);
			}
		}		
	}

TInt32 CThreadEntry::ConnectionCount()
	{
	__FLOG_1(_L("CThreadEntry %08x:\tConnectionCount()"), this);

	TInt32 count = 0;
	
	for (TInt i = iConnectionEntry.Count() - 1; i >=0; --i )
		{
		count+= iConnectionEntry[i]->Count();
		}	

	__FLOG_2(_L("\tcount = %d"), this, count);
	
	return count;
	}

TInt32	CThreadEntry::ConnectionCount(const Messages::TNodeId& aCommsId)
	{
	//__FLOG_2(_L("CThreadEntry %08x:\t ConnectionCount(), aCommsId = %d"), this, aCommsId.Printable());
	__FLOG_1(_L("CThreadEntry %08x:\t ConnectionCount()"), this);

	TInt32 index = 0;
	TInt32 count = 0;
	TBool found = FindConnectionEntry(aCommsId, index);

	if (found == EFalse)
		{
		User::Panic(KNetUpsPanic, KPanicInvalidLogic);
		}
	else
		{
		count = iConnectionEntry[index]->Count();			
		}	

	return count;
	}

RPointerArray<CConnectionEntry>& CThreadEntry::ConnectionEntry()
	{
	return iConnectionEntry;	
	}

const TThreadId& CThreadEntry::ThreadId() const
	{
	return iThreadId;
	}

void CThreadEntry::SetIsDead(TBool aDead)
	{
	iIsDead = aDead;
	}

TBool CThreadEntry::IsDead() const
	{
	return iIsDead;
	}

void CThreadEntry::SetThreadMonitor(CThreadMonitor* aThreadMonitor)
	{
	iThreadMonitor = aThreadMonitor;	
	__FLOG_6(_L("CThreadEntry %08x:\t SetThreadMonitor(), iIsDead = %d, thread id = %d, iThreadMonitor = %08x, iSubSession = %08x, iQueue = %08x"), this, iIsDead, iThreadId.Id(), iThreadMonitor, iSubSession, iQueue);	
	}

CThreadMonitor* CThreadEntry::ThreadMonitor() const
	{
	return iThreadMonitor;
	}

void CThreadEntry::SetSubSession(CSubSession* aSubSession)
	{
	iSubSession = aSubSession;	
	__FLOG_6(_L("CThreadEntry %08x:\t SetSubSession(), iIsDead = %d, iThreadId.Id() = %d, iThreadMonitor = %08x, iSubSession = %08x, iQueue = %08x"), this, iIsDead, iThreadId.Id(), iThreadMonitor, iSubSession, iQueue);
	}

CSubSession* CThreadEntry::SubSession() const
	{
	return iSubSession;
	}

CPolicyCheckRequestQueue& CThreadEntry::RequestQueue() const
	{
	return *iQueue;
	}

} // end of namespace