/**

* Copyright (c) 2005-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:

* Header file for the IP SubConnection Provider and its basic version

* 

*

*/

/**

 @file ipscpr.h

*/

#ifndef __IPSCPR_H__

#define __IPSCPR_H__

#include <e32base.h>

#include <e32std.h>

#include <ss_subconnprov.h>

#include "deft_scpr.h"

#include <eintsock.h>

#include <in_sock.h>

#include <es_sock.h>

#ifndef BASIC_IPSCPR

#include "asyncwriter.h"

#include <qoslib.h>

#include <ip_subconparams.h>

#ifdef SYMBIAN_NETWORKING_UMTSR5

#include <umtsextn.h>

#include <imsextn.h>

#endif

#endif

/**

Connection Provider Id - Protocol Family

@internalComponent

@released Since v9.0

*/

const TUint KIPConnectionProviderFactoryId = KAfInet;

/**

ECOM Implementation Id for Connection Provider

@internalComponent

@released Since v9.0

*/

#ifdef BASIC_IPSCPR

const TInt KSubConnectionProviderImplementationUid = { 0x102752C5 };

#else

const TInt KSubConnectionProviderImplementationUid = { 0x10204308 };

#endif

class CConnectionProviderBase;

class CIpSubConnectionProviderFactory : public CSubConnectionProviderFactoryBase

/**

Factory that is used to create instances of IP Connection Providers

@internalComponent

@released Since v9.0

*/

	{

public:

	static CIpSubConnectionProviderFactory* NewL(TAny* aConstructionParameters);

	virtual ~CIpSubConnectionProviderFactory();

	CIpSubConnectionProviderFactory(TUint aFactoryId, CSubConnectionFactoryContainer& aParentContainer);

	// methods to be overriden for CSubConnectionProviderFactory

	virtual CSubConnectionProviderBase* DoCreateProviderL(CConnectionProviderBase& aConnProvider, RSubConnection::TSubConnType aType);

	};

#ifndef BASIC_IPSCPR

class CQoSMsgWriter;

class CQoSMsgReader;

class TPfqosMessage;

class CSubConGenEventParamsGranted;

class CSubConQosGenericParamSet;

class CSubConQosIPLinkR99ParamSet;

class CSubConSBLPR5ExtensionParamSet;

class CSblpParameters;

class TQoSParameters;

class TUmtsQoSParameters;

#ifdef SYMBIAN_NETWORKING_UMTSR5  

class TUmtsR5QoSParameters;

class TImsParameter;

class CSubConQosR5ParamSet;

class CSubConIMSExtParamSet;

#endif 

// SYMBIAN_NETWORKING_UMTSR5 

class CIpSubConnectionProvider : public CEmptySubConnectionProvider

