Collapse all Symbian^3 Product Developer Library

TierNotification::CTierNotificationActivity Class Reference

class TierNotification::CTierNotificationActivity : public MeshMachine::CNodeParallelActivityBase

Inherits from

TierNotification::CTierNotificationActivity
- MeshMachine::CNodeParallelActivityBase
  - MeshMachine::CNodeActivityBase
    - CBase

Public Member Functions
	~CTierNotificationActivity()
TBool	AllAccessPointsReadyForAllCollectors()
IMPORT_C TBool	AllCollectorsUnlocked()
MEqualityComparator *	CreateEqualityComparatorL(const CParameterSetContainer &)
IMPORT_C void	DataReceivedL(CDataCollectorSession &, CParameterSetContainer &, TBool)
CommsDat::CMDBSession &	GetDbSession()
void	InitL(ESock::CRefCountOwnedParameterBundle *, const RMessage2 &, TBool)
IMPORT_C void	InitiateShutdown(TInt)
IMPORT_C MeshMachine::CNodeActivityBase *	NewL(const MeshMachine::TNodeActivity &, MeshMachine::AMMNodeBase &)
void	NotifyOtherCollectorsOfChangeL(CDataCollectorSession &, CParameterSetContainer &)
TBool	OneOffQuery()
ESock::CRefCountOwnedParameterBundle &	QueryBundleOwner()
IMPORT_C void	ReportChangesInCacheL()
IMPORT_C void	ReportIfReadyL()
IMPORT_C void	ShutdownFinished()
void	StartL(RPointerArray< MDataCollector > &)
ESock::CTierManagerBase &	TierManager()

Protected Member Functions
	CTierNotificationActivity(const MeshMachine::TNodeActivity &, MeshMachine::AMMNodeBase &, TUint)
TBool	HasSufficientCapabilities(const RMessage2 &)

Private Member Functions
void	PostRefCountedBundleToOriginators(const Messages::TSignatureBase &, ESock::CRefCountOwnedParameterBundle &)

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::IsIdle()const
	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::SetIdle()
	MeshMachine::CNodeActivityBase::SetPostedTo(const Messages::RNodeInterface &)
	MeshMachine::CNodeActivityBase::SetPostedTo(const Messages::TNodeId &)
	MeshMachine::CNodeActivityBase::Signal(TNodeContextBase &)
	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 &)

Private Attributes
CTierNotificationCache *	iCache
RPointerArray< CDataCollectorSession >	iCollectorSessions
CommsDat::CMDBSession *	iDbSession
TInt	iErrorToReport
TInt	iMessageCount
TBool	iOneOffQuery
ESock::CRefCountOwnedParameterBundle *	iQueryBundleOwner
TBool	iShuttingDown

Inherited Attributes
	MeshMachine::CNodeActivityBase::iNode
	MeshMachine::CNodeActivityBase::iOriginators
	MeshMachine::CNodeParallelActivityBase::iActivityId

Constructor & Destructor Documentation

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

CTierNotificationActivity	(	const MeshMachine::TNodeActivity &	aActivitySig,
		MeshMachine::AMMNodeBase &	aNode,
		TUint	aActivitiesCount
	)	[protected, inline]

Parameters

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

~CTierNotificationActivity()

~CTierNotificationActivity

(

)

[virtual]

Member Functions Documentation

AllAccessPointsReadyForAllCollectors()

TBool

AllAccessPointsReadyForAllCollectors

(

)

const

See if all data is ready to be reported

AllCollectorsUnlocked()

IMPORT_C TBool

AllCollectorsUnlocked

(

)

const

See if all data collectors are unlocked

CreateEqualityComparatorL(const CParameterSetContainer &)

MEqualityComparator *

CreateEqualityComparatorL

(

const CParameterSetContainer &

aData

)

[virtual]

Creates the equality comparator for the given parameter set for this class. If this ever needs to be different for a tier, this function can be overridden

Parameters

const CParameterSetContainer & aData

DataReceivedL(CDataCollectorSession &, CParameterSetContainer &, TBool)

