CkMemCheckPT Class Reference

#include <ckmemcheckpoint.h>

Inheritance diagram for CkMemCheckPT:

[legend]

Collaboration diagram for CkMemCheckPT:

[legend]

Public Member Functions
	CkMemCheckPT (int w)
	CkMemCheckPT (CkMigrateMessage *m)
virtual	~CkMemCheckPT ()
void	pup (PUP::er &p)
int	BuddyPE (int pe)
void	doItNow (int sp, CkCallback &)
void	restart (int diePe)
void	removeArrayElements ()
void	createEntry (CkArrayID aid, CkGroupID loc, CkArrayIndex index, int buddy)
void	recvData (CkArrayCheckPTMessage *)
void	gotData ()
void	recvProcData (CkProcCheckPTMessage *)
void	cpFinish ()
void	syncFiles (CkReductionMsg *)
void	report ()
void	recoverBuddies ()
void	recoverEntry (CkArrayCheckPTMessage *msg)
void	recoverArrayElements ()
void	quiescence (CkCallback &)
void	resetReductionMgr ()
void	finishUp ()
void	inmem_restore (CkArrayCheckPTMessage *m)
void	updateLocations (int n, CkGroupID *g, CkArrayIndex *idx, int nowOnPe)
void	resetLB (int diepe)
int	isFailed (int pe)
Static Public Attributes
static CkCallback	cpCallback
static int	inRestarting = 0
static double	startTime
static char *	stage
Private Member Functions
int	isMaster (int pe)
void	failed (int pe)
int	totalFailed ()
void	sendProcData ()
Private Attributes
CkVec< CkCheckPTInfo * >	ckTable
int	recvCount
int	peCount
int	expectCount
int	ackCount
int	cpStarter
	the processor who initiate the checkpointing
CkVec< int >	failedPes
int	thisFailedPe
int	where
	to use memory or disk checkpointing

---

Detailed Description

Definition at line 57 of file ckmemcheckpoint.h.

---

Constructor & Destructor Documentation

CkMemCheckPT::CkMemCheckPT

(

int

w

)

Definition at line 287 of file ckmemcheckpoint.C.

References ackCount, CcdCallOnCondition(), Converse::CkMyPe(), Converse::CkNumPes(), CmiNumPhysicalNodes(), expectCount, inRestarting, peCount, recvCount, and where.

CkMemCheckPT::CkMemCheckPT

(

CkMigrateMessage *

m

)

[inline]

Definition at line 60 of file ckmemcheckpoint.h.

CkMemCheckPT::~CkMemCheckPT

(

)

[virtual]

Definition at line 318 of file ckmemcheckpoint.C.

References ckTable, and CkVec< T >::length().

---

Member Function Documentation

void CkMemCheckPT::pup

(

PUP::er &

p

)

Definition at line 326 of file ckmemcheckpoint.C.

References CcdCallOnCondition(), cpCallback, cpStarter, failedPes, PUP::er::isUnpacking(), peCount, recvCount, thisFailedPe, and where.

int CkMemCheckPT::BuddyPE

(

int

pe

)

[inline]

Definition at line 103 of file ckmemcheckpoint.C.

References Converse::CkNumPes(), CmiAbort(), CmiGetPesOnPhysicalNode(), CmiNumPhysicalNodes(), CmiPhysicalNodeID(), CmiPhysicalRank(), CmiPrintf(), and isFailed().

Referenced by isMaster().

void CkMemCheckPT::doItNow	(	int	sp,
		CkCallback &	cb
	)

Definition at line 444 of file ckmemcheckpoint.C.

References CkCheckPTInfo::aid, Converse::CkMyPe(), CkSendMsgArray(), ckTable, CmiWallTimer(), cpCallback, cpFinish(), cpStarter, CkCheckPTInfo::index, isMaster(), CkVec< T >::length(), msg, CkCheckPTInfo::pNo, sendProcData(), and startTime.

void CkMemCheckPT::restart

(

int

diePe

)

Referenced by isMaster().

void CkMemCheckPT::removeArrayElements

(

)

Referenced by isMaster().

void CkMemCheckPT::createEntry	(	CkArrayID	aid,
		CkGroupID	loc,
		CkArrayIndex	index,
		int	buddy
	)

Definition at line 404 of file ckmemcheckpoint.C.

References CkCheckPTInfo::aid, Converse::CkMyPe(), ckTable, CmiAbort(), idx, CkCheckPTInfo::index, CkCheckPTInfo::locMgr, CkArrayIndex::print(), CkVec< T >::push_back(), CkVec< T >::size(), and where.

Referenced by recoverEntry().

void CkMemCheckPT::recvData

(

CkArrayCheckPTMessage *

msg

)

Definition at line 525 of file ckmemcheckpoint.C.

