comm_service Class Reference

#include <CommServer.h>

Inheritance diagram for comm_service:

List of all members.

Public Member Functions
MPI_Request *	req (void) const
int	tag (void) const
Static Public Member Functions
static int	init (MPI_Comm c=0)
static void	clean ()
static void	kill ()
static int	serve (MPI_Request)
static int	serve (bool nonblocking=true)
static std::ofstream &	flog (void)
static std::ostream &	log (void)
static int	dce (void)
static int	proc_me (void)
static int	proc_num (void)
static MPI_Comm	comm (void)
static MPI_Group	grp (void)
static int	num_services (void)
static int	comminit (void)
static void	set_comminit (void)
static void	reset_comminit (void)
static int	io_enabled (void)
static void	set_io_enable (void)
static void	reset_io_enable (void)
static int	proc_io (void)
static MPI_Comm	comm_io (void)
static MPI_Comm	comm_world (void)
static int	proc_world (void)
static MPI_Group	grp_world (void)
static MPI_Comm	comm (int const id)
static int	num_comm (void)
static void	add_comm (int const id)
static void	delete_comm (int const id)
static void	reset_comm (int const id)
static void	inc_commarray (int const inc)
static double	idle_time (void)
static double	srvc_time (void)
static void	error_msg (const char who[], const char what[], int R)
static void	error_die (const char who[], const char what[], int R)
Protected Member Functions
	comm_service (const int I, const int T, const int S=MPI_ANY_SOURCE)
	comm_service ()
virtual	~comm_service ()
virtual void	callrecv (const MPI_Status &)
virtual const char *	name (void) const
void	setreq (const int, const int, const int)
Protected Attributes
const int	Id
const int	Tag
const int	Src

---

Constructor & Destructor Documentation

comm_service::comm_service	(	const int	I,
		const int	T,
		const int	S = MPI_ANY_SOURCE
	)			[protected]

References CommIncrement, flog(), Id, init(), Src, and Tag.

comm_service::comm_service

(

)

[protected]

References CommIncrement, flog(), and init().

comm_service::~comm_service

(

)

[protected, virtual]

References CommIncrement, flog(), Id, Src, and Tag.

---

Member Function Documentation

void comm_service::add_comm

(

int const

id

)

[static]

Referenced by GridHierarchy::DAGH_AddGridFunction().

void comm_service::callrecv

(

const MPI_Status &

MS

)

[protected, virtual]

Reimplemented in DAGHIOServerRcv, DAGHIOServerSnd, DAGHIOServerPing, GridTableGhostRcv, and GridTableDataRcv.

References flog().

Referenced by serve().

void comm_service::clean

(

void

)

[static]

References flog(), proc_io(), proc_me(), and serve().

Referenced by kill().

static MPI_Comm comm_service::comm

(

int const

id

)

[inline, static]

static MPI_Comm comm_service::comm

(

void

)

[inline, static]

Referenced by GridTableGhostRcv::callrecvNpost(), GridTableDataRcv::callrecvNpost(), GridHierarchy::DAGH_RecomposeHierarchy(), GridFunction< GFType, dim >::GF_maxval(), GridFunction< GFType, dim >::GF_minval(), GridFunction< GFType, dim >::GF_norm(), GridFunction< GFType, dim >::GF_product(), GridFunction< GFType, dim >::GF_sum(), GridTableGhostRcv::postrcv(), GridTableDataRcv::postrcv(), and GridTable::send().

static MPI_Comm comm_service::comm_io

(

void

)

[inline, static]

Referenced by DAGHIOServerPing::callrecv(), DAGHIOServerSnd::callrecv(), DAGHIOServerRcv::callrecv(), DAGHIOServerPing::DAGHIOServerPing(), DAGHIOServerRcv::DAGHIOServerRcv(), DAGHIOServerSnd::DAGHIOServerSnd(), GridFunction< GFType, dim >::GF_Read(), GridFunction< GFType, dim >::GF_Write(), and DAGHIOServerSnd::snd_update().

static MPI_Comm comm_service::comm_world

(

void

)

[inline, static]

static int comm_service::comminit

(

void

)

[inline, static]

Referenced by DAGHIOServerPing::callrecv(), and GridHierarchy::DAGH_IOServe().

