/* Copyright (c) 2004, Nokia. All rights reserved */


// INCLUDE FILES
#include "Sockets.pan"
#include "SocketsReader.h"
#include "EngineNotifier.h"


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

// -----------------------------------------------------------------------------
// CSocketsReader::NewL()
// Two-phased constructor.
// -----------------------------------------------------------------------------
//
CSocketsReader* CSocketsReader::NewL( MEngineNotifier& aEngineNotifier,
                                      RSocket& aSocket )
    {
    CSocketsReader* self = CSocketsReader::NewLC( aEngineNotifier,
                                                  aSocket );
    CleanupStack::Pop( self );
    return self;
    }

// -----------------------------------------------------------------------------
// CSocketsReader::NewLC()
// Two-phased constructor.
// -----------------------------------------------------------------------------
//
CSocketsReader* CSocketsReader::NewLC( MEngineNotifier& aEngineNotifier,
                                       RSocket& aSocket )
    {
    CSocketsReader* self = new ( ELeave ) CSocketsReader( aEngineNotifier,
                                                          aSocket );
    CleanupStack::PushL( self );
    self->ConstructL();
    return self;
    }

// -----------------------------------------------------------------------------
// CSocketsReader::CSocketsReader()
// C++ default constructor can NOT contain any code, that might leave.
// -----------------------------------------------------------------------------
//
CSocketsReader::CSocketsReader( MEngineNotifier& aEngineNotifier,
                                RSocket& aSocket )
: CActive( EPriorityStandard ),
  iSocket( aSocket ),
  iEngineNotifier( aEngineNotifier )
    {
    // No implementation required
    }

// -----------------------------------------------------------------------------
// CSocketsReader::ConstructL()
// Symbian 2nd phase constructor can leave.
// -----------------------------------------------------------------------------
//
void CSocketsReader::ConstructL()
    {
    CActiveScheduler::Add( this );
    }

// -----------------------------------------------------------------------------
// CSocketsReader::~CSocketsReader()
// Destructor.
// -----------------------------------------------------------------------------
//
CSocketsReader::~CSocketsReader()
    {
    Cancel();
    }

// -----------------------------------------------------------------------------
// CSocketsReader::DoCancel()
// Cancels any outstanding operation.
// -----------------------------------------------------------------------------
//
void CSocketsReader::DoCancel()
    {
    // Cancel asychronous read request
    iSocket.CancelRead();
    }

// -----------------------------------------------------------------------------
// CSocketsReader::RunL()
// Called when operation completes.
// -----------------------------------------------------------------------------
//
void CSocketsReader::RunL()
    {
    // Active object request complete handler
    switch ( iStatus.Int() )
        {
        case KErrNone:
            // Character has been read from socket
            iEngineNotifier.ResponseReceived( iBuffer );
            IssueRead(); // Immediately start another read
            break;
        case KErrDisconnected:
            iEngineNotifier.ReportError( MEngineNotifier::EDisconnected,
                                         iStatus.Int() );
            break;
        default:
            iEngineNotifier.ReportError( MEngineNotifier::EGeneralReadError,
                                         iStatus.Int() );
            break;
        }
    }

// -----------------------------------------------------------------------------
// CSocketsReader::IssueRead()
// Initiates a read from socket.
// -----------------------------------------------------------------------------
//
void CSocketsReader::IssueRead()
    {
    // Initiate a new read from socket into iBuffer
    __ASSERT_ALWAYS( !IsActive(), User::Panic( KPanicSocketsEngineRead,
                                               ESocketsBadState ) );
    iSocket.RecvOneOrMore( iBuffer, 0, iStatus, iDummyLength );
    SetActive();
    }

// -----------------------------------------------------------------------------
// CSocketsReader::Start()
// Initiates a read from socket.
// -----------------------------------------------------------------------------
//
void CSocketsReader::Start()
    {
    // Initiate a new read from socket into iBuffer
    if ( !IsActive() )
        {
        IssueRead();
        }
    }

// End of File