/*

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

*

*/

// INCLUDE FILES

#include "HtiIpProxyServicePlugin.h"

#include <HtiDispatcherInterface.h>

#include <HTILogging.h>

#include <badesca.h>

#include <in_sock.h>

#include "MSocketObserver.h"

#include "MHostConnectionObserver.h"

#include "CIPProxyEngine.h"

// CONSTANTS

const static TUid KIpProxyServiceUid = { 0x10210CD3 };

// MACROS

// LOCAL CONSTANTS AND MACROS

// MODULE DATA STRUCTURES

// LOCAL FUNCTION PROTOTYPES

// FORWARD DECLARATIONS

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

// Create instance of concrete ECOM interface implementation

CHtiIpProxyServicePlugin* CHtiIpProxyServicePlugin::NewL()

    {

    CHtiIpProxyServicePlugin* self = new( ELeave ) CHtiIpProxyServicePlugin;

    CleanupStack::PushL( self );

    self->ConstructL();

    CleanupStack::Pop();

    return self;

    }

// Constructor

CHtiIpProxyServicePlugin::CHtiIpProxyServicePlugin() :

    iSocketObserver( NULL ),

    iHostObserver( NULL ),

    iProxyEngine( NULL ),

    iOutgoingArray( NULL ),

    iBusy( EFalse ),

    iConnected( EFalse )

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin" );

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin" );

    }

CHtiIpProxyServicePlugin::~CHtiIpProxyServicePlugin()

    {

    HTI_LOG_FUNC_IN( "~CHtiIpProxyServicePlugin" );

    if ( iProxyEngine )

        {

        iProxyEngine->StopListening();

        }

    delete iProxyEngine;

    delete iOutgoingArray;

    HTI_LOG_FUNC_OUT( "~CHtiIpProxyServicePlugin" );

    }

// Second phase construction.

void CHtiIpProxyServicePlugin::ConstructL()

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::ConstructL" );

    iOutgoingArray = new( ELeave ) CDesC8ArraySeg( 10 );

    iProxyEngine = CIPProxyEngine::NewL( this );

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::ConstructL" );

    }

void CHtiIpProxyServicePlugin::InitL()

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::InitL" );

    if ( iProxyEngine )

        {

        iProxyEngine->StartListening();

        }

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::InitL" );

    }

TBool CHtiIpProxyServicePlugin::IsBusy()

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::IsBusy" );

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::IsBusy" );

    return iBusy;

    }

void CHtiIpProxyServicePlugin::ProcessMessageL( const TDesC8& aMessage,

                                                THtiMessagePriority /* aPriority */ )

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::ProcessMessageL" );

    iBusy = ETrue;

    __ASSERT_ALWAYS( iSocketObserver, User::Panic( _L ( "IP-Proxy ECom-plugin" ), KErrBadHandle ) );

    iSocketObserver->DataReceivedL( this, aMessage );

    iBusy = EFalse;

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::ProcessMessageL" );

    }

void CHtiIpProxyServicePlugin::NotifyMemoryChange( TInt aAvailableMemory )

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::NotifyMemoryChange" );

    iBusy = ETrue;

    TInt count = iOutgoingArray->Count();

    if ( !count )

        {

        // No outgoing data

        return;

        }

    // Calculate needed outgoing buffer size

    TInt i = 0;

    TInt neededSize = 0;

    for ( ; i < count; ++i )

        {

        TInt size = ( *iOutgoingArray )[i].Size();

        if ( neededSize + size <= aAvailableMemory )

            {

            neededSize += size;

            }

        }

    if ( !neededSize )

       {

       // Not enough memory

       return;

       }

    // Create an outgoing buffer and join as many buffers as possible

    HBufC8* message = HBufC8::New( neededSize );

    if ( !message )

        {

        // Not enough memory

        return;

        }

    TPtr8 messagePtr( message->Des() );

    for ( TInt j = 0; j < i; ++j )

        {

        messagePtr.Append( ( *iOutgoingArray )[j] );

        }

    // Dispatch message to HTI-Framework which takes the ownership of message

    TInt err = iDispatcher->DispatchOutgoingMessage( message, KIpProxyServiceUid );

    if ( err == KErrNone )

        {

        message = NULL;

        iOutgoingArray->Delete( 0, i );

        iDispatcher->RemoveMemoryObserver( this );

        }

    else if ( err != KErrNoMemory )

        {

        delete message;

        iDispatcher->RemoveMemoryObserver( this );

        __ASSERT_ALWAYS( iHostObserver, User::Panic( _L ( "IP-Proxy ECom-plugin" ), KErrBadHandle ) );

        TRAP( err, iHostObserver->HostConnectionErrorL( err ) );

        }

    iBusy = EFalse;

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::NotifyMemoryChange" );

    }

