--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/adaptationlayer/dataport/dataport_csy/src/dppif.cpp	Fri Nov 06 17:28:23 2009 +0000
@@ -0,0 +1,272 @@
+/*
+* Copyright (c) 2007-2008 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 FILES
+#include <pipeisi.h>    // isi pipe
+
+#include "dpdef.h"      // dataport definitions
+#include "dpdataport.h" // dataport main and c32 interface
+#include "dppif.h"      // pipe interface (pif)
+#include "dpmif.h"      // message inteface (mif)
+#include "dplog.h"      // dataport logging
+#include <pipe_sharedisi.h>
+#include "osttracedefinitions.h"
+#ifdef OST_TRACE_COMPILER_IN_USE
+#include "dppiftraces.h"
+#endif
+
+
+// EXTERNAL DATA STRUCTURES
+// none
+
+// EXTERNAL FUNCTION PROTOTYPES
+// none
+
+// CONSTANTS
+// none
+
+// MACROS
+// none
+
+// LOCAL CONSTANTS AND MACROS
+// none
+
+// MODULE DATA STRUCTURES
+// none
+
+// LOCAL FUNCTION PROTOTYPES
+// none
+
+// FORWARD DECLARATIONS
+// none
+
+// ============================= LOCAL FUNCTIONS ===============================
+
+// none
+
+
+// ============================ MEMBER FUNCTIONS ===============================
+
+// ---------------------------------------------------------
+// CDpPif::CDpPif
+// C++ default constructor.
+// ---------------------------------------------------------
+CDpPif::CDpPif(
+    CDpDataPort& aDataPort ) :
+    CActive( KDpPifPriority ),
+    iDataPort( aDataPort ),
+    iPipeState( EDpPipeDisconnected ),
+    iPipeHandle( PN_PIPE_INVALID_HANDLE ),
+    iPifState( EDpPifInitial )
+    {
+    OstTrace0( TRACE_NORMAL, CDPPIF_CDPPIF, "CDpPif::CDpPif" );
+    LOGM(" CDpPif::CDpPif");
+
+    CActiveScheduler::Add( this );
+    }
+
+// ---------------------------------------------------------
+// CDpPif::~CDpPif
+// Destructor
+// ---------------------------------------------------------
+CDpPif::~CDpPif()
+    {
+    OstTrace0( TRACE_NORMAL, DUP1_CDPPIF_CDPPIF, "CDpPif::~CDpPif" );
+    LOGM(" CDpPif::~CDpPif");
+    }
+
+// ---------------------------------------------------------
+// CDpPif::RunL
+// PIF state is changed here after registering.
+// ---------------------------------------------------------
+//
+void CDpPif::RunL()
+    {
+    OstTrace0( TRACE_NORMAL, CDPPIF_RUNL, "CDpPif::RunL" );
+    OstTrace1( TRACE_NORMAL, DUP1_CDPPIF_RUNL, "CDpPif:: Port: %u", iDataPort.PortUnit() );
+
+    LOGM1("CDpPif::RunL - Port %d", iDataPort.PortUnit() );
+
+    // which state in initializing are we
+    switch ( iPifState )
+        {
+        case EDpPifRegister:
+            {
+            // if pns_name_add failed, there's not much to do,
+            // we just wait to get thrown away...
+            if ( KErrNone == iStatus.Int() )
+                {
+                iPifState = EDpPifReady;
+                }
+            //no else
+            break;
+            }
+        case EDpPifReady:
+        case EDpPifInitial:
+            {
+            break;
+            }
+        default:
+            {
+            LOG1(" ERROR, CDpPif::RunL, Unsupported PIFState: %d", iPifState );
+            OstTrace1( TRACE_NORMAL, DUP2_CDPPIF_RUNL, "ERROR, CDpPif::RunL, Unsupported PIFState: %d", iPifState );
+
+            User::Leave( KErrGeneral );
+            }
+        }
+    }
+
+// ---------------------------------------------------------
+// CDpPif::RunError
+// Leave in RunL() is handled here. Error code is returned,
+// when internal error has occured (unsupported pipe state).
+// ---------------------------------------------------------
+//
+TInt CDpPif::RunError(
+    TInt aError )
+    {
+    OstTrace0( TRACE_NORMAL, CDPPIF_RUNERROR, "CDpPif::RunError" );
+    OstTraceExt2( TRACE_NORMAL, DUP1_CDPPIF_RUNERROR, "CDpPif:: Port: %u, error code: %d", iDataPort.PortUnit(), aError );
+
+    LOGM2("CDpPif::RunError - Port %d, error code: %d",
+        iDataPort.PortUnit(), aError );
+
+    return aError;
+    }
+
+// ---------------------------------------------------------
+// CDpPif::DoCancel
+// This method signals PIF with KErrCancel, if PIF is
+// registered state.
+// ---------------------------------------------------------
+//
+void CDpPif::DoCancel()
+    {
+    OstTrace0( TRACE_NORMAL, CDPPIF_DOCANCEL, "CDpPif::DoCancel" );
+    LOGM(" CDpPif::DoCancel");
+
+    if ( IsActive() )
+        {
+        iDataPort.SignalPif( KErrCancel );
+        }
+    }
+
+// ---------------------------------------------------------
+// CDpPif::InitiatePipe
+// This method registers DataPort to Name Service.
+// ---------------------------------------------------------
+//
+TInt CDpPif::InitiatePipe(
+    const TUint aUnit )
+    {
+    OstTrace0( TRACE_NORMAL, CDPPIF_INITIATEPIPE, "CDpPif::InitiatePipe" );
+    OstTrace1( TRACE_NORMAL, DUP1_CDPPIF_INITIATEPIPE, "CDpPif:: Port: %u", aUnit );
+
+    LOGM1(" CDpPif::InitiatePipe - Port %d", aUnit );
+
+    TInt ret( KErrNone );
+
+    if ( !iPepRegistered )
+        {
+        // pep_register
+
+        TRAP( ret, iDataPort.Mif().SendNameAddReqL( aUnit ) );
+
+        if ( KErrNone == ret )
+            {
+            // set active
+            if ( !IsActive() )
+                {
+                iStatus = KRequestPending;
+                SetActive();
+                }
+            //no else
+
+            iPepRegistered = ETrue;
+            // state_change
+            iPifState = EDpPifRegister;
+            }
+        //no else
+        }
+    else
+        {
+        // registered pipe already exists
+        ret = KErrAlreadyExists;
+        }
+
+    return ret;
+    }
+
+// ---------------------------------------------------------
+// CDpPif::ClosePipeL
+// This method unregisters DataPort from Name Service.
+// ---------------------------------------------------------
+//
+void CDpPif::ClosePipeL( const TUint aUnit )
+    {
+    OstTrace0( TRACE_NORMAL, CDPPIF_CLOSEPIPEL, "CDpPif::ClosePipeL" );
+    OstTrace1( TRACE_NORMAL, DUP1_CDPPIF_CLOSEPIPEL, "CDpPif:: Port: %u", aUnit );
+
+    LOGM1(" CDpPif::ClosePipeL - Port %d", aUnit );
+
+    iPepRegistered = EFalse;
+
+    iDataPort.Mif().SendNameRemoveReqL( aUnit );
+
+    // state_change
+    iPifState = EDpPifInitial;
+    }
+
+// -----------------------------------------------------------------------------
+// CDpPif::Attach
+// Attach observer to CDpSubject.
+// -----------------------------------------------------------------------------
+//
+void CDpPif::Attach( CDpObserver& aObserver )
+    {
+    OstTrace0( TRACE_NORMAL, CDPPIF_ATTACH, "CDpPif::Attach" );
+    iDpSubject.Attach( aObserver );
+    }
+
+// -----------------------------------------------------------------------------
+// CDpPif::Detach
+// Detach observer from CDpSubject.
+// -----------------------------------------------------------------------------
+//
+void CDpPif::Detach( CDpObserver& aObserver )
+    {
+    OstTrace0( TRACE_NORMAL, CDPPIF_DETACH, "CDpPif::Detach" );
+    iDpSubject.Detach( aObserver );
+    }
+
+// -----------------------------------------------------------------------------
+// CDpPif::Notify
+// Notify all observers of CDpSubject object.
+// -----------------------------------------------------------------------------
+//
+void CDpPif::Notify()
+    {
+    OstTrace0( TRACE_NORMAL, CDPPIF_NOTIFY, "CDpPif::Notify" );
+    iDpSubject.Notify();
+    }
+
+// ================= OTHER EXPORTED FUNCTIONS ==============
+// none
+
+//  End of File