diff -r 000000000000 -r 857a3e953887 nettools/conntest/Engine/alractiveobject.cpp
--- /dev/null	Thu Jan 01 00:00:00 1970 +0000
+++ b/nettools/conntest/Engine/alractiveobject.cpp	Thu Dec 17 08:39:25 2009 +0200
@@ -0,0 +1,204 @@
+/*
+* Copyright (c) 2006-2009 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: conntest application
+*
+*/
+
+/**
+@file alractiveobject.cpp
+ALR application active object.
+*/
+
+// INCLUDE FILES
+#include <e32cons.h>
+#include <comms-infras/mobilitymessagesecom.h>
+#include <mobilitymessages.h>
+#include "alractiveobject.h"
+#include "uinotify.h"
+
+using namespace ESock;
+
+const TInt KCommsMobilityMaxMsgLength = 256;  //Max mobility message size is much less than that
+
+// ============================ MEMBER FUNCTIONS ===============================
+
+// -----------------------------------------------------------------------------
+// CALRActiveObject::NewL
+// -----------------------------------------------------------------------------
+//
+CALRActiveObject* CALRActiveObject::NewL(
+            MUINotify& aConsole, 
+            MMobilityProtocolResp* aApplication)
+    {
+    CALRActiveObject* self =
+        new ( ELeave ) CALRActiveObject(aConsole, aApplication);
+    CleanupStack::PushL( self );
+    self->ConstructL(aConsole);
+    CleanupStack::Pop( self );
+    return self;
+    }
+
+// -----------------------------------------------------------------------------
+// CALRActiveObject::ConstructL
+// -----------------------------------------------------------------------------
+//
+void CALRActiveObject::ConstructL(MUINotify& /*aConsole*/)
+    {
+    iResponseBuf.CreateL( KCommsMobilityMaxMsgLength );
+    }
+
+// -----------------------------------------------------------------------------
+// CALRActiveObject::CALRActiveObject
+// -----------------------------------------------------------------------------
+//
+CALRActiveObject::CALRActiveObject(MUINotify& aConsole, MMobilityProtocolResp* aApplication ) 
+    : CActive( CActive::EPriorityStandard ),
+    iConsole(aConsole), iApplication(aApplication)
+    {
+    CActiveScheduler::Add( this );
+    }
+
+// -----------------------------------------------------------------------------
+// CALRActiveObject::~CALRActiveObject
+// -----------------------------------------------------------------------------
+//
+CALRActiveObject::~CALRActiveObject()
+    {
+    Cancel();
+	iExtApi.Close();
+	iResponseBuf.Close();
+    }
+
+// -----------------------------------------------------------------------------
+// CALRActiveObject::OpenL
+// -----------------------------------------------------------------------------
+//
+void CALRActiveObject::OpenL( RCommsSubSession& aExtensionProvider )
+    {
+    User::LeaveIfError( iExtApi.Open( aExtensionProvider ) );
+    
+    //iConsole.PrintNotify(_L("\r\nRegister for mobility notification "));
+
+    iExtApi.RegisterForMobilityNotification( iResponseBuf, iStatus );
+    
+    //iConsole.PrintNotify(_L("\r\nRegistration successful "));
+
+    SetActive();
+    }
+
+// -----------------------------------------------------------------------------
+// CALRActiveObject::MigrateToPreferredCarrier
+// -----------------------------------------------------------------------------
+//
+void CALRActiveObject::MigrateToPreferredCarrier()
+	{
+	iExtApi.MigrateToPreferredCarrier();
+	}
+
+// -----------------------------------------------------------------------------
+// CALRActiveObject::IgnorePreferredCarrier
+// -----------------------------------------------------------------------------
+//
+void CALRActiveObject::IgnorePreferredCarrier()
+	{
+    iExtApi.IgnorePreferredCarrier();
+	}
+
+// -----------------------------------------------------------------------------
+// CALRActiveObject::NewCarrierAccepted
+// -----------------------------------------------------------------------------
+//
+void CALRActiveObject::NewCarrierAccepted()
+	{
+    iExtApi.NewCarrierAccepted();
+	}
+
+// -----------------------------------------------------------------------------
+// CALRActiveObject::NewCarrierRejected
+// -----------------------------------------------------------------------------
+//
+void CALRActiveObject::NewCarrierRejected()
+	{
+    iExtApi.NewCarrierRejected();
+	}
+
+// -----------------------------------------------------------------------------
+// CALRActiveObject::RunL
+// -----------------------------------------------------------------------------
+//
+void CALRActiveObject::RunL()
+    {
+    if( iStatus != KErrNone )
+        { 
+      //  iConsole.Printf(_L("\niStatus: %i\n"), iStatus.Int() );
+        iApplication->Error( iStatus.Int() );
+//          virtual void Error(TInt aError) = 0;
+
+        return;
+        }
+
+	//iConsole.PrintNotify(_L("\r\nReceived notification"));
+    CCommsApiExtensionMsg* msg = CCommsApiExtensionMsg::NewL( iResponseBuf );
+
+    //check types
+    STypeId preferredCarrierAvailableTID  = STypeId::CreateSTypeId( ESock::KMobilityMessagesImplementationUid, ESock::EPreferredCarrierAvailable );
+    STypeId newCarrierActiveTID = STypeId::CreateSTypeId( ESock::KMobilityMessagesImplementationUid, ESock::ENewCarrierActive );
+    
+    if (msg->IsTypeOf(preferredCarrierAvailableTID))
+        {
+        CPreferredCarrierAvailable& pca = reinterpret_cast<CPreferredCarrierAvailable&>( *msg );
+        iApplication->PreferredCarrierAvailable( pca.OldAPInfo(),
+                                                pca.NewAPInfo(),
+                                                pca.IsUpgrade(),
+                                                pca.IsSeamless() );         
+//        virtual void PreferredCarrierAvailable(TAccessPointInfo aOldAP, TAccessPointInfo aNewAP, TBool aIsUpgrade, TBool aIsSeamless) = 0;
+
+        //MigrateToPreferredCarrier();
+        }
+    else if (msg->IsTypeOf(newCarrierActiveTID))
+        {
+        CNewCarrierActive& nca = reinterpret_cast<CNewCarrierActive&>( *msg );
+        iApplication->NewCarrierActive( nca.NewAPInfo(), nca.IsSeamless() );
+//        virtual void NewCarrierActive(TAccessPointInfo aNewAP, TBool aIsSeamless) = 0;
+      	//NewCarrierAccepted();
+        }
+  
+    delete msg;
+
+    iExtApi.RegisterForMobilityNotification( iResponseBuf, iStatus );
+
+    SetActive();
+    }
+
+// -----------------------------------------------------------------------------
+// CALRActiveObject::DoCancel
+// -----------------------------------------------------------------------------
+//
+void CALRActiveObject::DoCancel()
+    {
+    iExtApi.CancelMobilityNotification();
+    }
+
+// -----------------------------------------------------------------------------
+// CALRActiveObject::RunError
+// -----------------------------------------------------------------------------
+//
+TInt CALRActiveObject::RunError(TInt aError)
+    {
+    //The notification has not been sent to the client because of KErrNoMemory
+    //We may need to provide an inplace construction for the messages to exclude this possibility.
+    return aError;
+    }
+
+//  End of File