/*

* Copyright (c) 2006 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:    Connection multiplexer is responsible for handling network

*                connections, send and receive data from the

*                network and allow client to start media flow between

*                connection multiplexer and socket media connection wrapper.

*

*/

#include <in_sock.h>

#include <es_sock.h>

#include "cncmconnectionmultiplexer.h"

#include "mncmconnectionmultiplexerobserver.h"

#include "cncmmediasource.h"

#include "ncmconnectionmultiplexerlogs.h"

#include "cncmsession.h"

#include "cncmstream.h"

#include "cncmconnection.h"

//#include "natfwmediawrapper.h"

const TUint KFirstSessionId = 1;

//Media connection is allways the first one

const TUint KMediaConnection = 1;

const TUint KDefaultProtocolSource = 0;

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

// CNcmConnectionMultiplexer::CNcmConnectionMultiplexer

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

//

CNcmConnectionMultiplexer::CNcmConnectionMultiplexer(

    MNcmConnectionMultiplexerObserver& aObserver ) :

    iObserver( aObserver ), iNextSessionId( KFirstSessionId )

    {

    }

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

// CNcmConnectionMultiplexer::NewL

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

//

EXPORT_C CNcmConnectionMultiplexer* CNcmConnectionMultiplexer::NewL(

        MNcmConnectionMultiplexerObserver& aObserver )

    {

    __CONNECTIONMULTIPLEXER( "CNcmConnectionMultiplexer::NewL" )

    CNcmConnectionMultiplexer* self =

        new (ELeave) CNcmConnectionMultiplexer( aObserver );

    return self;

    }

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

// CNcmConnectionMultiplexer::~CNcmConnectionMultiplexer

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

//

CNcmConnectionMultiplexer::~CNcmConnectionMultiplexer()

    {

    __CONNECTIONMULTIPLEXER( 

        "CNcmConnectionMultiplexer::~CNcmConnectionMultiplexer" )

    iSessions.ResetAndDestroy();

    }

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

// CNcmConnectionMultiplexer::CreateSessionL

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

//

EXPORT_C TUint CNcmConnectionMultiplexer::CreateSessionL( TUint32 aIapId,

    TUint aPortRangeStart, TUint aPortRangeStop )

    {

    CNcmSession* session = 

        CNcmSession::NewLC( iNextSessionId, aIapId,

            aPortRangeStart, aPortRangeStop, iObserver, *this );

    iSessions.AppendL( session );

    CleanupStack::Pop( session );

    iNextSessionId++;

    return session->SessionId();    

    }

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

// CNcmConnectionMultiplexer::CreateStreamL

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

//

EXPORT_C TUint CNcmConnectionMultiplexer::CreateStreamL( TUint aSessionId,

    TInt aQos, TUint aProtocol )

    {

    __CONNECTIONMULTIPLEXER( "CNcmConnectionMultiplexer::CreateStreamL" )

    CNcmSession* session( SessionByIdL( aSessionId ) );

    //__ASSERT_ALWAYS( session->Initialized(), User::Leave( KErrNotReady ) ); 

/*    TUint streamId( session->CreateStreamL( aQos, aProtocol ) );

    TInetAddr localAddr( session->LocalIPv4Address() );

    localAddr.SetPort( session->LocalIPv4Address().Port() );

    //StreamByIdL( streamId )->SetLocalAddr( localAddr );

    //Create a default connection for stream

    //CreateDefaultConnectionL( streamId, aProtocol );

    return streamId;*/

    return ( session->CreateStreamL( aQos, aProtocol ) );

    }

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

// CNcmConnectionMultiplexer::GetStreamInfoL

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

//

EXPORT_C void CNcmConnectionMultiplexer::GetStreamInfoL( 

    TUint /*aStreamId*/, TUint32& /*aIapId*/, TInt& /*aQos*/,

    TUint& /*aProtocol*/ )

    {

    __CONNECTIONMULTIPLEXER( "CNcmConnectionMultiplexer::GetStreamInfoL" )

/*    

    CNATFWMultiplexerStream* stream( StreamByIdL( aStreamId ) );

    aIapId = SessionByStreamIdL( aStreamId )->IapId();

    aQos = stream->Qos();

    aProtocol = stream->StreamProtocol();*/

    }

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

// CNcmConnectionMultiplexer::LocalIPAddressL

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

//

