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

 	}