/*
* Copyright (c) 2002-2003 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 "rtpcommrecv.h"

/////////////////////Class CRtpCommRecv///////////////////////////////////////
// ================= MEMBER FUNCTIONS =======================

// ---------------------------------------------------------------------------
// SetRemoteAddress
// ---------------------------------------------------------------------------
//
void CRtpCommRecv::SetRemoteAddress(TInetAddr& aAddr)
    {
    iRemoteAddr.SetAddress( aAddr.Address() ); 
    iRemoteAddr.SetPort( aAddr.Port() );     
    if (aAddr.Family() == KAfInet6 )
    	{
     	iRemoteAddr.SetAddress( aAddr.Ip6Address() ); 
     	}    
    iRemoteAddrSet = ETrue;
    }

// ---------------------------------------------------------------------------
// C++ default constructor can NOT contain any code, that
// might leave.
// ---------------------------------------------------------------------------
//
CRtpCommRecv::CRtpCommRecv( TPortType aPortType, RSocket& aSocket, 
                            TInt aPriority, MRtpErrNotify& aErrNotify,
                            TBool aNonRtpObserverSet ) 
    : CActive( aPriority ), 
      iPortType( aPortType ),
      iRecvNotify( NULL ),
      iSocket( aSocket ),
      iRtpErrNotify( aErrNotify ),
      iNonRtpObserverSet(aNonRtpObserverSet)
    {
    // Note: high priority needed to prevent socket server buffers filling up
    CActiveScheduler::Add( this );
    }

// ---------------------------------------------------------------------------
// Symbian 2nd phase constructor can leave.
// ---------------------------------------------------------------------------
// 
void CRtpCommRecv::ConstructL()
    {
    }

// ---------------------------------------------------------------------------
// Two-phased constructor.
// ---------------------------------------------------------------------------
//
CRtpCommRecv* CRtpCommRecv::NewL( TPortType aPortType, RSocket& aSocket, 
                                  TInt aPriority, MRtpErrNotify& aErrNotify,
                                  TBool aNonRtpObserverSet )
    {
    CRtpCommRecv* self = new ( ELeave ) CRtpCommRecv( aPortType, aSocket, 
                                                      aPriority, aErrNotify,
                                                      aNonRtpObserverSet );
    CleanupStack::PushL( self );
    self->ConstructL();
    CleanupStack::Pop(); //self
    return self;
    }

// ---------------------------------------------------------------------------
// Destructor
// ---------------------------------------------------------------------------
//
CRtpCommRecv::~CRtpCommRecv()
    {
    Cancel(); // -> in base class -> goes on to call DoCancel in this class...
    }

// ---------------------------------------------------------------------------
// CRtpCommRecv::DoCancel()
// Cancel ongoing requests.
// ---------------------------------------------------------------------------
//
void CRtpCommRecv::DoCancel()
    {
    // Cancel asychronous read request
    iSocket.CancelRead();
    }

// ---------------------------------------------------------------------------
// CRtpCommRecv::RegisterReceivedNotify()
// 
// ---------------------------------------------------------------------------
//
void CRtpCommRecv::RegisterReceivedNotify( MReceivedNotify* aNotify )
    {
    iRecvNotify = aNotify;
    }

// ---------------------------------------------------------------------------
// CRtpCommRecv::SetNonRtpObserverFlag()
// 
// ---------------------------------------------------------------------------
//
void CRtpCommRecv::SetNonRtpObserverFlag(TBool aValue)
    {
    iNonRtpObserverSet = aValue;
    }

// ---------------------------------------------------------------------------
// CRtpCommRecv::Recv()
// 
// ---------------------------------------------------------------------------
//
TInt CRtpCommRecv::Recv( TDes8& aPacket )
    {
    if ( !IsActive() )
        {
        iSocket.RecvFrom( aPacket, iFromAddr, 0, iStatus );
      
        SetActive();
        return KErrNone;
        }
    else
        {
        return KErrInUse;
        }
    }

// ---------------------------------------------------------------------------
// CRtpCommRecv::RunL()
// 
// ---------------------------------------------------------------------------
//
void CRtpCommRecv::RunL()
    {
    RTP_DEBUG_DETAIL( "CRtpCommRecv::RunL entry" );
    if ( !iRecvNotify )
		{
     	RTP_DEBUG_PACKET( "CRtpCommRecv::RunL -- No receiver registered" );
     	iRtpErrNotify.ErrorNotify( KErrNotReady );
   		}
    else
    	{
	  	if ( iStatus == KErrNone )
	  	  	{
	       	if (!iNonRtpObserverSet  &&
                 iRemoteAddrSet && !iFromAddr.Match(iRemoteAddr))
	            {
	            // reject
	            RTP_DEBUG_DETAIL( "Reject Rtp packet received" );
    
	            iRecvNotify->OnPacketRejected(iPortType);
	            }
			else                    
	       		{
	       		//Note that Floor Control Msgs comes from the same remote addr with 
	       		// rtp packets.
	   		 	if ( iPortType == ERTPPort )
	          		{
		          	RTP_DEBUG_DETAIL( "CRtpCommRecv::RunL -- Rtp Packet is received");
			      	iRecvNotify->OnRtpReceivedL();
	    	    	}
	            else if ( iPortType == ERTCPPort )
	      	  	    {
	        	    RTP_DEBUG_DETAIL( "CRtpCommRecv::RunL -- Rtcp Packet is received" );
	        	    iRecvNotify->OnRtcpReceivedL();
	        	    }
	    	    else
	      	  	    {
	        	    // Do nothing
	        	    RTP_DEBUG_DETAIL( "CRtpCommRecv::RunL -- Unknown port type" );
	        	    }
	            }
  	  	    }
  		else
      		{
      	    RTP_DEBUG_DETAIL_DVALUE( "CRtpCommRecv::RunL -- ERROR: iStatus: ", iStatus.Int() );
        	// Also let the client application know that this happened
        	iRtpErrNotify.ErrorNotify( iStatus.Int() );
        	// Let the session decide what to do with the error
         	iRecvNotify->OnReceptionError( iPortType, iStatus.Int() );
        	}
    	}
    RTP_DEBUG_DETAIL( "CRtpCommRecv::RunL exit" );
    }	

// ---------------------------------------------------------------------------
// CRtpCommRecv::IsSetRemoteAdress()
// 
// ---------------------------------------------------------------------------
//
TBool CRtpCommRecv::IsSetRemoteAdress()
	{
	TBool same = ETrue;
	//This will be called by RtpSession classe to verify if the packet come from
	// setting remote address. This is important when NonRtpObserver has been set
	// in RunL and when NonRtpObs has been set, then it does not check remote address
	// since some response might come from STUN server, but if "from" address is not
	//checked then there could be some intrusion RTP valid packet and RTP stack is
	// volunerable for this attack. 
	if ( iRemoteAddrSet && !iFromAddr.Match(iRemoteAddr))
		{
		same = EFalse;
        return same;
        }
    return same;    
	}

//  End of File