// Copyright (c) 2004-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:

//

#include "ss_mmnode_subsess.h"

#include "ss_apiext_messages.h"

#include <comms-infras/ss_nodemessages_internal_esock.h>

using namespace ESock;

using namespace Messages;

using namespace MeshMachine;

void CMMSockSubSession::HandleMessageReturnValue(TNodeContextBase& aContext)

    {

	TCFInternalEsock::TSubSess* msg = message_cast<TCFInternalEsock::TSubSess>(&aContext.iMessage);

	if (msg && !msg->iMessage.IsNull())

		{

		msg->iMessage.Complete(aContext.iReturn);

		DontCompleteCurrentRequest();

		}

	else

    	{

    	MeshMachine::AMMNodeBase::HandleMessageReturnValue(aContext);

    	}

    }

void CMMSockSubSession::ConstructL()

    {

    CSockSubSession::ConstructL(NULL);

    ACFMMNodeIdBase::ConstructL();

    }

//Very useful function not to have to construct a message on the stack

void CMMSockSubSession::ReceivedL(TUint16 aIpcId, const Messages::TSignatureBase& aCFMessage)

	{

	static_cast<Messages::ANode*>(this)->ReceivedL(TNodeCtxId(aIpcId, Id()), TNodeCtxId(aIpcId, Id()), const_cast<Messages::TSignatureBase&>(aCFMessage));

	}

//This function could be specialised by any of the subsessions

void CMMSockSubSession::CommsApiExtBindIfaceL(const RMessage2& aMessage)

	{

	const RNodeInterface* sp = ServiceProvider();

	if (sp)

    	{

		TSupportedCommsApiExt interfaceId = static_cast<TSupportedCommsApiExt>(aMessage.Int0());

		TOpenExtensionInterface msg(UniqueId(), interfaceId, aMessage);

    	sp->PostMessage(Id(), msg);

    	DontCompleteCurrentRequest();

    	}

    else

        {

        User::Leave(KErrNotReady);

        }

	}

//This function could be specialised by any of the subsessions

void CMMSockSubSession::CommsApiExtIfaceSendReceiveL(const RMessage2& aMessage)

	{

	const RNodeInterface* sp = ServiceProvider();

	if (sp)

    	{

		Elements::RResponseMsg responseMsg(aMessage, aMessage.Int0(), 1, 2);

		TApiExtMsgDispatcher msgDispatcher(UniqueId(), responseMsg);

    	sp->PostMessage(Id(), msgDispatcher);

    	DontCompleteCurrentRequest();

    	}

    else

        {

        User::Leave(KErrNotReady);

        }

	}

//This function could be specialised by any of the subsessions

void CMMSockSubSession::CloseExtensionInterface(const RMessage2& aMessage)

	{

	const RNodeInterface* sp = ServiceProvider();

	if (sp)

    	{

		TSupportedCommsApiExt interfaceId = static_cast<TSupportedCommsApiExt>(aMessage.Int0());

		TCloseExtensionInterface msg(UniqueId(), interfaceId, aMessage);

    	sp->PostMessage(Id(), msg);

    	DontCompleteCurrentRequest();

    	}

	}

//This function could be specialised by any of the subsessions

void CMMSockSubSession::CancelAndCloseAllClientExtIfaces()

	{

	const RNodeInterface* sp = ServiceProvider();

	if(sp)

		{

		TCancelAndCloseAllClientExtItf msg(UniqueId());

		sp->PostMessage(Id(), msg);

		}

	}