EXPORT_C TInetAddr& CNcmConnectionMultiplexer::LocalIPAddressL(

    TUint aStreamId, TUint aConnectionId )

    {

    return StreamByIdL( aStreamId )->

        ConnectionL( aConnectionId )->LocalAddress();

    }

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

// CNcmConnectionMultiplexer::GetSessionInfoL

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

//

EXPORT_C RSocketServ* CNcmConnectionMultiplexer::GetSessionInfoL(

    TUint aSessionId, TName& aConnectionName )

    {

    __CONNECTIONMULTIPLEXER( "CNcmConnectionMultiplexer::GetSessionInfoL" )

    CNcmSession* session( SessionByIdL( aSessionId ) );

    User::LeaveIfError( session->GetConnectionName( aConnectionName ) );

    return &session->SocketServer();

    }

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

// CNcmConnectionMultiplexer::CreateConnectionL

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

//

EXPORT_C TUint CNcmConnectionMultiplexer::CreateConnectionL( 

    TUint aStreamId, TUint /*aAddrFamily*/ )

    {

    __CONNECTIONMULTIPLEXER( 

        "CNcmConnectionMultiplexer::CreateConnectionL" )

    CNcmStream* stream( StreamByIdL( aStreamId ) );

    CNcmSession* session( SessionByStreamIdL( aStreamId ) );

    TInetAddr addr( KInetAddrNone, 0 );

    // Create Connection

    return stream->CreateConnectionL(

            *this, stream->ConnectionObserverHandler(),

            session->SocketServer(),

            session->Connection(), addr, EFalse );

//    return 2;

    }

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

// CNcmConnectionMultiplexer::CreateConnectionL

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

//

EXPORT_C TUint CNcmConnectionMultiplexer::CreateConnectionL( 

    TUint aStreamId, const TInetAddr& /*aLocalAddr*/ )

    {

    CNcmStream* stream( StreamByIdL( aStreamId ) );

    CNcmSession* session( SessionByStreamIdL( aStreamId ) );

    TInetAddr addr( KInetAddrNone, 0 );

    // Create Connection

    return stream->CreateConnectionL(

            *this, stream->ConnectionObserverHandler(),

            session->SocketServer(),

            session->Connection(), addr, ETrue );

//    return 2;

    }

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

// CNcmConnectionMultiplexer::OpenTcpConnectionL

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

//

EXPORT_C void CNcmConnectionMultiplexer::OpenTcpConnectionL(

    TUint /*aStreamId*/, TUint /*aConnectionId*/,

    TNATFWTcpConnectionSetup /*aConfig*/, const TInetAddr& /*aDestAddr*/ )

    {

    __CONNECTIONMULTIPLEXER( 

        "CNcmConnectionMultiplexer::OpenTcpConnectionL" )

    }

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

// CNcmConnectionMultiplexer::CancelTcpConnectionSetupL

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

//

EXPORT_C void CNcmConnectionMultiplexer::CloseTcpConnection(

        TUint /*aStreamId*/, TUint /*aConnectionId*/ )

    {

    __CONNECTIONMULTIPLEXER( 

        "CNcmConnectionMultiplexer::CloseTcpConnectionSetup" )

    }

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

// CNcmConnectionMultiplexer::RemoveSessionL

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

//

EXPORT_C void CNcmConnectionMultiplexer::RemoveSessionL( TUint aSessionId )

    {

    __CONNECTIONMULTIPLEXER( "CNcmConnectionMultiplexer::RemoveSessionL" )

    TInt sessionCount( iSessions.Count() );

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

        {

        if ( iSessions[i]->SessionId() == aSessionId )

            {

            delete iSessions[i];

            iSessions.Remove( i );

            return;

            }

        }

    User::Leave( KErrNotFound );

    }

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

// CNcmConnectionMultiplexer::RemoveStreamL

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

//

EXPORT_C void CNcmConnectionMultiplexer::RemoveStreamL( TUint aStreamId )

    {

    __CONNECTIONMULTIPLEXER( "CNcmConnectionMultiplexer::RemoveStreamL" )

    CNcmSession* session( SessionByStreamIdL( aStreamId ) );    

    session->RemoveStreamL( aStreamId );

    }

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

// CNcmConnectionMultiplexer::RemoveConnectionL

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

//