MSocket* CHtiIpProxyServicePlugin::GetSocket()

    {

    return this;

    }

MHostConnection* CHtiIpProxyServicePlugin::GetHostConnection()

    {

    return this;

    }

RSocket* CHtiIpProxyServicePlugin::GetRSocket()

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::GetRSocket" );

    RSocket* KSocket = NULL;

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::GetRSocket" );

    return KSocket;

    }

TUint CHtiIpProxyServicePlugin::LocalPort() const

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::LocalPort" );

    const TUint KLocalPort = 0;

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::LocalPort" );

    return KLocalPort;

    }

TUint CHtiIpProxyServicePlugin::RemotePort() const

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::RemotePort" );

    const TUint KRemotePort = 0;

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::RemotePort" );

    return KRemotePort;

    }

void CHtiIpProxyServicePlugin::SetObserver( MSocketObserver* aObserver )

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::SetObserver" );

    iSocketObserver = aObserver;

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::SetObserver" );

    }

void CHtiIpProxyServicePlugin::SetSocketOwnershipMode( TBool /* aHasOwnership */ )

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::SetSocketOwnershipMode" );

    /* Empty implementation */

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::SetSocketOwnershipMode" );

    }

void CHtiIpProxyServicePlugin::IssueRead()

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::IssueRead" );

    /* Empty implementation */

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::IssueRead" );

    }

void CHtiIpProxyServicePlugin::Cancel()

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::Cancel" );

    /* Empty implementation */

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::Cancel" );

    }

void CHtiIpProxyServicePlugin::SocketInfo( TProtocolDesc& aDesc ) const

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::SocketInfo" );

    aDesc.iProtocol = KProtocolInetTcp;

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::SocketInfo" );

    }

TBool CHtiIpProxyServicePlugin::IsUDP() const

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::IsUDP" );

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::IsUDP" );

    return EFalse;

    }

void CHtiIpProxyServicePlugin::WriteL( const TDesC8& aData )

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::WriteL" );

    iBusy = ETrue;

    // Dispatcher takes ownership of the message if no error has occured

    HBufC8* message = aData.AllocL();

    TInt err = iDispatcher->DispatchOutgoingMessage( message, KIpProxyServiceUid );

    if ( err != KErrNone && err != KErrNoMemory )

        {

        // Some error occured while dispatching the message

        delete message;

        __ASSERT_ALWAYS( iHostObserver, User::Panic( _L ( "IP-Proxy ECom-plugin" ), KErrBadHandle ) );

        iHostObserver->HostConnectionErrorL( err );

        }

    else if ( err == KErrNoMemory )

        {

        // No memory was available so add message to queue

        delete message;

        iOutgoingArray->AppendL( aData.Mid( 0 ) );

        iDispatcher->AddMemoryObserver( this );

        }

    iBusy = EFalse;

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::WriteL" );

    }

void CHtiIpProxyServicePlugin::IssueConnectL()

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::IssueConnectL" );

    iConnected = ETrue;

    __ASSERT_ALWAYS( iHostObserver, User::Panic( _L ( "IP-Proxy ECom-plugin" ), KErrBadHandle ) );

    iHostObserver->ConnectionEstablishedL();

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::IssueConnectL" );

    }

void CHtiIpProxyServicePlugin::IssueDisconnect()

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::IssueDisconnect" );

    __ASSERT_ALWAYS( iSocketObserver, User::Panic( _L ( "IP-Proxy ECom-plugin" ), KErrBadHandle ) );

    TRAP_IGNORE( iSocketObserver->DisconnectedL( this ) );

    iConnected = EFalse;

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::IssueDisconnect" );

    }

void CHtiIpProxyServicePlugin::SetObserver( MHostConnectionObserver* aObserver )

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::SetObserver 2" );

    iHostObserver = aObserver;

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::SetObserver 2" );

    }

TBool CHtiIpProxyServicePlugin::IsConnected()

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::IsConnected" );

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::IsConnected" );

    return iConnected;

    }

RSocket* CHtiIpProxyServicePlugin::Socket()

    {

    HTI_LOG_FUNC_IN( "CHtiIpProxyServicePlugin::Socket" );

    RSocket* KSocket = NULL;

    HTI_LOG_FUNC_OUT( "CHtiIpProxyServicePlugin::Socket" );

    return KSocket;

    }