ChareMlogData Class Reference

This file includes the definition of the class for storing the meta data associdated with the message logging protocol. More...

#include <ckcausalmlog.h>

Collaboration diagram for ChareMlogData:

[legend]


Public Member Functions
	ChareMlogData ()
	Default constructor.
MCount	nextSN (const CkObjID &recver)
Ticket	next_ticket (CkObjID &sender, MCount SN)
	Generates the next ticket for a request.
void	verifyTicket (CkObjID &sender, MCount SN, MCount TN)
	Inserts a ticket in the ticketTable if it is not already there.
Ticket	getTicket (CkObjID &sender, MCount SN)
	Get the ticket associated with a combination of sender and SN, if any.
void	addLogEntry (MlogEntry *entry)
	Adds an entry into the message log.
virtual void	pup (PUP::er &p)
	Pup method for the metadata.
CkQ< MlogEntry * > *	getMlog ()
MCount	searchRestoredLocalQ (CkObjID &sender, CkObjID &recver, MCount SN)
	Searches the restoredlocal map to see if the combination of sender and sequence number shows up in the map.
	ChareMlogData ()
	Default constructor.
MCount	nextSN (const CkObjID &recver)
int	checkAndStoreSsn (const CkObjID &sender, MCount ssn)
	Checks whether a ssn has been already received.
void	addLogEntry (MlogEntry *entry)
virtual void	pup (PUP::er &p)
CkQ< MlogEntry * > *	getMlog ()
Data Fields
CkObjID	objID
MCount	tCount
MCount	tProcessed
std::vector< MCount > *	receivedTNs
MCount *	ticketHoles
int	numberHoles
int	currentHoles
int	resendReplyRecvd
bool	restartFlag
bool	teamRecoveryFlag
CkHashtableT < CkHashtableAdaptorT< CkObjID > , SNToTicket * >	teamTable
bool	toResumeOrNot
int	resumeCount
bool	immigrantRecFlag
int	immigrantSourcePE
Private Member Functions
MCount	newTN ()
	Gets a new ticket for a particular object.
Private Attributes
CkHashtableT < CkHashtableAdaptorT< CkObjID > , MCount >	snTable
CkHashtableT < CkHashtableAdaptorT< CkObjID > , SNToTicket * >	ticketTable
CkQ< MlogEntry * >	mlog
CkHashtableT < CkHashtableAdaptorT< CkObjID > , MCount >	ssnTable
CkHashtableT < CkHashtableAdaptorT< CkObjID > , RSSN * >	receivedSsnTable
CkQ< MlogEntry * >	mlog

Detailed Description

This file includes the definition of the class for storing the meta data associdated with the message logging protocol.

This class stores all the message logging related data for a chare.

Definition at line 180 of file ckcausalmlog.h.

Constructor & Destructor Documentation

ChareMlogData::ChareMlogData ( ) [inline]

Default constructor.

Definition at line 224 of file ckcausalmlog.h.

References currentHoles, immigrantRecFlag, numberHoles, receivedTNs, resendReplyRecvd, restartFlag, resumeCount, tCount, teamRecoveryFlag, ticketHoles, toResumeOrNot, and tProcessed.

ChareMlogData::ChareMlogData ( ) [inline]

Default constructor.

Definition at line 180 of file ckmessagelogging.h.

References immigrantRecFlag, resendReplyRecvd, restartFlag, resumeCount, teamRecoveryFlag, and toResumeOrNot.

Member Function Documentation

MCount ChareMlogData::newTN ( ) [inline, private]

Gets a new ticket for a particular object.

Definition at line 3798 of file ckcausalmlog.C.

References currentHoles, numberHoles, tCount, and ticketHoles.

Referenced by next_ticket().

Here is the caller graph for this function:

MCount ChareMlogData::nextSN ( const CkObjID & recver ) [inline]

Definition at line 3784 of file ckcausalmlog.C.

References CkHashtableT< KEY, OBJ >::getPointer(), CkHashtableTslow< KEY, OBJ >::put(), and snTable.

Referenced by sendCommonMsg().

Here is the call graph for this function:

Here is the caller graph for this function:

Ticket ChareMlogData::next_ticket	(	CkObjID &	sender,
		MCount	SN
	)			`[inline]`

Generates the next ticket for a request.

Definition at line 3851 of file ckcausalmlog.C.

References Converse::CkMyPe(), CmiPrintf(), CmiWallTimer(), SNToTicket::get(), CkHashtableT< KEY, OBJ >::get(), newTN(), objID, CkHashtableTslow< KEY, OBJ >::put(), SNToTicket::put(), restartFlag, Ticket::state, tCount, ticketTable, Ticket::TN, and CkObjID::toString().

Referenced by _getTicket().

Here is the call graph for this function:

Here is the caller graph for this function:

void ChareMlogData::verifyTicket	(	CkObjID &	sender,
		MCount	SN,
		MCount	TN
	)			`[inline]`

Inserts a ticket in the ticketTable if it is not already there.

Definition at line 3830 of file ckcausalmlog.C.

References SNToTicket::get(), CkHashtableT< KEY, OBJ >::get(), SNToTicket::put(), CkHashtableTslow< KEY, OBJ >::put(), ticketTable, and Ticket::TN.

Referenced by _getTicket(), and processReceivedDet().

Here is the call graph for this function:

Here is the caller graph for this function:

Ticket ChareMlogData::getTicket	(	CkObjID &	sender,
		MCount	SN
	)			`[inline]`

Get the ticket associated with a combination of sender and SN, if any.

Definition at line 3817 of file ckcausalmlog.C.

References SNToTicket::get(), CkHashtableT< KEY, OBJ >::get(), and ticketTable.

Referenced by _getTicket().

Here is the call graph for this function:

Here is the caller graph for this function:

void ChareMlogData::addLogEntry ( MlogEntry * entry )

Adds an entry into the message log.

Definition at line 3894 of file ckcausalmlog.C.

References Converse::CkMyPe(), CmiMemoryCheck(), CkQ< T >::enq(), MlogEntry::env, mlog, objID, and CkObjID::toString().

Referenced by sendMsg(), and sendRemoteMsg().

Here is the call graph for this function:

Here is the caller graph for this function:

void ChareMlogData::pup ( PUP::er & p ) [virtual]

Pup method for the metadata.

We are preventing the whole message log to be stored (as proposed by Sayantan for dealing with multiple failures). Then, we only support one failure at a time. Read Sayantan's thesis, sections 4.2 and 4.3 for more details.

Definition at line 3928 of file ckcausalmlog.C.

References Converse::CkMyPe(), CmiMyPe(), CmiPrintf(), currentHoles, CkHashtableIterator::hasNext(), PUP::er::isSizing(), PUP::er::isUnpacking(), CkHashtable::iterator(), name, CkHashtableIterator::next(), numberHoles, CkHashtable::numObjects(), objID, p, SNToTicket::pup(), CkHashtableT< KEY, OBJ >::pup(), CkHashtableTslow< KEY, OBJ >::put(), receivedTNs, resendReplyRecvd, restartFlag, resumeCount, PUP::sizer::size(), snTable, tCount, teamRecoveryFlag, ticketHoles, ticketTable, toResumeOrNot, CkObjID::toString(), and tProcessed.