--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/realtimenetprots/sipfw/SIP/ConnectionMgr/src/multipleaddrressender.cpp Tue Feb 02 01:03:15 2010 +0200
@@ -0,0 +1,376 @@
+// 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:
+// Name : multipleaddrressender.cpp
+// Part of : ConnectionMgr
+// Version : SIP/4.0
+//
+
+
+
+
+#include "multipleaddrressender.h"
+#include "sipresponse.h"
+#include "multiaddrsenderowner.h"
+#include "CSIPServerResolver.h"
+#include "sipuri.h"
+#include "sipviaheader.h"
+#include "siphostport.h"
+#include "SipLogs.h"
+#include "MSIPResolvingResult.h"
+#include "sipstrings.h"
+#include "sipstrconsts.h"
+#include "TSIPTransportParams.h"
+#include "siperr.h"
+
+
+const TInt CMultipleAddrResSender::iMultisenderOffset =
+ _FOFF(CMultipleAddrResSender, iMultisenderLink);
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::CMultipleAddrResSender
+// -----------------------------------------------------------------------------
+//
+CMultipleAddrResSender::CMultipleAddrResSender(
+ const TSIPTransportParams& aParams,
+ MMultiAddrSenderOwner& aOwner,
+ MTimerManager& aTimer,
+ CSIPServerResolver& aServerResolver,
+ TUint aICMPErrorWaitTime
+ ) :
+ CActive( CActive::EPriorityStandard ),
+ iTransportParams( aParams ),
+ iOwner( &aOwner ),
+ iTimer( aTimer ),
+ iServerResolver( aServerResolver ),
+ iICMPErrorWaitTime( aICMPErrorWaitTime ),
+ iInUse( EFalse ),
+ iState( EInitialized ),
+ iICMPErrorOccuredWhileActive( EFalse )
+ {
+ CActiveScheduler::Add( this );
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::~CMultipleAddrResSender
+// -----------------------------------------------------------------------------
+//
+CMultipleAddrResSender::~CMultipleAddrResSender()
+ {
+ CompleteClientRequest( KErrSIPTransportFailure );
+ iTimer.Stop( iTimerId );
+ iServerResolver.Cancel( this );
+ Cancel();
+ iResultArray.ResetAndDestroy();
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::SendL
+// -----------------------------------------------------------------------------
+//
+void CMultipleAddrResSender::SendL ( CSIPResponse& aResponse,
+ const TInetAddr& aAddr,
+ TRequestStatus& aStat )
+ {
+ __ASSERT_ALWAYS( !iInUse, User::Leave( KErrInUse ) );
+
+ iFirstAddr = aAddr;
+ iResponse = &aResponse;
+ iInUse = ETrue;
+
+ iOwner->SendToNetL( iTransportParams, aResponse, aAddr, iStatus);
+
+ iState = CMultipleAddrResSender::ESendingFirst;
+ aStat = KRequestPending;
+ iClientStatus = &aStat;
+ SetActive();
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::ICMPErrorL
+// -----------------------------------------------------------------------------
+//
+void CMultipleAddrResSender::ICMPErrorL(
+ CSipConnectionMgr::TICMPError /*aICMPError*/,
+ const TInetAddr& aErrAddress )
+ {
+ if ( iState == CMultipleAddrResSender::ESendingList &&
+ IndexWithinBounds() &&
+ iResultArray[ iCurrentIndex ]->Address().CmpAddr( aErrAddress ) )
+ {
+ iResultArray[ iCurrentIndex ]->SetFailed(ETrue);
+ ICMPErrorWithCurrentAddressL();
+ }
+ else if ( iState == CMultipleAddrResSender::ESendingFirst )
+ {
+ if ( iFirstAddr.Match(aErrAddress) &&
+ iFirstAddr.Port() == aErrAddress.Port() )
+ {
+ ICMPErrorWithCurrentAddressL();
+ }
+ }
+ else
+ {
+ // Required by PC-Lint
+ }
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::RunL
+// -----------------------------------------------------------------------------
+//
+void CMultipleAddrResSender::RunL()
+ {
+ CompleteClientRequest( iStatus.Int() );
+
+ if ( iStatus == KErrNone )
+ {
+ switch ( iState )
+ {
+ case CMultipleAddrResSender::ESendingFirst:
+ case CMultipleAddrResSender::ESendingList:
+ WaitForICMPErrorsL();
+ break;
+ default:
+ break;
+ }
+ }
+ else
+ {
+ iOwner->Remove( this );
+ }
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::CancelResponse
+// -----------------------------------------------------------------------------
+//
+TBool CMultipleAddrResSender::CancelResponse( TRequestStatus& aStat )
+ {
+ if ( &aStat == iClientStatus &&
+ iState == CMultipleAddrResSender::ESendingFirst )
+ {
+ CompleteClientRequest( KErrSIPTransportFailure );
+ if ( IsActive() )
+ {
+ iOwner->CancelRequest( iStatus );
+ }
+ else
+ {
+ iTimer.Stop( iTimerId );
+ iOwner->Remove( this );
+ }
+ return ETrue;
+ }
+ return EFalse;
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::DoCancel
+// -----------------------------------------------------------------------------
+//
+void CMultipleAddrResSender::DoCancel()
+ {
+ iOwner->CancelRequest( iStatus );
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::RunError
+// -----------------------------------------------------------------------------
+//
+TInt CMultipleAddrResSender::RunError( TInt aError )
+ {
+ if ( aError != KErrNoMemory )
+ {
+ return KErrNone;
+ }
+ return aError;
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::ICMPErrorWithCurrentAddressL
+// -----------------------------------------------------------------------------
+//
+void CMultipleAddrResSender::ICMPErrorWithCurrentAddressL()
+ {
+ if ( !IsActive() )
+ {
+ iTimer.Stop( iTimerId );
+ SendNextL();
+ }
+ else
+ {
+ iICMPErrorOccuredWhileActive = ETrue;
+ }
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::WaitForICMPErrorsL
+// -----------------------------------------------------------------------------
+//
+void CMultipleAddrResSender::WaitForICMPErrorsL()
+ {
+ if ( iICMPErrorOccuredWhileActive )
+ {
+ SendNextL();
+ iICMPErrorOccuredWhileActive = EFalse;
+ }
+ else
+ {
+ iTimerId = iTimer.StartL( this, iICMPErrorWaitTime );
+ }
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::SendNextL
+// -----------------------------------------------------------------------------
+//
+void CMultipleAddrResSender::SendNextL()
+ {
+ if ( IsActive() )
+ {
+ return;
+ }
+
+ if ( iState == CMultipleAddrResSender::ESendingFirst )
+ {
+ ResolveL();
+ iState = CMultipleAddrResSender::EResolving;
+ return;
+ }
+
+ if ( iState == CMultipleAddrResSender::EResolving ||
+ iState == CMultipleAddrResSender::ESendingList )
+ {
+ MSIPResolvingResult* result = FirstUnfailedResult();
+ if ( result )
+ {
+ SendToNetL( *result );
+ iState = CMultipleAddrResSender::ESendingList;
+ }
+ else
+ {
+ // Sending to every resolved address failed, resolve more
+ ResolveL();
+ iState = CMultipleAddrResSender::EResolving;
+ }
+ }
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::TimerExpiredL
+// -----------------------------------------------------------------------------
+//
+void CMultipleAddrResSender::TimerExpiredL (TTimerId /*aTimerId*/,
+ TAny* /*aTimerParam*/)
+ {
+ __SIP_LOG( "CMultipleAddrResSender::TimerExpiredL" )
+ iOwner->Remove( this );
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::Has2xxResponse
+// -----------------------------------------------------------------------------
+//
+TBool CMultipleAddrResSender::Has2xxResponse() const
+ {
+ return ( iResponse && iResponse->Type() == CSIPResponse::E2XX );
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::CompletedL
+// -----------------------------------------------------------------------------
+//
+void CMultipleAddrResSender::CompletedL()
+ {
+ SendNextL();
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::ErrorOccured
+// -----------------------------------------------------------------------------
+//
+void CMultipleAddrResSender::ErrorOccured( TInt /*aError*/ )
+ {
+ iOwner->Remove( this );
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::SendToNetL
+// -----------------------------------------------------------------------------
+//
+void CMultipleAddrResSender::SendToNetL( MSIPResolvingResult& aResult )
+ {
+ iOwner->SendToNetL( iTransportParams, *iResponse, aResult.Address(), iStatus );
+ SetActive();
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::ResolveL
+// -----------------------------------------------------------------------------
+//
+void CMultipleAddrResSender::ResolveL()
+ {
+ if ( iResponse->HasHeader( SIPStrings::StringF(SipStrConsts::EViaHeader) ) )
+ {
+ CSIPHeaderBase* header = iResponse->Header(
+ SIPStrings::StringF(SipStrConsts::EViaHeader), 0 );
+ CSIPViaHeader* via = static_cast<CSIPViaHeader*>( header );
+ iServerResolver.GetByViaL( *via, iResultArray, this );
+ }
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::CompleteClientRequest
+// -----------------------------------------------------------------------------
+//
+void CMultipleAddrResSender::CompleteClientRequest(TInt aReason)
+ {
+ if ( iState == CMultipleAddrResSender::ESendingFirst )
+ {
+ TRequestStatus* stat = iClientStatus;
+ if ( stat && *stat == KRequestPending )
+ {
+ User::RequestComplete( stat, aReason );
+ }
+ iClientStatus = 0;
+ }
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::IndexWithinBounds
+// -----------------------------------------------------------------------------
+//
+TBool CMultipleAddrResSender::IndexWithinBounds()
+ {
+ return ( iCurrentIndex >= 0 && iCurrentIndex < iResultArray.Count() );
+ }
+
+// -----------------------------------------------------------------------------
+// CMultipleAddrResSender::FirstUnfailedResult
+// -----------------------------------------------------------------------------
+//
+MSIPResolvingResult* CMultipleAddrResSender::FirstUnfailedResult()
+ {
+ for ( TInt i = 0; i < iResultArray.Count(); i++ )
+ {
+ MSIPResolvingResult* result = iResultArray[ i ];
+ if ( !result->Failed() )
+ {
+ iCurrentIndex = i;
+ return result;
+ }
+ }
+ iCurrentIndex = KErrNotFound;
+ return 0;
+ }