/*

* 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 the License "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: 

*

*/

#include <kernel.h>             // For Kern

#include "p2plink.h"            // For DP2PLink

#include "p2proutertrace.h"     // For C_TRACE..

#include "mlinkmuxif.h"         // For MLinkMuxIf

#include "iscedefs.h"           // For EMuxAmountOfProtocols

#include "p2pdefs.h"            // For EP2PAmountOfProtocols

#include "trxdefs.h"            // For EAmountOfTrxs

// Faults

enum TP2PLinkFaults

    {

    EP2PLinkNullPtr = 0x00,

    EP2PMemAllocFailed,

    EP2PInitFailed,

    EP2PInitFailed2,

    EP2PRegisterFailed,

    };

// Macros

// Because P2P ids are different than multiplexing ids they had to be mapped.

// There is other than P2P protocols multiplexed and they shall not be visible 

// in P2P routing nor API.

#define MAP_P2P_TO_MUX( aP2PId )( aP2PId + ( EMuxAmountOfProtocols - EP2PAmountOfProtocols ) )

#define MAP_MUX_TO_P2P( aMuxId )( aMuxId - ( EMuxAmountOfProtocols - EP2PAmountOfProtocols ) )

MP2PRouterLinkIf* MP2PRouterLinkIf::CreateLinkF(

        MP2PLinkRouterIf* aRouter,

        const TUint8 aProtocolId,

        const TUint8 aTrxId

        )

    {

    C_TRACE( ( _T( "MP2PRouterLinkIf::CreateLinkF 0x%x %d %d>" ), aRouter, aProtocolId, aTrxId ) );

    ASSERT_RESET_ALWAYS( aRouter, ( EP2PLinkNullPtr | EDP2PLinkTraceId << KClassIdentifierShift ) );

    DP2PLink* link = new DP2PLink( aRouter, aProtocolId, aTrxId );

    ASSERT_RESET_ALWAYS( aRouter, ( EP2PMemAllocFailed | EDP2PLinkTraceId << KClassIdentifierShift ) );

    C_TRACE( ( _T( "MP2PRouterLinkIf::CreateLinkF 0x%x %d %d created 0x%x<" ), aRouter, aProtocolId, aTrxId, link ) );

    return link;

    }

DP2PLink::DP2PLink(

        ) : iRouter( NULL )

    {

    C_TRACE( ( _T( "DP2PLink::DP2PLink 0x%x>" ), this ) );

    iProtocolId = 0x00;

    iShTrxId = 0x00;

    iMux = NULL;

    C_TRACE( ( _T( "DP2PLink::DP2PLink 0x%x<" ), this ) );

    }

DP2PLink::DP2PLink(

        MP2PLinkRouterIf* aRouter,

        const TUint8 aProtocolId,

        const TUint8 aTrxId

        ) : iRouter( aRouter )

    {

    C_TRACE( ( _T( "DP2PLink::DP2PLink 0x%x protid %d map %d trxid %d>" ), this, aProtocolId, iProtocolId, aTrxId ) );

    // Map from Point-to-point protocol to multiplexing protocol.

    iProtocolId = MAP_P2P_TO_MUX( aProtocolId );

    iShTrxId = ~aTrxId;

    iMux = MLinkMuxIf::Register( this, aTrxId, iProtocolId );

    ASSERT_RESET_ALWAYS( aRouter, ( EP2PRegisterFailed | EDP2PLinkTraceId << KClassIdentifierShift ) );

    C_TRACE( ( _T( "DP2PLink::DP2PLink 0x%x protid %d map %d trxid %d<" ), this, aProtocolId, iProtocolId, aTrxId ) );

    }

DP2PLink::~DP2PLink()

    {

    C_TRACE( ( _T( "DP2PLink::~DP2PLink 0x%x>" ), this ) );

    C_TRACE( ( _T( "DP2PLink::~DP2PLink 0x%x<" ), this ) );

    }

// From MMuxLinkIf start

void DP2PLink::Receive(

        TDes8& aMsg

        )

    {

    C_TRACE( ( _T( "DP2PLink::Receive 0x%x 0x%x id %d>" ), this, &aMsg, iProtocolId ) );

    ASSERT_RESET_ALWAYS( iMux, ( EP2PInitFailed | EDP2PLinkTraceId << KClassIdentifierShift ) );

    iRouter->Receive( aMsg, MAP_MUX_TO_P2P( iProtocolId ) );

    C_TRACE( ( _T( "DP2PLink::Receive 0x%x 0x%x id %d<" ), this, &aMsg, iProtocolId ) );

    }

/*

* Called with FM held, no blocking no nesting of FMs and no allocation.

*/

void DP2PLink::EnqueTrxPresenceChangedDfc(

        TBool aPresent

        )

    {

    // No traces allowed due to not allowed to block.

    // Negation sets variable to be over EAmountOfTrxs if it is not present.

    iShTrxId = ~iShTrxId;// TODO: check this atomicity and synch if needed

    iRouter->NotifyTrxPresenceEnqueDfc( aPresent );

    }

// From MMuxLinkIf end

// From MP2PRouterLinkIf start

TBool DP2PLink::TrxPresent()

    {

    C_TRACE( ( _T( "DP2PLink::TrxPresent 0x%x>" ), this ) );

    // Amount of trx shall always be less than the negative

    TBool value( iShTrxId < EAmountOfTrxs ? ETrue : EFalse );

    C_TRACE( ( _T( "DP2PLink::TrxPresent 0x%x %d<" ), this, value ) );

    return value;

    }

void DP2PLink::Release(

        // None

        )

    {

    C_TRACE( ( _T( "DP2PLink::Release 0x%x>" ), this ) );

    delete this;

    C_TRACE( ( _T( "DP2PLink::Release 0x%x<" ), this ) );

    }

void DP2PLink::Send(

        TDes8& aMsg

        )

    {

    C_TRACE( ( _T( "DP2PLink::Send 0x%x 0x%x map %d <>" ), this, &aMsg, iProtocolId ) );

    ASSERT_RESET_ALWAYS( iMux, ( EP2PInitFailed2 | EDP2PLinkTraceId << KClassIdentifierShift ) );

    // Send with default prio.

    iMux->Send( aMsg, iProtocolId ); // TODO: send priorities

    }

// From MP2PRouterLinkIf end