// 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 Default SubConnection Provider class definition.
// 
//

/**
 @file
 @internalComponent
*/

#ifndef SYMBIAN_IPDEFTBASESCPR_H
#define SYMBIAN_IPDEFTBASESCPR_H

#include <comms-infras/ss_subconnprov.h>
#include <comms-infras/corescpr.h>
#include <comms-infras/corescprstates.h>
#include <comms-infras/ss_nodeinterfaces.h>
#include <comms-infras/ss_corepractivities.h>

#ifdef SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW
#include <tcprecvwin.h>
#endif //SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

namespace IPBaseSCprStates
    {
    class TStoreAddressUpdate;
    class TRejoinDataClient;
    }

class CIpDefaultSubConnectionProviderFactory;
class CIpSubConnectionProviderFactory;

class RIPDataClientNodeInterface : public Messages::RNodeInterface
/** IP SCPR override for RNodeInterface data client.
Caches IP address updates reported by the data clients.

@internalTechnology
@released Since 9.4 */
    {
    public:
	TSockAddr   iCliSrcAddr;
	TSockAddr   iCliDstAddr;
	TInt        iProtocolId;
	TInt        iActivityAwaitingResponse;
	TUid	    iAppSid;

	RIPDataClientNodeInterface()
    	:Messages::RNodeInterface(),
    	 iActivityAwaitingResponse(MeshMachine::KActivityNull)
    	 {}
    };

NONSHARABLE_CLASS(CIpSubConnectionProviderBase) : public CCoreSubConnectionProvider
/** IP subconnection provider base class

@internalTechnology
@released Since 9.4 */
    {
    friend class IPBaseSCprStates::TStoreAddressUpdate;
    friend class IPBaseSCprStates::TRejoinDataClient;
public:
    static const TUint32 KInvalidIapId = 0xFFFFFFFF;

protected:
    virtual Messages::RNodeInterface* NewClientInterfaceL(const Messages::TClientType& aClientType, TAny* aClientInfo = NULL);
    CIpSubConnectionProviderBase(ESock::CSubConnectionProviderFactoryBase& aFactory,
                                 const MeshMachine::TNodeActivityMap& aActivityMap);

protected:
	TUint32 iIapId;
    };

