libs/ck-libs/multicast/ckmulticast.C File Reference

Go to the source code of this file.

Data Structures
class	reductionInfo
	Information about the status of reductions proceeding along a given section. More...
class	mCastPacket
class	SectionLocation
class	mCastEntry
	Cookie for an array section. More...
class	cookieMsg
class	multicastSetupMsg
	multicast tree setup message More...
class	multicastGrpMsg
	message send in spanning tree More...
Typedefs
typedef CkQ< multicastGrpMsg * >	multicastGrpMsgBuf
typedef CkVec< CkArrayIndex >	arrayIndexList
typedef CkVec< CkSectionInfo >	sectionIdList
typedef CkVec< CkReductionMsg * >	reductionMsgs
typedef CkQ< int >	PieceSize
typedef CkVec< LDObjid >	ObjKeyList
typedef unsigned char	byte
typedef CkQ< mCastPacket * >	multicastGrpPacketBuf
Functions
void	CkPackMessage (envelope **pEnv)
void	CkUnpackMessage (envelope **pEnv)
void	_ckMulticastInit (void)
LDObjid	idx2LDObjid (const CkArrayIndex &idx)
void	CkGetSectionInfo (CkSectionInfo &id, void *msg)
	Retrieve section info from a multicast msg. Part of API.

---

Typedef Documentation

typedef CkQ<multicastGrpMsg *> multicastGrpMsgBuf

Definition at line 29 of file ckmulticast.C.

typedef CkVec<CkArrayIndex> arrayIndexList

Definition at line 30 of file ckmulticast.C.

typedef CkVec<CkSectionInfo> sectionIdList

Definition at line 31 of file ckmulticast.C.

typedef CkVec<CkReductionMsg *> reductionMsgs

Definition at line 32 of file ckmulticast.C.

typedef CkQ<int> PieceSize

Definition at line 33 of file ckmulticast.C.

typedef CkVec<LDObjid> ObjKeyList

Definition at line 34 of file ckmulticast.C.

typedef unsigned char byte

Definition at line 35 of file ckmulticast.C.

typedef CkQ<mCastPacket *> multicastGrpPacketBuf

Definition at line 94 of file ckmulticast.C.

---

Function Documentation

void CkPackMessage

(

envelope **

pEnv

)

Definition at line 1299 of file ck.C.

References _msgTable, EnvToUsr(), envelope::getMsgIdx(), envelope::isPacked(), envelope::setPacked(), and UsrToEnv().

Referenced by _createGroup(), _createNodeGroup(), _infoFn(), _initCharm(), _noCldEnqueue(), _noCldEnqueueMulti(), _noCldNodeEnqueue(), _skipCldEnqueue(), ComlibManager::ArraySectionSend(), ComlibManager::ArraySend(), CkPupMessage(), RectMulticastStrategy::forwardMulticast(), ComlibSectionInfo::getNewMulticastMessage(), ComlibManager::GroupBroadcast(), ComlibManager::GroupSend(), RectMulticastStrategy::handleNewMulticastMessage(), RectMulticastStrategy::insertMessage(), MulticastStrategy::insertMessage(), ChunkMulticastStrategy::insertMessage(), BroadcastStrategy::insertMessage(), CkMemCheckPT::isMaster(), CkMessageReplay::isNext(), ComlibManager::multicast(), CkMessageReplay::process(), CkMessageDetailRecorder::process(), CkMessageRecorder::process(), RectMulticastStrategy::remoteMulticast(), OneTimeMulticastStrategy::remoteMulticast(), MulticastStrategy::remoteMulticast(), ChunkMulticastStrategy::remoteMulticast(), sendMlogLocation(), RectMulticastStrategy::sendRectDest(), and CkMulticastMgr::sendToSection().

void CkUnpackMessage

(

envelope **

pEnv

)

Definition at line 1313 of file ck.C.

References _msgTable, EnvToUsr(), envelope::getMsgIdx(), envelope::isPacked(), envelope::setPacked(), and UsrToEnv().

Referenced by _createGroup(), _createNodeGroup(), _initCharm(), _initHandler(), _processBufferedBocInits(), _processBufferedNodeBocInits(), _processHandler(), _receiveMlogLocationHandler(), CkPupMessage(), CkSendMsgInline(), PipeBroadcastStrategy::deliver(), EachToManyMulticastStrategy::deliver(), ComlibArrayInfo::deliver(), CharmStrategy::deliverToIndices(), OneTimeMulticastStrategy::handleMessage(), ChunkMulticastStrategy::handleMessage(), RectMulticastStrategy::handleNewMulticastMessage(), MulticastStrategy::handleNewMulticastMessage(), ChunkMulticastStrategy::insertMessage(), CkMemCheckPT::isMaster(), CkMessageReplay::isNext(), EachToManyMulticastStrategy::localMulticast(), ComlibArrayInfo::localMulticast(), CkMessageReplay::process(), CkMessageDetailRecorder::process(), CkMessageRecorder::process(), CpdList_localQ::pup(), CpdList_localQ::pupSingleMessage(), recv_array_msg(), CkMulticastMgr::recvPacket(), CkMulticastMgr::sendToSection(), and CkDiskCheckPTInfo::updateBuffer().

void _ckMulticastInit

(

void

)

Definition at line 214 of file ckmulticast.C.

LDObjid idx2LDObjid

(

const CkArrayIndex &

idx

)

Definition at line 65 of file cklocation.C.

References circleShift(), CkArrayIndex::data(), data, _LDObjid::id, and CkArrayIndexBase::nInts.

Referenced by CkLocRec_local::CkLocRec_local(), CkLocMgr::deliver(), CkMulticastMgr::prepareCookie(), and CkMulticastMgr::setSection().

void CkGetSectionInfo	(	CkSectionInfo &	id,
		void *	msg
	)

Retrieve section info from a multicast msg. Part of API.

Definition at line 929 of file ckmulticast.C.

References CkMcastBaseMsg::checkMagic(), CmiAbort(), CmiPrintf(), CkMcastBaseMsg::cookie(), and CkMcastBaseMsg::gpe().