/**

Defines the IP Connection Provider.  Class provides a mapping from ESock Subconnection

function calls to QoS.PRT messages.

@internalComponent

@released Since v9.0

*/

	{

private:

    enum 

        {

        KParameterRelInvalid = 0,

        KParameterRelGeneric = 1,

        KParameterRel4Rel99 = 4,

        KParameterRel5 = 5,

        };

public:

	// Construction

	static CIpSubConnectionProvider* NewL(CIpSubConnectionProviderFactory& aFactory, CConnectionProviderBase& aConnProvider);

protected:

	// Construction

	CIpSubConnectionProvider(CIpSubConnectionProviderFactory& aFactory, CConnectionProviderBase& aConnProvider);

	// Methods to be overriden be derived subconnection provider

	virtual void DoDataClientJoiningL(MSubConnectionDataClient& aDataClient);

	virtual void DoDataClientLeaving(MSubConnectionDataClient& aDataClient);

	virtual void DoSourceAddressUpdate(MSubConnectionDataClient& aDataClient, const TSockAddr& aSource);

	virtual void DoDestinationAddressUpdate(MSubConnectionDataClient& aDataClient, const TSockAddr& aDestination);

	virtual void DoDataClientRouted(MSubConnectionDataClient& aDataClient, const TSockAddr& aSource, const TSockAddr& aDestination, const TDesC8& aConnectionInfo);

	virtual void DoParametersAboutToBeSetL(CSubConParameterBundle& aParameterBundle);

	virtual TInt DoControl(TUint aOptionLevel, TUint aOptionName, TDes8& aOption);

    virtual void DoStartL();

	virtual void DoStop();

	virtual CSubConnectionProviderBase* DoNextLayer();

	virtual CConnDataTransfer& DoDataTransferL();

	//MConnectionDataClient

	virtual TAny* FetchInterfaceInstanceL(CSubConnectionProviderBase& aProvider, const STypeId& aTid);

	virtual void ConnectionGoingDown(CConnectionProviderBase& aConnProvider);

	virtual void Notify(TNotify aNotifyType,  CConnectionProviderBase* aConnProvider, TInt aError, const CConNotificationEvent* aConNotificationEvent);

    virtual void AttachToNext(CSubConnectionProviderBase* aSubConnProvider);

	// Don't allow clients to invoke the destructor.

	// (Only the CCommsFactoryBase should do this)

	virtual ~CIpSubConnectionProvider();

	void ConstructL();

public:

	// Messages from PRT

	void ProcessPRTMsg(TPfqosMessage& aMsg);

	void ProcessPRTError(TPfqosMessage& aMsg, TInt aError);

#ifdef _DEBUG

	void ProcessPRTError(TInt aMsgType, TInt aError);

#endif

private:

	// Messages to PRT

	void SendOpenExistingL(const TInetAddr &aSrcAddr, const TInetAddr &aDstAddr, TUint32 aIapId, TUint32 aProtocol);

	void SendCreateL(const TInetAddr &aSrcAddr, const TInetAddr &aDstAddr, TUint32 aIapId, TUint32 aProtocol);

	void SendCloseL();

	void SendJoinL(const TInetAddr &aSrcAddr, const TInetAddr &aDstAddr, TUint32 aIapId, TUint32 aProtocol);

	void SendLeaveL(const TInetAddr &aSrcAddr, const TInetAddr &aDstAddr, TUint32 aIapId, TUint32 aProtocol);

	void SendSetQoSL();

	// Internal Processing

	void ProcessPRTEventL(TPfqosMessage& aMsg);

	void ProcessPRTReplyL(TPfqosMessage& aMsg);

	void ConvertParametersFromESockL(CSubConParameterBundle& aParameterBundle);

	void ConvertParametersFromQOSL(TPfqosMessage& aMsg, CSubConGenEventParamsGranted* aEvent);

	TInt DetermineClient(const TPfqosMessage& aMsg, MSubConnectionDataClient*& aDataClient);

	void MapGenericParamsFromESockToPRTL(const CSubConQosGenericParamSet& generic) const;

	void MapGenericParamsFromPRTToESockL(CSubConQosGenericParamSet& generic) const;

	void MapExtensionParamsFromESockToPRTL(const CSubConQosIPLinkR99ParamSet& extension, TUmtsQoSParameters& params);

	void ResetPrtExtensions();

#ifdef SYMBIAN_NETWORKING_UMTSR5  

	void MapExtensionParamsFromESockToPRTL(const CSubConQosR5ParamSet& aExtension, TUmtsR5QoSParameters& aParams);

	void MapExtensionParamsFromESockToPRTL(const CSubConImsExtParamSet& aExtension, TImsParameter& aParams);

    CSubConExtensionParameterSet* MapFromUmtsR5ExtensionL (const CUmtsR5QoSPolicy* aPolicy);

    CSubConExtensionParameterSet* MapFromImsExtensionL (const CImsPolicy* aPolicy);

#endif 

// SYMBIAN_NETWORKING_UMTSR5 

	void MapExtensionParamsFromESockToPRTL(const CSubConSBLPR5ExtensionParamSet& extension, CSblpParameters& params) const;

	void ConvertTQoSIntoCQoSParamsL(const TQoSParameters& aParameter);

	void ConvertCQoSIntoTQoSParamsL(TQoSParameters& aParameters) const;

private:

	/** Internal Socket */

	RInternalSocket iSocket;

	/** PRT message writer */

	CQoSMsgWriter* iWriter;

	/** PRT message reader */

	CQoSMsgReader* iReader;

	/** QoS channel Id */

	TInt iChannelId;

	/** Process UID */

	TUidType iUid;

	/** QoS Parameters */

    CQoSParameters* iPrtParameters;

	/** QoS Extensions */

    TQoSExtensionQueue iPrtExtensions;

	/** QoS Parameters Set */

	TBool iParametersSet;

	TInt iParameterRelease;

	/**Class for doing async writes */

	CAsyncWriter* iAsyncWriter;

	};

#endif  // BASIC_IPSCPR

#endif  // __IPSCPR_H__