localconnectivityservice/dun/utils/src/DunDataPusher.cpp
branchRCL_3
changeset 20 4a793f564d72
parent 19 0aa8cc770c8a
child 21 74aa6861c87d
--- a/localconnectivityservice/dun/utils/src/DunDataPusher.cpp	Tue Aug 31 16:03:15 2010 +0300
+++ /dev/null	Thu Jan 01 00:00:00 1970 +0000
@@ -1,450 +0,0 @@
-/*
-* Copyright (c) 2009-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
-*
-*/
-
-
-#include "DunDataPusher.h"
-#include "DunDownstream.h"
-#include "DunDebug.h"
-
-// ---------------------------------------------------------------------------
-// Two-phased constructor.
-// ---------------------------------------------------------------------------
-//
-CDunDataPusher* CDunDataPusher::NewL( CDunDownstream& aParent,
-                                      MDunCompletionReporter* aStreamCallback )
-    {
-    CDunDataPusher* self = new (ELeave) CDunDataPusher( aParent,
-                                                        aStreamCallback );
-    CleanupStack::PushL( self );
-    self->ConstructL();
-    CleanupStack::Pop( self );
-    return self;
-    }
-
-// ---------------------------------------------------------------------------
-// Destructor.
-// ---------------------------------------------------------------------------
-//
-CDunDataPusher::~CDunDataPusher()
-    {
-    FTRACE(FPrint( _L("CDunDataPusher::~CDunDataPusher()" )));
-    ResetData();
-    FTRACE(FPrint( _L("CDunDataPusher::~CDunDataPusher() complete" )));
-    }
-
-// ---------------------------------------------------------------------------
-// Resets data to initial values
-// ---------------------------------------------------------------------------
-//
-void CDunDataPusher::ResetData()
-    {
-    // APIs affecting this:
-    // SendQueuedData()
-    Stop();
-    // AddToEventQueue()
-    iEventQueue.Close();
-    // Internal
-    Initialize();
-    }
-
-// ---------------------------------------------------------------------------
-// Sets media to be used for this endpoint
-// ---------------------------------------------------------------------------
-//
-TInt CDunDataPusher::SetMedia( RComm* aComm )
-    {
-    FTRACE(FPrint( _L("CDunDataPusher::SetMedia() (RComm)" )));
-    if ( !aComm )
-        {
-        FTRACE(FPrint( _L("CDunDataPusher::SetMedia() (RComm) (not initialized!) complete" )));
-        return KErrGeneral;
-        }
-    iComm = aComm;
-    FTRACE(FPrint( _L("CDunDataPusher::SetMedia() (RComm) complete" )));
-    return KErrNone;
-    }
-
-// ---------------------------------------------------------------------------
-// Sets media to be used for this endpoint
-// ---------------------------------------------------------------------------
-//
-TInt CDunDataPusher::SetMedia( RSocket* aSocket )
-    {
-    FTRACE(FPrint( _L("CDunDataPusher::SetMedia() (RSocket)" )));
-    if ( !aSocket )
-        {
-        FTRACE(FPrint( _L("CDunDataPusher::SetMedia() (RSocket) (not initialized!) complete" )));
-        return KErrGeneral;
-        }
-    iSocket = aSocket;
-    FTRACE(FPrint( _L("CDunDataPusher::SetMedia() (RSocket) complete" )));
-    return KErrNone;
-    }
-
-// ---------------------------------------------------------------------------
-// Adds event notification to queue
-// ---------------------------------------------------------------------------
-//
-TInt CDunDataPusher::AddToEventQueue( const TDesC8* aDataToPush,
-                                      MDunCompletionReporter* aCallback )
-    {
-    FTRACE(FPrint( _L("CDunDataPusher::AddToQueue()" )));
-    if ( !aDataToPush || aDataToPush->Length()<0 )
-        {
-        FTRACE(FPrint( _L("CDunDataPusher::AddToQueue() (unknown data) complete" )));
-        return KErrGeneral;
-        }
-    // Check if identical pointer to data already exists
-    TInt foundIndex = FindEventFromQueue( aDataToPush );
-    if ( foundIndex >= 0 )
-        {
-        FTRACE(FPrint( _L("CDunDataPusher::AddToQueue() (already exists) complete" )));
-        return KErrAlreadyExists;
-        }
-    // Unique pointer -> add to event queue
-    TDunDataPush dataPush;
-    dataPush.iDataToPush = aDataToPush;
-    dataPush.iCallback = aCallback;
-    TInt retTemp = iEventQueue.Append( dataPush );
-    if ( retTemp != KErrNone )
-        {
-        FTRACE(FPrint( _L("CDunDataPusher::AddToQueue() (append failed!) complete" )));
-        return retTemp;
-        }
-    FTRACE(FPrint( _L("CDunDataPusher::AddToQueue() complete (count=%d)" ), iEventQueue.Count() ));
-    return KErrNone;
-    }
-
-// ---------------------------------------------------------------------------
-// Finds an event from queue
-// ---------------------------------------------------------------------------
-//
-TInt CDunDataPusher::FindEventFromQueue( const TDesC8* aDataToPush )
-    {
-    FTRACE(FPrint( _L("CDunDataPusher::FindEventFromQueue()" )));
-    TInt i;
-    TInt count = iEventQueue.Count();
-    for ( i=0; i<count; i++ )
-        {
-        if ( iEventQueue[i].iDataToPush == aDataToPush )
-            {
-            FTRACE(FPrint( _L("CDunDataPusher::FindEventFromQueue() complete" )));
-            return i;
-            }
-        }
-    FTRACE(FPrint( _L("CDunDataPusher::FindEventFromQueue() (not found) complete" )));
-    return KErrNotFound;
-    }
-
-// ---------------------------------------------------------------------------
-// Stops one event in the event queue
-// ---------------------------------------------------------------------------
-//
-TInt CDunDataPusher::StopOneEvent( const TDesC8* aDataToPush )
-    {
-    FTRACE(FPrint( _L("CDunDataPusher::StopOneEvent()" )));
-    if ( !aDataToPush )
-        {
-        FTRACE(FPrint( _L("CDunDataPusher::StopOneEvent() (unknown data) complete" )));
-        return KErrGeneral;
-        }
-    TInt foundIndex = FindEventFromQueue( aDataToPush );
-    if ( foundIndex >= 0 )
-        {
-        if ( iEventIndex == foundIndex )
-            {
-            Stop();
-            }
-        FTRACE(FPrint( _L("CDunDataPusher::StopOneEvent() complete" )));
-        return KErrNone;
-        }
-    FTRACE(FPrint( _L("CDunDataPusher::StopOneEvent() (not found) complete" )));
-    return KErrNotFound;
-    }
-
-// ---------------------------------------------------------------------------
-// Sends queued data in round robin
-// ---------------------------------------------------------------------------
-//
-TBool CDunDataPusher::SendQueuedData()
-    {
-    FTRACE(FPrint( _L("CDunDataPusher::SendQueuedData()" )));
-    if ( iPushState!=EDunStateIdle || iEventQueue.Count()==0 )
-        {
-        FTRACE(FPrint( _L("CDunDataPusher::SendQueuedData() (not ready) complete" )));
-        return EFalse;
-        }
-    TInt retTemp = ManageOneEvent();
-    if ( retTemp != KErrNone )
-        {
-        FTRACE(FPrint( _L("CDunDataPusher::SendQueuedData() (ERROR) complete" )));
-        return EFalse;
-        }
-    iPushState = EDunStateDataPushing;
-    FTRACE(FPrint( _L("CDunDataPusher::SendQueuedData() complete (%d)" ), iEventQueue.Count() ));
-    return ETrue;
-    }
-
-// ---------------------------------------------------------------------------
-// Stops sending for write endpoint
-// ---------------------------------------------------------------------------
-//
-TInt CDunDataPusher::Stop()
-    {
-    FTRACE(FPrint( _L("CDunDataPusher::Stop()" )));
-    if ( iPushState != EDunStateDataPushing )
-        {
-        FTRACE(FPrint( _L("CDunDataPusher::Stop() (not ready) complete" )));
-        return KErrNotReady;
-        }
-    // As the EDunStateDataPushing can be on even with multiple requests,
-    // cancel the actual operation in DoCancel()
-    Cancel();
-    iPushState = EDunStateIdle;
-    FTRACE(FPrint( _L("CDunDataPusher::Stop() complete" )));
-    return KErrNone;
-    }
-
-// ---------------------------------------------------------------------------
-// Stops sending for write endpoint and clears event queue
-// ---------------------------------------------------------------------------
-//
-TInt CDunDataPusher::StopAndClearQueue()
-    {
-    FTRACE(FPrint( _L("CDunDataPusher::StopAndClearQueue()" )));
-    TInt retVal = Stop();
-    iEventQueue.Reset();
-    iEventIndex = 0;
-    FTRACE(FPrint( _L("CDunDataPusher::StopAndClearQueue() complete" )));
-    return retVal;
-    }
-
-// ---------------------------------------------------------------------------
-// Signals completion status in round robin and clears event queue
-// ---------------------------------------------------------------------------
-//
-TInt CDunDataPusher::SignalCompletionAndClearQueue()
-    {
-    FTRACE(FPrint( _L("CDunDataPusher::SignalCompletionAndClearQueue()" )));
-    // First copy the event queue to temporary notitication queue and
-    // reset the real event queue before notifications. This is done because
-    // implementor of NotifyDataPushComplete() can call AddToEventQueue()
-    // (and KErrAlreadyExists will happen there)
-    TInt i;
-    TInt retTemp;
-    RPointerArray<MDunCompletionReporter> notify;
-    TInt count = iEventQueue.Count();
-    for ( i=0; i<count; i++ )
-        {
-        if ( !iEventQueue[i].iCallback )
-            {
-            continue;
-            }
-        retTemp = notify.Append( iEventQueue[i].iCallback );
-        if ( retTemp != KErrNone )
-            {
-            FTRACE(FPrint( _L("CDunDataPusher::SignalCompletionAndClearQueue() (append failed!) complete" )));
-            return retTemp;
-            }
-        }
-    iEventQueue.Reset();
-    iEventIndex = 0;
-    // Now notify
-    count = notify.Count();
-    for ( i=0; i<count; i++ )
-        {
-        notify[i]->NotifyDataPushComplete( EFalse );
-        }
-    notify.Close();
-    FTRACE(FPrint( _L("CDunDataPusher::SignalCompletionAndClearQueue() complete (%d)" ), count ));
-    return KErrNone;
-    }
-
-// ---------------------------------------------------------------------------
-// CDunDataPusher::CDunDataPusher
-// ---------------------------------------------------------------------------
-//
-CDunDataPusher::CDunDataPusher( CDunDownstream& aParent,
-                                MDunCompletionReporter* aStreamCallback ) :
-    CActive( EPriorityHigh ),
-    iParent( aParent ),
-    iStreamCallback( aStreamCallback )
-    {
-    Initialize();
-    }
-
-// ---------------------------------------------------------------------------
-// CDunDataPusher::ConstructL
-// ---------------------------------------------------------------------------
-//
-void CDunDataPusher::ConstructL()
-    {
-    FTRACE(FPrint( _L("CDunDataPusher::ConstructL()" )));
-    if ( !iStreamCallback )
-        {
-        User::Leave( KErrGeneral );
-        }
-    CActiveScheduler::Add( this );
-    FTRACE(FPrint( _L("CDunDataPusher::ConstructL() complete" )));
-    }
-
-// ---------------------------------------------------------------------------
-// Initializes this class
-// ---------------------------------------------------------------------------
-//
-void CDunDataPusher::Initialize()
-    {
-    // Don't initialize iUtility here (it is set through NewL)
-    // Don't initialize iStreamCallback here (it is set through NewL)
-    iPushState = EDunStateIdle;
-    iEventIndex = 0;
-    iSocket = NULL;
-    iComm = NULL;
-    }
-
-// ---------------------------------------------------------------------------
-// Manages one event's data push
-// ---------------------------------------------------------------------------
-//
-TInt CDunDataPusher::ManageOneEvent()
-    {
-    FTRACE(FPrint( _L("CDunDataPusher::ManageOneEvent()" )));
-    if ( IsActive() )
-        {
-        FTRACE(FPrint( _L("CDunDataPusher::ManageOneEvent() (not ready) complete" )));
-        return KErrNotReady;
-        }
-    if ( iEventIndex < 0 ||
-         iEventIndex >= iEventQueue.Count() )
-        {
-        FTRACE(FPrint( _L("CDunDataPusher::ManageOneEvent() (buffer mismatch) complete" )));
-        return KErrGeneral;
-        }
-    const TDesC8* dataToPush = iEventQueue[iEventIndex].iDataToPush;
-    if ( iComm )
-        {
-        iStatus = KRequestPending;
-        iComm->Write( iStatus, *dataToPush );
-        FTRACE(FPrint( _L("CDunDataPusher::ManageOneEvent() RComm Write() requested (buffer=0x%08X)" ), dataToPush ));
-        }
-    else if ( iSocket )
-        {
-        iStatus = KRequestPending;
-        iSocket->Send( *dataToPush, 0, iStatus );
-        FTRACE(FPrint( _L("CDunDataPusher::ManageOneEvent() RSocket Send() requested (buffer=0x%08X)" ), dataToPush ));
-        }
-    else
-        {
-        FTRACE(FPrint( _L("CDunDataPusher::ManageOneEvent() (ERROR) complete" )));
-        return KErrGeneral;
-        }
-    SetActive();
-    FTRACE(FPrint( _L("CDunDataPusher::ManageOneEvent() complete" )));
-    return KErrNone;
-    }
-
-// ---------------------------------------------------------------------------
-// Check whether an error code is severe error or not
-// ---------------------------------------------------------------------------
-//
-TInt CDunDataPusher::ProcessErrorCondition( TInt aError, TBool& aIsError )
-    {
-    FTRACE(FPrint( _L("CDunDataPusher::ProcessErrorCondition() (Dir=%d)" ), EDunWriterDownstream));
-    aIsError = EFalse;
-    if ( aError != KErrNone )
-        {
-        aIsError = ETrue;
-        TInt retTemp = iParent.iOkErrorsW.Find( aError );
-        if ( retTemp == KErrNotFound )
-            {
-            FTRACE(FPrint( _L("CDunDataPusher::ProcessErrorCondition() (Dir=%d) (%d=ETrue) complete" ), EDunWriterDownstream, aError));
-            return ETrue;
-            }
-        }
-    FTRACE(FPrint( _L("CDunDataPusher::ProcessErrorCondition() (Dir=%d) (%d=EFalse) complete" ), EDunWriterDownstream, aError));
-    return EFalse;
-    }
-
-// ---------------------------------------------------------------------------
-// From class CActive.
-// Gets called when endpoint data write complete
-// ---------------------------------------------------------------------------
-//
-void CDunDataPusher::RunL()
-    {
-    FTRACE(FPrint( _L("CDunDataPusher::RunL() (buffer=0x%08X)" ), iEventQueue[iEventIndex].iDataToPush ));
-
-    TBool isError;
-    TInt retTemp = iStatus.Int();
-    TInt stop = ProcessErrorCondition( retTemp, isError );
-
-    if ( !stop )  // no real error detected -> continue
-        {
-        if ( !isError )
-            {
-            iEventIndex++;
-            }
-        if ( iEventIndex < iEventQueue.Count() )
-            {
-            // More to serve so start again
-            ManageOneEvent();
-            }
-        else
-            {
-            // Last was served so stop processing and notify
-            iPushState = EDunStateIdle;
-            iStreamCallback->NotifyDataPushComplete( ETrue );
-            }
-        }  // if ( !stop )
-    else  // stop -> tear down connection
-        {
-        TDunConnectionReason connReason;
-        connReason.iReasonType = EDunReasonTypeRW;
-        connReason.iContext = EDunMediaContextLocal;
-        connReason.iSignalType = 0;
-        connReason.iSignalHigh = EFalse;
-        connReason.iDirection = EDunWriterDownstream;
-        connReason.iErrorCode = retTemp;
-        iParent.iUtility->DoNotifyConnectionNotOk( iComm,
-                                                   iSocket,
-                                                   connReason,
-                                                   iParent.iCallbacksW );
-        }  // else
-
-    FTRACE(FPrint( _L("CDunDataPusher::RunL() complete" )));
-    }
-
-// ---------------------------------------------------------------------------
-// From class CActive.
-// Gets called on cancel
-// ---------------------------------------------------------------------------
-//
-void CDunDataPusher::DoCancel()
-    {
-    FTRACE(FPrint( _L("CDunDataPusher::DoCancel()" )));
-    if ( iComm )
-        {
-        iComm->WriteCancel();
-        FTRACE(FPrint( _L("CDunDataPusher::DoCancel() (RComm) cancelled" )));
-        }
-    else if ( iSocket )
-        {
-        iSocket->CancelWrite();
-        FTRACE(FPrint( _L("CDunDataPusher::DoCancel() (RSocket) cancelled" )));
-        }
-    FTRACE(FPrint( _L("CDunDataPusher::DoCancel() complete" )));
-    }