/*
* Copyright (c) 2003-2007 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:  IKEv1 keep alive object
*
*/


#include <eikenv.h>
#include <es_sock.h>
#include <e32math.h>
#include "ikedebug.h"
#include "ikev1keepalive.h"
#include "ikev1pluginsession.h"

_LIT8(KMsgContent, "\xff");

CIkeV1KeepAlive* CIkeV1KeepAlive::NewL( CIkev1PluginSession& aPluginSession,
                                        TInt aPort,
                                        TInetAddr& aDestAddr, 
                                        TInt NatKeepAlive,
                                        TInt DpdKeepAlive,
                                        MDpdHeartBeatEventHandler* aHandler,
                                        TUint8 aDscp )
    {
	CIkeV1KeepAlive* self = new (ELeave) CIkeV1KeepAlive( aPluginSession,
	                                                      aPort,
	                                                      aDestAddr,
	                                                      NatKeepAlive, 
	                                                      DpdKeepAlive,
	                                                      aHandler,
	                                                      aDscp );
	CleanupStack::PushL( self );					   	
	self->ConstructL();
	CleanupStack::Pop( self );
	return self;
    }



CIkeV1KeepAlive::CIkeV1KeepAlive( CIkev1PluginSession& aPluginSession,
                                  TInt aPort,
                                  TInetAddr& aDestAddr, 
                                  TInt aNatKeepAlive,
                                  TInt aDpdKeepAlive, 
                                  MDpdHeartBeatEventHandler* aHandler,
                                  TUint8 aDscp ) 
 : CTimer( EPriorityStandard ),
   iPluginSession( aPluginSession ),
   iPort( aPort ),
   iMsg( KMsgContent )
    {
	iDestAddr     = aDestAddr;
	iNatKeepAlive = aNatKeepAlive;
	iDpdKeepAlive = aDpdKeepAlive;
	iCallback     = aHandler;
	iDscp         = aDscp;
    CActiveScheduler::Add( this );
    }

//Destructor
CIkeV1KeepAlive::~CIkeV1KeepAlive()
    {
    Cancel();
    }


void CIkeV1KeepAlive::ConstructL()
    {
    //
    // If NAT keepalive timoeut allocate (and initialize) a TIkeXmitBfr data buffer for
    // NAT keepalive. Allocate a data buffer for special "Echo request"
    // keepalive message, if proprietary "Nokia NAT Traversal is used".
    // Start keep alive timer
    //
    CTimer::ConstructL();
   
    if ( (iNatKeepAlive >= iDpdKeepAlive) && (iDpdKeepAlive != 0) && iCallback )
        iNatKeepAlive	= 0;  // Not needed

    if ( iNatKeepAlive )
        {
        iDestAddr.SetPort(iPort);
	   
        iRemainingTime = iNatKeepAlive;
        if ( iCallback )
            iCurrDPDTimeLeft = iDpdKeepAlive - iNatKeepAlive;
        else iDpdKeepAlive = 0;
        }
    else
        {
        iRemainingTime = iDpdKeepAlive;
        }	    

    StartTimer();
    }


void CIkeV1KeepAlive::DoCancel()
    {
    CTimer::DoCancel();
    }

void CIkeV1KeepAlive::RunL()
    {
	if ( iRemainingTime == 0 ) 
	    {
	    TBool DpdEvent = EFalse;	
	    if ( iDpdKeepAlive )
	        {
	        if ( ( iCurrDPDTimeLeft == 0 ) && iCallback )
	            {
	            //
	            // Call DPD event handler 
	            //
	            DpdEvent = ETrue; 
	            iCallback->EventHandlerL();
	            iRemainingTime = iDpdKeepAlive;				 			  
	            }		 
	        }	   

	    if ( iNatKeepAlive )
	        {
	        //
	        // Send a NAT keepalive message(s)
	        //
	        if ( !DpdEvent )
	            {	   
	            iPluginSession.SendNatKeepAliveL( iDestAddr,
	                                              iMsg,
	                                              iDscp );
	            }
		   
	        iRemainingTime = iNatKeepAlive;
		   
	        if ( iDpdKeepAlive )
	            {
	            if ( DpdEvent )
	                {	  
	                iCurrDPDTimeLeft = iDpdKeepAlive - iNatKeepAlive;
	                }	 
	            else
	                {
	                if ( iCurrDPDTimeLeft < iNatKeepAlive )
	                    {
	                    iRemainingTime   = iCurrDPDTimeLeft; 
	                    iCurrDPDTimeLeft = 0;					 
	                    }	 
	                else iCurrDPDTimeLeft -= iNatKeepAlive;
	                }	  
	            }
	        }	   
	    }
	
	StartTimer();	
    }

TInt CIkeV1KeepAlive::RunError(TInt /*aError*/)
    {
    return KErrNone;
    }

void CIkeV1KeepAlive::StartTimer()
    {	
    if ( iRemainingTime > KMaxTInt/1000000 )   //To avoid overflowing the Timer
        {
        iRemainingTime -= KMaxTInt/1000000;
		After(KMaxTInt);
        }
    else    //No overflow
        {
		if ( iRemainingTime )
		    {
		    After(iRemainingTime*1000000);
		    }
		iRemainingTime = 0;
        }
    }