// Copyright (c) 2005-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:
// CC32Server
// 
//


inline CC32WorkerThread& CC32Server::WorkerThread() const 
	{
	return *iOwnerThread;
	};

inline CommsFW::TWorkerId CC32Server::WorkerId() const
	{
	return WorkerThread().WorkerId();
	}

//
// CCommSession
//

inline const CC32Dealer& CCommSession::Dealer() const 
	{ 
	return *reinterpret_cast<const CC32Dealer*>(Server());	
	}

inline CC32SubSessionIx& CCommSession::SubSessions()
	{
	return iSubSessions;
	}

inline void CCommSession::CompleteDisconnect()
	{
	RMessage2 dm = iDisconnectMessage;
	inherited::Disconnect(dm);
	}


//
// CCommSubSession
//

inline void CCommSubSession::Open()
	{
	iAccessCount++;
	}

inline void CCommSubSession::Close()
	{
	iAccessCount--;
	ASSERT(iAccessCount >= 0);
	if(iAccessCount == 0)
		{
		RemoveAndDestroy();
		}
	}

inline TInt CCommSubSession::AccessCount() const
	{
	return iAccessCount;
	}

inline CCommSession* CCommSubSession::Session() const
	{ 
	ASSERT(iSession); 
	return iSession;
	}

inline CC32Player& CCommSubSession::Player() const 
	{ 
	ASSERT(iPlayer); 
	return *iPlayer; 
	}

	
//
// CC32SubSessionIx
// 

/**
Optional locking. When accessing any of the public methods of this class in a multithreaded 
environment, locking is often necessary. This lock does not allow for lock nesting.
*/
inline void CC32SubSessionIx::Lock() const
	{ 
	iLock.Wait(); 
	}

/**
Unlocking.
@see Lock()
*/
inline void CC32SubSessionIx::Unlock() const
	{ 
	iLock.Signal(); 
	}


//
// RWorkerLock
//

inline void CC32SubSessionIx::RWorkerLock::Wait()
	{
#ifdef _DEBUG
	TThreadId self = RThread().Id();
	// If this faults then you're attempting to claim a lock you already hold. See below
	__ASSERT_ALWAYS(self != iHolder,Fault(EBadState,_L8("RWorkerLock::Wait: Attempt to claim a lock twice (self == iHolder(%lu))! Panicking."),&iHolder));
#endif
	RFastLock::Wait();
#ifdef _DEBUG
	iHolder = self;
#endif
	}



inline void CC32SubSessionIx::RWorkerLock::Signal()
	{
#ifdef _DEBUG
	TThreadId self = RThread().Id();
	// If this faults then you're attempting to release a lock you do not hold.
	__ASSERT_ALWAYS(self == iHolder,Fault(EBadState,_L8("RWorkerLock::Signal: Attempt to release a lock not held (self(%lu) != iHolder(%lu))! Panicking."),&self,&iHolder));
	iHolder = KNullHandle;
#endif
	RFastLock::Signal();
	}
	
	
		
inline void CC32SubSessionIx::RWorkerLock::AssertLockHeld() const
	{
#ifdef _DEBUG
	TThreadId self = RThread().Id();
	__ASSERT_ALWAYS(self == iHolder,Fault(EBadState,_L8("RWorkerLock::AssertLockHeld: failed: self(%lu) != iHolder(%lu)! Panicking."),&self,&iHolder));
#endif
	}