/*

* 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:  Socket reader

*

*/

// INCLUDE FILES

#include "MSocketReaderObserver.h"

#include <badesca.h>

#define DEBUG_FILENAME "IPProxyEngine.log"

#include "DebugPrint.h"

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

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

// CSocketReader::CSocketReader

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

//

CSocketReader::CSocketReader( RSocket& aSocket,

        TInt aUDPRemotePort /*= -1*/ ) :

    CActive( EPriorityStandard ),

    iSocket( aSocket ),

    iUDPRemotePort( aUDPRemotePort )

    {

    }

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

// CSocketReader::ConstructL

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

//

void CSocketReader::ConstructL()

    {

    CActiveScheduler::Add( this );

    IssueRead();

    }

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

// CSocketReader::NewL

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

//

CSocketReader* CSocketReader::NewL( RSocket& aSocket,

        TInt aUDPRemotePort /*= -1*/ )

    {

    CSocketReader* self = CSocketReader::NewLC( aSocket, aUDPRemotePort );

    CleanupStack::Pop();

    return self;

    }

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

// CSocketReader::NewLC

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

//

CSocketReader* CSocketReader::NewLC( RSocket& aSocket,

        TInt aUDPRemotePort /*= -1*/ )

    {

    CSocketReader* self = new( ELeave ) CSocketReader( aSocket, aUDPRemotePort );

    CleanupStack::PushL( self );

    self->ConstructL();

    return self;

    }

// Destructor

CSocketReader::~CSocketReader()

    {

    Cancel();

    }

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

// CSocketReader::SetObserver

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

//

void CSocketReader::SetObserver( MSocketReaderObserver* aObserver )

    {

    iObserver = aObserver;

    }

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

// CSocketReader::IssueRead

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

//

void CSocketReader::IssueRead()

    {

    DEBUG_PRINT( DEBUG_STRING(

        "CSocketReader::IssueRead +" ) );

    __ASSERT_ALWAYS( !IsActive() || iStatus != KRequestPending,

        User::Panic( _L ( "s-reader" ), 1 ) );

    TProtocolDesc desc;

    TInt err = iSocket.Info( desc );

    DEBUG_PRINT( DEBUG_STRING(

        "CSocketReader::IssueRead, err = %d" ), err );

    DEBUG_PRINT( DEBUG_STRING(

        "desc.iProtocol = %d, iUDPRemotePort=%d" ), desc.iProtocol, iUDPRemotePort );

    if ( desc.iProtocol == KProtocolInetUdp && iUDPRemotePort > -1 )

        {

        // UDP

        DEBUG_PRINT( DEBUG_STRING(

            "CSocketReader::IssueRead(), UDP, local port=%d" ), iUDPRemotePort );

        iSocket.RecvFrom( iReadBuffer, iUDPRemoteAddr, 0, iStatus );

        }

    else

        {

        // TCP

        DEBUG_PRINT( DEBUG_STRING(

            "CSocketReader::IssueRead(), TCP, local port=%d" ), iSocket.LocalPort() );

        iSocket.RecvOneOrMore( iReadBuffer, 0, iStatus, iReceivedDataLength );

        }

    SetActive();

    DEBUG_PRINT( DEBUG_STRING(

        "CSocketReader::IssueRead() -" ) );

    }

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

// CSocketReader::Start

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

//

void CSocketReader::Start()

    {

    DEBUG_PRINT( DEBUG_STRING(

        "CSocketReader::Start" ) );

    if ( !IsActive() )

        {

        IssueRead();

        }

    }

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

// CSocketReader::RunL

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

//

void CSocketReader::RunL()

    {

    TInt status = iStatus.Int();

    if ( status == KErrNone )

        {

        iObserver->DataReceivedL( iReadBuffer );

        iReadBuffer.SetLength( 0 );

        IssueRead();

        }

    else

        {

        iObserver->ReaderErrorL( status );

        }

    }

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

// CSocketReader::DoCancel

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

//

void CSocketReader::DoCancel()

    {

    iSocket.CancelRead();

    }

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

// CSocketReader::RunError

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

//

TInt CSocketReader::RunError( TInt aError )

    {

    iObserver->ObserverLeaved( aError );

    iReadBuffer.SetLength( 0 );

    IssueRead();

    return KErrNone;

    }