// Copyright (c) 1997-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:
// CCommonServer
// 
//

#ifdef _DEBUG
// Panic category for "absolutely impossible!" vanilla ASSERT()-type panics from this module
// (if it could happen through user error then you should give it an explicit, documented, category + code)
_LIT(KSpecAssert_ElemSvrDenStdI, "ElemSvrDenStdI");
#endif

inline CCommonWorkerThread& CCommonServer::WorkerThread() const
	{
	return *iOwnerThread;
	};

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

//
// CWorkeerSession
//
inline CCommonDealer* CWorkerSession::Dealer() const
	{
	// NB: this is really only a static_cast<> but the Gordian knot of class dependencies results in a forward
	// declaration
	CServer2* server=const_cast<CServer2*>(Server());
	CCommonServer* commonServer=static_cast<CCommonServer*>(server);
	return commonServer->Dealer();
	}

inline CSubSessionIx& CWorkerSession::SubSessions()
	{
	return iSubSessions;
	}

inline const CSubSessionIx& CWorkerSession::SubSessions() const
	{
	return iSubSessions;
	}

inline const RMessage2& CWorkerSession::Message() const
	{
	return *iOurMessage;
	}

inline RSafeMessage& CWorkerSession::SafeMessage() const
	{
	return static_cast<RSafeMessage&>(const_cast<RMessage2&>(*iOurMessage));
	}

inline RSafeMessage& CWorkerSession::SafeMessage(const RMessage2& aMessage) const
	{
	return static_cast<RSafeMessage&>(const_cast<RMessage2&>(aMessage));
	}

inline CCommonWorkerThread& CWorkerSession::WorkerThread() const
	{
	//return Dealer().WorkerThread();

	CServer2* server=const_cast<CServer2*>(Server());
	CCommonServer* commonServer=static_cast<CCommonServer*>(server);
	return commonServer->WorkerThread();
	}

inline CommsFW::TWorkerId CWorkerSession::WorkerId() const
	{
	//return Dealer().WorkerId();

	CServer2* server=const_cast<CServer2*>(Server());
	CCommonServer* commonServer=static_cast<CCommonServer*>(server);
	return commonServer->WorkerId();
	}

inline CCommonPitBoss& CWorkerSession::PitBoss() const
	{
	return WorkerThread().PitBoss();
	}

//
// CWorkerSubSession
//


inline CWorkerSession* CWorkerSubSession::Session()
	{
	__ASSERT_DEBUG(iSession, User::Panic(KSpecAssert_ElemSvrDenStdI, 1));
	return iSession;
	}

inline const CWorkerSession* CWorkerSubSession::Session() const
	{
	__ASSERT_DEBUG(iSession, User::Panic(KSpecAssert_ElemSvrDenStdI, 2));
	return iSession;
	}

inline CCommonPlayer& CWorkerSubSession::Player() const
	{
	__ASSERT_DEBUG(iPlayer, User::Panic(KSpecAssert_ElemSvrDenStdI, 3));
	return *iPlayer;
	}


inline void CWorkerSubSession::SetSession(CWorkerSession* aSession)
	{
	iSession = aSession;
	}

inline CCommonSessionProxy* CWorkerSubSession::SessionProxy()
	{
	return iSessionProxy;
	}

inline const CCommonSessionProxy* CWorkerSubSession::SessionProxy() const
	{
	return iSessionProxy;
	}

inline void CWorkerSubSession::SetSessionProxy(CCommonSessionProxy* aProxy)
	{
	iSessionProxy = aProxy;
	}

// migrate to using SafeMessage
/*
inline const RMessage2& CWorkerSubSession::Message() const
	{
	return static_cast<RMessage2&>(const_cast<RSafeMessage&>(SafeMessage()));
	}
*/

//
// CSubSessionIx
//

/**
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 CSubSessionIx::Lock() const
	{
	iLock.Wait();
	}

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

/**
@return the number of active sub-sessions in the container.
*/
inline TInt CSubSessionIx::ActiveCount() const
	{
	return iActiveCount;
	}