Attempt to represent the S^2->S^3 header reorganisation as a series of "hg rename" operations
// 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;
}