// 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:
// Socket server global (TLS) data
// Structure of the pseudo statics stored in Dll local storage.
// 
//

/**
 @file
 @internalTechnology
*/

#ifndef __SS_GLOB_H__
#define __SS_GLOB_H__

#include <comms-infras/ss_common.h>
#include <elements/cftransport.h> // TCookie
#include <ss_pman.h>
#include <comms-infras/ss_factorycontainermap.h>
#include <comms-infras/cfperfmetrics.h>
#include <comms-infras/ss_apiext_register.h>

class CWorkerThread;
class CPlayer;

class CSocketServer;
class CMBufManager;

namespace ESock
{

class CCommsFactoryBase;
class CConnectionFactoryContainer;
class CSubConnectionFactoryContainer;
class CSubConnectionFlowFactoryContainer;
class CProtocolFamilyFactoryContainer;
class CProtocolIntfFactoryContainer;
class CConnectionServer;

enum EFactoryType
	{
	EProtocolFamilyFactory = 1,
	ESubConnectionFactory
	};

class CMetaConnectionFactoryContainer;
class CTierManagerFactoryContainer;
class CCFFactoryContainerBroker;
}

class CSockManData : public CBase
/**
@internalTechnology
*/
	{
public:
	// Some accessor functions to try to reduce the coupling
	IMPORT_C CPlayer* SelfPlayer();
	const CESockIniData* IniData();
	IMPORT_C CWorkerThread* SelfWorker() const;

#ifdef ESOCK_HOME_THREAD_CHECK_ENABLED
	void AssertOwnThread() const;
#endif

#ifdef _DEBUG
	void LogActiveProtocols();
#endif

public:
//TODO Move some of this stuff to Den::Globals?
	CWorkerThread* iWorkerThread;			//
	CSocketServer* iSocketServer;			//< Back pointer to the CServer (for shutdown)
	TProtocolRefList* iProtocols;			//< List of all socket types available
	TSglQue<CProtocolFamilyRef>* iProtocolFamilies;	//< List of all protocol families used
	CESockIniData* iEskData;
	TUint iNumProtocols;					//< Count of protocols.
#ifdef SYMBIAN_ZERO_COPY_NETWORKING	
	RCommsBufPond iCommsBufPond;			//< The Comms buf pond
#else
	 CMBufManager* iMBufManager;             //< The MBuf manager
#endif
	CDeltaTimer* iTimer;					//< The global delta timer.
	TInt iNumFamilies;
	TBool iShutdownGracefully;              //< Flag that shutdown should be done when there's no more sessions or loaded families.
	HBufC *iDeps;							//< List of protocols requiring other protocols to be loaded first
	Messages::CGlobals& iTransportGlobals;

public:
	IMPORT_C static ESock::CCommsFactoryBase* InstallFactoryL( ESock::EFactoryType aFactoryType, const TDesC8& aName, TUid aFactoryUid );
	IMPORT_C Messages::TNodeId GetPlaneFC(const Den::TPlayerRole& aPlane);

	TBool ShutdownGracefully();
	void InstallFactoryContainersL();
	void UninstallFactoryContainers();

	ESock::CTierManagerFactoryContainer* iTierManagerFactories;
	ESock::CMetaConnectionFactoryContainer* iMetaConnectionFactories;
	ESock::CConnectionFactoryContainer* iConnectionFactories; // Connection Provider factories
	ESock::CSubConnectionFactoryContainer* iSubConnectionFactories; //< Sub-Connection Provider factories
	ESock::CSubConnectionFlowFactoryContainer* iSubConnectionFlowFactories; //< Sub-Connection Flow factories
	ESock::CProtocolFamilyFactoryContainer* iProtocolFamilyFactories; //< ProtocolFamily Provider factories
	ESock::CProtocolIntfFactoryContainer* iProtocolIntfFactories;

	ESock::RPlaneFCMap iFCMap;

	//Register of api extensions opened in this thread.
	//This register does not belong with the interfaces because their lifetime is implementation (or host) specific
	//This register also does not belong with the sessions, because they can disappear at any time (plus it would
	//not be possible to access the count of opened interfaces)
	ESock::TCommsApiExtRegister iCommsApiExtRegister;

	Messages::TNodeId iCommsFactoryContainerBroker;
	ESock::CCFFactoryContainerBroker* iCommsFactoryContainerBrokerSingleton;

	void AddFactoryContainerObjectBrokerClient(
		const Messages::TNodeId& aNodeId,
		const TCFPlayerRole& aType);

#ifdef SYMBIAN_NETWORKING_PERFMETRICS
	void IncludePerformanceData(TInt aDeltaClientRxBytes, TInt aDeltaClientRxBuffBytes, TInt aDeltaClientTxBytes);
private:
	static TBool AddToPerfLog(TAny* aSelf, TDes8& aBuffer, TDes8Overflow* aOverflowHandler);

	struct TXferStats
		{
		enum
			{
			KNumBuckets = 6 // power series from 128 - >65536
			};
		// No ctor; relying on embedding object to zero fill RAM
		void AccumulateXfer(TUint aValue);

		TUint iBuckets[KNumBuckets];
		TUint iTotal;
		TUint iCount;
		};
	TXferStats iRxStats;
	TXferStats iRxBuffStats;
	TXferStats iTxStats;
public:
#endif

	/** List of socket server extensions */
	TDblQue<CSocketServExtRef> iExtensions;
public:
	static CSockManData* NewL(Messages::CGlobals& aGlobals, CWorkerThread* aWorker);
	~CSockManData();
private:
	CSockManData(Messages::CGlobals& aGlobals, CWorkerThread* aWorker);
	void ConstructL();
	};

class SockManGlobals
/**
@internalTechnology
*/
	{
public:
	static IMPORT_C CSockManData* Get();
	static void Set(CSockManData * aGlobals);	//lint -sem(SockManGlobals::Set, custodial(1))
	};

/** Test that the current thread is the "home thread" */
#ifdef ESOCK_HOME_THREAD_CHECK_ENABLED
#define ASSERT_HOME_THREAD SockManGlobals::Get()->AssertOwnThread();
#else
#define ASSERT_HOME_THREAD
#endif

#endif