EXPORT_C void CNcmConnectionMultiplexer::RemoveConnectionL(

    TUint /*aStreamId*/, TUint /*aConnectionId*/ )

    {

    __CONNECTIONMULTIPLEXER( "CNcmConnectionMultiplexer::RemoveConnectionL" )

/*    CNATFWMultiplexerStream* stream( StreamByIdL( aStreamId ) );

    if ( KMediaConnection == aConnectionId )

        {

        //Default media stream can't be deleted.        

        User::Leave( KErrPermissionDenied );

        }

    stream->RemoveConnectionL( aConnectionId );     */

    }

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

// CNcmConnectionMultiplexer::RegisterIncomingConnectionObserverL

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

//

EXPORT_C void CNcmConnectionMultiplexer::

    RegisterIncomingConnectionObserverL( TUint /*aStreamId*/,

        MNcmIncomingConnectionObserver& /*aObserver*/ )

    {

    __CONNECTIONMULTIPLEXER(

        "CNcmConnectionMultiplexer::RegisterIncomingConnectionObserver" )

/*        

    StreamByIdL( aStreamId )->

        ConnectionObserverHandler().

        RegisterIncomingConnectionObserverL( aObserver );*/

    }

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

// CNcmConnectionMultiplexer::RegisterOutgoingConnectionObserverL

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

//

EXPORT_C void CNcmConnectionMultiplexer::

    RegisterOutgoingConnectionObserverL(

        TUint /*aStreamId*/, MNcmOutgoingConnectionObserver& /*aObserver*/ )

    {

    __CONNECTIONMULTIPLEXER(

        "CNcmConnectionMultiplexer::RegisterOutgoingConnectionObserver" )

/*

    StreamByIdL( aStreamId )->

        ConnectionObserverHandler().

        RegisterOutgoingConnectionObserverL( aObserver );*/

    }

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

// CNcmConnectionMultiplexer::RegisterMessageObserverL

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

//

EXPORT_C void CNcmConnectionMultiplexer::RegisterMessageObserverL(

    TUint /*aStreamId*/, MNcmMessageObserver& /*aObserver*/ )

    {

    __CONNECTIONMULTIPLEXER(

        "CNcmConnectionMultiplexer::RegisterMessageObserverL" )

    }

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

// CNcmConnectionMultiplexer::UnregisterMessageObserverL

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

//

EXPORT_C void CNcmConnectionMultiplexer::UnregisterMessageObserverL(

    TUint /*aStreamId*/, MNcmMessageObserver& /*aObserver*/ )

    {

    __CONNECTIONMULTIPLEXER(

        "CNcmConnectionMultiplexer::UnregisterMessageObserverL" )

    }

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

// CNcmConnectionMultiplexer::UnregisterIncomingConnectionObserverL

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

//

EXPORT_C void CNcmConnectionMultiplexer::

    UnregisterIncomingConnectionObserverL(

        TUint /*aStreamId*/, MNcmIncomingConnectionObserver& /*aObserver*/ )

    {

    __CONNECTIONMULTIPLEXER(

        "CNcmConnectionMultiplexer::UnregisterIncomingConnectionObserver" )

/*

    StreamByIdL( aStreamId )->ConnectionObserverHandler().

        UnregisterIncomingConnectionObserverL( aObserver );*/

    }

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

// CNcmConnectionMultiplexer::UnregisterOutgoingConnectionObserverL

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

//

EXPORT_C void CNcmConnectionMultiplexer::

    UnregisterOutgoingConnectionObserverL(

        TUint /*aStreamId*/, MNcmOutgoingConnectionObserver& /*aObserver*/ )

    {

    __CONNECTIONMULTIPLEXER(

        "CNcmConnectionMultiplexer::UnregisterOutgoingConnectionObserver" )

/*

    StreamByIdL( aStreamId )->ConnectionObserverHandler().

        UnregisterOutgoingConnectionObserverL( aObserver );*/

    }

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

// CNcmConnectionMultiplexer::RegisterConnectionObserverL

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

//

EXPORT_C void CNcmConnectionMultiplexer::RegisterConnectionObserverL(

    TUint /*aStreamId*/, MNcmConnectionObserver& /*aObserver*/ )

    {

    __CONNECTIONMULTIPLEXER(

        "CNcmConnectionMultiplexer::RegisterConnectionObserverL" )

/*

    StreamByIdL( aStreamId )->

        ConnectionObserverHandler().

        RegisterConnectionObserverL( aObserver );*/

    }

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

