// Copyright (c) 2008-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 "app_protintf_udp.h"

#include <in_sock.h>

using namespace Messages;

CApplicationProtocolIntfBase* CApplicationProtocolIntfUdp::NewL ( TInt aPort )

	{

	CApplicationProtocolIntfUdp* self = new (ELeave)CApplicationProtocolIntfUdp( aPort );

	return self;			

	}

CApplicationProtocolIntfUdp::CApplicationProtocolIntfUdp ( TInt aPort )

: CApplicationProtocolIntfBase ( aPort, KProtocolInetUdp )

	{

	LOG_NODE_CREATE ( KESockFlowTag, CApplicationProtocolIntfUdp );	

	}

CApplicationProtocolIntfUdp::~CApplicationProtocolIntfUdp()

	{

	Shutdown();

	LOG_NODE_DESTROY(KESockFlowTag, CApplicationProtocolIntfUdp);

	}

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

	{

	if ( aMessage.MessageId().Realm() == TAppProtIntfMessage::ERealmId )

		{

		CApplicationProtocolIntfBase::ReceivedL ( aSender, aRecipient, aMessage );

		switch ( aMessage.MessageId().MessageId() )

			{

			case TAppProtIntfMessage::TJoinWithMulticastAddress::EId:

				{

				const TAppProtIntfMessage::TJoinWithMulticastAddress& msg = message_cast<const TAppProtIntfMessage::TJoinWithMulticastAddress> ( aMessage );

				iMulticastAddr = msg.iAddr;				

				InitiateLinkL ( address_cast<TNodeCtxId> ( aSender ), KSockDatagram, KProtocolInetUdp );

				}

				break;

			}

		}

	// The below message are self posted. Just to keep the operation to continue.

	if ( aMessage.MessageId().Realm() == ESock::TCFMessage::ERealmId )

		{

		switch ( aMessage.MessageId ().MessageId () )

			{

			case CApplicationProtocolIntfBase::TRecvFrom::EId:

				{

				__ASSERT_DEBUG ( iLinks.Count() > 0, User::Invariant() );

				if ( iLinks[0].Flags () != TClientType::ELeaving )

					{

					iSocketHandler.RecvFrom ();

					}

				}

			break;

			}

		}

	}

TInt CApplicationProtocolIntfUdp::Startup ()

	{

	TInt ret = KErrNone;	

	TInetAddr addr;

  	addr.SetAddress ( iMulticastAddr.iAddr );

  	addr.SetPort ( iMulticastAddr.iPort );

	if ( addr.IsMulticast() )

		{

		if ( addr.Family() != KAfInet6 )

			{

			addr.ConvertToV4Mapped();				

			}

		TPckgBuf<TIp6Mreq> mReqBuf;

		mReqBuf().iAddr = addr.Ip6Address();

		mReqBuf().iInterface = 0;

		ret = iSocket.SetOpt( KSoIp6JoinGroup, KSolInetIp, mReqBuf ); // Join the multicast group

		}

	iSocketHandler.RecvFrom(); // Start the receive

	return ret;	

	}

void CApplicationProtocolIntfUdp::Shutdown ()

	{

	TInetAddr addr;

  	addr.SetAddress ( iMulticastAddr.iAddr );

  	addr.SetPort ( iMulticastAddr.iPort );

	if ( addr.IsMulticast() )

		{

		if ( addr.Family() != KAfInet6 )

			{

			addr.ConvertToV4Mapped();				

			}

		TPckgBuf<TIp6Mreq> mReqBuf;

		mReqBuf().iAddr = addr.Ip6Address();

		mReqBuf().iInterface = 0;

		TInt ret = iSocket.SetOpt( KSoIp6LeaveGroup, KSolInetIp, mReqBuf ); // leave the multicast group

		ASSERT ( ret == KErrNone );

		}

	CApplicationProtocolIntfBase::Shutdown ();	

	}

void CApplicationProtocolIntfUdp::RecvFromComplete ( RMBufChain& aData, const TSockAddr& aAddr )

	{

	__ASSERT_DEBUG ( iLinks.Count() > 0, User::Invariant() );

	// if client is in leaving state, no need of any posts

	if ( iLinks[0].Flags() != TClientType::ELeaving )

		{

		TInetAddr inetAddr ( aAddr );

  		TAppProtAddr protAddr ( inetAddr.Address(), inetAddr.Port() );

		TAppProtIntfMessage::TDataReceived msg ( protAddr, aData );

		PostToLink ( iLinks[0], msg ); // We do assume that we have only one link ( atleast for the timebeing ).

		// Note: If we have more link then we need to make copies of RMBufChain before posting. Otherwise the ownership

		// of the RMBufChain will be an issue?			

		TNodeCtxId ctx ( MeshMachine::KActivityNull, NodeId () );

		PostToLink ( ctx, CApplicationProtocolIntfBase::TRecvFrom ().CRef () ); // Self post to keep continue with the receiving

		}

	else

		{

		aData.Free ();

		}

	}