/*

* Copyright (c) 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:  Local TCP connection for emulator testing

*

*/

// INCLUDE FILES

#include "CLocalHostConnection.h"

#include "MHostConnectionObserver.h"

#define DEBUG_FILENAME "IPProxyEngine.log"

#include "DebugPrint.h"

// ============================ MEMBER FUNCTIONS ===============================

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

// CLocalHostConnection::CLocalHostConnection

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

//

CLocalHostConnection::CLocalHostConnection(

    RSocketServ& aSocketServer,  TInt aPort ) :

    CActive( EPriorityStandard ),

    iSocketServer( aSocketServer )

    {

    DEBUG_PRINT( DEBUG_STRING(

        "CLocalHostConnection::CLocalHostConnection() aPort=%d" ), aPort );

    iAddr.SetPort( aPort );

    iAddr.SetAddress( KInetAddrLoop );

    }

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

// CLocalHostConnection::ConstructL

// Symbian 2nd phase constructor can leave.

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

//

void CLocalHostConnection::ConstructL()

    {

    User::LeaveIfError( iClientSocket.Open(

        iSocketServer, KAfInet, KSockStream, KProtocolInetTcp ) );

    CActiveScheduler::Add( this );

    }

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

// CLocalHostConnection::NewL

// Two-phased constructor.

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

//

CLocalHostConnection* CLocalHostConnection::NewL(

    RSocketServ& aSocketServer,  TInt aPort  )

    {

    CLocalHostConnection* self =

        CLocalHostConnection::NewLC( aSocketServer, aPort );

    CleanupStack::Pop();

    return self;

    }

CLocalHostConnection* CLocalHostConnection::NewLC(

    RSocketServ& aSocketServer,  TInt aPort  )

    {

    CLocalHostConnection* self =

        new( ELeave ) CLocalHostConnection( aSocketServer, aPort );

    CleanupStack::PushL( self );

    self->ConstructL();

    return self;

    }

// Destructor

CLocalHostConnection::~CLocalHostConnection()

    {

    Cancel();

    iClientSocket.Close();

    }

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

// CLocalHostConnection::RunL

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

//

void CLocalHostConnection::RunL()

    {

    DEBUG_PRINT( DEBUG_STRING(

        "CLocalHostConnection::RunL(), iStatus=%d" ),

        iStatus.Int() );

    if ( iStatus.Int() == KErrNone )

        {

        switch ( iState )

            {

            case ELCStateConnecting:

                {

                DEBUG_PRINT( DEBUG_STRING(

                    "CLocalHostConnection::RunL(), ELCStateConnecting" ) );

                iState = ELCStateConnected;

                iObserver->ConnectionEstablishedL();

                break;

                }

            case ELCStateDisconnecting:

                {

                DEBUG_PRINT( DEBUG_STRING(

                    "CLocalHostConnection::RunL(), ELCStateDisconnecting" ) );

                iState = ELCStateDisconnected;

                iClientSocket.Close();

                User::LeaveIfError( iClientSocket.Open(

                    iSocketServer, KAfInet, KSockStream, KProtocolInetTcp ) );

                break;

                }

            }

        }

    else

        {

        iObserver->HostConnectionErrorL( iStatus.Int() );

        iClientSocket.Close();

        User::LeaveIfError( iClientSocket.Open(

            iSocketServer, KAfInet, KSockStream, KProtocolInetTcp ) );

        }

    }

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

// CLocalHostConnection::DoCancel

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

//

void CLocalHostConnection::DoCancel()

    {

    iClientSocket.CancelConnect();

    }

TInt CLocalHostConnection::RunError( TInt aError )

    {

    DEBUG_PRINT( DEBUG_STRING(

        "CLocalHostConnection::RunError( %d )" ), aError );

    iObserver->HostConnectionObserverLeaved( aError );

    return KErrNone;

    }

TInt CLocalHostConnection::Port()

    {

    return iAddr.Port();

    }

void CLocalHostConnection::IssueConnectL()

    {

    DEBUG_PRINT( DEBUG_STRING(

        "CLocalHostConnection::IssueConnectL()" ) );

    iClientSocket.Connect( iAddr, iStatus );

    SetActive();

    iState = ELCStateConnecting;

    }

void CLocalHostConnection::IssueDisconnect()

    {

    DEBUG_PRINT( DEBUG_STRING(

        "CLocalHostConnection::IssueDisconnect()" ) );

    iClientSocket.CancelAll();

    Cancel();

    iClientSocket.Shutdown( RSocket::ENormal, iStatus );

    SetActive();

    iState = ELCStateDisconnecting;

    }

void CLocalHostConnection::SetObserver( MHostConnectionObserver* aObserver )

    {

    iObserver = aObserver;

    }

RSocket* CLocalHostConnection::Socket()

    {

    return &iClientSocket;

    }

TBool CLocalHostConnection::IsConnected()

    {

    return ( iState == ELCStateConnected || iState == ELCStateDisconnecting );

    }

//  End of File