CkArrayBroadcaster Class Reference

This arrayListener is in charge of delivering broadcasts to the array. More...

Inheritance diagram for CkArrayBroadcaster:

[legend]

Collaboration diagram for CkArrayBroadcaster:

[legend]

Public Member Functions
	CkArrayBroadcaster (bool _stableLocations, bool _broadcastViaScheduler)
	CkArrayBroadcaster (CkMigrateMessage *m)
virtual void	pup (PUP::er &p)
virtual	~CkArrayBroadcaster ()
	PUPable_decl (CkArrayBroadcaster)
virtual void	ckElementStamp (int *eltInfo)
	Element creation message is about to be sent.
virtual CmiBool	ckElementCreated (ArrayElement *elt)
	Element was just created on this processor Return false if the element migrated away or deleted itself.
virtual CmiBool	ckElementArriving (ArrayElement *elt)
	Element just arrived on this processor (so just called pup) Return false if the element migrated away or deleted itself.
void	incoming (CkArrayMessage *msg)
CmiBool	deliver (CkArrayMessage *bcast, ArrayElement *el, bool doFree)
void	springCleaning (void)
void	flushState ()
	used by checkpointing to reset the states
Private Member Functions
int &	getData (ArrayElement *el)
CmiBool	bringUpToDate (ArrayElement *el)
	Deliver all needed broadcasts to the given local element.
Private Attributes
int	bcastNo
int	oldBcastNo
CkQ< CkArrayMessage * >	oldBcasts
bool	stableLocations
bool	broadcastViaScheduler

---

Detailed Description

This arrayListener is in charge of delivering broadcasts to the array.

Definition at line 95 of file ckarray.C.

---

Constructor & Destructor Documentation

CkArrayBroadcaster::CkArrayBroadcaster	(	bool	_stableLocations,
		bool	_broadcastViaScheduler
	)

Definition at line 1148 of file ckarray.C.

CkArrayBroadcaster::CkArrayBroadcaster

(

CkMigrateMessage *

m

)

Definition at line 1153 of file ckarray.C.

CkArrayBroadcaster::~CkArrayBroadcaster

(

)

[virtual]

Definition at line 1169 of file ckarray.C.

References CkQ< T >::deq(), and oldBcasts.

---

Member Function Documentation

int& CkArrayBroadcaster::getData

(

ArrayElement *

el

)

[inline, private]

Definition at line 96 of file ckarray.C.

References CkArrayListener::ckGetData().

Referenced by bringUpToDate().

void CkArrayBroadcaster::pup

(

PUP::er &

p

)

[virtual]

Reimplemented from CkArrayListener.

Definition at line 1157 of file ckarray.C.

References bcastNo, broadcastViaScheduler, PUP::er::isUnpacking(), oldBcastNo, CkArrayListener::pup(), and stableLocations.

CkArrayBroadcaster::PUPable_decl

(

CkArrayBroadcaster

)

virtual void CkArrayBroadcaster::ckElementStamp

(

int *

eltInfo

)

[inline, virtual]

Element creation message is about to be sent.

Reimplemented from CkArrayListener.

Definition at line 104 of file ckarray.C.

References bcastNo.

virtual CmiBool CkArrayBroadcaster::ckElementCreated

(

ArrayElement *

elt

)

[inline, virtual]

Element was just created on this processor Return false if the element migrated away or deleted itself.

Reimplemented from CkArrayListener.

Definition at line 108 of file ckarray.C.

References bringUpToDate().

virtual CmiBool CkArrayBroadcaster::ckElementArriving

(

ArrayElement *

elt

)

[inline, virtual]

Element just arrived on this processor (so just called pup) Return false if the element migrated away or deleted itself.

Reimplemented from CkArrayListener.

Definition at line 113 of file ckarray.C.

References bringUpToDate().

void CkArrayBroadcaster::incoming

(

CkArrayMessage *

msg

)

Definition at line 1175 of file ckarray.C.

References bcastNo, CmiMemoryMarkBlock(), CkQ< T >::enq(), oldBcasts, stableLocations, and UsrToEnv().

Referenced by CkArray::recvBroadcast().

CmiBool CkArrayBroadcaster::deliver	(	CkArrayMessage *	bcast,
		ArrayElement *	el,
		bool	doFree
	)

Referenced by bringUpToDate(), and CkArray::recvBroadcast().

void CkArrayBroadcaster::springCleaning

(

void

)

Definition at line 1250 of file ckarray.C.

References bcastNo, CkQ< T >::deq(), CkQ< T >::length(), oldBcastNo, and oldBcasts.

Referenced by CkArray::springCleaning().

void CkArrayBroadcaster::flushState

(

)

[virtual]

used by checkpointing to reset the states

Reimplemented from CkArrayListener.

Definition at line 1262 of file ckarray.C.

References bcastNo, CkQ< T >::deq(), oldBcastNo, and oldBcasts.

CmiBool CkArrayBroadcaster::bringUpToDate

(

ArrayElement *

el

)

[private]

Deliver all needed broadcasts to the given local element.

Definition at line 1220 of file ckarray.C.

References bcastNo, CmiFalse, CmiTrue, deliver(), CkQ< T >::deq(), CkQ< T >::enq(), getData(), idx2str(), CkQ< T >::length(), oldBcasts, and stableLocations.

Referenced by ckElementArriving(), and ckElementCreated().

---

Field Documentation

int CkArrayBroadcaster::bcastNo [private]

Definition at line 124 of file ckarray.C.

Referenced by bringUpToDate(), ckElementStamp(), flushState(), incoming(), pup(), and springCleaning().

int CkArrayBroadcaster::oldBcastNo [private]

Definition at line 125 of file ckarray.C.

Referenced by flushState(), pup(), and springCleaning().

CkQ<CkArrayMessage *> CkArrayBroadcaster::oldBcasts [private]

Definition at line 128 of file ckarray.C.

Referenced by bringUpToDate(), flushState(), incoming(), springCleaning(), and ~CkArrayBroadcaster().

bool CkArrayBroadcaster::stableLocations [private]

Definition at line 129 of file ckarray.C.

Referenced by bringUpToDate(), incoming(), and pup().

bool CkArrayBroadcaster::broadcastViaScheduler [private]

Definition at line 130 of file ckarray.C.

Referenced by pup().

---

The documentation for this class was generated from the following file:

• ck-core/ckarray.C