ck-core/envelope.h File Reference

Go to the source code of this file.

Data Structures
class	PathHistoryEnvelope
	A class that is used to track the entry points and other information about a critical path as a charm++ program executes. More...
class	envelope
	The class envelope defines a Charm++ message's header. More...
union	envelope::u_type
	This union stores the type-specific message information. More...
struct	envelope::u_type::s_chare
struct	envelope::u_type::s_group
struct	envelope::u_type::s_array
struct	envelope::u_type::s_roData
struct	envelope::u_type::s_roMsg
struct	envelope::s_attribs
class	MsgPool
Typedefs
typedef unsigned int	UInt
typedef unsigned short	UShort
typedef unsigned char	UChar
Functions
	CkpvExtern (int, envelopeEventID)
void	CkPackMessage (envelope **pEnv)
void	CkUnpackMessage (envelope **pEnv)
	CkpvExtern (MsgPool *, _msgPool)
envelope *	UsrToEnv (const void *const msg)
void *	EnvToUsr (const envelope *const env)
envelope *	_allocEnv (const int msgtype, const int size=0, const int prio=0)
void *	_allocMsg (const int msgtype, const int size, const int prio=0)
void	_resetEnv (envelope *env)
void	setEventID (envelope *env)
Variables
UChar	_defaultQueueing

---

Typedef Documentation

typedef unsigned int UInt

Definition at line 85 of file envelope.h.

typedef unsigned short UShort

Definition at line 86 of file envelope.h.

typedef unsigned char UChar

Definition at line 87 of file envelope.h.

---

Function Documentation

CkpvExtern	(	int	,
		envelopeEventID
	)

envelope* UsrToEnv

(

const void *const

msg

)

[inline]

Definition at line 375 of file envelope.h.

Referenced by _bcastQD1(), _bcastQD2(), _handlePhase1(), _handlePhase2(), _initCharm(), _prepareImmediateMsg(), _prepareMsg(), _prepareMsgBranch(), _processNewVChareMsg(), MsgPool::_reset(), _sendStats(), CkArray::allocate(), CkArrayMessage::array_ep(), CkArrayMessage::array_ep_bcast(), CkArrayMessage::array_getSrcPe(), CkArrayMessage::array_hops(), CkArrayMessage::array_ifNotThere(), CkArrayMessage::array_index(), CkArrayMessage::array_setIfNotThere(), ComlibManager::ArrayBroadcast(), ComlibManager::ArraySectionSend(), ComlibManager::ArraySend(), NullLB::AtSync(), CkLocRec_buffering::beenReplaced(), CkArray::broadcastHomeElements(), Chare::CkAddThreadListeners(), CkAllocateMarshallMsg(), CkAllocateMarshallMsgNoninline(), CkAllocateMarshallMsgT(), CkAllocBuffer(), CkArrayManagerDeliver(), CkArrayManagerInsert(), CProxy_ArrayBase::ckBroadcast(), CkCopyMsg(), CkCreateAttachedFuture(), CkCreateAttachedFutureSend(), CkCreateChare(), CkCreateGroup(), CkCreateNodeGroup(), CkFreeMsg(), CkGetRefNum(), CkGetSrcPe(), CkMessageToEpIdx(), CkPackMessage(), CkPriorityPtr(), CkPupChareData(), CkPupGroupData(), CkPupMessage(), CkPupNodeGroupData(), CkSemaSignal(), CkSendMsg(), CkSendMsgBranchImmediate(), CkSendMsgBranchInline(), CkSendMsgInline(), CkSendMsgNodeBranchImmediate(), CkSendMsgNodeBranchInline(), CkSendToFutureID(), CkSetQueueing(), CkSetRefNum(), CkStartQD(), CkUnpackMessage(), CpdAfterEp(), CpdBeforeEp(), CpdPythonGroup::cpdCheck(), CpdDeliverSingleMessage(), CpdPupMessage(), CkLocMgr::deliver(), CkLocRec_buffering::deliver(), CkLocRec_local::deliver(), CharmStrategy::deliverToIndices(), CkLocMgr::deliverUnknown(), CkLocMgr::demandCreateElement(), CkLocMgr::emigrate(), CkReductionMgr::endArrayReduction(), MeshStreamer< dtype >::flushDimension(), MeshStreamer< dtype >::flushLargestBucket(), FuncSingleHelper::FuncSingleHelper(), ampi::generic(), ComlibSectionInfo::getNewMulticastMessage(), ComlibManager::GroupBroadcast(), ComlibManager::GroupSend(), ChunkMulticastStrategy::handleMessage(), RectMulticastStrategy::handleNewMulticastMessage(), CkArrayBroadcaster::incoming(), RectMulticastStrategy::insertMessage(), PrioStreaming::insertMessage(), OneTimeMulticastStrategy::insertMessage(), MulticastStrategy::insertMessage(), EachToManyMulticastStrategy::insertMessage(), ChunkMulticastStrategy::insertMessage(), BroadcastStrategy::insertMessage(), CkLocRec_local::invokeEntry(), CkMemCheckPT::isMaster(), CentralLB::LoadBalance(), RectMulticastStrategy::localMulticast(), MulticastStrategy::localMulticast(), ampi::makeAmpiMsg(), msg_prepareSend(), msg_prepareSend_noinline(), ComlibManager::multicast(), FuncNodeHelper::parallelizeFunc(), CkArray::prepareCtorMsg(), printPriority(), CentralLB::ProcessReceiveMigration(), QdState::propagate(), Event::pup(), CpdList_localQ::pup(), GroupMeshStreamer< dtype >::receiveAtDestination(), ArrayElement::recvBroadcast(), CkNodeReductionMgr::reduceMessages(), CkReductionMgr::reduceMessages(), CkNodeReductionMgr::ReductionStarting(), CkReductionMgr::ReductionStarting(), OneTimeMulticastStrategy::remoteMulticast(), ChunkMulticastStrategy::remoteMulticast(), rewritePEs(), QdState::sendCount(), sendGroupMsg(), MeshStreamer< dtype >::sendLargestBuffer(), sendNodeGroupMsg(), sendTicketGroupRequest(), sendTicketNodeGroupRequest(), CkMulticastMgr::sendToSection(), FutureBOC::SetFuture(), SequentialSolver::setParentInfo(), ParallelSolver::setParentInfo(), FutureBOC::SetSema(), CkArrayReductionMgr::startNodeGroupReduction(), FuncSingleHelper::stealWork(), CentralLB::Strategy(), CkDiskCheckPTInfo::updateBuffer(), and Chare::~Chare().

