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

//

/**

 @file SS_NODE.CPP

*/

#include "ss_mmcommsprov.h"

#include <elements/nm_messages_child.h>

#ifdef _DEBUG

// Panic category for "absolutely impossible!" vanilla ASSERT()-type panics from this module

// (if it could happen through user error then you should give it an explicit, documented, category + code)

_LIT(KSpecAssert_ESockSSocksmcmsp, "ESockSSocksmcmsp");

#endif

using namespace ESock;

using namespace Messages;

CMMCommsProviderBase::CMMCommsProviderBase(CCommsFactoryBase& aFactory,

                                    const MeshMachine::TNodeActivityMap& aActivityMap)

:	ACommsFactoryNodeId(aFactory),

	ACFMMNodeBase(aActivityMap, ANodeId::Id()),

	TIfStaticFetcherNearestInHierarchy(this)

    {

    }

CMMCommsProviderBase::~CMMCommsProviderBase()

    {

#ifdef SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

	if(!iParameterBundle.IsNull())

		{

		iParameterBundle.Close();

		}

#endif // SYMBIAN_ADAPTIVE_TCP_RECEIVE_WINDOW

    }

EXPORT_C void CMMCommsProviderBase::SetParametersL(const RCFParameterFamilyBundleC& aParameterBundle)

/** Request from a control client to set the parameters of this mm-comms provider

@param aParameterBundle Bundle of parameters to be applied to this mm-comms node

@exception Leaves with System Error Code dependant on the implementation of the mm-comms provider */

	{

	if (! iParameterBundle.IsNull())

		{

		iParameterBundle.Close();

		}

	iParameterBundle.Open(aParameterBundle);

	}

EXPORT_C RCFParameterFamilyBundleC& CMMCommsProviderBase::GetOrCreateParameterBundleL()

	{

	if( ! iParameterBundle.IsNull())

		{

		return iParameterBundle;

		}

	return CreateParameterBundleL();

	}

EXPORT_C RCFParameterFamilyBundleC& CMMCommsProviderBase::CreateParameterBundleL()

{

	__ASSERT_DEBUG(iParameterBundle.IsNull(), User::Panic(KSpecAssert_ESockSSocksmcmsp, 1));

	RCFParameterFamilyBundle newBundle;

	newBundle.CreateL();

	iParameterBundle.Open(newBundle);

	return iParameterBundle;

}

/*

void CMMCommsProviderBase::AddCtrlProviderNJoinAsDataClientL( const Messages::TSignatureBase& aCFMessage, TInt aJoinFlags )

    {

   	AddClientL(aCFMessage.iSender, TClientType(TCFClientType::ECtrlProvider));

#ifndef __GCCXML__

	EJoined(Factory().ParentContainer()(),

			aCFMessage.ActivityId(),

	    	(*this)(),

	    	CFNODE_SET_CLIENT_TYPENFLAGS(RNodeInterface::EData, aJoinFlags)

		).PostTo(aCFMessage.iSender);

#endif

    }

*/

EXPORT_C NetInterfaces::TInterfaceControl* CMMCommsProviderBase::FetchNodeInterfaceControlL(TInt aInterfaceId)

	{

	return ACFMMNodeBase::FetchNodeInterfaceControlL(aInterfaceId);

	}

EXPORT_C const RMetaExtensionContainerC& CMMCommsProviderBase::GetAccessPointConfig() const

	{

	return AccessPointConfig();

	}

EXPORT_C void CMMCommsProviderBase::ReturnInterfacePtrL(MAccessPointConfigApi*& aInterface)

	{

	aInterface = this;

	}

void CMMCommsProviderBase::DestroyOrphanedDataClients()

	{

	//Destroy orphaned data clients

	RNodeInterface* dc;

	TClientIter<TDefaultClientMatchPolicy> iter = GetClientIter<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EData));

	while ((dc = iter++) != NULL)

		{

		if (!(dc->Flags()&(TCFClientType::EActive|TCFClientType::EActivating|TCFClientType::ELeaving|TCFClientType::EStarted|TCFClientType::EStarting)))

			{

			//AbortActivitiesOriginatedBy(dc->RecipientId(),aContext);

			dc->PostMessage(Id(), TEChild::TDestroy().CRef());

			dc->SetFlags(TClientType::ELeaving);

			}

		}

	}