NONSHARABLE_CLASS(CIpDefaultBaseSubConnectionProvider) : public CIpSubConnectionProviderBase
/** Default IP subconnection provider

@internalTechnology
@released Since 9.4 */
    {
    friend class CIpDefaultSubConnectionProviderFactory;

public:
    typedef CIpSubConnectionProviderFactory FactoryType;
	TBool ImsFlag();

protected:
    CIpDefaultBaseSubConnectionProvider(ESock::CSubConnectionProviderFactoryBase& aFactory,
                             const MeshMachine::TNodeActivityMap& aActivityMap);
    static CIpDefaultBaseSubConnectionProvider* NewL(ESock::CSubConnectionProviderFactoryBase& aFactory);

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

//-=========================================================
//
// Activities
//
//-=========================================================
namespace IPDeftSCprBaseActivities
    {
    enum TIPDeftSCprBaseActivities
        {
        ECFActivityAddressUpdate 	= ESock::ECFActivityCustom,
#ifdef SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW
    	ECFActivityCPFCreate		= ESock::ECFActivityCustom + 1,
    	ECFActivityReceiveWin       = ESock::ECFActivityCustom+2
#else
	    ECFActivityCPFCreate		= ESock::ECFActivityCustom + 1
#endif //SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

		};

    DECLARE_ACTIVITY_MAP(ipscprbaseActivityMap)
    }

namespace IPDeftBaseSCprActivities
    {
    enum TIPDeftBaseSCprActivities
        {
        ECFActivityAddressUpdate 	= ESock::ECFActivityCustom,
        };

    DECLARE_ACTIVITY_MAP(ipdeftbasescprActivityMap)
    }


//-=========================================================
//
// States
//
//-=========================================================
namespace IPBaseSCprStates
{
typedef MeshMachine::TNodeContext<CIpSubConnectionProviderBase, SCprStates::TContext> TContext;

DECLARE_SMELEMENT_HEADER( TAwaitingAddressUpdate, MeshMachine::TState<TContext>, NetStateMachine::MState, IPBaseSCprStates::TContext )
	virtual TBool Accept();
DECLARE_SMELEMENT_FOOTER( TAwaitingAddressUpdate )

DECLARE_SMELEMENT_HEADER( TStoreAddressUpdate, MeshMachine::TStateTransition<TContext>, NetStateMachine::MStateTransition, IPBaseSCprStates::TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TStoreAddressUpdate )

DECLARE_SMELEMENT_HEADER( TRejoinDataClient, MeshMachine::TStateTransition<TContext>, NetStateMachine::MStateTransition, IPBaseSCprStates::TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TRejoinDataClient )

#ifdef SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW
//State transition to store bearer type in provisionconfig and send window size to data clients in custom message
DECLARE_SMELEMENT_HEADER( TSendTransportNotificationToDataClients, MeshMachine::TStateTransition<TContext>, NetStateMachine::MStateTransition, IPBaseSCprStates::TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TSendTransportNotificationToDataClients )

//State to accept TTransportNotification from IPCPR.
DECLARE_SMELEMENT_HEADER( TAwaitingTransportNotification, MeshMachine::TState<TContext>, NetStateMachine::MState, IPBaseSCprStates::TContext )
 	virtual TBool Accept();
DECLARE_SMELEMENT_FOOTER( TAwaitingTransportNotification )
#endif //SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

}

namespace IPDeftBaseSCprBinderRequestActivity
{
const TInt KPermissionDenied = 1;

typedef MeshMachine::TNodeContext<CIpDefaultBaseSubConnectionProvider, SCprStates::TContext> TContext;

DECLARE_SMELEMENT_HEADER( TNoTagOrUseExistingOrPermissionDenied, PRActivities::CCommsBinderActivity::TNoTagOrUseExisting, NetStateMachine::MStateFork, TContext )
	virtual TInt TransitionTag();
DECLARE_SMELEMENT_FOOTER( TNoTagOrUseExistingOrPermissionDenied )
}

namespace IPDeftBaseSCprDataClientStartActivity
{
typedef MeshMachine::TNodeContext<CIpDefaultBaseSubConnectionProvider, SCprStates::TContext> TContext;

DECLARE_SMELEMENT_HEADER( TGetParams, MeshMachine::TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TGetParams )
}

namespace IPDeftSCprStopActivity
{
typedef IPBaseSCprStates::TContext TContext;

DECLARE_SMELEMENT_HEADER( TStopYourFlows, MeshMachine::TStateTransition<TContext>, NetStateMachine::MStateTransition, TContext )
	virtual void DoL();
DECLARE_SMELEMENT_FOOTER( TStopYourFlows )

DECLARE_SMELEMENT_HEADER( TNoTagBackwardsOrProviderStopped, MeshMachine::TStateFork<TContext>, NetStateMachine::MStateFork, TContext )
	virtual TInt TransitionTag();
DECLARE_SMELEMENT_FOOTER( TNoTagBackwardsOrProviderStopped )

DECLARE_SMELEMENT_HEADER( TNoTagOrProviderStopped, MeshMachine::TStateFork<TContext>, NetStateMachine::MStateFork, TContext )
	virtual TInt TransitionTag();
DECLARE_SMELEMENT_FOOTER( TNoTagOrProviderStopped )



DECLARE_SERIALIZABLE_STATE(
	TNoTagOrProviderStoppedBlockedByStart,
	CoreNetStates::TActivityStartMutex,
	IPDeftSCprStopActivity::TNoTagOrProviderStopped
	)
}

#endif //SYMBIAN_IPDEFTBASESCPR_H