/*

* Copyright (c) 2009-2010 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:

* MSRP Implementation

*

*/

// INTERNAL INCLUDES

#include "CMSRPConnector.h"

#include "MSRPCommon.h"

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

// CMSRPConnListener::NewL

// Static constructor

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

//

/*static*/ MMSRPConnector* CMSRPConnector::NewL(MMSRPConnectionManager& aConnMngr, MMSRPConnectorObserver& aConnection)

    {

    MSRPLOG( "CMSRPConnector::NewL enter" )

    CMSRPConnector* self = new (ELeave) CMSRPConnector( aConnMngr, aConnection );

    CleanupStack::PushL(self);

    self->ConstructL();

    CleanupStack::Pop(self);

    MSRPLOG( "CMSRPConnector::NewL exit" )

    return self;

    }

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

// CMSRPConnector::CMSRPConnector

// Constructor

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

//

CMSRPConnector::CMSRPConnector(MMSRPConnectionManager& aConnMngr, MMSRPConnectorObserver& aConnection)        

    : CActive(CActive::EPriorityStandard), iConnMngr(aConnMngr), iConnection( aConnection )

    {  

    CActiveScheduler::Add(this);

    }

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

// CMSRPConnector::~CMSRPConnector

// Destructor

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

//

CMSRPConnector::~CMSRPConnector()

    {

    MSRPLOG( "CMSRPConnector::~CMSRPConnector enter" )

    delete iTimer;

    Cancel();    

    if(iSocket)

        {

        iSocket->Close();

        delete iSocket;

        }

    MSRPLOG( "CMSRPConnector::~CMSRPConnector exit" )

    }

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

// CMSRPConnector::ConstructL

// 2nd phase constructor

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

//

void CMSRPConnector::ConstructL()

    {

    //iState = ENotConnected;

    iTimer = CMSRPTimeOutTimer::NewL( *this );

    //create socket

    iSocket = new (ELeave) RSocket();   

    User::LeaveIfError( iSocket->Open(

            iConnMngr.SocketServer(), KAfInet, KSockStream, KProtocolInetTcp, iConnMngr.SocketServerConn()));

    User::LeaveIfError( iSocket->SetOpt( KSoReuseAddr, KSolInetIp, ETrue ) );

    iSocket->SetLocalPort(KMsrpPort);

    }

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

// CMSRPConnector::DoCancel

// Cancels outstanding request.

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

//

void CMSRPConnector::DoCancel()

    {

    MSRPLOG( "CMSRPConnector::DoCancel enter" )

    iSocket->CancelConnect();

    MSRPLOG( "CMSRPConnector::DoCancel exit" )

    }

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

// CMSRPConnector::Connect

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

//

void CMSRPConnector::Connect(TInetAddr& aRemoteAddr)

    {

    MSRPLOG( "CMSRPConnector::Connect enter" )

    iSocket->Connect( aRemoteAddr, iStatus );

    //iState = EConnecting;

    SetActive();

    iTimer->After( KTimeOutInSeconds * KSecondinMicroseconds );

    MSRPLOG( "CMSRPConnector::Connect exit" )

    }

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

// CMSRPConnector::TimerExpired

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

//

void CMSRPConnector::TimerExpiredL()   

    {

    MSRPLOG( "CMSRPConnector::TimerExpired enter" )

    iConnection.ConnectionEstablishedL(MMSRPConnection::EConnectTimedOut, iSocket, KErrTimedOut);

    MSRPLOG( "CMSRPConnector::TimerExpired exit" )

    }

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

// CMSRPConnector::RunL

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

//

void CMSRPConnector::RunL()

    {

    MSRPLOG( "CMSRPConnector::RunL enter" )

    iTimer->Cancel();

    if(iStatus.Int() != KErrNone)

        {

        MSRPLOG2( "CMSRPConnector::RunL Connection Error %d", iStatus.Int() );

        iConnection.ConnectionEstablishedL(MMSRPConnection::EError, iSocket, iStatus.Int());

        return;

        }

    iConnection.ConnectionEstablishedL(MMSRPConnection::EConnected, iSocket, KErrNone);

    MSRPLOG( "CMSRPConnector::RunL exit" )

    }

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

// CMSRPConnector::RunError

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

//

TInt CMSRPConnector::RunError(TInt aError)

    {

    //handle error delete connector on error

    //make sure ConnectorStateL does not leave on EError

    MSRPLOG( "CMSRPConnector::RunError enter" )

    TRAPD(err, iConnection.ConnectionEstablishedL(MMSRPConnection::EError, iSocket, aError));

    MSRPLOG( "CMSRPConnector::RunError exit" )

    return err;

    }

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

// CMSRPConnector::ConnectComplete

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

//

void CMSRPConnector::ConnectComplete()

    {

    MSRPLOG( "CMSRPConnector::ConnectComplete enter" )

    iSocket = NULL;

    MSRPLOG( "CMSRPConnector::ConnectComplete exit" )

    }

// End of File