// Copyright (c) 2002-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          : CTcpTransConnecting.cpp

// Part of       : ConnectionMgr

// Version       : SIP/6.0 

//

#include "CTcpTransConnecting.h"

#include "sipmessage.h"

#include "CTransportTcp.h"

#include "CReceiverTcp.h"

#include "CSender.h"

#include "COutgoingData.h"

#include "MTransportOwner.h"

#include "CommonConsts.h"

#include "sipstrings.h"

#include "sipstrconsts.h"

#include "siperr.h"

// -----------------------------------------------------------------------------

// CTcpTransportConnecting::NewL

// -----------------------------------------------------------------------------

//

CTcpTransportConnecting* CTcpTransportConnecting::NewL(

    const TSIPTransportParams& aParams)

	{

	CTcpTransportConnecting* self = NewLC(aParams);

	CleanupStack::Pop(self);

	return self;

	}

// -----------------------------------------------------------------------------

// CTcpTransportConnecting::NewLC

// -----------------------------------------------------------------------------

//

CTcpTransportConnecting* CTcpTransportConnecting::NewLC(

    const TSIPTransportParams& aParams)

	{

	CTcpTransportConnecting* self = 

	                new (ELeave) CTcpTransportConnecting(aParams);

	CleanupStack::PushL(self);

	return self;

	}

// -----------------------------------------------------------------------------

// CTcpTransportConnecting::CancelSend

// -----------------------------------------------------------------------------

//

TBool CTcpTransportConnecting::CancelSend(TRequestStatus& aStatus,

										  CTransportTcp* aContext)

	{

	__ASSERT_DEBUG(aContext, User::Panic(_L("Nullpointer"), KErrGeneral));

	return aContext->GetSender()->FindAndCancel(aStatus);

	}

// -----------------------------------------------------------------------------

// CTcpTransportConnecting::Wait

// -----------------------------------------------------------------------------

//

void CTcpTransportConnecting::Wait(CTransportTcp* /*aContext*/)

	{

	}

// -----------------------------------------------------------------------------

// CTcpTransportConnecting::HandleMessage

// -----------------------------------------------------------------------------

//

TBool CTcpTransportConnecting::HandleMessage(RStringF aProtocol, 

										 	 const TInetAddr& aRemoteAddr, 

										 	 CTransportTcp* aContext)

	{

	__ASSERT_DEBUG(aContext, User::Panic(_L("Nullpointer"), KErrGeneral));

	TInetAddr connect;

	aContext->GetRemoteAddr(connect);

	return (aProtocol == SIPStrings::StringF(SipStrConsts::ETCP) &&

	    	connect.CmpAddr(aRemoteAddr));

	}

// -----------------------------------------------------------------------------

// CTcpTransportConnecting::SendToNetL

// -----------------------------------------------------------------------------

//

void CTcpTransportConnecting::SendToNetL(const TSIPTransportParams& aParams,

                            CSIPMessage& aMessage,

							const TInetAddr& aAddr,

							TRequestStatus &aStatus,

							TUint aOrigTransport,

							CTransportTcp* aContext)

	{

	__ASSERT_DEBUG(aContext, User::Panic(_L("Nullpointer"), KErrGeneral));

	TBool connect = aContext->GetSender()->SendL(aParams,

                	                             aMessage,

                							     aAddr,

                			                     aOrigTransport,

                			                     aStatus,

                			                     ETrue,

                			                     EFalse);

	if ( connect )

	    {

	    aContext->ConnectSocket();

	    }

	}

// -----------------------------------------------------------------------------

// CTcpTransportConnecting::CancelAllRequests

// -----------------------------------------------------------------------------

//

void CTcpTransportConnecting::CancelAllRequests(CSIPConnection::TState aReason, 

												CTransportTcp* aContext)

	{

	__ASSERT_DEBUG(aContext, User::Panic(_L("Nullpointer"), KErrGeneral));

	aContext->GetSender()->CancelAllRequests(aReason);

	}

// -----------------------------------------------------------------------------

// CTcpTransportConnecting::ConnectionOpenL

// -----------------------------------------------------------------------------

//

void CTcpTransportConnecting::ConnectionOpenL(CTransportTcp* aContext)

	{

	__ASSERT_DEBUG(aContext, User::Panic(_L("Nullpointer"), KErrGeneral));

	aContext->SetCurrentState(iConnected);

	// Possibly update sender socket opts before sending

	aContext->GetSender()->SendNextL();

	aContext->StartTimerL();

	}

// -----------------------------------------------------------------------------

// CTcpTransportConnecting::DisconnectedL

// -----------------------------------------------------------------------------

//

void CTcpTransportConnecting::DisconnectedL(CTransportTcp* aContext)

	{

	__ASSERT_DEBUG(aContext, User::Panic(_L("Nullpointer"), KErrGeneral));

	COutgoingData* data = 0;

	CSender* sender = aContext->GetSender();

	while ( (data = sender->StoredData()) != 0)

		{

		if (data->OrigTransport() == KProtocolInetUdp &&

			data->Message().IsRequest())

			{

			data->Sent();

			CleanupStack::PushL( data );

			aContext->TransportOwner()->ReRouteL(KProtocolInetUdp, 

			                                     data);

			CleanupStack::Pop( data );

			}

		else if (data->OrigTransport() == KProtocolInetTcp &&

				 !data->Message().IsRequest())

			{

			data->Sent();

			CleanupStack::PushL( data );

			aContext->TransportOwner()->ReRouteL(KProtocolInetTcp, 

			                                     data);

			CleanupStack::Pop( data );

			}

		else

			{

			TRequestStatus* stat = data->Status();

			User::RequestComplete(stat, KErrSIPTransportFailure);

			delete data;

			}

		}

	aContext->Remove();

	}

// -----------------------------------------------------------------------------

// CTcpTransportConnecting::SetNeighborState

// -----------------------------------------------------------------------------

//

void CTcpTransportConnecting::SetNeighborState(CTcpTransportState* aState)

	{

	iConnected = aState;

	}

// -----------------------------------------------------------------------------

// CTcpTransportConnecting::~CTcpTransportConnecting

// -----------------------------------------------------------------------------

//

CTcpTransportConnecting::~CTcpTransportConnecting()

	{

	}

// -----------------------------------------------------------------------------

// CTcpTransportConnecting::CTcpTransportConnecting

// -----------------------------------------------------------------------------

//

CTcpTransportConnecting::CTcpTransportConnecting(

    const TSIPTransportParams& aParams) : 

    CTcpTransportState(aParams)

	{

	}