PRActivities::CRejoinDataClientActivity Class Reference

class PRActivities::CRejoinDataClientActivity : public MeshMachine::CNodeRetryParallelActivity
Public Member Functions
~CRejoinDataClientActivity()
TContext TBoolAccept()
DECLARE_SMELEMENT_FOOTER(TRejoinDataClient)
DECLARE_SMELEMENT_FOOTER(TApplyRejoin)
DECLARE_SMELEMENT_FOOTER(TRejoinLoopTag)
DECLARE_SMELEMENT_FOOTER(TAwaitingJoinComplete)
TContext voidDoL()
EXPORT_DECLARE_SMELEMENT_HEADER(TRejoinDataClient, MeshMachine::TStateTransition< TContext >, NetStateMachine::MStateTransition, TContext)
IMPORT_C MeshMachine::CNodeActivityBase *NewL(const MeshMachine::TNodeActivity &, MeshMachine::AMMNodeBase &)
TContext virtual IMPORT_C TIntTransitionTag()
Protected Member Functions
CRejoinDataClientActivity(const MeshMachine::TNodeActivity &, TUint, MeshMachine::AMMNodeBase &)
Inherited Functions
CBase::CBase()
CBase::Delete(CBase *)
CBase::Extension_(TUint,TAny *&,TAny *)
CBase::operator new(TUint)
CBase::operator new(TUint,TAny *)
CBase::operator new(TUint,TLeave)
CBase::operator new(TUint,TLeave,TUint)
CBase::operator new(TUint,TUint)
CBase::~CBase()
MeshMachine::CNodeActivityBase::Abort(TNodeContextBase &,TBool)
MeshMachine::CNodeActivityBase::Accept(TNodeContextBase &,const TNodeActivity &,TInt)
MeshMachine::CNodeActivityBase::ActivitySigId()const
MeshMachine::CNodeActivityBase::AppendActivityL()
MeshMachine::CNodeActivityBase::AppendPreallocatedActivity()
MeshMachine::CNodeActivityBase::BorrowPreallocatedSpace(AMMNodeBase &,TUint)
MeshMachine::CNodeActivityBase::CNodeActivityBase(const TNodeActivity &,AMMNodeBase &)
MeshMachine::CNodeActivityBase::Cancel(TNodeContextBase &)
MeshMachine::CNodeActivityBase::ClearPostedTo()
MeshMachine::CNodeActivityBase::Destroy()
MeshMachine::CNodeActivityBase::DoFetchInterfaceControlL(TInt)
MeshMachine::CNodeActivityBase::Error()const
MeshMachine::CNodeActivityBase::FindOriginator(const Messages::RNodeInterface &)const
MeshMachine::CNodeActivityBase::FindOriginator(const Messages::TNodePeerId &)const
MeshMachine::CNodeActivityBase::FindOriginator(const Messages::TRuntimeCtxId &)const
MeshMachine::CNodeActivityBase::FirstOriginator()const
MeshMachine::CNodeActivityBase::InsertPreallocatedDestroyActivity()
MeshMachine::CNodeActivityBase::KickOffMessageId()const
MeshMachine::CNodeActivityBase::MatchSender(const TNodeContextBase &)const
MeshMachine::CNodeActivityBase::Next(TNodeContextBase &)
MeshMachine::CNodeActivityBase::PostRequestTo(const Messages::RNodeInterface &,const Messages::TSignalBase &,const TBool)
MeshMachine::CNodeActivityBase::PostRequestTo(const Messages::TNodeId &,const Messages::TSignalBase &,const TBool)
MeshMachine::CNodeActivityBase::PostToOriginator(const Messages::TNodePeerId &,const Messages::TSignalBase &)const
MeshMachine::CNodeActivityBase::PostToOriginators(const Messages::TSignalBase &,TUint32,TUint32)
MeshMachine::CNodeActivityBase::PostedToNodeId()const
MeshMachine::CNodeActivityBase::PostedToPeer()const
MeshMachine::CNodeActivityBase::RemoveOriginator(TInt)
MeshMachine::CNodeActivityBase::ReturnPreallocatedSpace(TAny *)
MeshMachine::CNodeActivityBase::SetError(TInt)
MeshMachine::CNodeActivityBase::SetPostedTo(const Messages::RNodeInterface &)
MeshMachine::CNodeActivityBase::SetPostedTo(const Messages::TNodeId &)
MeshMachine::CNodeActivityBase::SoleOriginator()const
MeshMachine::CNodeActivityBase::StartL(TNodeContextBase &,const Messages::XNodePeerId &,const NetStateMachine::TStateTriple &)
MeshMachine::CNodeActivityBase::~CNodeActivityBase()
MeshMachine::CNodeParallelActivityBase::ActivityId()const
MeshMachine::CNodeParallelActivityBase::CNodeParallelActivityBase(const TNodeActivity &,AMMNodeBase &,TUint)
MeshMachine::CNodeParallelActivityBase::GetNextActivityCount(const TNodeActivity &,const AMMNodeBase &)
MeshMachine::CNodeParallelActivityBase::GetNextActivityCountL(const TNodeActivity &,const AMMNodeBase &)
MeshMachine::CNodeRetryParallelActivity::CNodeRetryParallelActivity(const TNodeActivity &,AMMNodeBase &,TUint)
MeshMachine::CNodeRetryParallelActivity::IsIdle()const
MeshMachine::CNodeRetryParallelActivity::ReturnInterfacePtrL(AActivitySemaphore *&)
MeshMachine::CNodeRetryParallelActivity::ReturnInterfacePtrL(AContextStore *&)
MeshMachine::CNodeRetryParallelActivity::SetIdle()
MeshMachine::CNodeRetryParallelActivity::Signal(TNodeContextBase &)
Public Member Type Definitions
typedef MeshMachine::TNodeContext< ESock::CMMCommsProviderBase, CoreNetStates::TContext > TContext
Public Attributes
RArray< TMigrationPairs >iDataClients
Inherited Attributes
MeshMachine::CNodeActivityBase::iNode
MeshMachine::CNodeActivityBase::iOriginators
MeshMachine::CNodeParallelActivityBase::iActivityId

