/*

* 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:  HtiEchoServicePlugin implementation

*

*/

// INCLUDE FILES

#include "HtiEchoServicePlugin.h"

#include <HtiDispatcherInterface.h>

#include <HtiLogging.h>

// CONSTANTS

const static TUid KEchoServiceUid = { 0x1020DEBF };

// MACROS

// LOCAL CONSTANTS AND MACROS

// MODULE DATA STRUCTURES

// LOCAL FUNCTION PROTOTYPES

// FORWARD DECLARATIONS

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

// Create instance of concrete ECOM interface implementation

CHtiEchoServicePlugin* CHtiEchoServicePlugin::NewL()

    {

    CHtiEchoServicePlugin* self = new (ELeave) CHtiEchoServicePlugin;

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop();

    return self;

    }

// Constructor

CHtiEchoServicePlugin::CHtiEchoServicePlugin():

    iReply( NULL )

    {

    }

CHtiEchoServicePlugin::~CHtiEchoServicePlugin()

    {

    HTI_LOG_TEXT( "CHtiEchoServicePlugin destroy" );

    delete iReply;

    }

// Second phase construction.

void CHtiEchoServicePlugin::ConstructL()

    {

    HTI_LOG_TEXT( "CHtiEchoServicePlugin::ConstructL" );

    }

void CHtiEchoServicePlugin::ProcessMessageL( const TDesC8& aMessage,

                                 THtiMessagePriority /*aPriority*/ )

    {

    HTI_LOG_FUNC_IN( "CHtiEchoServicePlugin::ProcessMessage" );

    HTI_LOG_FORMAT( "Msg len: %d", aMessage.Length() );

    if ( iReply )

        {

        HTI_LOG_TEXT( "sending previous echo, reject request" );

        return;

        }

    //make copy of the message and send it back

    iReply = HBufC8::NewL( aMessage.Length() );

    iReply->Des().Copy( aMessage );

    if ( iDispatcher->DispatchOutgoingMessage( iReply, KEchoServiceUid )

            == KErrNoMemory )

        {

        HTI_LOG_TEXT( "KErrNoMemory" );

        iDispatcher->AddMemoryObserver( this );

        }

    else

        {

        iReply = NULL;

        }

    HTI_LOG_FUNC_OUT( "CHtiEchoServicePlugin::ProcessMessage" );

    }

void CHtiEchoServicePlugin::NotifyMemoryChange( TInt aAvailableMemory )

    {

    if ( iReply )

        {

        if ( aAvailableMemory >= iReply->Size() )

            {

            TInt err = iDispatcher->DispatchOutgoingMessage( iReply,

                            KEchoServiceUid );

            if (  err == KErrNone )

                {

                iReply = NULL;

                iDispatcher->RemoveMemoryObserver( this );

                }

            else if ( err != KErrNoMemory ) //some other error

                {

                delete iReply;

                iReply = NULL;

                iDispatcher->RemoveMemoryObserver( this );

                }

            }

        }

    else

        {

        //some error, should not be called

        iDispatcher->RemoveMemoryObserver( this );

        }

    }

// End of File