References ckTable, CmiAbort(), CkArrayCheckPTMessage::cp_flag, cpFinish(), cpStarter, idx, CkCheckPTInfo::index, CkArrayCheckPTMessage::index, CkVec< T >::length(), CkCheckPTInfo::locMgr, CkArrayCheckPTMessage::locMgr, recvCount, CkReduction::sum_int, and where.

Referenced by recoverEntry().

void CkMemCheckPT::gotData

(

)

Referenced by isMaster().

void CkMemCheckPT::recvProcData

(

CkProcCheckPTMessage *

msg

)

Definition at line 516 of file ckmemcheckpoint.C.

References Converse::CkMyPe(), cpFinish(), and CkProcCheckPTMessage::reportPe.

void CkMemCheckPT::cpFinish

(

)

Definition at line 567 of file ckmemcheckpoint.C.

References Converse::CkMyPe(), CmiPrintf(), CmiWallTimer(), cpCallback, cpStarter, peCount, CkCallback::send(), and startTime.

Referenced by doItNow(), recvData(), recvProcData(), and syncFiles().

void CkMemCheckPT::syncFiles

(

CkReductionMsg *

m

)

Definition at line 557 of file ckmemcheckpoint.C.

References cpFinish(), and cpStarter.

void CkMemCheckPT::report

(

)

Definition at line 581 of file ckmemcheckpoint.C.

References Converse::CkMyPe(), ckTable, CkCheckPTInfo::getSize(), and CkVec< T >::length().

void CkMemCheckPT::recoverBuddies

(

)

Referenced by isMaster().

void CkMemCheckPT::recoverEntry

(

CkArrayCheckPTMessage *

msg

)

Definition at line 432 of file ckmemcheckpoint.C.

References CkArrayCheckPTMessage::aid, CkArrayCheckPTMessage::bud1, CkArrayCheckPTMessage::bud2, Converse::CkMyPe(), createEntry(), CkArrayCheckPTMessage::index, CkArrayCheckPTMessage::locMgr, and recvData().

void CkMemCheckPT::recoverArrayElements

(

)

Referenced by isMaster().

void CkMemCheckPT::quiescence

(

CkCallback &

)

Referenced by isMaster().

void CkMemCheckPT::resetReductionMgr

(

)

Referenced by isMaster().

void CkMemCheckPT::finishUp

(

)

Referenced by isMaster().

void CkMemCheckPT::inmem_restore

(

CkArrayCheckPTMessage *

m

)

Definition at line 348 of file ckmemcheckpoint.C.

References CkArrayCheckPTMessage::aid, CkArrayCheckPTMessage::bud1, CkArrayCheckPTMessage::bud2, ArrayElement::budPEs, c, CmiFalse, CmiMyPe(), CmiTrue, CkArrayCheckPTMessage::index, CkVec< T >::length(), list, ArrayElement::listenerData, CkArrayCheckPTMessage::locMgr, CkLocMgr::lookup(), CkLocMgr::migratableList(), CkMigratable::myRec, p, CkArrayCheckPTMessage::packData, contributorInfo::redNo, and CkLocMgr::resume().

Referenced by isMaster().

void CkMemCheckPT::updateLocations	(	int	n,
		CkGroupID *	g,
		CkArrayIndex *	idx,
		int	nowOnPe
	)

Referenced by isMaster().

void CkMemCheckPT::resetLB

(

int

diepe

)

Referenced by isMaster().

int CkMemCheckPT::isFailed

(

int

pe

)

Definition at line 384 of file ckmemcheckpoint.C.

References failedPes, and CkVec< T >::length().

Referenced by BuddyPE(), failed(), and isMaster().

int CkMemCheckPT::isMaster

(

int

pe

)

[inline, private]

Todo:

: the following definitions should be moved to a separate file containing

* : function for killing a process

: reads the file with the kill information

Definition at line 599 of file ckmemcheckpoint.C.