void* EnvToUsr

(

const envelope *const

env

)

[inline]

Definition at line 379 of file envelope.h.

Referenced by MsgPool::_alloc(), _allocMsg(), _exitHandler(), _initCharm(), _invokeEntryNoTrace(), _processArrayEltInitMsg(), _processArrayEltMsg(), _processFillVidMsg(), _processRODataMsg(), _processROMsgMsg(), _qdCommHandler(), _qdHandler(), _receiveMlogLocationHandler(), bdcastRO(), CkAllocBuffer(), CkAllocMsg(), CkCopyMsg(), CkPackMessage(), CkPupMessage(), CkUnpackMessage(), PipeBroadcastStrategy::deliver(), EachToManyMulticastStrategy::deliver(), ComlibArrayInfo::deliver(), RectMulticastStrategy::forwardMulticast(), CharmMessageHolder::getCharmMessage(), PipeBroadcastStrategy::getFragmentHeader(), ComlibSectionInfo::getNewMulticastMessage(), ComlibSectionInfo::getPeList(), BroadcastStrategy::handleHypercube(), RectMulticastStrategy::handleMessage(), OneTimeMulticastStrategy::handleMessage(), MulticastStrategy::handleMessage(), ChunkMulticastStrategy::handleMessage(), RectMulticastStrategy::handleMessageForward(), RectMulticastStrategy::handleNewMulticastMessage(), MulticastStrategy::handleNewMulticastMessage(), BroadcastStrategy::handleTree(), ChunkMulticastStrategy::insertMessage(), CkMemCheckPT::isMaster(), RectMulticastStrategy::localMulticast(), MulticastStrategy::localMulticast(), ComlibArrayInfo::localMulticast(), migrationDone(), Event::pup(), CpdList_message::pup(), CpdList_localQ::pup(), CpdList_localQ::pupSingleMessage(), recv_array_msg(), CkMulticastMgr::recvPacket(), RectMulticastStrategy::remoteMulticast(), sendGroupMsg(), sendMlogLocation(), sendNodeGroupMsg(), sendTicketGroupRequest(), sendTicketNodeGroupRequest(), CkMulticastMgr::sendToSection(), ComlibSectionInfo::unpack(), and CkDiskCheckPTInfo::updateBuffer().

envelope* _allocEnv	(	const int	msgtype,
		const int	size = 0,
		const int	prio = 0
	)			[inline]

Definition at line 383 of file envelope.h.

References envelope::alloc(), prio, and size.

Referenced by MsgPool::_alloc(), _CkExit(), _initCharm(), _sendStats(), _sendTriggers(), bdcastRO(), CkAllocBuffer(), CkAllocMsg(), CkExit(), CkPupMessage(), LibCkExit(), and MlogEntry::pup().

void* _allocMsg	(	const int	msgtype,
		const int	size,
		const int	prio = 0
	)			[inline]

Definition at line 387 of file envelope.h.

References envelope::alloc(), EnvToUsr(), and prio.

Referenced by _processNewVChareMsg(), Stats::operator new(), and Chare::~Chare().

void _resetEnv

(

envelope *

env

)

[inline]

Definition at line 391 of file envelope.h.

References envelope::reset().

Referenced by MsgPool::_reset().

void setEventID

(

envelope *

env

)

[inline]

Definition at line 395 of file envelope.h.

References envelope::setEvent().

Referenced by _prepareMsg(), and _prepareMsgBranch().

void CkPackMessage

(

envelope **

pEnv

)

Definition at line 1299 of file ck.C.

void CkUnpackMessage

(

envelope **

pEnv

)

Definition at line 1313 of file ck.C.

CkpvExtern	(	MsgPool *	,
		_msgPool
	)