Constructor & Destructor Documentation

CRejoinDataClientActivity(const MeshMachine::TNodeActivity &, TUint, MeshMachine::AMMNodeBase &)

CRejoinDataClientActivity(const MeshMachine::TNodeActivity &aActivitySig,
TUintaNextActivityCount,
MeshMachine::AMMNodeBase &aNode
)[protected, inline]

Parameters

const MeshMachine::TNodeActivity & aActivitySig
TUint aNextActivityCount
MeshMachine::AMMNodeBase & aNode

~CRejoinDataClientActivity()

~CRejoinDataClientActivity()[virtual]

Member Functions Documentation

Accept()

TContext TBoolAccept()[virtual]

DECLARE_SMELEMENT_FOOTER(TRejoinDataClient)

DECLARE_SMELEMENT_FOOTER(TRejoinDataClient)

DECLARE_SMELEMENT_FOOTER(TApplyRejoin)

DECLARE_SMELEMENT_FOOTER(TApplyRejoin)

Parameters

TApplyRejoin

DECLARE_SMELEMENT_FOOTER(TRejoinLoopTag)

DECLARE_SMELEMENT_FOOTER(TRejoinLoopTag)

Parameters

TRejoinLoopTag

DECLARE_SMELEMENT_FOOTER(TAwaitingJoinComplete)

DECLARE_SMELEMENT_FOOTER(TAwaitingJoinComplete)[inline]

Is a self-dispatcher for the peerless dataclient rejoin sent by RejoinDataClient. The dispatcher will assume the node (aItf) it's working with is the new owner of the given dataclient. It will add the dataclient to the new owner, mark it as RClientIdenifiedInterface::EJoining, so that the new owner will know the subjects of the subsequent TApply and confirm back to the sender.

DoL()

TContext voidDoL()[virtual]

EXPORT_DECLARE_SMELEMENT_HEADER(TRejoinDataClient, MeshMachine::TStateTransition< TContext >, NetStateMachine::MStateTransition, TContext)

EXPORT_DECLARE_SMELEMENT_HEADER(TRejoinDataClient,
MeshMachine::TStateTransition< TContext >,
NetStateMachine::MStateTransition,
TContext
)

NewL(const MeshMachine::TNodeActivity &, MeshMachine::AMMNodeBase &)

IMPORT_C MeshMachine::CNodeActivityBase *NewL(const MeshMachine::TNodeActivity &aActivitySig,
MeshMachine::AMMNodeBase &aNode
)[static]

Create a new activity. This should never be called by user code.

Parameters

const MeshMachine::TNodeActivity & aActivitySigContext information about how the activity is to be started
MeshMachine::AMMNodeBase & aNodeThe node to which this activity will belong.

TransitionTag()

TContext virtual IMPORT_C TIntTransitionTag()[virtual]

Member Type Definitions Documentation

Member Data Documentation

RArray< TMigrationPairs > iDataClients

RArray< TMigrationPairs >iDataClients