// Copyright (c) 2006-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:

// IP SubConnection Provider class definition.

// 

//

/**

 @file

 @internalComponent

*/

#ifndef SYMBIAN_IPSCPR_H

#define SYMBIAN_IPSCPR_H

#include <comms-infras/ss_subconnprov.h>

#include <comms-infras/corescpr.h>

#include <comms-infras/corescprstates.h>

#include <cs_subconevents.h>

#include <cs_subconparams.h>

#include <ip_subconparams.h>

#include <networking/umtsextn.h>

#include <networking/imsextn.h>

#include <networking/pfqoslib.h>

#include <networking/sblpextn.h>

#include <comms-infras/eintsock.h>

#include "IPSCPRFactory.h"

#include "asyncwriter.h"

#include "ipdeftbasescpr.h"

#ifdef SYMBIAN_ENABLE_SPLIT_HEADERS

#include <networking/qoslib_internal.h>

#endif

class CQoSMsgWriter;

class CQoSMsgReader;

class TUmtsR5QoSParameters;

class TImsParameter;

class CSubConQosR5ParamSet;

class CSubConIMSExtParamSet;

namespace QoSIpSCprStates

    {

    class TAddClientToQoSChannel;

    class TRemoveClientToQoSChannel;

    class TRemoveLeavingClientFromQoSChannel;

    class TSetParameters;

    }

class CIpSubConnectionProvider : public CIpSubConnectionProviderBase

/** Non-default/reserved IP subconnection provider

@internalTechnology

@released Since 9.4 */

    {

    friend class CIpDefaultSubConnectionProviderFactory;

    friend class QoSIpSCprStates::TAddClientToQoSChannel;

    friend class QoSIpSCprStates::TRemoveClientToQoSChannel;

    friend class QoSIpSCprStates::TRemoveLeavingClientFromQoSChannel;

    friend class QoSIpSCprStates::TSetParameters;

    friend class CQoSSocketOpener;    

public:

    typedef CIpDefaultSubConnectionProviderFactory FactoryType;

	virtual ~CIpSubConnectionProvider();

private:

    enum

        {

        KParameterRelInvalid = 0,

        KParameterRelGeneric = 1,

        KParameterRel4Rel99 = 4,

        KParameterRel5 = 5,

        };

protected:

    //-====================================

    //Construction methods bundle - accessible thru the factory only

    //-====================================

    CIpSubConnectionProvider(ESock::CSubConnectionProviderFactoryBase& aFactory);

	static CIpSubConnectionProvider* NewL(CIpDefaultSubConnectionProviderFactory& aFactory);

	void ConstructL();

    void ResetPrtExtensions();

    //-====================================

    //ACFNode overrides

    //-====================================

    virtual Messages::RNodeInterface* NewClientInterfaceL(const Messages::TClientType& aClientType, TAny* aClientInfo = NULL);

    void Received(MeshMachine::TNodeContextBase& aContext);

    void ReceivedL(const Messages::TRuntimeCtxId& aSender, const Messages::TNodeId& aRecipient, Messages::TSignatureBase& aMessage);

    //-====================================

    //Callbacks from MESH.

    //-====================================

    void SetQoSParametersL();

    RInternalSocket& InternalSocket();

    void InternalSocketOpened(TInt aErr);    

    //-====================================

    //Callbacks from QoSMsg.

    //-====================================

public:

	// Messages from PRT

	void ProcessPRTMsg(TPfqosMessage& aMsg);

	void ProcessPRTError(TPfqosMessage& aMsg, TInt aError);

#ifdef _DEBUG

	void ProcessPRTError(TInt aMsgType, TInt aError);

#endif

private:

    //-====================================

    //Custom methods

    //-====================================

	void DataClientJoiningL(RIPDataClientNodeInterface& aDataClient);

	void DataClientLeaving(RIPDataClientNodeInterface& aDataClient);

	// 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(const ESock::RCFParameterFamilyBundleC& aParameterBundle);

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

	RIPDataClientNodeInterface* DetermineClient(const TPfqosMessage& aMsg);

	void MapGenericParamsFromESockToPRTL(const CSubConQosGenericParamSet& generic) const;

	void MapGenericParamsFromPRTToESockL(CSubConQosGenericParamSet& generic) const;

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

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

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

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

    CSubConExtensionParameterSet* MapFromUmtsR5ExtensionL (const CUmtsR5QoSPolicy* aPolicy);

    CSubConExtensionParameterSet* MapFromImsExtensionL (const CImsPolicy* aPolicy);

	void ConvertTQoSIntoCQoSParamsL(const TQoSParameters& aParameter);

	void ConvertCQoSIntoTQoSParamsL(TQoSParameters& aParameters) const;

private:

	/** Internal Socket */

	RInternalSocket iSocket;

        TInt iSocketError;	

	/** 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 //SYMBIAN_IPSCPR_H