static int comm_service::dce

(

void

)

[inline, static]

Referenced by GridHierarchy::DAGH_AddGridFunction(), GridHierarchy::DAGH_DelGridFunction(), GridHierarchy::DAGH_RecomposeHierarchy(), GridFunction< GFType, dim >::GF_maxval(), GridFunction< GFType, dim >::GF_minval(), GridFunction< GFType, dim >::GF_norm(), GridFunction< GFType, dim >::GF_product(), and GridFunction< GFType, dim >::GF_sum().

void comm_service::delete_comm

(

int const

id

)

[static]

Referenced by GridHierarchy::DAGH_DelGridFunction().

void comm_service::error_die	(	const char	who[],
		const char	what[],
		int	R
	)			[static]

References error_msg().

Referenced by DAGHIOServerPing::callrecv(), DAGHIOServerSnd::callrecv(), DAGHIOServerRcv::callrecv(), GridTableGhostRcv::callrecvNpost(), GridTableDataRcv::callrecvNpost(), DAGHIOServerPing::DAGHIOServerPing(), DAGHIOServerRcv::DAGHIOServerRcv(), DAGHIOServerSnd::DAGHIOServerSnd(), GridFunction< GFType, dim >::GF_maxval(), GridFunction< GFType, dim >::GF_minval(), GridFunction< GFType, dim >::GF_norm(), GridFunction< GFType, dim >::GF_product(), GridFunction< GFType, dim >::GF_Read(), GridFunction< GFType, dim >::GF_sum(), GridFunction< GFType, dim >::GF_Write(), GridTableGhostRcv::postrcv(), GridTableDataRcv::postrcv(), GridTable::send(), serve(), and DAGHIOServerSnd::snd_update().

void comm_service::error_msg	(	const char	who[],
		const char	what[],
		int	R
	)			[static]

Referenced by error_die().

std::ofstream & comm_service::flog

(

void

)

[static]

Referenced by callrecv(), clean(), comm_service(), init(), kill(), serve(), and ~comm_service().

static MPI_Group comm_service::grp

(

void

)

[inline, static]

static MPI_Group comm_service::grp_world

(

void

)

[inline, static]

static double comm_service::idle_time

(

void

)

[inline, static]

void comm_service::inc_commarray

(

int const

inc

)

[static]

Referenced by GridHierarchy::DAGH_AddGridFunction().

int comm_service::init

(

MPI_Comm

c = 0

)

[static]

References CommIncrement, and flog().

Referenced by comm_service(), and if().

static int comm_service::io_enabled

(

void

)

[inline, static]

Referenced by GridHierarchy::DAGH_ComposeHierarchy(), DAGHIO_HDF_NCSA_Write(), GridFunction< GFType, dim >::GF_Read(), and GridFunction< GFType, dim >::GF_Write().

void comm_service::kill

(

void

)

[static]

References clean(), and flog().

static std::ostream& comm_service::log

(

void

)

[inline, static]

Referenced by GridData< Type, 3 >::allocate(), GridData< Type, 2 >::allocate(), GridData< Type, 1 >::allocate(), DAGHIOServerPing::callrecv(), DAGHIOServerSnd::callrecv(), DAGHIOServerRcv::callrecv(), GridTableGhostRcv::callrecvNpost(), GridTableDataRcv::callrecvNpost(), GridHierarchy::DAGH_ComposeHierarchy(), GridHierarchy::DAGH_CreateGridUnitList(), GridHierarchy::DAGH_IOServe(), GridHierarchy::DAGH_RecomposeHierarchy(), GridHierarchy::DAGH_Refine(), DAGHCluster(), DAGHIO_HDF_NCSA_Read(), DAGHIO_HDF_NCSA_Write(), DAGHIOServerPing::DAGHIOServerPing(), DAGHIOServerRcv::DAGHIOServerRcv(), DAGHIOServerSnd::DAGHIOServerSnd(), DataBucketVoid::DataBucketVoid(), GridFunction< GFType, dim >::GF_AdaptiveBndryUpdate(), GridFunction< GFType, dim >::GF_ExternalBndryUpdate(), GridFunction< GFType, dim >::GF_maxval(), GridFunction< GFType, dim >::GF_minval(), GridFunction< GFType, dim >::GF_norm(), GridFunction< GFType, dim >::GF_product(), GridFunction< GFType, dim >::GF_Read(), GridFunction< GFType, dim >::GF_ReadGhosts(), GridFunction< GFType, dim >::GF_sum(), GridFunction< GFType, dim >::GF_Write(), GridFunction< GFType, dim >::GF_WriteGhosts(), GridData< Type, 3 >::GridData(), GridData< Type, 2 >::GridData(), GridData< Type, 1 >::GridData(), GridTableGhostRcv::postrcv(), GridTableDataRcv::postrcv(), GridTableGhostRcv::rcv_update(), GridTableDataRcv::rcv_update(), DAGHIOServerRcv::rcv_update(), AllocError::ReportAllocError(), GridTable::send(), and DAGHIOServerSnd::snd_update().

