realtimenetprots/sipfw/SIP/ConnectionMgr/src/CResHandler.cpp
changeset 0 307788aac0a8
equal deleted inserted replaced
-1:000000000000 0:307788aac0a8
       
     1 // Copyright (c) 2002-2009 Nokia Corporation and/or its subsidiary(-ies).
       
     2 // All rights reserved.
       
     3 // This component and the accompanying materials are made available
       
     4 // under the terms of "Eclipse Public License v1.0"
       
     5 // which accompanies this distribution, and is available
       
     6 // at the URL "http://www.eclipse.org/legal/epl-v10.html".
       
     7 //
       
     8 // Initial Contributors:
       
     9 // Nokia Corporation - initial contribution.
       
    10 //
       
    11 // Contributors:
       
    12 //
       
    13 // Description:
       
    14 // Name          : CResHandler.cpp
       
    15 // Part of       : ConnectionMgr
       
    16 // Version       : SIP/4.0 
       
    17 //
       
    18 
       
    19 
       
    20 
       
    21 
       
    22 #include "CResHandler.h"
       
    23 #include "SipLogs.h"
       
    24 #include "Lwtimer.h"
       
    25 #include "CTransportUdp.h"
       
    26 #include "multipleaddrressender.h"
       
    27 #include "sipresponse.h"
       
    28 #include "sipmessage.h"
       
    29 
       
    30 const TInt CResponseHandler::iOffset = _FOFF(CResponseHandler, iLink);
       
    31 
       
    32 // -----------------------------------------------------------------------------
       
    33 // CResponseHandler::NewL
       
    34 // -----------------------------------------------------------------------------
       
    35 //
       
    36 CResponseHandler* CResponseHandler::NewL(CTransportUdp& aOwner,
       
    37 										 MTimerManager& aTimer,
       
    38 										 CSIPServerResolver& aServerResolver,
       
    39 										 TTransactionId aId,
       
    40 										 TUint aICMPErrorWaitTime)
       
    41 	{
       
    42 	CResponseHandler* self = NewLC(aOwner, aTimer, aServerResolver,
       
    43 								   aId, aICMPErrorWaitTime);
       
    44 	CleanupStack::Pop(self);
       
    45 	return self;
       
    46 	}
       
    47 
       
    48 // -----------------------------------------------------------------------------
       
    49 // CResponseHandler::NewLC
       
    50 // -----------------------------------------------------------------------------
       
    51 //
       
    52 CResponseHandler* CResponseHandler::NewLC(CTransportUdp& aOwner,
       
    53 										  MTimerManager& aTimer,
       
    54 										  CSIPServerResolver& aServerResolver,
       
    55 										  TTransactionId aId,
       
    56 										  TUint aICMPErrorWaitTime)
       
    57 	{
       
    58 	CResponseHandler* self =
       
    59 		new (ELeave) CResponseHandler(aOwner, aTimer, aServerResolver,
       
    60 									  aId, aICMPErrorWaitTime);
       
    61 	CleanupStack::PushL(self);
       
    62 	return self;
       
    63 	}
       
    64 
       
    65 // -----------------------------------------------------------------------------
       
    66 // CResponseHandler::Handle
       
    67 // -----------------------------------------------------------------------------
       
    68 //
       
    69 TBool CResponseHandler::Handle(TTransactionId aId) const
       
    70 	{
       
    71 	return (aId == iId);
       
    72 	}
       
    73 
       
    74 // -----------------------------------------------------------------------------
       
    75 // CResponseHandler::SendL
       
    76 // -----------------------------------------------------------------------------
       
    77 //
       
    78 void CResponseHandler::SendL(const TSIPTransportParams& aParams,
       
    79                              CSIPResponse& aResponse,
       
    80 							 const TInetAddr& aAddr,
       
    81 							 TRequestStatus& aStat)
       
    82 	{
       
    83 	CMultipleAddrResSender* multiSender =
       
    84 		new (ELeave) CMultipleAddrResSender(aParams,
       
    85 		                                    *this,
       
    86 											*iTimer,
       
    87 											*iServerResolver,
       
    88 											iICMPErrorWaitTime
       
    89 											);
       
    90 	iList.AddLast(*multiSender);
       
    91 	multiSender->SendL(aResponse, aAddr, aStat);
       
    92 	}
       
    93 
       
    94 // -----------------------------------------------------------------------------
       
    95 // CResponseHandler::CancelAll
       
    96 // -----------------------------------------------------------------------------
       
    97 //
       
    98 TBool CResponseHandler::CancelAll(
       
    99     TTransactionId aId, 
       
   100     TBool aCancelAlso2xxResponses)
       
   101 	{
       
   102 	if ( aId == iId )
       
   103 		{
       
   104 		CMultipleAddrResSender* listItem;
       
   105 		iListIter.SetToFirst();
       
   106 		while ( ( listItem = iListIter++ ) != 0 )
       
   107 			{
       
   108 			if ( aCancelAlso2xxResponses || !listItem->Has2xxResponse() )
       
   109 			    {
       
   110 			    iList.Remove( *listItem );
       
   111 			    delete listItem;
       
   112 			    }
       
   113 			}
       
   114 	    if ( iList.IsEmpty() )
       
   115 	        {
       
   116 	    	iTransport->RemoveResHandler( this );
       
   117 	        }
       
   118 		return ETrue;
       
   119 		}
       
   120 	return EFalse;
       
   121 	}
       
   122 
       
   123 // -----------------------------------------------------------------------------
       
   124 // CResponseHandler::SendToNetL
       
   125 // -----------------------------------------------------------------------------
       
   126 //
       
   127 void CResponseHandler::SendToNetL(const TSIPTransportParams& aParams,
       
   128                                   CSIPResponse& aResponse,
       
   129 								  const TInetAddr& aAddr,
       
   130 								  TRequestStatus& aStat)
       
   131 	{
       
   132 	iTransport->SendToNetL(aParams, aAddr, aResponse, aStat);
       
   133 	}
       
   134 
       
   135 // -----------------------------------------------------------------------------
       
   136 // CResponseHandler::CancelRequest
       
   137 // -----------------------------------------------------------------------------
       
   138 //
       
   139 TBool CResponseHandler::CancelRequest(TRequestStatus& aStat)
       
   140 	{
       
   141 	return iTransport->CancelSend(aStat);
       
   142 	}
       
   143 
       
   144 // -----------------------------------------------------------------------------
       
   145 // CResponseHandler::ICMPErrorL
       
   146 // -----------------------------------------------------------------------------
       
   147 //
       
   148 void CResponseHandler::ICMPErrorL(CSipConnectionMgr::TICMPError aICMPError,
       
   149 								  const TInetAddr& aSourceAddr)
       
   150 	{
       
   151 	CMultipleAddrResSender* listItem;
       
   152 	iListIter.SetToFirst();
       
   153 	while ((listItem = iListIter++) !=0)
       
   154 		{
       
   155 		listItem->ICMPErrorL(aICMPError, aSourceAddr);
       
   156 		}
       
   157 	}
       
   158 
       
   159 // -----------------------------------------------------------------------------
       
   160 // CResponseHandler::Remove
       
   161 // -----------------------------------------------------------------------------
       
   162 //
       
   163 void CResponseHandler::Remove(CMultipleAddrResSender* aSender)
       
   164 	{
       
   165 	if( !iList.IsEmpty() )
       
   166 	    {
       
   167 	    iList.Remove(*aSender);
       
   168 	    delete aSender;
       
   169 	    __SIP_LOG( "CMultipleAddrResSender removed" )
       
   170 	    }
       
   171 	}
       
   172 
       
   173 // -----------------------------------------------------------------------------
       
   174 // CResponseHandler::CResponseHandler
       
   175 // -----------------------------------------------------------------------------
       
   176 //
       
   177 CResponseHandler::CResponseHandler(CTransportUdp& aOwner,
       
   178 								   MTimerManager& aTimer,
       
   179 								   CSIPServerResolver& aServerResolver,
       
   180 								   TTransactionId aId,
       
   181 								   TUint aICMPErrorWaitTime) : 
       
   182 	iTransport(&aOwner), iTimer(&aTimer), iServerResolver(&aServerResolver),  
       
   183 	iList(CMultipleAddrResSender::iMultisenderOffset), iListIter(iList),
       
   184 	iICMPErrorWaitTime(aICMPErrorWaitTime)
       
   185 	{
       
   186 	iId = aId;
       
   187 	}
       
   188 
       
   189 // -----------------------------------------------------------------------------
       
   190 // CResponseHandler::~CResponseHandler
       
   191 // -----------------------------------------------------------------------------
       
   192 //
       
   193 CResponseHandler::~CResponseHandler() 
       
   194 	{
       
   195 	CMultipleAddrResSender* listItem = 0;
       
   196 	iListIter.SetToFirst();
       
   197 	while ((listItem = iListIter++) != 0)
       
   198 		{
       
   199 		iList.Remove(*listItem);
       
   200 		delete listItem;
       
   201 		}
       
   202 	}