realtimenetprots/sipfw/SIP/ConnectionMgr/src/COutgoingData.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          : COutgoingData.cpp
       
    15 // Part of       : ConnectionMgr
       
    16 // Version       : SIP/4.0 
       
    17 //
       
    18 
       
    19 
       
    20 
       
    21 
       
    22 #include "COutgoingData.h"
       
    23 #include "siprouteheader.h"
       
    24 #include "sipaddress.h"
       
    25 #include "sipuri.h"
       
    26 #include "siprequest.h"
       
    27 #include "sipresponse.h"
       
    28 #include "sipcontactheader.h"
       
    29 #include "sipfromheader.h"
       
    30 #include "siphostport.h"
       
    31 #include "MSigCompController.h"
       
    32 #include "TSIPTransportParams.h"
       
    33 
       
    34 
       
    35 
       
    36 const TInt COutgoingData::iOffset = _FOFF(COutgoingData, iLink);
       
    37 
       
    38 // -----------------------------------------------------------------------------
       
    39 // COutgoingData::NewL
       
    40 // -----------------------------------------------------------------------------
       
    41 //
       
    42 COutgoingData* COutgoingData::NewL (const TSIPTransportParams& aTransportParams,
       
    43                                     CSIPMessage& aMessage,
       
    44 									const TInetAddr& aAddr,
       
    45 								    TUint aOrigTransport, 
       
    46 									TRequestStatus& aStatus, 
       
    47 									MSigCompController& aSigCompHandler,
       
    48 									TBool aForceUDP)
       
    49 	{
       
    50 	COutgoingData* self = NewLC(aTransportParams,
       
    51 	                            aMessage,
       
    52 		                        aAddr,
       
    53 								aOrigTransport,
       
    54 								aStatus,
       
    55 								aSigCompHandler,
       
    56 								aForceUDP);
       
    57 	CleanupStack::Pop();
       
    58 	return self;
       
    59 	}
       
    60 
       
    61 // -----------------------------------------------------------------------------
       
    62 // COutgoingData::NewLC
       
    63 // -----------------------------------------------------------------------------
       
    64 //
       
    65 COutgoingData* COutgoingData::NewLC (const TSIPTransportParams& aTransportParams,
       
    66                                      CSIPMessage& aMessage,
       
    67 									 const TInetAddr& aAddr, 
       
    68 									 TUint aOrigTransport,
       
    69 									 TRequestStatus& aStatus, 
       
    70 									 MSigCompController& aSigCompHandler,
       
    71 									 TBool aForceUDP)
       
    72 	{
       
    73 	COutgoingData* self = new (ELeave) COutgoingData(aTransportParams,
       
    74 	                                                 aMessage,
       
    75 		                                             aAddr,
       
    76 		                                             aOrigTransport,
       
    77 												     aSigCompHandler,
       
    78 												     aStatus,
       
    79 												     aForceUDP);
       
    80 	CleanupStack::PushL(self);
       
    81 	return self;
       
    82 	}
       
    83 
       
    84 // -----------------------------------------------------------------------------
       
    85 // COutgoingData::NewL
       
    86 // -----------------------------------------------------------------------------
       
    87 //
       
    88 COutgoingData* COutgoingData::NewL (const TSIPTransportParams& aTransportParams,
       
    89                                     CSIPMessage& aMessage,
       
    90 									TRequestStatus& aStatus, 
       
    91 									MSigCompController& aSigCompHandler)
       
    92 	{
       
    93 	COutgoingData* self = NewLC (aTransportParams,
       
    94 	                             aMessage,
       
    95 		                         aStatus,
       
    96 								 aSigCompHandler);
       
    97 	CleanupStack::Pop();
       
    98 	return self;
       
    99 	}
       
   100 
       
   101 // -----------------------------------------------------------------------------
       
   102 // COutgoingData::NewLC
       
   103 // -----------------------------------------------------------------------------
       
   104 //
       
   105 COutgoingData* COutgoingData::NewLC (const TSIPTransportParams& aTransportParams,
       
   106                                      CSIPMessage& aMessage,
       
   107 									 TRequestStatus& aStatus, 
       
   108 									 MSigCompController& aSigCompHandler)
       
   109 	{
       
   110 	COutgoingData* self = new (ELeave) COutgoingData(aTransportParams,
       
   111 	                                                 aMessage,
       
   112 												     aSigCompHandler,
       
   113 												     aStatus);
       
   114 	CleanupStack::PushL(self);
       
   115 	return self;
       
   116 	}
       
   117 
       
   118 // -----------------------------------------------------------------------------
       
   119 // COutgoingData::COutgoingData
       
   120 // -----------------------------------------------------------------------------
       
   121 //
       
   122 COutgoingData::COutgoingData (const TSIPTransportParams& aTransportParams,
       
   123                               CSIPMessage& aMessage,
       
   124 							  MSigCompController& aSigCompHandler,
       
   125 							  TRequestStatus& aStatus)
       
   126  : iTransportParams(aTransportParams),
       
   127    iMessage(aMessage),
       
   128    iSigCompHandler(aSigCompHandler),
       
   129    iForceUDP(EFalse)
       
   130 	{
       
   131 	aStatus = KRequestPending;
       
   132 	iStatus = &aStatus;
       
   133 	}
       
   134 
       
   135 // -----------------------------------------------------------------------------
       
   136 // COutgoingData::COutgoingData
       
   137 // -----------------------------------------------------------------------------
       
   138 //
       
   139 COutgoingData::COutgoingData (const TSIPTransportParams& aTransportParams,
       
   140                               CSIPMessage& aMessage,
       
   141 							  const TInetAddr& aAddr,
       
   142 							  TUint aOrigTransport,
       
   143 							  MSigCompController& aSigCompHandler,
       
   144 							  TRequestStatus& aStatus,
       
   145 							  TBool aForceUDP)
       
   146  : iTransportParams(aTransportParams),
       
   147    iMessage(aMessage),
       
   148    iSigCompHandler(aSigCompHandler),
       
   149    iOrigTransport(aOrigTransport),
       
   150    iForceUDP(aForceUDP)
       
   151 	{
       
   152 	iAddress = aAddr;
       
   153 	aStatus = KRequestPending;
       
   154 	iStatus = &aStatus;
       
   155 	}
       
   156 
       
   157 // -----------------------------------------------------------------------------
       
   158 // COutgoingData::~COutgoingData
       
   159 // -----------------------------------------------------------------------------
       
   160 //
       
   161 COutgoingData::~COutgoingData()
       
   162 	{
       
   163 	delete iData;
       
   164 	}
       
   165 
       
   166 // -----------------------------------------------------------------------------
       
   167 // COutgoingData::DataL
       
   168 // -----------------------------------------------------------------------------
       
   169 //
       
   170 TPtr8 COutgoingData::EncodeL(TBool aStreambasedProtocol)
       
   171 	{
       
   172 	if(iData)
       
   173 	    {
       
   174 	    // Encoded data existed already
       
   175 	    return iData->Ptr(0);
       
   176 	    }
       
   177 	    
       
   178 	if(iSigCompHandler.IsSupported())
       
   179 		{
       
   180 		if(iMessage.IsRequest())
       
   181 			{
       
   182 			iData = iSigCompHandler.EncodeL(iTransportParams,
       
   183 			                                static_cast<CSIPRequest&>(iMessage),
       
   184 										    iAddress, 
       
   185 										    aStreambasedProtocol,
       
   186 											iCompressed);
       
   187 			}
       
   188 		else
       
   189 			{
       
   190 			iData =
       
   191 				iSigCompHandler.EncodeL(iTransportParams,
       
   192 				                        static_cast<CSIPResponse&>(iMessage), 
       
   193 										iAddress, 
       
   194 										aStreambasedProtocol, 
       
   195 										iCompressed);
       
   196 			}
       
   197 		}
       
   198 	else
       
   199 		{
       
   200 		if(aStreambasedProtocol)
       
   201 			{
       
   202 			iData = iMessage.ToTextHeaderPartL();
       
   203 			}
       
   204 		else
       
   205 			{
       
   206 			iData = iMessage.ToTextL();
       
   207 			}
       
   208 		}
       
   209 	return iData->Ptr(0);
       
   210 	}
       
   211 
       
   212 // -----------------------------------------------------------------------------
       
   213 // COutgoingData::Sent
       
   214 // -----------------------------------------------------------------------------
       
   215 //
       
   216 void COutgoingData::Sent()
       
   217 	{
       
   218 	delete iData;
       
   219 	iData = 0;
       
   220 	}
       
   221 
       
   222 // -----------------------------------------------------------------------------
       
   223 // COutgoingData::TransportParams
       
   224 // -----------------------------------------------------------------------------
       
   225 //	
       
   226 const TSIPTransportParams& COutgoingData::TransportParams() const
       
   227     {
       
   228     return iTransportParams;
       
   229     }
       
   230 
       
   231 // -----------------------------------------------------------------------------
       
   232 // COutgoingData::ForceUDP
       
   233 // -----------------------------------------------------------------------------
       
   234 //
       
   235 TBool COutgoingData::ForceUDP() const
       
   236     {
       
   237     return iForceUDP;
       
   238     }
       
   239     
       
   240 // -----------------------------------------------------------------------------
       
   241 // COutgoingData::HeaderPartL
       
   242 // -----------------------------------------------------------------------------
       
   243 //
       
   244 TPtr8 COutgoingData::HeaderPartL()
       
   245 	{
       
   246 	__ASSERT_DEBUG(iData == 0,
       
   247 		User::Panic(_L("Sent() was not called"),
       
   248 		KErrGeneral));
       
   249 		
       
   250 	iData = iMessage.ToTextHeaderPartL();
       
   251 	return iData->Ptr(0);
       
   252 	}
       
   253 
       
   254 // -----------------------------------------------------------------------------
       
   255 // COutgoingData::Message
       
   256 // -----------------------------------------------------------------------------
       
   257 //
       
   258 CSIPMessage& COutgoingData::Message()
       
   259 	{
       
   260 	return iMessage;
       
   261 	}
       
   262 
       
   263 // -----------------------------------------------------------------------------
       
   264 // COutgoingData::SetAddress
       
   265 // -----------------------------------------------------------------------------
       
   266 //
       
   267 void COutgoingData::SetAddress(const TInetAddr& aAddress)
       
   268 	{
       
   269 	iAddress = aAddress;
       
   270 	}