const char * comm_service::name

(

void

)

const [protected, virtual]

Reimplemented in DAGHIOServerRcv, DAGHIOServerSnd, DAGHIOServerPing, GridTableGhostRcv, and GridTableDataRcv.

Referenced by serve().

static int comm_service::num_comm

(

void

)

[inline, static]

Referenced by GridHierarchy::DAGH_AddGridFunction().

static int comm_service::num_services

(

void

)

[inline, static]

static int comm_service::proc_io

(

void

)

[inline, static]

Referenced by clean(), GridHierarchy::DAGH_ComposeHierarchy(), GridFunction< GFType, dim >::GF_Read(), and GridFunction< GFType, dim >::GF_Write().

static int comm_service::proc_me

(

void

)

[inline, static]

Referenced by DAGHIOServerPing::callrecv(), DAGHIOServerSnd::callrecv(), DAGHIOServerRcv::callrecv(), GridTableGhostRcv::callrecvNpost(), GridTableDataRcv::callrecvNpost(), clean(), GridHierarchy::DAGH_Checkpoint(), GridHierarchy::DAGH_ComposeHierarchy(), GridHierarchy::DAGH_IOServe(), GridHierarchy::DAGH_RecomposeHierarchy(), DAGHIOServerPing::DAGHIOServerPing(), DAGHIOServerRcv::DAGHIOServerRcv(), DAGHIOServerSnd::DAGHIOServerSnd(), GridFunction< GFType, dim >::GF_CheckpointRestart(), GridFunction< GFType, dim >::GF_maxval(), GridFunction< GFType, dim >::GF_minval(), GridFunction< GFType, dim >::GF_norm(), GridFunction< GFType, dim >::GF_product(), GridFunction< GFType, dim >::GF_Read(), GridFunction< GFType, dim >::GF_ReadGhosts(), GridFunction< GFType, dim >::GF_sum(), GridFunction< GFType, dim >::GF_Write(), GridFunction< GFType, dim >::GF_WriteGhosts(), GridTableGhostRcv::postrcv(), GridTableDataRcv::postrcv(), GridTableGhostRcv::rcv_update(), GridTableDataRcv::rcv_update(), DAGHIOServerRcv::rcv_update(), AllocError::ReportAllocError(), GridTable::send(), and DAGHIOServerSnd::snd_update().

static int comm_service::proc_num

(

void

)

[inline, static]

Referenced by DAGHIOServerPing::callrecv(), DAGHIOServerSnd::callrecv(), DAGHIOServerRcv::callrecv(), GridHierarchy::DAGH_ComposeHierarchy(), GridHierarchy::DAGH_OpenChkptOStream(), GridHierarchy::DAGH_RecomposeHierarchy(), DAGHIO_HDF_NCSA_Write(), GridDataBlock< Type, dim >::gdbPrintData(), GridFunction< GFType, dim >::GF_CheckpointRestart(), GridFunction< GFType, dim >::GF_maxval(), GridFunction< GFType, dim >::GF_minval(), GridFunction< GFType, dim >::GF_norm(), GridFunction< GFType, dim >::GF_product(), GridFunction< GFType, dim >::GF_ReadGhosts(), GridFunction< GFType, dim >::GF_sum(), GridFunction< GFType, dim >::GF_WriteGhosts(), GridFunction< GFType, dim >::GridFunction(), and GridDataBlock< Type, dim >::MemoryUsage().

