#include <coordinatorapi.h>

Public Member Functions
	CoordinatorAPI (void)

void	setupVirtualCoordinator (CoordinatorInfo coordInfo, struct in_addr localIP)

void	waitForCheckpointCommand ()

void	connectToCoordOnStartup (CoordinatorMode mode, string progname, DmtcpUniqueProcessId compId, CoordinatorInfo coordInfo, struct in_addr *localIP)

void	createNewConnectionBeforeFork (string &progname)

void	connectToCoordOnRestart (CoordinatorMode mode, string progname, UniquePid compGroup, int np, CoordinatorInfo coordInfo, const char host, int port, struct in_addr *localIP)

void	closeConnection ()

bool	isValid ()

void	sendMsgToCoordinator (const DmtcpMessage &msg, const void *extraData=NULL, size_t len=0)

void	recvMsgFromCoordinator (DmtcpMessage msg, void *extraData=NULL)

void	connectAndSendUserCommand (char c, int coordCmdStatus=NULL, int numPeers=NULL, int isRunning=NULL, int ckptInterval=NULL)

void	updateCoordCkptDir (const char *dir)

string	getCoordCkptDir (void)

void	sendCkptFilename ()

int	sendKeyValPairToCoordinator (const char id, const void key, uint32_t key_len, const void *val, uint32_t val_len, int sync=0)

int	sendQueryToCoordinator (const char id, const void key, uint32_t key_len, void val, uint32_t val_len)

Static Public Member Functions
static void *	operator new (size_t nbytes, void *p)

static void *	operator new (size_t nbytes)

static void	operator delete (void *p)

static CoordinatorAPI &	instance ()

static void	init ()

static void	restart ()

static void	resetOnFork (CoordinatorAPI &coordAPI)

static bool	noCoordinator ()

Detailed Description

Definition at line 42 of file coordinatorapi.h.

Constructor & Destructor Documentation

dmtcp::CoordinatorAPI::CoordinatorAPI ( void )

inline

Definition at line 50 of file coordinatorapi.h.

Member Function Documentation

void dmtcp::CoordinatorAPI::closeConnection ( )

inline

Definition at line 77 of file coordinatorapi.h.

void CoordinatorAPI::connectAndSendUserCommand	(	char	c,
		int *	coordCmdStatus = `NULL`,
		int *	numPeers = `NULL`,
		int *	isRunning = `NULL`,
		int *	ckptInterval = `NULL`
	)

Definition at line 288 of file coordinatorapi.cpp.

void CoordinatorAPI::connectToCoordOnRestart	(	CoordinatorMode	mode,
		string	progname,
		UniquePid	compGroup,
		int	np,
		CoordinatorInfo *	coordInfo,
		const char *	host,
		int	port,
		struct in_addr *	localIP
	)

Definition at line 580 of file coordinatorapi.cpp.

void CoordinatorAPI::connectToCoordOnStartup	(	CoordinatorMode	mode,
		string	progname,
		DmtcpUniqueProcessId *	compId,
		CoordinatorInfo *	coordInfo,
		struct in_addr *	localIP
	)

Definition at line 519 of file coordinatorapi.cpp.

void CoordinatorAPI::createNewConnectionBeforeFork ( string & progname)

Definition at line 558 of file coordinatorapi.cpp.

string CoordinatorAPI::getCoordCkptDir ( void )

Definition at line 344 of file coordinatorapi.cpp.

void CoordinatorAPI::init ( )

static

Definition at line 116 of file coordinatorapi.cpp.

CoordinatorAPI & CoordinatorAPI::instance ( )

static

Definition at line 104 of file coordinatorapi.cpp.

bool dmtcp::CoordinatorAPI::isValid ( )

inline

Definition at line 80 of file coordinatorapi.h.

bool CoordinatorAPI::noCoordinator ( )

static

Definition at line 271 of file coordinatorapi.cpp.

static void dmtcp::CoordinatorAPI::operator delete ( void * p)

inlinestatic

Definition at line 48 of file coordinatorapi.h.

static void* dmtcp::CoordinatorAPI::operator new	(	size_t	nbytes,
		void *	p
	)

inlinestatic

Definition at line 46 of file coordinatorapi.h.

static void* dmtcp::CoordinatorAPI::operator new ( size_t nbytes)

inlinestatic

Definition at line 47 of file coordinatorapi.h.

void CoordinatorAPI::recvMsgFromCoordinator	(	DmtcpMessage *	msg,
		void **	extraData = `NULL`
	)

Definition at line 385 of file coordinatorapi.cpp.

void CoordinatorAPI::resetOnFork ( CoordinatorAPI & coordAPI)

static

Definition at line 133 of file coordinatorapi.cpp.

void CoordinatorAPI::restart ( )

static

Definition at line 70 of file coordinatorapi.cpp.

void CoordinatorAPI::sendCkptFilename ( )

Definition at line 620 of file coordinatorapi.cpp.

int CoordinatorAPI::sendKeyValPairToCoordinator	(	const char *	id,
		const void *	key,
		uint32_t	key_len,
		const void *	val,
		uint32_t	val_len,
		int	sync = `0`
	)

Definition at line 640 of file coordinatorapi.cpp.

void CoordinatorAPI::sendMsgToCoordinator	(	const DmtcpMessage &	msg,
		const void *	extraData = `NULL`,
		size_t	len = `0`
	)

Definition at line 372 of file coordinatorapi.cpp.

int CoordinatorAPI::sendQueryToCoordinator	(	const char *	id,
		const void *	key,
		uint32_t	key_len,
		void *	val,
		uint32_t *	val_len
	)

Definition at line 685 of file coordinatorapi.cpp.

void CoordinatorAPI::setupVirtualCoordinator	(	CoordinatorInfo *	coordInfo,
		struct in_addr *	localIP
	)

Definition at line 156 of file coordinatorapi.cpp.

void CoordinatorAPI::updateCoordCkptDir ( const char * dir)

Definition at line 362 of file coordinatorapi.cpp.

void CoordinatorAPI::waitForCheckpointCommand ( )

Definition at line 187 of file coordinatorapi.cpp.

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

src/coordinatorapi.h
src/coordinatorapi.cpp

Public Member Functions

Static Public Member Functions

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation