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

/**
 @file
 @internalTechnology
 @prototype
*/

#ifndef SYMBIAN_NETMCPR_H
#define SYMBIAN_NETMCPR_H

#define SYMBIAN_NETWORKING_UPS

#include <comms-infras/mobilitymcpr.h>
#include <comms-infras/ss_nodemessages.h>
#include "netmcprstates.h"
#include "IPMessages.h"

#include <cdbcols.h>
#include <cdbover.h>
#include <metadatabase.h>
#include <commsdattypesv1_1.h>
#include <in_sock.h>

#ifdef SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW
#include <tcprecvwin.h>
#include <comms-infras/ss_protopt.h>
#endif //SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

_LIT(KNetMCprPanic, "NetworkMCprPanic");

static const TInt KPanicNoActivity = 1;
static const TInt KPanicNoContext = 2;
static const TInt KPanicNoConnectionHandle = 3;
class RParameterFamily;

namespace NetMCprStates
	{
	class TProcessPolicyParams;
	}


//
//CNetworkMetaConnectionProvider
NONSHARABLE_CLASS(CNetworkMetaConnectionProvider) : public CMobilityMetaConnectionProvider
    {
friend class NetMCprStates::TProcessPolicyParams;

public:
	static CNetworkMetaConnectionProvider* NewL(ESock::CMetaConnectionProviderFactoryBase& aFactory,
	                                            const ESock::TProviderInfo& aProviderInfo);

protected:
    CNetworkMetaConnectionProvider(ESock::CMetaConnectionProviderFactoryBase& aFactory,
                                   const ESock::TProviderInfo& aProviderInfo,
                                   const MeshMachine::TNodeActivityMap& aActivityMap);
    void ConstructL();

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

private:
	TBool FindMatchingPolicyL(TCFIPMessage::TPolicyParams& aPolicyParam);
	//void ProcessPolicyParamsL(const ESock::TAddrUpdate& aAddrUpdate, const Messages::TNodeId& aFlowId, const Messages::TNodeId& aSenderSCprId, const Messages::TNodeId& aSenderIPCprId);
	void InitDbL();

	void ProcessPolicyParamsL(const Messages::TRuntimeCtxId& aSender, TCFIPMessage::TPolicyParams& aPolicyParam);
	ESock::RCFParameterFamilyBundleC CreateParameterBundleL(TUint aPolicyId);
	TInt FillInParamsL(TUint aParamId, RParameterFamily& aFamily);
	TInt FillInGenericQosParamsL(TUint aParamId, RParameterFamily& aFamily);
	TInt FillInUMTSParamsL(TUint aParamId, RParameterFamily& aFamily);

	// matching helper functions
	TBool CheckSrcAddressMatch(const TSockAddr& aFirst, CCDPolicySelectorRecord* aRecord);
	TBool CheckDstAddressMatch(const TSockAddr& aFirst, CCDPolicySelectorRecord* aRecord);
	TBool CheckProtocol(TUint aProtocolId, CCDPolicySelectorRecord* aRecord);
	TBool CheckSrcPort(TUint aPort, CCDPolicySelectorRecord* aRecord);
	TBool CheckDstPort(TUint aPort, CCDPolicySelectorRecord* aRecord);
	TBool CheckIap(TUint aIapId, CCDPolicySelectorRecord* aRecord);
	TBool CheckAppUid(TUid aAppUid, CCDPolicySelectorRecord* aRecord);

private:
	CommsDat::CMDBSession* iDbSession;
	CommsDat::CMDBRecordSet<CommsDat::CCDPolicySelectorRecord>* iPolicySelectorRecSet;
    };

#ifdef SYMBIAN_NETWORKING_UPS

#define DEFINE_NETMCPR_TRANSITION(class, method) DEFINE_SMELEMENT(class::method, NetStateMachine::MStateTransition, class::TContext)
#define DEFINE_NETMCPR_STATEFORK(class, method) 	DEFINE_SMELEMENT(class::method, NetStateMachine::MStateFork, class::TContext)
#define DEFINE_NETMCPR_STATE(class, method)		DEFINE_SMELEMENT(class::method, NetStateMachine::MState, class::TContext)

#endif


#endif //SYMBIAN_NETMCPR_H