/*

* Copyright (c) 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: S60 MCPR mobility activity implementation

*

*/

/**

@file s60mcprmobilityactivity.cpp

S60 MCPR mobility activity implementation

*/

#include "s60mcpractivities.h"

#include "s60mcprstates.h"

using namespace Messages;

using namespace MeshMachine;

using namespace ESock;

// -----------------------------------------------------------------------------

// S60MCprMobilityActivity

// -----------------------------------------------------------------------------

//

namespace S60MCprMobilityActivity

    {

    // -----------------------------------------------------------------------------

    // S60MCprMobilityActivity::TDoNothingOrReSendPendingNotification::DoL

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( TDoNothingOrReSendPendingNotification, NetStateMachine::MStateTransition, TContext )

    void TDoNothingOrReSendPendingNotification::DoL()

        {

        S60MCPRLOGSTRING1("S60MCPR<%x>::TDoNothingOrReSendPendingNotification::DoL()",(TInt*)&iContext.Node())

        __ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KS60MCprPanic, KPanicNoActivity));

        CS60MetaConnectionProvider& node = (CS60MetaConnectionProvider&)iContext.Node();

        // Process the pending request first.

        //

        node.ReSendPolicyNotification();

        node.ClearPolicyNotification();

        }

    // -----------------------------------------------------------------------------

    // S60MCprMobilityActivity::TReplyMobilityStarted::DoL

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( TReplyMobilityStarted, NetStateMachine::MStateTransition, TContext )

    void TReplyMobilityStarted::DoL()

        {

        S60MCPRLOGSTRING1("S60MCPR<%x>::TReplyMobilityStarted::DoL()",(TInt*)&iContext.Node())

        __ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KS60MCprPanic, KPanicNoActivity));

        iContext.iNodeActivity->PostToOriginators( TCFMobilityProvider::TMobilityStarted().CRef() );

        iContext.iNodeActivity->ClearPostedTo();

        }

    // -----------------------------------------------------------------------------

    // S60MCprMobilityActivity::TSendAvailabilityRequest::DoL

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( TSendAvailabilityRequest, NetStateMachine::MStateTransition, TContext )

    void TSendAvailabilityRequest::DoL()

        {

        S60MCPRLOGSTRING1("S60MCPR<%x>::TSendAvailabilityRequest::DoL()", (TInt*)&iContext.Node())

        CS60MetaConnectionProvider& node = (CS60MetaConnectionProvider&)iContext.Node();

        node.Policy()->RegisterPreferredIAPNotificationL();

        }

    // -----------------------------------------------------------------------------

    // S60MCprMobilityActivity::TSendInitialApplicationReject::DoL

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( TSendInitialApplicationReject, 

                      NetStateMachine::MStateTransition, 

                      TContext )

    void TSendInitialApplicationReject::DoL()

        {

        S60MCPRLOGSTRING1("S60MCPR<%x>::TSendInitialApplicationReject::DoL()", (TInt*)&iContext.Node())

        CS60MetaConnectionProvider& node = (CS60MetaConnectionProvider&)iContext.Node();

        RMetaServiceProviderInterface* sp = NULL;

        // Set service provider to point to active service provider.

        sp = (RMetaServiceProviderInterface*) node.ServiceProvider();

        TInt iapid = sp ? sp->ProviderInfo().APId() : 0;

        node.Policy()->ApplicationRejectedTheCarrierL( iapid );

        }

    // -----------------------------------------------------------------------------

    // S60MCprMobilityActivity::TAwaitingStartMobility::Accept

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( TAwaitingStartMobility, NetStateMachine::MState, TContext )

    TBool TAwaitingStartMobility::Accept()

        {

        if (!iContext.iMessage.IsMessage<TCFMobilityProvider::TStartMobility>())

            {

            return EFalse;

            }

        if (iContext.Node().ServiceProvider()==NULL)

            {

            S60MCPRLOGSTRING1("S60MCPR<%x>::TAwaitingStartMobility::Accept() no Provider!",(TInt*)&iContext.Node())

            //There is no mobility on the lowest layer of the stack

            iContext.iMessage.ClearMessageId();

            return EFalse;

            }

        S60MCPRLOGSTRING1("S60MCPR<%x>::TAwaitingStartMobility::Accept()", (TInt*)&iContext.Node() );

        return ETrue;

        }

    // -----------------------------------------------------------------------------

    // S60MCprMobilityActivity::TAwaitingMigrationRequestedOrRejectedOrCancel::Accept

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( TAwaitingMigrationRequestedOrRejectedOrCancel, 

                      NetStateMachine::MState, TContext )

    TBool TAwaitingMigrationRequestedOrRejectedOrCancel::Accept()

        {

        S60MCPRLOGSTRING1("S60MCPR<%x>::TAwaitingMigrationRequestedOrRejectedOrCancel::Accept()", 

                (TInt*)&iContext.Node())

        return (iContext.iMessage.IsMessage<TCFMobilityProvider::TMigrationRequested>()) ||

               (iContext.iMessage.IsMessage<TCFMobilityProvider::TMigrationRejected>()) ||

               (iContext.iMessage.IsMessage<TEBase::TCancel>());

//               (iContext.iMessage.IsMessage<TEBase::TError>());

        }

    // -----------------------------------------------------------------------------

    // S60MCprMobilityActivity::TAwaitingMigrationAcceptedOrRejectedOrStartupErrorIgnoredOrCancel::Accept

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( TAwaitingMigrationAcceptedOrRejectedOrStartupErrorIgnoredOrCancel, NetStateMachine::MState, TContext )

    TBool TAwaitingMigrationAcceptedOrRejectedOrStartupErrorIgnoredOrCancel::Accept()

        {

        if ( (iContext.iMessage.IsMessage<TCFMobilityProvider::TMigrationAccepted>()) ||

             (iContext.iMessage.IsMessage<TCFMobilityProvider::TMigrationRejected>()) ||

             (iContext.iMessage.IsMessage<TCFS60MCPRMessage::TMPMStartupErrorIgnoredMsg>()) ||

             (iContext.iMessage.IsMessage<TEBase::TCancel>()) )

            {

            S60MCPRLOGSTRING1("S60MCPR<%x>::TAwaitingMigrationAcceptedOrRejectedOrStartupErrorIgnoredOrCancel::Accept()",(TInt*)&iContext.Node())

            return ETrue;

            }

        return EFalse;

        }

    // -----------------------------------------------------------------------------

    // S60MCprMobilityActivity::TAwaitingMigrationRejected::Accept

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( TAwaitingMigrationRejected, NetStateMachine::MState, TContext )

    TBool TAwaitingMigrationRejected::Accept()

        {

        if ( iContext.iMessage.IsMessage<TCFMobilityProvider::TMigrationRejected>() )

            {

            S60MCPRLOGSTRING1("S60MCPR<%x>::TAwaitingMigrationRejected::Accept()",(TInt*)&iContext.Node())

            return ETrue;

            }

        return EFalse;

        }

    // -----------------------------------------------------------------------------

    // S60MCprMobilityActivity::TNoTagOrInformMigrationAvailableBackwardsOrErrorOrCancel::TransitionTag

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( TNoTagOrInformMigrationAvailableBackwardsOrErrorOrCancel, NetStateMachine::MStateFork, TContext )

    TBool TNoTagOrInformMigrationAvailableBackwardsOrErrorOrCancel::TransitionTag()

        {

        // Error notification falls into the error -case.

        if ( iContext.iNodeActivity->Error() ) 

            {

            S60MCPRLOGSTRING1("S60MCPR<%x>::TNoTagOrInformMigrationAvailableBackwardsOrErrorOrCancel::TransitionTag() Error",(TInt*)&iContext.Node());    

            return MeshMachine::KErrorTag | NetStateMachine::EForward;

            }

        if ( iContext.iMessage.IsMessage<TCFS60MCPRMessage::TMPMStartIAPNotificationMsg>() ) 

            {

            S60MCPRLOGSTRING1("S60MCPR<%x>::TNoTagOrInformMigrationAvailableBackwardsOrErrorOrCancel::TransitionTag() TMPMStartIAPNotificationMsg",(TInt*)&iContext.Node())    

            return KNoTag | NetStateMachine::EForward;

            }

        if ( iContext.iMessage.IsMessage<TCFS60MCPRMessage::TMPMPreferredCarrierAvailableMsg>() )

            {

            S60MCPRLOGSTRING1("S60MCPR<%x>::TNoTagOrInformMigrationAvailableBackwardsOrErrorOrCancel::TransitionTag() TMPMPreferredCarrierAvailableMsg",(TInt*)&iContext.Node())    

            return S60MCprStates::KInformMigrationAvailable | NetStateMachine::EBackward;

        // else cancel

        return KCancelTag | NetStateMachine::EForward;

        }

    // -----------------------------------------------------------------------------

    // S60MCprMobilityActivity::TStartMobilityHandshakeBackwardsOrError::TransitionTag

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( TStartMobilityHandshakeBackwardsOrError, NetStateMachine::MStateFork, TContext )

    TBool TStartMobilityHandshakeBackwardsOrError::TransitionTag()

        {

        if ( iContext.iNodeActivity->Error() )

            {

            S60MCPRLOGSTRING1("S60MCPR<%x>::TStartMobilityHandshakeBackwardsOrError::TransitionTag() KErrorTag",(TInt*)&iContext.Node())

            return MeshMachine::KErrorTag | NetStateMachine::EForward;

            }

        S60MCPRLOGSTRING1("S60MCPR<%x>::TStartMobilityHandshakeBackwardsOrError::TransitionTag() KStartMobilityHandshake",(TInt*)&iContext.Node())

        return MobilityMCprStates::KStartMobilityHandshake | NetStateMachine::EBackward;

        }

    // -----------------------------------------------------------------------------

    // S60MCprMobilityActivity::TInformMigrationAvailableOrCancelTag::TransitionTag

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( TInformMigrationAvailableOrCancelTag, NetStateMachine::MStateFork, TContext )

    TBool TInformMigrationAvailableOrCancelTag::TransitionTag()

        {

        if ( iContext.iMessage.IsMessage<TEBase::TCancel>() )

            {

            S60MCPRLOGSTRING1("S60MCPR<%x>::TInformMigrationAvailableOrCancelTag::TransitionTag() KCancelTag",(TInt*)&iContext.Node())

            return KCancelTag | NetStateMachine::EForward;

            }

        else if ( iContext.iMessage.IsMessage<TCFMobilityProvider::TMigrationRejected>() )

            {

            S60MCPRLOGSTRING1("S60MCPR<%x>::TInformMigrationAvailableOrCancelTag::TransitionTag() KSendInitialApplicationReject",

                    (TInt*)&iContext.Node())

            return S60MCprStates::KSendInitialApplicationReject | NetStateMachine::EForward;

            }

        else

            {

            S60MCPRLOGSTRING1("S60MCPR<%x>::TInformMigrationAvailableOrCancelTag::TransitionTag() KInformMigrationAvailable",(TInt*)&iContext.Node())

            return S60MCprStates::KInformMigrationAvailable | NetStateMachine::EForward;

            }

        }

    // -----------------------------------------------------------------------------

    // S60MCprMobilityActivity::TNoTagOrErrorTagOrApplicationRejectedOrConsumeRejected::TransitionTag

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( TNoTagOrErrorTagOrApplicationRejectedOrConsumeRejected, NetStateMachine::MStateFork, TContext )

    TBool TNoTagOrErrorTagOrApplicationRejectedOrConsumeRejected::TransitionTag()

        {

        if ( iContext.iNodeActivity->Error() )

            {

            S60MCPRLOGSTRING1("S60MCPR<%x>::TNoTagOrErrorTagOrApplicationRejectedOrConsumeRejected::TransitionTag() KErrorTag",(TInt*)&iContext.Node())

            return MeshMachine::KErrorTag | NetStateMachine::EForward;

            }

        if ( message_cast<TCFMobilityProvider::TMigrationAccepted>(&iContext.iMessage) )

            {

            S60MCPRLOGSTRING1("S60MCPR<%x>::TNoTagOrErrorTagOrApplicationRejectedOrConsumeRejected::TransitionTag() KNoTag",(TInt*)&iContext.Node())

            return MeshMachine::KNoTag | NetStateMachine::EForward;

            }

        else if ( message_cast<TCFMobilityProvider::TMigrationRejected>(&iContext.iMessage) )

            {

            S60MCPRLOGSTRING1("S60MCPR<%x>::TNoTagOrErrorTagOrApplicationRejectedOrConsumeRejected::TransitionTag() KApplicationRejectedMigration",(TInt*)&iContext.Node())

            return S60MCprStates::KApplicationRejectedMigration | NetStateMachine::EForward; 

            }

        else if ( message_cast<TCFS60MCPRMessage::TMPMStartupErrorIgnoredMsg>(&iContext.iMessage) )

            {

            S60MCPRLOGSTRING1("S60MCPR<%x>::TNoTagOrErrorTagOrApplicationRejectedOrConsumeRejected::TransitionTag() KSwallowRejectedMsg",(TInt*)&iContext.Node())

            return S60MCprStates::KConsumeRejectedMsg | NetStateMachine::EForward; 

            }

        else

            {

            S60MCPRLOGSTRING1("S60MCPR<%x>::TNoTagOrErrorTagOrApplicationRejectedOrConsumeRejected::TransitionTag() KCancelTag",(TInt*)&iContext.Node())

            return MeshMachine::KCancelTag | NetStateMachine::EForward;

            }

        }

    // -----------------------------------------------------------------------------

    // S60MCprMobilityActivity::TWaitPolicyServerResponseBackwardOrErrorTag::TransitionTag

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( TWaitPolicyServerResponseBackwardOrErrorTag, NetStateMachine::MStateFork, TContext )

    TBool TWaitPolicyServerResponseBackwardOrErrorTag::TransitionTag()

        {

        if ( iContext.iMessage.IsMessage<TCFS60MCPRMessage::TMPMProcessErrorCompletedMsg>() )

            {

            // Make sure policy server doesn't say, reselect.

            ASSERT( message_cast<TCFS60MCPRMessage::TMPMProcessErrorCompletedMsg>(&iContext.iMessage)->iValue !=

                    (TInt)EDoReselection );

            // Make sure we're are no longer in error state.

            iContext.iNodeActivity->SetError( KErrNone );

            S60MCPRLOGSTRING1("S60MCPR<%x>::TWaitPolicyServerResponseBackwardOrErrorTag::TransitionTag() KWaitPolicyServerResponse",(TInt*)&iContext.Node())

            return S60MCprStates::KWaitPolicyServerResponse | NetStateMachine::EBackward;

            }

        else

            {

            S60MCPRLOGSTRING1("S60MCPR<%x>::TWaitPolicyServerResponseBackwardOrErrorTag::TransitionTag() KErrorTag",(TInt*)&iContext.Node())

            return MeshMachine::KErrorTag | NetStateMachine::EForward;

            }

        }

    // -----------------------------------------------------------------------------

    // CS60MobilityActivity::NewL

    // -----------------------------------------------------------------------------

    //

    MeshMachine::CNodeActivityBase* CS60MobilityActivity::NewL( const MeshMachine::TNodeActivity& aActivitySig, 

                                                                       MeshMachine::AMMNodeBase& aNode )

        {

        CS60MobilityActivity* self = new(ELeave) CS60MobilityActivity( aActivitySig, aNode );

        return self;

        }

    // -----------------------------------------------------------------------------

    // CS60MobilityActivity::CS60MobilityActivity

    // -----------------------------------------------------------------------------

    //

    CS60MobilityActivity::CS60MobilityActivity( const MeshMachine::TNodeActivity& aActivitySig, 

                                                MeshMachine::AMMNodeBase& aNode )

        :   S60MCprStates::CS60ErrorRecoveryActivity( aActivitySig, aNode )

        {}

    // -----------------------------------------------------------------------------

    // CS60MobilityActivity::TInformMigrationAvailableAndSetHandshakingFlag::DoL

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( CS60MobilityActivity::TInformMigrationAvailableAndSetHandshakingFlag, 

                      NetStateMachine::MStateTransition, 

                      CS60MobilityActivity::TContext )

    void CS60MobilityActivity::TInformMigrationAvailableAndSetHandshakingFlag::DoL()

        {

        S60MCPRLOGSTRING1("S60MCPR<%x>::TInformMigrationAvailableAndSetHandshakingFlag::DoL()",(TInt*)&iContext.Node())

        __ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KS60MCprPanic, KPanicNoActivity));

        CS60MobilityActivity& activity = static_cast<CS60MobilityActivity&>(*iContext.iNodeActivity);

        //Inform the CPR that a potential migration is available. We only support a single data client

        //in this implementation.

        __ASSERT_DEBUG(activity.iPreferredAPId, User::Panic(KS60MCprPanic, KPanicNoServiceProvider));

        // Activity received the necessary information from the policy server earlier 

        // and now holds that information which we'll send to IPCPR.

        TCFMobilityControlClient::TMigrationNotification msg( activity.iCurrentAssumedAPId,

                                                              //activity.iCurrent->ProviderInfo().APId(),

                                                              activity.iPreferredAPId,

                                                              activity.iIsUpgrade, 

                                                              activity.iIsSeamless );

        activity.PostToOriginators(msg);

        activity.ClearPostedTo();

        activity.SetHandshakingFlag();

        }

    // -----------------------------------------------------------------------------

    // CS60MobilityActivity::TSendMigrationRejected::DoL

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( CS60MobilityActivity::TSendMigrationRejected, 

                      NetStateMachine::MStateTransition, 

                      CS60MobilityActivity::TContext )

    void CS60MobilityActivity::TSendMigrationRejected::DoL()

        {

        S60MCPRLOGSTRING1("S60MCPR<%x>::TSendMigrationRejected::DoL()",(TInt*)&iContext.Node())

        CS60MetaConnectionProvider& node = (CS60MetaConnectionProvider&)iContext.Node();

        CS60MobilityActivity& activity = static_cast<CS60MobilityActivity&>(*iContext.iNodeActivity);

        node.Policy()->ApplicationIgnoredTheCarrierL( activity.iPreferredAPId );

        }

    // -----------------------------------------------------------------------------

    // CS60MobilityActivity::TSendMigrationAccepted::DoL

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( CS60MobilityActivity::TSendMigrationAccepted, 

                      NetStateMachine::MStateTransition, 

                      CS60MobilityActivity::TContext )

    void CS60MobilityActivity::TSendMigrationAccepted::DoL()

        {

        S60MCPRLOGSTRING1("S60MCPR<%x>::TSendMigrationAccepted::DoL()",(TInt*)&iContext.Node())

        CS60MetaConnectionProvider& node = (CS60MetaConnectionProvider&)iContext.Node();

        CS60MobilityActivity& activity = static_cast<CS60MobilityActivity&>(*iContext.iNodeActivity);

        node.Policy()->ApplicationMigratesToCarrierL( activity.iPreferredAPId );

        }

    // -----------------------------------------------------------------------------

    // CS60MobilityActivity::TSendApplicationAccept::DoL

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( CS60MobilityActivity::TSendApplicationAccept, 

                      NetStateMachine::MStateTransition, 

                      CS60MobilityActivity::TContext )

    void CS60MobilityActivity::TSendApplicationAccept::DoL()

        {

        S60MCPRLOGSTRING1("S60MCPR<%x>::TSendApplicationAccept::DoL()",(TInt*)&iContext.Node())

        CS60MetaConnectionProvider& node = (CS60MetaConnectionProvider&)iContext.Node();

        CS60MobilityActivity& activity = static_cast<CS60MobilityActivity&>(*iContext.iNodeActivity);

        node.Policy()->ApplicationAcceptedTheCarrierL( activity.iPreferredAPId );

        }

    // -----------------------------------------------------------------------------

    // CS60MobilityActivity::TSendApplicationReject::DoL

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( CS60MobilityActivity::TSendApplicationReject, 

                      NetStateMachine::MStateTransition, 

                      CS60MobilityActivity::TContext )

    void CS60MobilityActivity::TSendApplicationReject::DoL()

        {

        S60MCPRLOGSTRING1("S60MCPR<%x>::TSendApplicationReject::DoL()",(TInt*)&iContext.Node())

        CS60MetaConnectionProvider& node = (CS60MetaConnectionProvider&)iContext.Node();

        CS60MobilityActivity& activity = static_cast<CS60MobilityActivity&>(*iContext.iNodeActivity);

        node.Policy()->ApplicationRejectedTheCarrierL( activity.iPreferredAPId );

        }

    // -----------------------------------------------------------------------------

    // CS60MobilityActivity::TClearHandshakingFlag::DoL

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( CS60MobilityActivity::TClearHandshakingFlag, 

                      NetStateMachine::MStateTransition, CS60MobilityActivity::TContext )

    void CS60MobilityActivity::TClearHandshakingFlag::DoL()

        {

        S60MCPRLOGSTRING1("S60MCPR<%x>::TClearHandshakingFlag::DoL()",(TInt*)&iContext.Node())

        __ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KS60MCprPanic, KPanicNoActivity));

        CS60MobilityActivity& activity = static_cast<CS60MobilityActivity&>(*iContext.iNodeActivity);

        activity.ClearHandshakingFlag();

        }

    // -----------------------------------------------------------------------------

    // CS60MobilityActivity::TInformMigrationCompleted::DoL

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( CS60MobilityActivity::TInformMigrationCompleted, 

                      NetStateMachine::MStateTransition, CS60MobilityActivity::TContext )

    void CS60MobilityActivity::TInformMigrationCompleted::DoL()

        {

        S60MCPRLOGSTRING1("S60MCPR<%x>::TInformMigrationCompleted::DoL()",(TInt*)&iContext.Node())

        __ASSERT_DEBUG(iContext.iNodeActivity, User::Panic(KS60MCprPanic, KPanicNoActivity));

        iContext.iNodeActivity->PostToOriginators(TCFMobilityProvider::TMigrationComplete().CRef());

        iContext.iNodeActivity->ClearPostedTo();

        }

    // -----------------------------------------------------------------------------

    // CS60MobilityActivity::TCancelMobilityActivity::DoL

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( CS60MobilityActivity::TCancelMobilityActivity, 

                      NetStateMachine::MStateTransition, CS60MobilityActivity::TContext )

    void CS60MobilityActivity::TCancelMobilityActivity::DoL()

        {

        S60MCPRLOGSTRING1("S60MCPR<%x>::TCancelAvailabilityRequest::DoL()",(TInt*)&iContext.Node())

        CS60MetaConnectionProvider& node = (CS60MetaConnectionProvider&)iContext.Node();

        // Unregister from preferred IAP Notifications.

        //

        node.Policy()->UnregisterPreferredIAPNotificationL();

        // Clear the mobility handshaking flag.

        // 

        CS60MobilityActivity& activity = static_cast<CS60MobilityActivity&>(*iContext.iNodeActivity);

        activity.ClearHandshakingFlag();

        // At last we must set the activity in error since we're ready to go down.

        //

        iContext.iNodeActivity->SetError( KErrCancel );

        }

    // -----------------------------------------------------------------------------

    // CS60MobilityActivity::TErrorOriginatorAndStopDataClient::DoL

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( CS60MobilityActivity::TErrorOriginatorAndStopDataClient, 

                      NetStateMachine::MStateTransition, CS60MobilityActivity::TContext )

    void CS60MobilityActivity::TErrorOriginatorAndStopDataClient::DoL()

        {

		// Post error to originators

		TEBase::TError errmsg(TCFMobilityProvider::TStartMobility::Id(), iContext.iNodeActivity->Error());

		iContext.iNodeActivity->PostToOriginators(errmsg);

		RNodeInterface* dc = iContext.Node().GetFirstClient<TDefaultClientMatchPolicy>(TClientType(TCFClientType::EData),

			TClientType(TCFClientType::EData, TCFClientType::ELeaving));

		iContext.iNodeActivity->PostRequestTo(*dc, TCFDataClient::TStop(iContext.iNodeActivity->Error()).CRef());

		}

    // -----------------------------------------------------------------------------

    // CS60MobilityActivity::TAwaitingPreferredCarrierOrCancelOrRejectedOrErrorNotification::Accept

    // -----------------------------------------------------------------------------

    //

    DEFINE_SMELEMENT( CS60MobilityActivity::TAwaitingPreferredCarrierOrCancelOrRejectedOrErrorNotification, 

                      NetStateMachine::MState, TContext )

    TBool CS60MobilityActivity::TAwaitingPreferredCarrierOrCancelOrRejectedOrErrorNotification::Accept()

        {

        TBool result( EFalse );

        if ( iContext.iMessage.IsMessage<TCFS60MCPRMessage::TMPMPreferredCarrierAvailableMsg>() )

            {

            CS60MobilityActivity& activity = static_cast<CS60MobilityActivity&>(*iContext.iNodeActivity);