static int comm_service::proc_world

(

void

)

[inline, static]

Referenced by GridHierarchy::DAGH_ComposeHierarchy(), GridHierarchy::DAGH_RecomposeHierarchy(), GridFunction< GFType, dim >::GF_Read(), and GridFunction< GFType, dim >::GF_Write().

MPI_Request* comm_service::req

(

void

)

const [inline]

Referenced by DAGHIOServerPing::callrecv(), DAGHIOServerSnd::callrecv(), DAGHIOServerRcv::callrecv(), GridTableGhostRcv::callrecvNpost(), GridTableDataRcv::callrecvNpost(), GridHierarchy::DAGH_IOServe(), DAGHIOServerPing::DAGHIOServerPing(), DAGHIOServerRcv::DAGHIOServerRcv(), DAGHIOServerSnd::DAGHIOServerSnd(), GridTableDataRcv::GridTableDataRcv(), GridTableGhostRcv::GridTableGhostRcv(), GridTableGhostRcv::postrcv(), and GridTableDataRcv::postrcv().

void comm_service::reset_comm

(

int const

id

)

[static]

Referenced by GridHierarchy::DAGH_RecomposeHierarchy().

static void comm_service::reset_comminit

(

void

)

[inline, static]

static void comm_service::reset_io_enable

(

void

)

[inline, static]

int comm_service::serve

(

bool

nonblocking = true

)

[static]

References callrecv(), COUNT, flog(), and name().

int comm_service::serve

(

MPI_Request

req_in

)

[static]

References callrecv(), COUNT, error_die(), flog(), and name().

Referenced by DAGHIOServerSnd::callrecv(), DAGHIOServerRcv::callrecv(), clean(), GridHierarchy::DAGH_IOServe(), GridFunction< GFType, dim >::GF_Read(), GridFunction< GFType, dim >::GF_ReadGhosts(), GridFunction< GFType, dim >::GF_Write(), GridTable::send(), and DAGHIOServerSnd::snd_update().

static void comm_service::set_comminit

(

void

)

[inline, static]

static void comm_service::set_io_enable

(

void

)

[inline, static]

void comm_service::setreq	(	const int	I,
		const int	T,
		const int	S
	)			[protected]

Referenced by GridTableDataRcv::GridTableDataRcv(), and GridTableGhostRcv::GridTableGhostRcv().

static double comm_service::srvc_time

(

void

)

[inline, static]

int comm_service::tag

(

void

)

const [inline]

References Tag.

---

Member Data Documentation

const int comm_service::Id [protected]

Referenced by GridTableGhostRcv::callrecvNpost(), GridTableDataRcv::callrecvNpost(), comm_service(), GridTableDataRcv::GridTableDataRcv(), GridTableGhostRcv::GridTableGhostRcv(), GridTableGhostRcv::postrcv(), GridTableDataRcv::postrcv(), and ~comm_service().

const int comm_service::Src [protected]

Referenced by GridTableGhostRcv::callrecvNpost(), GridTableDataRcv::callrecvNpost(), comm_service(), GridTableDataRcv::GridTableDataRcv(), GridTableGhostRcv::GridTableGhostRcv(), GridTableGhostRcv::postrcv(), GridTableDataRcv::postrcv(), and ~comm_service().

const int comm_service::Tag [protected]

Referenced by DAGHIOServerPing::callrecv(), DAGHIOServerSnd::callrecv(), DAGHIOServerRcv::callrecv(), GridTableGhostRcv::callrecvNpost(), GridTableDataRcv::callrecvNpost(), comm_service(), DAGHIOServerPing::DAGHIOServerPing(), DAGHIOServerRcv::DAGHIOServerRcv(), DAGHIOServerSnd::DAGHIOServerSnd(), GridTableDataRcv::GridTableDataRcv(), GridTableGhostRcv::GridTableGhostRcv(), GridTableGhostRcv::postrcv(), GridTableDataRcv::postrcv(), tag(), and ~comm_service().

---

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

• amroc/hds/CommServer.h
• amroc/hds/src/CommServer.C
• amroc/hds/src/DAGHStatics.C