IMPORT_C void	DataReceivedL	(	CDataCollectorSession &	aSource,
			CParameterSetContainer &	aNewData,
			TBool	aEnableNotify = ETrue
		)

To be called by collector (via collector session) to tell the activity that data has been received. Updates the cache (by making merge calls back to the collector (via collector session) and notifies the client if appropriate.

Parameters

CDataCollectorSession & aSource
CParameterSetContainer & aNewData
TBool aEnableNotify = ETrue

GetDbSession()

CommsDat::CMDBSession &

GetDbSession

(

)

[inline]

HasSufficientCapabilities(const RMessage2 &)

TBool

HasSufficientCapabilities

(

const RMessage2 &

aPlatSecInfo

)

const [protected, virtual]

Parameters

const RMessage2 & aPlatSecInfo

InitL(ESock::CRefCountOwnedParameterBundle *, const RMessage2 &, TBool)

void	InitL	(	ESock::CRefCountOwnedParameterBundle *	aQuery,
			const RMessage2 &	aPlatSecInfo,
			TBool	aOneOffQuery
		)

Performs the given query

Parameters

ESock::CRefCountOwnedParameterBundle * aQuery	input: query to run. ownership is given to this method
const RMessage2 & aPlatSecInfo
TBool aOneOffQuery

InitiateShutdown(TInt)

IMPORT_C void

InitiateShutdown

(

TInt

aErrorToReport

)

Parameters

TInt aErrorToReport

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 & aActivitySig	Context information about how the activity is to be started
MeshMachine::AMMNodeBase & aNode	The node to which this activity will belong.

NotifyOtherCollectorsOfChangeL(CDataCollectorSession &, CParameterSetContainer &)

void	NotifyOtherCollectorsOfChangeL	(	CDataCollectorSession &	aSource,
			CParameterSetContainer &	aModifiedCacheEntry
		)

Parameters

CDataCollectorSession & aSource
CParameterSetContainer & aModifiedCacheEntry

OneOffQuery()

TBool

OneOffQuery

(

)

const [inline]

Accessors to help build the collectors

PostRefCountedBundleToOriginators(const Messages::TSignatureBase &, ESock::CRefCountOwnedParameterBundle &)

void	PostRefCountedBundleToOriginators	(	const Messages::TSignatureBase &	aMsg,
			ESock::CRefCountOwnedParameterBundle &	aBundleOwner
		)	[private]

Parameters

const Messages::TSignatureBase & aMsg
ESock::CRefCountOwnedParameterBundle & aBundleOwner

QueryBundleOwner()

ESock::CRefCountOwnedParameterBundle &

QueryBundleOwner

(

)

const [inline]

ReportChangesInCacheL()

IMPORT_C void

ReportChangesInCacheL

(

)

Scans cache for changes marked worthy for reporting. Copies them into a new bundle (whilst removing the report flags in the cache). Then sends the bundle to the originator.

ReportIfReadyL()

IMPORT_C void

ReportIfReadyL

(

)

Call this whenever notification might be appropriate, it'll figure out using the cache flags whether to report.

ShutdownFinished()

IMPORT_C void

ShutdownFinished

(

)

StartL(RPointerArray< MDataCollector > &)

void

StartL

(

RPointerArray< MDataCollector > &

aCollectors

)

Parameters

RPointerArray< MDataCollector > & aCollectors

TierManager()

ESock::CTierManagerBase &

TierManager

(

)

[inline]

Member Data Documentation

CTierNotificationCache * iCache

CTierNotificationCache *

iCache

[private]

RPointerArray< CDataCollectorSession > iCollectorSessions

RPointerArray< CDataCollectorSession >

iCollectorSessions

[private]

CommsDat::CMDBSession * iDbSession

CommsDat::CMDBSession *

iDbSession

[private]

TInt iErrorToReport

TInt

iErrorToReport

[private]

TInt iMessageCount

TInt

iMessageCount

[private]

TBool iOneOffQuery

TBool

iOneOffQuery

[private]

ESock::CRefCountOwnedParameterBundle * iQueryBundleOwner

ESock::CRefCountOwnedParameterBundle *

iQueryBundleOwner

[private]

TBool iShuttingDown

TBool

iShuttingDown

[private]