// CNcmConnectionMultiplexer::UnregisterConnectionObserverL

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

//

EXPORT_C void CNcmConnectionMultiplexer::UnregisterConnectionObserverL(

    TUint /*aStreamId*/, MNcmConnectionObserver& /*aObserver*/ )

    {

    __CONNECTIONMULTIPLEXER(

        "CNcmConnectionMultiplexer::UnregisterConnectionObserverL" )

/*

    StreamByIdL( aStreamId )->ConnectionObserverHandler().

        UnregisterConnectionObserverL( aObserver );*/

    }

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

// CNcmConnectionMultiplexer::RegisterMediaWrapperL

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

//

EXPORT_C void CNcmConnectionMultiplexer::RegisterMediaWrapperL(

    MNATFWMediaWrapper* /*aMediaWrapper*/ )

    {

/*    __CONNECTIONMULTIPLEXER(

        "CNcmConnectionMultiplexer::RegisterMediaWrapperL" )

    __ASSERT_ALWAYS( aMediaWrapper, User::Leave( KErrNotReady ) );

    TUint streamId( aMediaWrapper->StreamId() );

    CNATFWMultiplexerStream* stream( StreamByIdL( streamId ) );

    stream->RegisterWrapperL( aMediaWrapper );

    // set up media source (ownership tranferred)

    CNATFWMultiplexerConnection* connection(

        stream->ConnectionL( KMediaConnection ) );

    User::LeaveIfError( connection->RegisterSource(

        CNATFWMultiplexerMediaSource::NewL( *connection, *this,

        stream->WrapperL(), SessionByStreamIdL( streamId )->SocketServer(),

        stream->LocalAddress() ) ) );*/

    }

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

// CNcmConnectionMultiplexer::SendL

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

//

EXPORT_C void CNcmConnectionMultiplexer::SendL( TUint /*aStreamId*/,

    TUint /*aConnectionId*/, const TDesC8& /*aMessage*/,

    MNcmSenderObserver* /*aSenderObserver*/ )

    {

    __CONNECTIONMULTIPLEXER( "CNcmConnectionMultiplexer::SendL" )

/*    CNATFWMultiplexerConnection* connection = StreamByIdL( aStreamId )->

        ConnectionL( aConnectionId );

    __ASSERT_ALWAYS( connection, User::Leave( KErrArgument ) );  

    // Get source for plug-in (always the first one)

    RPointerArray<CNATFWMultiplexerSourceBase> sources;

    CleanupClosePushL( sources );

    connection->GetSources( sources );

    if ( !sources.Count() )

        {

        User::Leave( KErrNotFound );

        }

    // Send the message

    User::LeaveIfError( static_cast<CNATFWMultiplexerProtocolSource*>( 

        sources[KDefaultProtocolSource] )->Send( aMessage, KAFUnspec,

        aSenderObserver ) );

    CleanupStack::PopAndDestroy( &sources );*/

    }

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

// CNcmConnectionMultiplexer::SendL

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

//

EXPORT_C void CNcmConnectionMultiplexer::SendL( TUint /*aStreamId*/,

    TUint /*aConnectionId*/, const TDesC8& /*aMessage*/,

    const TInetAddr& /*aDestinationAddress*/,

    MNcmSenderObserver* /*aSenderObserver*/  )

    {

    __CONNECTIONMULTIPLEXER( "CNcmConnectionMultiplexer::SendL" )

/*    CNATFWMultiplexerConnection* connection( NULL );

    CNATFWMultiplexerStream* stream = StreamByIdL( aStreamId );

    if ( aConnectionId )

        {     

        connection = stream->ConnectionL( aConnectionId );      

        }

    else

        {

        connection =

            stream->ConnectionByDestinationAddressL( aDestinationAddress );

        } 

    __ASSERT_ALWAYS( connection, User::Leave( KErrArgument ) ); 

    // Get source for plug-in (always the first one)

    RPointerArray<CNATFWMultiplexerSourceBase> sources;

    CleanupClosePushL( sources );

    connection->GetSources( sources );

    __ASSERT_ALWAYS( sources.Count(), User::Leave( KErrNotFound ) );

    // Send the message

    User::LeaveIfError( static_cast<CNATFWMultiplexerProtocolSource*>( 

        sources[KDefaultProtocolSource] )->

            Send( aMessage, aDestinationAddress, aSenderObserver ) );