mpi_utilities.cpp File Reference

#include "cddefines.h"
#include "save.h"
#include "dynamics.h"
#include "grid.h"
#include "service.h"
#include "rfield.h"

Include dependency graph for mpi_utilities.cpp:

Go to the source code of this file.

Macros
#define	pid_t   int
#define	fork()   TotalInsanityAsStub<pid_t>()
#define	wait(X)   TotalInsanityAsStub<pid_t>()

Functions
STATIC void	GridGatherOutput (const string &, long, const vector< long > &)
STATIC void	GridGatherOutputSequential (const string &, long)
STATIC void	GridGatherOutputParallel (const string &, long, const vector< long > &)
STATIC bool	lgIsRemote (const string &)
STATIC void	check_grid_file (const string &, int, int)
int	total_insanity (MPI_File, int, MPI_Status *)
void	process_output ()
void	append_file (FILE *dest, const char *source)
void	append_file (MPI_File dest, const char *source)

Variables
int	MPI_MODE_RDONLY = 0
int	MPI_MODE_WRONLY = 0
int	MPI_MODE_CREATE = 0
int	MPI_MODE_APPEND = 0
int	MPI_SUCCESS = 0
int	MPI_ERR_INTERN = -1
MPI_File	MPI_FILE_NULL = 0
int	mpi_mode_r = MPI_MODE_RDONLY
int	mpi_mode_w = MPI_MODE_WRONLY | MPI_MODE_CREATE
int	mpi_mode_a = MPI_MODE_WRONLY | MPI_MODE_CREATE | MPI_MODE_APPEND

Macro Definition Documentation

#define fork

(

)

TotalInsanityAsStub<pid_t>()

Definition at line 16 of file mpi_utilities.cpp.

Referenced by load_balance::init().

#define pid_t   int

Definition at line 15 of file mpi_utilities.cpp.

Referenced by load_balance::init().

#define wait

(

X

)

TotalInsanityAsStub<pid_t>()

Definition at line 17 of file mpi_utilities.cpp.

Referenced by load_balance::finalize().

Function Documentation

void append_file	(	FILE *	dest,
		const char *	source
	)

append_file: append output produced on file <source> to open file descriptor <dest>

Definition at line 417 of file mpi_utilities.cpp.

References AS_LOCAL_ONLY_TRY, DEBUG_ENTRY, and open_data().

Referenced by GridGatherOutputParallel(), GridGatherOutputSequential(), optimize_phymir(), phymir_state< X, Y, NP, NSTR >::p_process_output(), and process_output().

Here is the call graph for this function:

void append_file	(	MPI_File	dest,
		const char *	source
	)

append_file: append output produced on file <source> to open file handle <dest> using MPI I/O

Definition at line 441 of file mpi_utilities.cpp.

References AS_LOCAL_ONLY_TRY, DEBUG_ENTRY, MPI_File_write, and open_data().

Here is the call graph for this function:

STATIC void check_grid_file	(	const string &	fnam,
		int	j,
		int	ipPun
	)

check_grid_file: check whether the save file is present and is terminated by a GRID_DELIMIT string

Definition at line 356 of file mpi_utilities.cpp.

References AS_LOCAL_ONLY_TRY, t_save::chHashString, DEBUG_ENTRY, dynamics, GridPointPrefix(), t_save::lg_separate_iterations, t_save::lgFITS, t_save::lgHashEndIter, t_dynamics::lgTimeDependentStatic, mode_a, mode_r, open_data(), and save.

Referenced by process_output().

Here is the call graph for this function:

STATIC void GridGatherOutput	(	const string &	basenam,
		long	nfiles,
		const vector< long > &	bound
	)

Definition at line 236 of file mpi_utilities.cpp.

References cpu, GridGatherOutputParallel(), GridGatherOutputSequential(), t_cpu::i(), lgIsRemote(), t_cpu_i::lgMaster(), and t_cpu_i::lgMPI().

Referenced by process_output().

Here is the call graph for this function:

STATIC void GridGatherOutputParallel	(	const string &	basenam,
		long	nfiles,
		const vector< long > &	bound
	)

Definition at line 265 of file mpi_utilities.cpp.

References append_file(), AS_LOCAL_ONLY_TRY, cpu, GridPointPrefix(), t_cpu::i(), MPI_Bcast, MPI_File_close, MPI_File_get_size, MPI_FILE_NULL, MPI_File_set_view, mpi_mode_a, t_cpu_i::nCPU(), t_cpu_i::nRANK(), and open_data().

Referenced by GridGatherOutput().

Here is the call graph for this function:

STATIC void GridGatherOutputSequential	(	const string &	basenam,
		long	nfiles
	)

Definition at line 248 of file mpi_utilities.cpp.

References append_file(), AS_LOCAL_ONLY_TRY, GridPointPrefix(), and open_data().

Referenced by GridGatherOutput().

Here is the call graph for this function:

STATIC bool lgIsRemote

(

const string &

)

Definition at line 348 of file mpi_utilities.cpp.

Referenced by GridGatherOutput().

void process_output

(

)

process_output: concatenate output files produced in grid run

Definition at line 129 of file mpi_utilities.cpp.

References append_file(), ASSERT, check_grid_file(), t_save::chFileName, t_save::chFilenamePrefix, t_save::chRedirectPrefix, cpu, DEBUG_ENTRY, t_save::FITStype, fprintf(), grid, GridGatherOutput(), GridPointPrefix(), t_cpu::i(), ioQQQ, ipPun, t_grid::lgKeepMainOutputSeparate, t_cpu_i::lgMaster(), t_cpu_i::lgMPI(), t_save::lgSaveToSeparateFiles, t_save::lgXSPEC, t_cpu_i::nCPU(), t_rfield::nflux, t_cpu_i::nRANK(), t_save::nsave, NUM_OUTPUT_TYPES, open_data(), t_save::punarg, rd_block(), rfield, save, saveFITSfile(), t_grid::Spectra, and t_grid::totNumModels.

Referenced by main().

Here is the call graph for this function:

int total_insanity	(	MPI_File	,
		int	,
		MPI_Status *
	)

Definition at line 48 of file mpi_utilities.cpp.

Variable Documentation

int MPI_ERR_INTERN = -1

Definition at line 45 of file mpi_utilities.cpp.

Referenced by open_data().

MPI_File MPI_FILE_NULL = 0

Definition at line 46 of file mpi_utilities.cpp.

Referenced by GridGatherOutputParallel(), and open_data().

int mpi_mode_a = MPI_MODE_WRONLY | MPI_MODE_CREATE | MPI_MODE_APPEND

Definition at line 57 of file mpi_utilities.cpp.

Referenced by GridGatherOutputParallel().

int MPI_MODE_APPEND = 0

Definition at line 42 of file mpi_utilities.cpp.

int MPI_MODE_CREATE = 0

Definition at line 41 of file mpi_utilities.cpp.

int mpi_mode_r = MPI_MODE_RDONLY

Definition at line 55 of file mpi_utilities.cpp.

Referenced by open_data().

int MPI_MODE_RDONLY = 0

Definition at line 39 of file mpi_utilities.cpp.

int mpi_mode_w = MPI_MODE_WRONLY | MPI_MODE_CREATE

Definition at line 56 of file mpi_utilities.cpp.

int MPI_MODE_WRONLY = 0

Definition at line 40 of file mpi_utilities.cpp.

int MPI_SUCCESS = 0

Definition at line 44 of file mpi_utilities.cpp.

Referenced by open_data().