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

//

#ifndef SS_SUBCONN_H

#define SS_SUBCONN_H

#include <ss_std.h>

#include <comms-infras/ss_subconnprov.h>

#include <comms-infras/ss_coreprstates.h>

#include <comms-infras/ss_platsec_apiext.h>

#include <comms-infras/ss_mmnode.h>

#include <comms-infras/ss_mmnode_subsess.h>

#include <cs_subconevents.h>

using namespace CorePanics;

const int KMaxUidFilterListLen = 10;

namespace SubConnActivities

{

	class CRejoin;

	class CBuildStack;

	class CSetParameters;

}

namespace SubConnStates

{

	class TJoinCPR;

	class TRequestServiceProvider;

	class TJoinTheOtherOwner;

	class TLeaveCPR;

	class TSendParamsToServiceProvider;

	class TStoreParams;

	class TNoTagOrParamsPresent;

	class TSendParamRequest;

	class TWriteSubConnParamsLength;

	class TWriteSubConnParams;

	class TFillInEvent;

	class TNoTagOrWaitForIncoming;

	class TEnqueueEvent;

	class TNoTagOrActiveWhenEventEnqued;

	class TStoreNewParams;

	class TSendBuildStack;

	class TRequestServiceProviderFromCPR;

	class TNoTagOrAttachToDefaultOrWaitForIncoming;

}

namespace ESock

{

class ASubConnectionLegacy;

NONSHARABLE_CLASS(CSubConnection) : public CMMSockSubSession, private ASubSessionPlatsecApiExt,

                                    public ITFHIERARCHY_LINK_1(CSubConnection, MeshMachine::AMMNodeBase, MPlatsecApiExt)

/**

Handle subconnection-related asynchronous client requests that may not complete immediately

@internalComponent

*/

	{

	friend class SubConnStates::TJoinCPR;

	friend class SubConnStates::TRequestServiceProvider;

	friend class SubConnStates::TJoinTheOtherOwner;

	friend class SubConnStates::TLeaveCPR;

	friend class SubConnStates::TSendParamsToServiceProvider;

	friend class SubConnStates::TStoreParams;

	friend class SubConnStates::TSendParamRequest;

	friend class SubConnStates::TNoTagOrParamsPresent;

	friend class SubConnStates::TWriteSubConnParamsLength;

	friend class SubConnStates::TWriteSubConnParams;

	friend class SubConnStates::TFillInEvent;

	friend class SubConnStates::TNoTagOrWaitForIncoming;

	friend class SubConnStates::TEnqueueEvent;

	friend class SubConnStates::TNoTagOrActiveWhenEventEnqued;

	friend class SubConnStates::TStoreNewParams;

	friend class SubConnStates::TSendBuildStack;

	friend class SubConnStates::TRequestServiceProviderFromCPR;

	friend class SubConnStates::TNoTagOrAttachToDefaultOrWaitForIncoming;

	friend class SubConnActivities::CRejoin;

	friend class SubConnActivities::CBuildStack;

	friend class SubConnActivities::CSetParameters;

	friend class AConnectionLegacy;

#ifdef __X86GCC__

	// gcc-mingw does not support template function instantiations as friends, only the

	// generic template.

	template<class NODE>

	friend  NODE* mcfnode_cast(Messages::ANode* aNode);

	template<class NODE>

	friend  NODE& mcfnode_cast(Messages::ANode& aNode);

#elif !defined(__GCCXML__)

    friend CSubConnection* mcfnode_cast<CSubConnection>(Messages::ANode* aNode);

    friend CSubConnection& mcfnode_cast<CSubConnection>(Messages::ANode& aNode);

#endif

    static const TInt KMaxEventQueueLength = 8;

public:

	typedef ITFHIERARCHY_LINK_1(CSubConnection, MeshMachine::AMMNodeBase, MPlatsecApiExt) TIfStaticFetcherNearestInHierarchy;

public:

    static CSubConnection* NewL(CConnection& aConnection, CPlayer* aPlayer, const TSubSessionUniqueId aSubSessionUniqueId);

    virtual ~CSubConnection();

    //-----------------------------------

    //from TInterfaceControl

    //-----------------------------------

    void ReturnInterfacePtrL(MPlatsecApiExt*& aInterface)

        {

        aInterface = this;

        }

protected:

    CSubConnection(CPlayer* aPlayer, const TSubSessionUniqueId aSubSessionUniqueId);

    void ConstructL(CConnection& aConnection);

    CConnection& ControlProvider();

    //-----------------------------------

    //from CMMSockSubSession

    //-----------------------------------

    void Received(MeshMachine::TNodeContextBase& aContext);

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

    //-----------------------------------

    //from CSockSubSession

    //-----------------------------------

protected:

    void ProcessMessageL();

    virtual void FinalCompleteAllBlockedMessages(TInt aResult);

public:

  	virtual Den::TSubSessInfo Type() const

  		{

  		return TCFSubSessInfo(TCFSubSessInfo::ESubConnection);

  		}

inline RSubConnection::TSubConnType SubConnType() const

	{

	return iSubConnType;

	}

public:

	IMPORT_C RCFParameterFamilyBundleC& GetOrCreateParameterBundleL();

	IMPORT_C RCFParameterFamilyBundleC& CreateParameterBundleL();

private:

  	RCFParameterFamilyBundleC iParameterBundle;

  	RSubConnection::TSubConnType iSubConnType;

    TNotificationQueue<CRefCountOwnedSubConNotification*, KMaxEventQueueLength> iEventQueue;

	};

} // namespace Esock

#endif

// SS_SUBCONN_H