diff -r 453dfc402455 -r 0aa8cc770c8a localconnectivityservice/dun/utils/inc/DunDataPusher.h
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/localconnectivityservice/dun/utils/inc/DunDataPusher.h	Tue Aug 31 16:03:15 2010 +0300
@@ -0,0 +1,284 @@
+/*
+* Copyright (c) 2008-2010 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:  Pushes data to existing stream from outside
+*
+*/
+
+
+#ifndef C_CDUNDATAPUSHER_H
+#define C_CDUNDATAPUSHER_H
+
+#include "DunTransporter.h"
+
+class MDunCompletionReporter;
+
+/**
+ *  Class used for storing data related to data push
+ *  (data coming from MDunStreamManipulator::NotifyDataPushRequest())
+ *
+ *  @lib dunutils.lib
+ *  @since S60 v3.2
+ */
+NONSHARABLE_CLASS( TDunDataPush )
+    {
+
+public:
+
+    /**
+     * Data to push to the stream (not copied)
+     */
+    const TDesC8* iDataToPush;
+
+    /**
+     * Callback to call when data is processed by the stream
+     * If this is NULL then no callback will be made
+     */
+    MDunCompletionReporter* iCallback;
+
+    };
+
+/**
+ *  Class for notifications of stream manipulator's completion events
+ *
+ *  @lib dunutils.lib
+ *  @since S60 v3.2
+ */
+NONSHARABLE_CLASS( MDunCompletionReporter )
+    {
+
+public:
+
+    /**
+     * Gets called when data from
+     * MDunStreamManipulator::NotifyDataPushRequest() has been processed and
+     * CDunDownstream is ready to process more data.
+     *
+     * @since S60 5.0
+     * @param aAllPushed ETrue if all in the queue were pushed, EFalse otherwise
+     * @return None
+     */
+    virtual void NotifyDataPushComplete( TBool aAllPushed ) = 0;
+
+    };
+
+/**
+ *  Class for pushing data to existing CDunDownstream stream from outside
+ *
+ *  @lib dunutils.lib
+ *  @since S60 v3.2
+ */
+NONSHARABLE_CLASS( CDunDataPusher ) : public CActive
+    {
+
+public:
+
+    /**
+     * Two-phased constructor.
+     * @param aParent Parent class owning this friend class (CDunDownstream)
+     * @param aStreamCallback Callback to call when events processed
+     * @return Instance of self
+     */
+	static CDunDataPusher* NewL( CDunDownstream& aParent,
+	                             MDunCompletionReporter* aStreamCallback );
+
+    /**
+    * Destructor.
+    */
+    virtual ~CDunDataPusher();
+
+    /**
+     * Resets data to initial values
+     *
+     * @since S60 3.2
+     * @return None
+     */
+    void ResetData();
+
+    /**
+     * Sets media to be used for this endpoint
+     *
+     * @since S60 3.2
+     * @param aComm RComm pointer to use as the endpoint
+     * @return Symbian error code on error, KErrNone otherwise
+     */
+    TInt SetMedia( RComm* aComm );
+
+    /**
+     * Sets media to be used for this endpoint
+     *
+     * @since S60 3.2
+     * @param aSocket RSocket pointer to use as the endpoint
+     * @return Symbian error code on error, KErrNone otherwise
+     */
+    TInt SetMedia( RSocket* aSocket );
+
+    /**
+     * Adds event notification to queue
+     *
+     * @since S60 3.2
+     * @param aDataToPush Data to push to the stream (not copied)
+     * @param aCallback Callback to call when data is processed by the stream
+     * @return Symbian error code on error, KErrNone otherwise
+     */
+    TInt AddToEventQueue( const TDesC8* aDataToPush,
+                          MDunCompletionReporter* aCallback );
+
+    /**
+     * Finds an event from queue
+     *
+     * @since S60 5.0
+     * @param aDataToPush Data to push to the stream (not copied)
+     * @return Index of found event, Symbian error code otherwise
+     */
+    TInt FindEventFromQueue( const TDesC8* aDataToPush );
+
+    /**
+     * Stops one event in the event queue
+     *
+     * @since S60 5.0
+     * @param aDataToPush Data to push to the stream (not copied)
+     * @return Symbian error code on error, KErrNone otherwise
+     */
+    TInt StopOneEvent( const TDesC8* aDataToPush );
+
+    /**
+     * Sends queued data in round robin
+     *
+     * @since S60 3.2
+     * @return ETrue if sending started, EFalse if nothing to do
+     */
+    TBool SendQueuedData();
+
+    /**
+     * Stops sending for write endpoint
+     *
+     * @since S60 3.2
+     * @return Symbian error code on error, KErrNone otherwise
+     */
+    TInt Stop();
+
+    /**
+     * Stops sending for write endpoint and clears event queue
+     *
+     * @since S60 3.2
+     * @return Symbian error code on error, KErrNone otherwise
+     */
+    TInt StopAndClearQueue();
+
+    /**
+     * Signals completion status in round robin and clears event queue
+     *
+     * @return Symbian error code on error, KErrNone otherwise
+     * @return None
+     */
+    TInt SignalCompletionAndClearQueue();
+
+private:
+
+    CDunDataPusher( CDunDownstream& aParent,
+                    MDunCompletionReporter* aStreamCallback );
+
+    void ConstructL();
+
+    /**
+     * Initializes this class
+     *
+     * @since S60 3.2
+     * @return None
+     */
+    void Initialize();
+
+    /**
+     * Manages one event's data push
+     *
+     * @since S60 3.2
+     * @return None
+     */
+    TInt ManageOneEvent();
+
+    /**
+     * Check whether an error code is severe error or not
+     *
+     * @since S60 3.2
+     * @param aError Error code to check for severity
+     * @param aIsError ETrue if error code is error, EFalse if not error
+     * @return ETrue if severe error detected, EFalse if not severe error
+     */
+    TBool ProcessErrorCondition( TInt aError, TBool& aIsError );
+
+// from base class CActive
+
+    /**
+     * From CActive.
+     * Gets called when endpoint data write complete
+     *
+     * @since S60 3.2
+     * @return None
+     */
+    void RunL();
+
+    /**
+     * From CActive.
+     * Gets called on cancel
+     *
+     * @since S60 3.2
+     * @return None
+     */
+    void DoCancel();
+
+private:  // data
+
+    /**
+     * Parent class owning this friend class (CDunDownstream)
+     */
+    CDunDownstream& iParent;
+
+    /**
+     * Callback to call when notification via MDunCompletionReporter to be made
+     * Not own.
+     */
+    MDunCompletionReporter* iStreamCallback;
+
+    /**
+     * Event queue for pushed data requests
+     */
+    RArray<TDunDataPush> iEventQueue;
+
+    /**
+     * Current state of data push: active or inactive
+     */
+    TDunState iPushState;
+
+    /**
+     * Index of current event to serve
+     */
+    TInt iEventIndex;
+
+    /**
+     * RSocket object of local media side
+     * If this is set then iComm is not used
+     * Not own.
+     */
+    RSocket* iSocket;
+
+    /**
+     * RComm object of local media or network side
+     * If this is set then iSocket is not used
+     * Not own.
+     */
+    RComm* iComm;
+
+    };
+
+#endif  // C_DUNDATAPUSHER_H