// 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 Connection Provider implementation
// 
//

/**
 @file
 @internalComponent
*/

#define SYMBIAN_NETWORKING_UPS

#include <comms-infras/corecprstates.h>
#include <comms-infras/corecpractivities.h>
#include "IPCpr.h"
#include "IPMessages.h"
#include <comms-infras/ss_log.h>
#include <comms-infras/api_ext_list.h>

#include <comms-infras/ss_msgintercept.h>

#ifdef SYMBIAN_TRACE_ENABLE
	#define KIPCprTag KESockConnectionTag
	// _LIT8(KIPCprSubTag, "ipcpr");
#endif // SYMBIAN_TRACE_ENABLE

using namespace Messages;
using namespace ESock;
using namespace NetStateMachine;
using namespace MeshMachine;

//We reserve space for two preallocated activities that may start concurrently on the CPR
//node: destroy and data client stop.
static const TUint KDefaultMaxPreallocatedActivityCount = 2;
static const TUint KMaxPreallocatedActivitySize = sizeof(MeshMachine::CNodeRetryParallelActivity) + sizeof(MeshMachine::APreallocatedOriginators<4>);
static const TUint KIPCPRPreallocatedActivityBufferSize = KDefaultMaxPreallocatedActivityCount * KMaxPreallocatedActivitySize;

//-=========================================================
//
// CIPConnectionProvider methods
//
//-=========================================================
CIPConnectionProvider* CIPConnectionProvider::NewL(ESock::CConnectionProviderFactoryBase& aFactory)
    {
    CIPConnectionProvider* provider = new (ELeave) CIPConnectionProvider(aFactory);
    CleanupStack::PushL(provider);
    provider->ConstructL(KIPCPRPreallocatedActivityBufferSize);
    CleanupStack::Pop(provider);
	return provider;
    }

CIPConnectionProvider::CIPConnectionProvider(ESock::CConnectionProviderFactoryBase& aFactory)
	: CMobilityConnectionProvider(aFactory, IpCprActivities::ipCprActivities::Self())
    {
    LOG_NODE_CREATE(KIPCprTag, CIPConnectionProvider);
    }

CIPConnectionProvider::~CIPConnectionProvider()
    {
    LOG_NODE_DESTROY(KIPCprTag, CIPConnectionProvider);
    }

void CIPConnectionProvider::ReceivedL(const TRuntimeCtxId& aSender, const TNodeId& aRecipient, TSignatureBase& aMessage)
	{
   	TNodeContext<CIPConnectionProvider> ctx(*this, aMessage, aSender, aRecipient);
	ESOCK_DEBUG_MESSAGE_INTERCEPT(aSender, aMessage, aRecipient);
	CMobilityConnectionProvider::ReceivedL(aSender, aRecipient, aMessage);
	User::LeaveIfError(ctx.iReturn);
	}


#ifdef SYMBIAN_NETWORKING_UPS
RNodeInterface* CIPConnectionProvider::NewClientInterfaceL(const TClientType& aClientType, TAny* aClientInfo)
    {
    
    if (aClientType.Type() & TCFClientType::ECtrl)
    		{
    		if (aClientInfo == NULL)
    			{ // This is not CPR, probably CConnection, use min priority.
    			return new (ELeave) RIPCprControlClientNodeInterface(KMaxTUint);
    			}
    		else
    			{
    			const TUint* priority = static_cast<const TUint*>(aClientInfo);
    			return new (ELeave) RIPCprControlClientNodeInterface(*priority);
    			}
    		}
    
    return CConnectionProviderBase::NewClientInterfaceL(aClientType, aClientInfo);
    }
#endif