CkMessageReplay Class Reference

Inheritance diagram for CkMessageReplay:

[legend]

Collaboration diagram for CkMessageReplay:

[legend]

Public Member Functions
	CkMessageReplay (FILE *f_)
	~CkMessageReplay ()
Private Member Functions
void	getNext (void)
	Read the next message we need from the file:.
CmiBool	isNext (envelope *env)
	If this is the next message we need, advance and return CmiTrue.
CmiBool	isNext (CthThreadToken *token)
void	flush (void)
	Try to flush out any delayed messages.
virtual CmiBool	process (envelope **envptr, CkCoreState *ck)
	These are used internally by this class to call the correct subclass method.
virtual CmiBool	process (CthThreadToken *token, CkCoreState *ck)
virtual CmiBool	process (LBMigrateMsg **msg, CkCoreState *ck)
Private Attributes
int	counter
int	nextPE
int	nextSize
int	nextEvent
int	nexttype
int	nextEP
unsigned int	crc1
unsigned int	crc2
FILE *	lbFile
CkQ< envelope * >	delayedMessages
	This is a (short) list of messages we aren't yet ready for:.
CkQ< CthThreadToken * >	delayedTokens
	This is a (short) list of tokens (i.e messages that awake user-threads) we aren't yet ready for:.

---

Detailed Description

Definition at line 2211 of file ck.C.

---

Constructor & Destructor Documentation

CkMessageReplay::CkMessageReplay

(

FILE *

f_

)

[inline]

Definition at line 2336 of file ck.C.

References CkMessageReplayQuiescence(), Converse::CkMyPe(), CmiStartQD(), and CkMessageWatcher::f.

CkMessageReplay::~CkMessageReplay

(

)

[inline]

Definition at line 2343 of file ck.C.

References CkMessageWatcher::f.

---

Member Function Documentation

void CkMessageReplay::getNext

(

void

)

[inline, private]

Read the next message we need from the file:.

Definition at line 2218 of file ck.C.

References CkMessageWatcher::f.

CmiBool CkMessageReplay::isNext

(

envelope *

env

)

[inline, private]

If this is the next message we need, advance and return CmiTrue.

Definition at line 2243 of file ck.C.

References checksum_initial(), Converse::CkMyPe(), CkPackMessage(), CkUnpackMessage(), CmiFalse, CmiTrue, crc32_initial(), envelope::getEpIdx(), envelope::getEvent(), envelope::getSrcPe(), envelope::getTotalsize(), and envelope::isPacked().

CmiBool CkMessageReplay::isNext

(

CthThreadToken *

token

)

[inline, private]

Definition at line 2287 of file ck.C.

References Converse::CkMyPe(), CmiFalse, CmiTrue, and CthThreadToken::serialNo.

void CkMessageReplay::flush

(

void

)

[inline, private]

Try to flush out any delayed messages.

Definition at line 2298 of file ck.C.

References CthEnqueueBigSimThread(), envelope::getEpIdx(), envelope::getEvent(), envelope::getSrcPe(), envelope::getTotalsize(), and CthThreadToken::serialNo.

virtual CmiBool CkMessageReplay::process	(	envelope **	env,
		CkCoreState *	ck
	)			[inline, private, virtual]

These are used internally by this class to call the correct subclass method.

Implements CkMessageWatcher.

Definition at line 2346 of file ck.C.

References BGConverse::CkMyNode(), BGConverse::CkMyNodeSize(), Converse::CkMyPe(), BGConverse::CkNodeFirst(), CkPackMessage(), CkUnpackMessage(), CmiFalse, Converse::CmiSyncSendAndFree(), CmiTrue, ForNodeBocMsg, envelope::getEpIdx(), envelope::getEvent(), envelope::getMsgIdx(), envelope::getMsgtype(), envelope::getSrcPe(), envelope::getTotalsize(), and NodeBocInitMsg.

virtual CmiBool CkMessageReplay::process	(	CthThreadToken *	token,
		CkCoreState *	ck
	)			[inline, private, virtual]

Reimplemented from CkMessageWatcher.

Definition at line 2379 of file ck.C.

References CmiFalse, CmiTrue, and CthThreadToken::serialNo.

virtual CmiBool CkMessageReplay::process	(	LBMigrateMsg **	msg,
		CkCoreState *	ck
	)			[inline, private, virtual]

Reimplemented from CkMessageWatcher.

Definition at line 2394 of file ck.C.

References Converse::CkNumPes(), CmiTrue, openReplayFile(), p, and LBMigrateMsg::pup().

---

Field Documentation

int CkMessageReplay::counter [private]

Definition at line 2212 of file ck.C.

int CkMessageReplay::nextPE [private]

Definition at line 2213 of file ck.C.

int CkMessageReplay::nextSize [private]

Definition at line 2213 of file ck.C.

int CkMessageReplay::nextEvent [private]

Definition at line 2213 of file ck.C.

int CkMessageReplay::nexttype [private]

Definition at line 2213 of file ck.C.

int CkMessageReplay::nextEP [private]

Definition at line 2214 of file ck.C.

unsigned int CkMessageReplay::crc1 [private]

Definition at line 2215 of file ck.C.

unsigned int CkMessageReplay::crc2 [private]

Definition at line 2215 of file ck.C.

FILE* CkMessageReplay::lbFile [private]

Definition at line 2216 of file ck.C.

CkQ<envelope *> CkMessageReplay::delayedMessages [private]

This is a (short) list of messages we aren't yet ready for:.

Definition at line 2293 of file ck.C.

CkQ<CthThreadToken *> CkMessageReplay::delayedTokens [private]

This is a (short) list of tokens (i.e messages that awake user-threads) we aren't yet ready for:.

Definition at line 2295 of file ck.C.

---

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

• ck-core/ck.C