/*

* Copyright (c) 2008 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:  This is the implementation of application class

 *

*/

#include "sockets.pan"

#include "socketreader.h"

#include "socketobserver.h"

#include "debug.h"

CSocketReader* CSocketReader::NewL(TUint aSocketID,

        MSocketObserver& aObserver, TInt aInitialBufSize)

    {

    CSocketReader* self = CSocketReader::NewLC(aSocketID, aObserver,

            aInitialBufSize);

    CleanupStack::Pop(self);

    return self;

    }

CSocketReader* CSocketReader::NewLC(TUint aSocketID,

        MSocketObserver& aObserver, TInt aInitialBufSize)

    {

    CSocketReader* self = new (ELeave) CSocketReader(aSocketID, aObserver);

    CleanupStack::PushL(self);

    self->ConstructL(aInitialBufSize);

    return self;

    }

CSocketReader::CSocketReader(TUint aSocketID, MSocketObserver& aObserver) :

    CActive(EPriorityStandard), iSocketID(aSocketID), iObserver(aObserver),

            iBufferPtr(0, 0)

    {

    }

CSocketReader::~CSocketReader()

    {

    Cancel(); // Causes DoCancel

    delete iBuffer;

    }

void CSocketReader::ConstructL(TInt aInitialBufSize)

    {

    iBuffer = HBufC8::NewL(aInitialBufSize);

    iBufferPtr.Set(iBuffer->Des());

    CActiveScheduler::Add(this);

    }

void CSocketReader::DoCancel()

    {

    // Cancel asynchronous read request

    iSocket->CancelRead();

    }

void CSocketReader::RunL()

    {

        // Active object request complete handler

        TRACE_INFO((_L("CSocketReader::RunL(), iStatus.Int()=%d, socketID=%d"),iStatus.Int(), iSocketID));

    switch (iStatus.Int())

        {

        case KErrNone:

            {

            // Data has been read from socket

            // Inform the observer and issue another read if we want

            // to continue listening

            if (iObserver.HandleDataReceived(iSocketID, iBufferPtr))

                {

                IssueRead();

                }

            break;

            }

        default:

            {

            // A read error has occurred. Inform the observer the connection is lost

            iObserver.HandleSocketError(iSocketID, ETrue, iStatus.Int());

            break;

            }

        }

    }

void CSocketReader::IssueRead()

    {

    // Initiate a new read from socket into iBuffer

    iSocket->Read(iBufferPtr, iStatus);

    SetActive();

    }

void CSocketReader::StartReadingL(RSocket* aSocket, TInt aMTU)

    {

    // Initiate a new read from socket into iBuffer

    __ASSERT_DEBUG(!IsActive(),

            User::Panic(KPanicSocketsEngineRead, ESocketsBadState));

    if (aMTU > iBufferPtr.MaxLength())

        {

        // Realloc the buffer as it isn't large enough.

        iBufferPtr.Set(0, 0, 0);

        delete iBuffer;

        iBuffer = 0;

        iBuffer = HBufC8::NewL(aMTU);

        iBufferPtr.Set(iBuffer->Des());

        }

    iSocket = aSocket;

    IssueRead();

    }