--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/connectivitylayer/isce/p2prouter_dll/src/p2plink.cpp	Fri Nov 06 17:28:23 2009 +0000
@@ -0,0 +1,165 @@
+/*
+* 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
+