References _discard_charm_message(), _handleProcData(), _initDone(), _resume_charm_message(), ackCount, CkCheckPTInfo::aid, CkArrayCheckPTMessage::bud1, CkArrayCheckPTMessage::bud2, BuddyPE(), CcdCallFnAfter(), CcdCallOnCondition(), ChkptOnPe(), CkDieNow(), CkFreeMsg(), CkHasCheckpoints(), CkInRestarting(), IrrGroup::ckJustMigrated(), CkMemRestart(), BGConverse::CkMyNode(), BGConverse::CkMyNodeSize(), Converse::CkMyPe(), BGConverse::CkMyRank(), Converse::CkNumPes(), CkPackMessage(), CkStartMemCheckpoint(), CkStartQD(), ckTable, CkUnpackMessage(), CmiAbort(), CmiAlloc(), CmiFree(), CmiGetArgFlagDesc(), CmiMyPe(), CmiMyRank(), CmiNodeFirst(), CmiNumPesOnPhysicalNode(), CmiNumPhysicalNodes(), CmiPhysicalNodeID(), CmiPrintf(), Converse::CmiSyncBroadcastAllAndFree(), Converse::CmiSyncSendAndFree(), CmiWallTimer(), CkArrayCheckPTMessage::cp_flag, cpCallback, CkProcCheckPTMessage::cur_restart_phase, EnvToUsr(), expectCount, failed(), failedPes, finishUp(), IrrGroup::flushStates(), get_avail_vector(), CkCheckPTInfo::getCopy(), CkLocation::getIndex(), envelope::getTotalsize(), gotData(), CkLocMgr::homePe(), _ckGroupID::idx, idx, CkArrayCheckPTMessage::index, CkCheckPTInfo::index, init_memcheckpt(), inmem_restore(), inRestarting, isFailed(), CkCallback::isInvalid(), killFile, killLocal(), CkVec< T >::length(), CkArrayCheckPTMessage::locMgr, CkCheckPTInfo::locMgr, msg, n, notify_crash_fn, p, CkProcCheckPTMessage::packData, CkCheckPTInfo::pNo, CkArrayIndex::print(), printf(), CkVec< T >::push_back(), quiescence(), readKillFile(), recoverArrayElements(), recoverBuddies(), removeArrayElements(), resetLB(), resetReductionMgr(), restart(), CkCallback::send(), set_avail_vector(), size, stage, startTime, thisFailedPe, totalFailed(), CkCheckPTInfo::updateBuddy(), CkLocMgr::updateLocation(), updateLocations(), and UsrToEnv().

Referenced by doItNow().

void CkMemCheckPT::failed

(

int

pe

)

[private]

Definition at line 392 of file ckmemcheckpoint.C.

References failedPes, isFailed(), and CkVec< T >::push_back().

Referenced by isMaster().

int CkMemCheckPT::totalFailed

(

)

[private]

Definition at line 398 of file ckmemcheckpoint.C.

References failedPes, and CkVec< T >::length().

Referenced by isMaster().

void CkMemCheckPT::sendProcData

(

)

[private]

Definition at line 494 of file ckmemcheckpoint.C.

References _handleProcData(), ChkptOnPe(), Converse::CkMyPe(), cpStarter, CkProcCheckPTMessage::len, msg, p, CkProcCheckPTMessage::packData, CkProcCheckPTMessage::pe, CkProcCheckPTMessage::reportPe, PUP::sizer::size(), and size.

Referenced by doItNow().

---

Field Documentation

CkCallback CkMemCheckPT::cpCallback [static]

Definition at line 85 of file ckmemcheckpoint.h.

Referenced by cpFinish(), doItNow(), isMaster(), and pup().

int CkMemCheckPT::inRestarting = 0 [static]

Definition at line 87 of file ckmemcheckpoint.h.

Referenced by CkMemCheckPT(), and isMaster().

double CkMemCheckPT::startTime [static]

Definition at line 88 of file ckmemcheckpoint.h.

Referenced by cpFinish(), doItNow(), and isMaster().

char * CkMemCheckPT::stage [static]

Definition at line 89 of file ckmemcheckpoint.h.

Referenced by isMaster().

CkVec<CkCheckPTInfo *> CkMemCheckPT::ckTable [private]

Definition at line 91 of file ckmemcheckpoint.h.

Referenced by createEntry(), doItNow(), isMaster(), recvData(), report(), and ~CkMemCheckPT().

int CkMemCheckPT::recvCount [private]

Definition at line 93 of file ckmemcheckpoint.h.

Referenced by CkMemCheckPT(), pup(), and recvData().

int CkMemCheckPT::peCount [private]

Definition at line 93 of file ckmemcheckpoint.h.

Referenced by CkMemCheckPT(), cpFinish(), and pup().

int CkMemCheckPT::expectCount [private]

Definition at line 94 of file ckmemcheckpoint.h.

Referenced by CkMemCheckPT(), and isMaster().

int CkMemCheckPT::ackCount [private]

Definition at line 94 of file ckmemcheckpoint.h.

Referenced by CkMemCheckPT(), and isMaster().

int CkMemCheckPT::cpStarter [private]

the processor who initiate the checkpointing

Definition at line 96 of file ckmemcheckpoint.h.

Referenced by cpFinish(), doItNow(), pup(), recvData(), sendProcData(), and syncFiles().

CkVec<int> CkMemCheckPT::failedPes [private]

Definition at line 97 of file ckmemcheckpoint.h.

Referenced by failed(), isFailed(), isMaster(), pup(), and totalFailed().

int CkMemCheckPT::thisFailedPe [private]

Definition at line 98 of file ckmemcheckpoint.h.

Referenced by isMaster(), and pup().

int CkMemCheckPT::where [private]

to use memory or disk checkpointing

Definition at line 101 of file ckmemcheckpoint.h.

Referenced by CkMemCheckPT(), createEntry(), pup(), and recvData().

---

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

• ck-core/ckmemcheckpoint.h
• ck-core/ckmemcheckpoint.C