diff -r 6ca72c0fe49a -r a941bc465d9f PECengine/TransferAdapter2/Src/CPEngPureDataHandler.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/PECengine/TransferAdapter2/Src/CPEngPureDataHandler.h	Wed Sep 01 12:31:13 2010 +0100
@@ -0,0 +1,234 @@
+/*
+* Copyright (c) 2004 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:  Access handler of the network session
+*
+*/
+
+#ifndef __CPENGPUREDATAHANDLER_H__
+#define __CPENGPUREDATAHANDLER_H__
+
+//  INCLUDES
+#include <E32Base.h>
+#include <impspurecli.h>
+#include "MPEngPureDataHandler.h"
+#include "MPEngSessionStatusObserver.h"
+
+// FORWARD DECLARATIONS
+class CPEngSendDataOperation;
+class CPEngSessionSlotId;
+class RImpsEng;
+class MPEngSessionManager;
+class MPEngAccessHandler;
+
+/**
+ * CPEngPureDataHandler implementation.
+ *
+ * @since 3.0
+ */
+NONSHARABLE_CLASS( CPEngPureDataHandler ) :
+        public CBase,
+        public MPEngPureDataHandler,
+        public MImpsPureHandler2,
+        public MImpsErrorHandler2,
+        public MPEngSessionStatusObserver
+    {
+public: /* Construction */
+
+
+    /**
+     * Instantiates CPEngPureDataHandler object.
+     *
+     * @return New CPEngPureDataHandler instance.
+     */
+    static CPEngPureDataHandler* NewL( RImpsEng& aSessClient,
+    MPEngSessionManager& aSessManager,
+    MPEngAccessHandler& aAccessHandler,
+    const CPEngSessionSlotId& aSessionId );
+
+
+    /**
+     * Destructor.
+     */
+    ~CPEngPureDataHandler();
+
+    //-----------------------------------------------------------------------
+
+public: // new functions from MPEngPureDataHandler
+
+    /**
+     *  Close reference to the Pure data handler
+     *  @see <MPEngPureDataHandler.h>
+     *  @since 3.0
+     */
+    void Close();
+
+    /**
+     *  Get Transfer buffer for out going message
+     *  @see <MPEngPureDataHandler.h>
+     *  @since 3.0
+     */
+    TPtr8 TransferBufferL();
+
+    /**
+     *  Sends data from the transfer buffer to the network
+     *  @see <MPEngPureDataHandler.h>
+     *  @since 3.0
+     */
+    TInt SendDataL( TRequestStatus& aStatus );
+
+    /**
+     *  Gets response for the message of given operation id
+     *  @see <MPEngPureDataHandler.h>
+     *  @since 3.0
+     */
+    HBufC8* ResponseL( TInt aTransId );
+
+    /**
+     *  Cancel sendin operation of given transaction id
+     *  @see <MPEngPureDataHandler.h>
+     *  @since 3.0
+     */
+    void CancelSending( TInt aTransId );
+
+    /**
+     *  Listen Incoming data
+     *  @see <MPEngPureDataHandler.h>
+     *  @since 3.0
+     */
+    TInt ListenIncomingData( TRequestStatus& aStatus );
+
+    /**
+     *  Cancel incoming data listening
+     *  @see <MPEngPureDataHandler.h>
+     *  @since 3.0
+     */
+    void CancelListening();
+
+public: // new functions from MImpsPureHandler
+
+    /**
+     * Observer method for pure message content.
+     * @see <impspurecli.h>
+     * @seince 3.0
+     */
+    void HandlePureDataL( TInt aOpId,
+                          const TDesC8& aBuffer,
+                          TImpsCspIdentifier& aCspId );
+
+public: // new functions from MImpsErrorHandler
+
+    /**
+     * Observer method for error messages.
+     * @see <impspurecli.h>
+     * @seince 3.0
+     */
+    void HandleErrorL( TInt aStatus,
+                       TInt aOpId,
+                       const TDesC* aDescription,
+                       const CImpsDetailed* aDetailedRes,
+                       TImpsCspIdentifier& aCspId );
+
+public: //  new function from the MPEngSessionStatusObserver
+    /**
+     *  Handle Session status change
+     *  @see <MPEngSessionStatusObserver.h>
+     *  @since 3.0
+     */
+    void StatusChangedL( TPEngNWSessionSlotState aNewState,
+                         TPEngNWSessionSlotEvent aNewEvent );
+
+public: // New functions
+
+    /**
+     *  Open new reference to the object
+     *
+     *  @since 3.0
+     */
+    void Open();
+
+private: // new private functions
+
+    /**
+     *  Find operation
+     *
+     *  @since 3.0
+     *  @return index in array
+     */
+    TInt FindOperation( TInt aOpId, TInt ( CPEngSendDataOperation:: *aIdFunc )() const ) const;
+    TInt FindOperationL( TInt aOpId, TInt ( CPEngSendDataOperation:: *aIdFunc )() const ) const;
+
+protected: // construction
+
+    /**
+     * C++ constructor. protected
+     */
+    CPEngPureDataHandler( MPEngSessionManager& aSessManager,
+                          MPEngAccessHandler& aAccessHandler,
+                          const CPEngSessionSlotId& aSessionId,
+                          RImpsEng& aSessClient );
+
+    /**
+     * Symbian Second phase constructor
+     */
+    void ConstructL( RImpsEng& aSessClient );
+
+private: //Data
+
+    /// OWN: Access count
+    TInt                                    iCount;
+
+    /// OWN: Session manager
+    MPEngSessionManager&                    iSessionManager;
+
+    /// OWN: Access handler
+    MPEngAccessHandler&						iAccessHandler;
+
+    /// REF: Session Id
+    const CPEngSessionSlotId&               iSessionId;
+
+    /// OWN: Max number of active requests
+    TInt                                    iMaxActive;
+
+    /// OWN: Transfer buffer, OWNED
+    HBufC8*                                 iTrasferBuffer;
+
+    /// OWN: Incoming data queue, OWNED
+    RPointerArray<HBufC8>                   iIncomingData;
+
+    // Incoming data Request Status
+    TRequestStatus*                         iIncReqStatus;
+
+    /// REF: Main client of the IMPS Engine
+    RImpsEng&                               iSessClient;
+
+    /// OWN: Pure client
+    RImpsPureClient2                        iPureClient;
+
+    /// OWN: Send data operations]
+    ///     Elements OWNed
+    RPointerArray<CPEngSendDataOperation>   iOperations;
+
+    /// OWN: Id which is used to do logs more human readable
+    TInt                                    iConnectionLogsId;
+
+    /// OWN: Logs Id iteration,
+    TInt                                    iOpidIterator;
+
+    /// OWN: Last served op Id
+    TInt                                    iLastServerOpId;
+    };
+
+#endif  //__CPENGPUREDATAHANDLER_H__
+
+// End of File