// 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 the License "Symbian Foundation License v1.0" to Symbian Foundation members and "Symbian Foundation End User License Agreement v1.0" to non-members
// which accompanies this distribution, and is available
// at the URL "http://www.symbianfoundation.org/legal/licencesv10.html".
//
// Initial Contributors:
// Nokia Corporation - initial contribution.
//
// Contributors:
//
// Description:
// CSocketServer
// 
//

inline CWorkerThread& CSocketServer::WorkerThread() const 
	{
	return *iOwnerThread;
	};

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

//
// CSockSession
//

inline const CDealer& CSockSession::Dealer() const 
	{ 
	// NB: this is really only a static_cast<> but the Gordian knot of class dependencies results in a forward
	// declaration
	return *reinterpret_cast<const CDealer*>(Server());	
	}

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

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

inline TSockManData* CSockSession::SockManGlobals() const
    {
        return WorkerThread().SockManGlobals();
    }

//
// CSockSubSession
//

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

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

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

inline CSockSession* CSockSubSession::Session()
	{ 
	ASSERT(iSession); 
	return iSession;
	}

inline CPlayer& CSockSubSession::Player() const 
	{ 
	ASSERT(iPlayer); 
	return *iPlayer; 
	}

#ifdef SYMBIAN_NETWORKING_PERFMETRICS
inline void CSockSubSession::IncludePerformanceData(TInt aDeltaClientRxBytes, TInt aDeltaClientRxBuffBytes, TInt aDeltaClientTxBytes)
	{
	iSession->IncludePerformanceData(aDeltaClientRxBytes, aDeltaClientRxBuffBytes, aDeltaClientTxBytes);
	}
#endif


inline const RMessage2& CSockSession::Message() const
	{ 
	return *iOurMessage; 
	}
	
inline void CSockSession::CompleteDisconnect()
	{
	RMessage2 dm = iDisconnectMessage;
	inherited::Disconnect(dm);
	}


inline void CSocketScheduler::SetGlobals(TSockManData* aGlobals)
    { 
	static_cast<CSocketScheduler*>(CActiveScheduler::Current())->iGlobals = aGlobals; 
	}

//inline void CSocketScheduler::SetWaitHook(TCallBack* aCall)
//	{ ((CSocketScheduler*)CActiveScheduler::Current())->iWaitHook=aCall; }

inline TSockManData* CSocketScheduler::Globals()
	{ 
	return static_cast<CSocketScheduler*>(CActiveScheduler::Current())->iGlobals; 
	}

//
// 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;
	}