dmtcp::DmtcpCoordinator Class Reference

#include <dmtcp_coordinator.h>

Classes
struct	ComputationStatus

Public Member Functions
void	onData (CoordClient *client)
void	onConnect ()
void	onDisconnect (CoordClient *client)
void	eventLoop (bool daemon)
void	addDataSocket (CoordClient *client)
void	updateCheckpointInterval (uint32_t timeout)
void	updateMinimumState (WorkerState oldState)
void	initializeComputation ()
void	broadcastMessage (DmtcpMessageType type, int numPeers=-1)
bool	startCheckpoint ()
void	handleUserCommand (char cmd, DmtcpMessage *reply=NULL)
void	printStatus (size_t numPeers, bool isRunning)
void	processDmtUserCmd (DmtcpMessage &hello_remote, jalib::JSocket &remote)
bool	validateNewWorkerProcess (DmtcpMessage &hello_remote, jalib::JSocket &remote, CoordClient *client, const struct sockaddr_storage *addr, socklen_t len)
bool	validateRestartingWorkerProcess (DmtcpMessage &hello_remote, jalib::JSocket &remote, const struct sockaddr_storage *addr, socklen_t len)
ComputationStatus	getStatus () const
WorkerState	minimumState () const
pid_t	getNewVirtualPid ()

Protected Member Functions
void	writeRestartScript ()

Detailed Description

Definition at line 72 of file dmtcp_coordinator.h.

Member Function Documentation

void DmtcpCoordinator::addDataSocket

(

CoordClient *

client)

Definition at line 1741 of file dmtcp_coordinator.cpp.

void DmtcpCoordinator::broadcastMessage	(	DmtcpMessageType	type,
		int	numPeers = -1
	)

Definition at line 1311 of file dmtcp_coordinator.cpp.

void DmtcpCoordinator::eventLoop

(

bool

daemon)

Definition at line 1663 of file dmtcp_coordinator.cpp.

pid_t DmtcpCoordinator::getNewVirtualPid

(

)

Definition at line 512 of file dmtcp_coordinator.cpp.

DmtcpCoordinator::ComputationStatus DmtcpCoordinator::getStatus

(

)

const

Definition at line 1334 of file dmtcp_coordinator.cpp.

void DmtcpCoordinator::handleUserCommand	(	char	cmd,
		DmtcpMessage *	reply = NULL
	)

Definition at line 531 of file dmtcp_coordinator.cpp.

void DmtcpCoordinator::initializeComputation

(

)

Definition at line 939 of file dmtcp_coordinator.cpp.

WorkerState dmtcp::DmtcpCoordinator::minimumState ( ) const

inline

Definition at line 110 of file dmtcp_coordinator.h.

void DmtcpCoordinator::onConnect

(

)

Definition at line 957 of file dmtcp_coordinator.cpp.

void DmtcpCoordinator::onData

(

CoordClient *

client)

Definition at line 764 of file dmtcp_coordinator.cpp.

void DmtcpCoordinator::onDisconnect

(

CoordClient *

client)

Definition at line 900 of file dmtcp_coordinator.cpp.

void DmtcpCoordinator::printStatus	(	size_t	numPeers,
		bool	isRunning
	)

Definition at line 632 of file dmtcp_coordinator.cpp.

void DmtcpCoordinator::processDmtUserCmd	(	DmtcpMessage &	hello_remote,
		jalib::JSocket &	remote
	)

Definition at line 1087 of file dmtcp_coordinator.cpp.

bool DmtcpCoordinator::startCheckpoint

(

)

Definition at line 1281 of file dmtcp_coordinator.cpp.

void DmtcpCoordinator::updateCheckpointInterval

(

uint32_t

timeout)

Definition at line 1651 of file dmtcp_coordinator.cpp.

void DmtcpCoordinator::updateMinimumState

(

WorkerState

oldState)

Definition at line 657 of file dmtcp_coordinator.cpp.

bool DmtcpCoordinator::validateNewWorkerProcess	(	DmtcpMessage &	hello_remote,
		jalib::JSocket &	remote,
		CoordClient *	client,
		const struct sockaddr_storage *	addr,
		socklen_t	len
	)

Definition at line 1192 of file dmtcp_coordinator.cpp.

bool DmtcpCoordinator::validateRestartingWorkerProcess	(	DmtcpMessage &	hello_remote,
		jalib::JSocket &	remote,
		const struct sockaddr_storage *	addr,
		socklen_t	len
	)

Definition at line 1115 of file dmtcp_coordinator.cpp.

void DmtcpCoordinator::writeRestartScript ( )

protected

Definition at line 1367 of file dmtcp_coordinator.cpp.

---

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

• src/dmtcp_coordinator.h
• src/dmtcp_coordinator.cpp