--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/localconnectivityservice/dun/atext/src/DunAtUrcHandler.cpp	Mon Jan 18 21:03:15 2010 +0200
@@ -0,0 +1,228 @@
+/*
+* Copyright (c) 2008 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:  AT command URC handler
+*
+*/
+
+
+#include <atext.h>
+#include "DunAtCmdHandler.h"
+#include "DunAtUrcHandler.h"
+#include "DunDownstream.h"
+#include "DunDebug.h"
+
+// ---------------------------------------------------------------------------
+// Two-phased constructor.
+// ---------------------------------------------------------------------------
+//
+CDunAtUrcHandler* CDunAtUrcHandler::NewL(
+    RATExt* aAtCmdExt,
+    MDunStreamManipulator* aStreamCallback )
+    {
+    CDunAtUrcHandler* self = NewLC( aAtCmdExt, aStreamCallback );
+    CleanupStack::Pop( self );
+    return self;
+    }
+
+// ---------------------------------------------------------------------------
+// Two-phased constructor.
+// ---------------------------------------------------------------------------
+//
+CDunAtUrcHandler* CDunAtUrcHandler::NewLC(
+    RATExt* aAtCmdExt,
+    MDunStreamManipulator* aStreamCallback )
+    {
+    CDunAtUrcHandler* self = new (ELeave) CDunAtUrcHandler( aAtCmdExt,
+                                                            aStreamCallback );
+    CleanupStack::PushL( self );
+    self->ConstructL();
+    return self;
+    }
+
+// ---------------------------------------------------------------------------
+// Destructor.
+// ---------------------------------------------------------------------------
+//
+CDunAtUrcHandler::~CDunAtUrcHandler()
+    {
+    FTRACE(FPrint( _L("CDunAtUrcHandler::~CDunAtUrcHandler()") ));
+    ResetData();
+    FTRACE(FPrint( _L("CDunAtUrcHandler::~CDunAtUrcHandler() complete") ));
+    }
+
+// ---------------------------------------------------------------------------
+// Resets data to initial values
+// ---------------------------------------------------------------------------
+//
+void CDunAtUrcHandler::ResetData()
+    {
+    FTRACE(FPrint( _L("CDunAtUrcHandler::ResetData()") ));
+    // APIs affecting this:
+    // IssueRequest()
+    Stop();
+    // Don't close iAtCmdExt here (it is done in CDunAtCmdHandler)!
+    // Internal
+    Initialize();
+    FTRACE(FPrint( _L("CDunAtUrcHandler::ResetData() complete") ));
+    }
+
+// ---------------------------------------------------------------------------
+// Starts waiting for an incoming URC message
+// ---------------------------------------------------------------------------
+//
+TInt CDunAtUrcHandler::IssueRequest()
+    {
+    FTRACE(FPrint( _L("CDunAtUrcHandler::IssueRequest()") ));
+    if ( iUrcHandleState != EDunStateIdle )
+        {
+        FTRACE(FPrint( _L("CDunAtUrcHandler::IssueRequest() (not ready) complete") ));
+        return KErrNotReady;
+        }
+    iStatus = KRequestPending;
+    iAtCmdExt->ReceiveUnsolicitedResult( iStatus, iRecvBuffer, iOwnerUidPckg );
+    SetActive();
+    iUrcHandleState = EDunStateAtUrcHandling;
+    // Next mark ownership
+    if ( !iStarted )
+        {
+        TInt retTemp = iAtCmdExt->MarkUrcHandlingOwnership( iOwnerUid );
+        if ( retTemp != KErrNone )
+            {
+            FTRACE(FPrint( _L("CDunAtUrcHandler::IssueRequest() (not owned) complete") ));
+            return KErrGeneral;
+            }
+        }
+    iStarted = ETrue;
+    FTRACE(FPrint( _L("CDunAtUrcHandler::IssueRequest() complete") ));
+    return KErrNone;
+    }
+
+// ---------------------------------------------------------------------------
+// Stops waiting for an incoming URC message
+// ---------------------------------------------------------------------------
+//
+TInt CDunAtUrcHandler::Stop()
+    {
+    FTRACE(FPrint( _L("CDunAtUrcHandler::Stop()") ));
+    if ( iUrcHandleState != EDunStateAtUrcHandling )
+        {
+        FTRACE(FPrint( _L("CDunAtUrcHandler::Stop() (not ready) complete" )));
+        return KErrNotReady;
+        }
+    iAtCmdExt->CancelReceiveUnsolicitedResult( iOwnerUid );
+    Cancel();
+    iUrcHandleState = EDunStateIdle;
+    FTRACE(FPrint( _L("CDunAtUrcHandler::Stop() complete") ));
+    // Note: Don't mark iStarted to EFalse here as it is used to get the UID
+    return KErrNone;
+    }
+
+// ---------------------------------------------------------------------------
+// UID of the owning plugin
+// ---------------------------------------------------------------------------
+//
+TUid CDunAtUrcHandler::OwnerUid()
+    {
+    return iOwnerUid;
+    }
+
+// ---------------------------------------------------------------------------
+// CDunAtUrcHandler::CDunAtUrcHandler
+// ---------------------------------------------------------------------------
+//
+CDunAtUrcHandler::CDunAtUrcHandler( RATExt* aAtCmdExt,
+                                    MDunStreamManipulator* aStreamCallback ) :
+    CActive( EPriorityHigh ),
+    iAtCmdExt( aAtCmdExt ),
+    iStreamCallback( aStreamCallback ),
+    iOwnerUidPckg( iOwnerUid )
+    {
+    Initialize();
+    }
+
+// ---------------------------------------------------------------------------
+// CDunAtUrcHandler::ConstructL
+// ---------------------------------------------------------------------------
+//
+void CDunAtUrcHandler::ConstructL()
+    {
+    FTRACE(FPrint( _L("CDunAtUrcHandler::ConstructL()") ));
+    if ( !iAtCmdExt || !iStreamCallback  )
+        {
+        User::Leave( KErrGeneral );
+        }
+    CActiveScheduler::Add( this );
+    FTRACE(FPrint( _L("CDunAtUrcHandler::ConstructL() complete") ));
+    }
+
+// ---------------------------------------------------------------------------
+// Initializes this class
+// ---------------------------------------------------------------------------
+//
+void CDunAtUrcHandler::Initialize()
+    {
+    // Don't initialize iStreamCallback here (it is set through NewL)
+    iUrcHandleState = EDunStateIdle;
+    iOwnerUid = TUid::Null();
+    iStarted = EFalse;
+    }
+
+// ---------------------------------------------------------------------------
+// From class CActive.
+// Gets called when URC command received
+// ---------------------------------------------------------------------------
+//
+void CDunAtUrcHandler::RunL()
+    {
+    FTRACE(FPrint( _L("CDunAtUrcHandler::RunL()") ));
+    iUrcHandleState = EDunStateIdle;
+    TInt retTemp = iStatus.Int();
+    if ( retTemp != KErrNone )
+        {
+        FTRACE(FPrint( _L("CDunAtUrcHandler::RunL() (ERROR) complete (%d)"), retTemp));
+        return;
+        }
+    if ( iRecvBuffer.Length() == 0 )
+        {
+        FTRACE(FPrint( _L("CDunAtUrcHandler::RunL() (empty buffer) complete") ));
+        return;
+        }
+
+    // Send received URC message
+
+    iStreamCallback->NotifyDataPushRequest( &iRecvBuffer, this );
+
+    FTRACE(FPrint( _L("CDunAtUrcHandler::RunL() complete") ));
+    }
+
+// ---------------------------------------------------------------------------
+// From class CActive.
+// Gets called on cancel
+// ---------------------------------------------------------------------------
+//
+void CDunAtUrcHandler::DoCancel()
+    {
+    }
+
+// ---------------------------------------------------------------------------
+// From class MDunCompletionReporter.
+// Gets called when data push is complete
+// ---------------------------------------------------------------------------
+//
+void CDunAtUrcHandler::NotifyDataPushComplete( TBool /*aAllPushed*/ )
+    {
+    FTRACE(FPrint( _L("CDunAtUrcHandler::NotifyDataPushComplete()") ));
+    IssueRequest();
+    FTRACE(FPrint( _L("CDunAtUrcHandler::NotifyDataPushComplete() complete") ));
+    }