/*

* Copyright (c) 2002-2007 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:  Receiver class for TCP / UDP sockets

*

*/

// INCLUDE FILES

#include <es_sock.h>

#include "CSatBIPDataReceiver.h"

#include "CSatBIPGPRSDataChannel.h"

#include "SatLog.h"

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

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

// CSatBIPDataReceiver::CSatBIPDataReceiver

// C++ default constructor can NOT contain any code, that

// might leave.

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

//

CSatBIPDataReceiver::CSatBIPDataReceiver( CSatBIPGPRSDataChannel& aObserver,  

    RSocket& aSocket,

    TBool aIsTcpSocket ) : CActive( EPriorityNormal ),

    iObserver( aObserver ),

    iSocket( aSocket ),

    iReceiveDataLen( 0 ),

    iRecvPckg( iReceiveDataLen )

    {

    LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::CSatBIPDataReceiver\

         calling-exiting" )

    iIsTcpSocket = aIsTcpSocket;

    CActiveScheduler::Add( this );

    }

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

// CSatBIPDataReceiver::~CSatBIPDataReceiver

// Destructor

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

//

CSatBIPDataReceiver::~CSatBIPDataReceiver()

    {

    LOG( SIMPLE, 

    "SATENGINE: CSatBIPDataReceiver::~CSatBIPDataReceiver calling" )

    // Don't have our own pointers...

    LOG( SIMPLE, 

    "SATENGINE: CSatBIPDataReceiver::~CSatBIPDataReceiver exiting" )

    }

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

// CSatBIPDataReceiver::RunL

// Two-phased constructor.

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

//

void CSatBIPDataReceiver::RunL()

    {

    LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::RunL calling" )

    LOG2( NORMAL, "  RunL with error: %i", iStatus.Int() )

    LOG2( NORMAL, "  RunL Data received <buffer>: %i", iRecvBuffer.Length() )

    // Notify observer

    if ( KErrNone == iStatus.Int() )

        {

        iObserver.DataReceivedNotificationL( iRecvBuffer );

        }    

    else

        {

        iObserver.DataReceiveError( iStatus.Int() );

        }

    LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::RunL exiting" )

    }

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

// CSatBIPDataReceiver::DoCancel

// Two-phased constructor.

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

//

void CSatBIPDataReceiver::DoCancel()

    {

    LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::DoCancel calling" )

    iSocket.CancelRecv();

    LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::DoCancel exiting" )

    }

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

// CSatBIPDataReceiver::ReceiveStoreEmptyNotification

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

//

void CSatBIPDataReceiver::ReceiveStoreEmptyNotificationL()

    {

    LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::ReceiveStoreEmptyNotification\

         calling" )

    // It doesn't matter, if this buffer is empty

    iObserver.DataReceivedNotificationL( iRecvBuffer );

    LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::ReceiveStoreEmptyNotification\

         exiting" )

    }

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

// CSatBIPDataReceiver::StartReceive

// Starts to receive data

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

//

void CSatBIPDataReceiver::StartReceive( TInetAddr& aAddr )

    {

    LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::StartReceive calling" )

    // It may already be active

    if ( !IsActive() )

        {

        // This is used only with TCP sockets

        iReceiveDataLen = 0;

        // Remove previously received data

        iRecvBuffer.Zero();

        // Check the socket type

        if ( iIsTcpSocket )

            {

            LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::StartReceive TCP" )

            // Only TCP / Stream socket may receive one or more bytes

            iSocket.RecvOneOrMore( iRecvBuffer, 0, iStatus, iRecvPckg );

            }

        else

            {

            LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::StartReceive UDP" )

            // Use different receive method with UPD / Datagram socket

            // Destination has already been stored in iSocket during 

            // activation, 

            // so we don't have to tell it here.        

            iSocket.RecvFrom( iRecvBuffer, aAddr, 0, iStatus );

            }

        SetActive();

        }

    LOG( SIMPLE, "SATENGINE: CSatBIPDataReceiver::StartReceive exiting" )

    }

// End of file