#include <mpi_module.h>

Inheritance diagram for Realm::MPIModule:

Collaboration diagram for Realm::MPIModule:

Public Member Functions
virtual void	get_shared_peers (NodeSet &shared_peers)

virtual void	parse_command_line (RuntimeImpl *runtime, std::vector< std::string > &cmdline)

virtual void	attach (RuntimeImpl runtime, std::vector< NetworkSegment > &segments)

virtual void	create_memories (RuntimeImpl *runtime)

virtual void	detach (RuntimeImpl runtime, std::vector< NetworkSegment > &segments)

virtual void	barrier (void)

virtual void	broadcast (NodeID root, const void val_in, void val_out, size_t bytes)

virtual void	gather (NodeID root, const void val_in, void vals_out, size_t bytes)

virtual void	allgatherv (const char *val_in, size_t bytes, std::vector< char > &vals_out, std::vector< size_t > &lengths)

virtual void	sample_quiescence_state (QuiescenceState &state)

virtual void	quiescence_allreduce_sum (const uint64_t local_counts, uint64_t total_counts, size_t count)

virtual MemoryImpl *	create_remote_memory (RuntimeImpl *runtime, Memory m, size_t size, Memory::Kind kind, const ByteArray &rdma_info)

virtual IBMemory *	create_remote_ib_memory (RuntimeImpl *runtime, Memory m, size_t size, Memory::Kind kind, const ByteArray &rdma_info)

virtual ActiveMessageImpl *	create_active_message_impl (NodeID target, unsigned short msgid, size_t header_size, size_t max_payload_size, const void src_payload_addr, size_t src_payload_lines, size_t src_payload_line_stride, void storage_base, size_t storage_size)

virtual ActiveMessageImpl *	create_active_message_impl (NodeID target, unsigned short msgid, size_t header_size, size_t max_payload_size, const LocalAddress &src_payload_addr, size_t src_payload_lines, size_t src_payload_line_stride, const RemoteAddress &dest_payload_addr, void *storage_base, size_t storage_size)

virtual ActiveMessageImpl *	create_active_message_impl (NodeID target, unsigned short msgid, size_t header_size, size_t max_payload_size, const RemoteAddress &dest_payload_addr, void *storage_base, size_t storage_size)

virtual ActiveMessageImpl *	create_active_message_impl (const NodeSet &targets, unsigned short msgid, size_t header_size, size_t max_payload_size, const void src_payload_addr, size_t src_payload_lines, size_t src_payload_line_stride, void storage_base, size_t storage_size)

virtual size_t	recommended_max_payload (NodeID target, bool with_congestion, size_t header_size)

virtual size_t	recommended_max_payload (const NodeSet &targets, bool with_congestion, size_t header_size)

virtual size_t	recommended_max_payload (NodeID target, const RemoteAddress &dest_payload_addr, bool with_congestion, size_t header_size)

virtual size_t	recommended_max_payload (NodeID target, const void *data, size_t bytes_per_line, size_t lines, size_t line_stride, bool with_congestion, size_t header_size)

virtual size_t	recommended_max_payload (const NodeSet &targets, const void *data, size_t bytes_per_line, size_t lines, size_t line_stride, bool with_congestion, size_t header_size)

virtual size_t	recommended_max_payload (NodeID target, const LocalAddress &src_payload_addr, size_t bytes_per_line, size_t lines, size_t line_stride, const RemoteAddress &dest_payload_addr, bool with_congestion, size_t header_size)

virtual size_t	max_payload_size (size_t header_size, const void *src_payload_addr)

Public Member Functions inherited from Realm::NetworkModule
virtual bool	custom_quiescence_check (IncomingMessageManager *message_manager, Network::QuiescenceStatus &status)

Public Member Functions inherited from Realm::Module
virtual	~Module (void)

const std::string &	get_name (void) const

virtual void	initialize (RuntimeImpl *runtime)

virtual void	create_processors (RuntimeImpl *runtime)

virtual void	create_dma_channels (RuntimeImpl *runtime)

virtual void	create_code_translators (RuntimeImpl *runtime)

virtual void	pre_detach_cleanup (void)

virtual void	cleanup (void)

Static Public Member Functions
static NetworkModule *	create_network_module (RuntimeImpl runtime, int argc, const char ***argv)

Protected Member Functions
	MPIModule (void)

Protected Member Functions inherited from Realm::NetworkModule
	NetworkModule (const std::string &_name)

Protected Member Functions inherited from Realm::Module
	Module (const std::string &_name)

Protected Attributes
MPI_Win	g_am_win

void **	g_am_bases

size_t	global_mem_size

Protected Attributes inherited from Realm::Module
std::string	name

Constructor & Destructor Documentation

◆ MPIModule()

Realm::MPIModule::MPIModule ( void )

protected

Member Function Documentation

◆ allgatherv()

virtual void Realm::MPIModule::allgatherv	(	const char *	val_in,
		size_t	bytes,
		std::vector< char > &	vals_out,
		std::vector< size_t > &	lengths
	)

virtual

Implements Realm::NetworkModule.

◆ attach()

virtual void Realm::MPIModule::attach	(	RuntimeImpl *	runtime,
		std::vector< NetworkSegment * > &	segments
	)

virtual

Implements Realm::NetworkModule.

◆ barrier()

virtual void Realm::MPIModule::barrier ( void )

virtual

Implements Realm::NetworkModule.

◆ broadcast()

virtual void Realm::MPIModule::broadcast	(	NodeID	root,
		const void *	val_in,
		void *	val_out,
		size_t	bytes
	)

virtual

Implements Realm::NetworkModule.

◆ create_active_message_impl() [1/4]

virtual ActiveMessageImpl * Realm::MPIModule::create_active_message_impl	(	const NodeSet &	targets,
		unsigned short	msgid,
		size_t	header_size,
		size_t	max_payload_size,
		const void *	src_payload_addr,
		size_t	src_payload_lines,
		size_t	src_payload_line_stride,
		void *	storage_base,
		size_t	storage_size
	)

virtual

Implements Realm::NetworkModule.

◆ create_active_message_impl() [2/4]

virtual ActiveMessageImpl * Realm::MPIModule::create_active_message_impl	(	NodeID	target,
		unsigned short	msgid,
		size_t	header_size,
		size_t	max_payload_size,
		const LocalAddress &	src_payload_addr,
		size_t	src_payload_lines,
		size_t	src_payload_line_stride,
		const RemoteAddress &	dest_payload_addr,
		void *	storage_base,
		size_t	storage_size
	)

virtual

Implements Realm::NetworkModule.

◆ create_active_message_impl() [3/4]

virtual ActiveMessageImpl * Realm::MPIModule::create_active_message_impl	(	NodeID	target,
		unsigned short	msgid,
		size_t	header_size,
		size_t	max_payload_size,
		const RemoteAddress &	dest_payload_addr,
		void *	storage_base,
		size_t	storage_size
	)

virtual

Implements Realm::NetworkModule.

◆ create_active_message_impl() [4/4]

virtual ActiveMessageImpl * Realm::MPIModule::create_active_message_impl	(	NodeID	target,
		unsigned short	msgid,
		size_t	header_size,
		size_t	max_payload_size,
		const void *	src_payload_addr,
		size_t	src_payload_lines,
		size_t	src_payload_line_stride,
		void *	storage_base,
		size_t	storage_size
	)

virtual

Implements Realm::NetworkModule.

◆ create_memories()

virtual void Realm::MPIModule::create_memories ( RuntimeImpl * runtime )

virtual

Reimplemented from Realm::Module.

◆ create_network_module()

static NetworkModule * Realm::MPIModule::create_network_module	(	RuntimeImpl *	runtime,
		int *	argc,
		const char ***	argv
	)

static

◆ create_remote_ib_memory()

virtual IBMemory * Realm::MPIModule::create_remote_ib_memory	(	RuntimeImpl *	runtime,
		Memory	m,
		size_t	size,
		Memory::Kind	kind,
		const ByteArray &	rdma_info
	)

virtual

Implements Realm::NetworkModule.

◆ create_remote_memory()

virtual MemoryImpl * Realm::MPIModule::create_remote_memory	(	RuntimeImpl *	runtime,
		Memory	m,
		size_t	size,
		Memory::Kind	kind,
		const ByteArray &	rdma_info
	)

virtual

Implements Realm::NetworkModule.

◆ detach()

virtual void Realm::MPIModule::detach	(	RuntimeImpl *	runtime,
		std::vector< NetworkSegment * > &	segments
	)

virtual

Implements Realm::NetworkModule.

◆ gather()

virtual void Realm::MPIModule::gather	(	NodeID	root,
		const void *	val_in,
		void *	vals_out,
		size_t	bytes
	)

virtual

Implements Realm::NetworkModule.

◆ get_shared_peers()

virtual void Realm::MPIModule::get_shared_peers ( NodeSet & shared_peers )

virtual

Implements Realm::NetworkModule.

◆ max_payload_size()

virtual size_t Realm::MPIModule::max_payload_size	(	size_t	header_size,
		const void *	src_payload_addr
	)

virtual

Implements Realm::NetworkModule.

◆ parse_command_line()

virtual void Realm::MPIModule::parse_command_line	(	RuntimeImpl *	runtime,
		std::vector< std::string > &	cmdline
	)

virtual

Reimplemented from Realm::NetworkModule.

◆ quiescence_allreduce_sum()

virtual void Realm::MPIModule::quiescence_allreduce_sum	(	const uint64_t *	local_counts,
		uint64_t *	total_counts,
		size_t	count
	)

virtual

Implements Realm::NetworkModule.

◆ recommended_max_payload() [1/6]

virtual size_t Realm::MPIModule::recommended_max_payload	(	const NodeSet &	targets,
		bool	with_congestion,
		size_t	header_size
	)

virtual

Implements Realm::NetworkModule.

◆ recommended_max_payload() [2/6]

virtual size_t Realm::MPIModule::recommended_max_payload	(	const NodeSet &	targets,
		const void *	data,
		size_t	bytes_per_line,
		size_t	lines,
		size_t	line_stride,
		bool	with_congestion,
		size_t	header_size
	)

virtual

Implements Realm::NetworkModule.

◆ recommended_max_payload() [3/6]

virtual size_t Realm::MPIModule::recommended_max_payload	(	NodeID	target,
		bool	with_congestion,
		size_t	header_size
	)

virtual

Implements Realm::NetworkModule.

◆ recommended_max_payload() [4/6]

virtual size_t Realm::MPIModule::recommended_max_payload	(	NodeID	target,
		const LocalAddress &	src_payload_addr,
		size_t	bytes_per_line,
		size_t	lines,
		size_t	line_stride,
		const RemoteAddress &	dest_payload_addr,
		bool	with_congestion,
		size_t	header_size
	)

virtual

Implements Realm::NetworkModule.

◆ recommended_max_payload() [5/6]

virtual size_t Realm::MPIModule::recommended_max_payload	(	NodeID	target,
		const RemoteAddress &	dest_payload_addr,
		bool	with_congestion,
		size_t	header_size
	)

virtual

Implements Realm::NetworkModule.

◆ recommended_max_payload() [6/6]

virtual size_t Realm::MPIModule::recommended_max_payload	(	NodeID	target,
		const void *	data,
		size_t	bytes_per_line,
		size_t	lines,
		size_t	line_stride,
		bool	with_congestion,
		size_t	header_size
	)

virtual

Implements Realm::NetworkModule.

◆ sample_quiescence_state()

virtual void Realm::MPIModule::sample_quiescence_state ( QuiescenceState & state )

virtual

Implements Realm::NetworkModule.

Member Data Documentation

◆ g_am_bases

void** Realm::MPIModule::g_am_bases

protected

◆ g_am_win

MPI_Win Realm::MPIModule::g_am_win

protected

◆ global_mem_size

size_t Realm::MPIModule::global_mem_size

protected

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

/home/runner/work/realm/realm/realm-src/src/realm/mpi/mpi_module.h

Public Member Functions

Static Public Member Functions

Protected Member Functions

Protected Attributes

Constructor & Destructor Documentation

◆ MPIModule()

Member Function Documentation

◆ allgatherv()

◆ attach()

◆ barrier()

◆ broadcast()

◆ create_active_message_impl() [1/4]

◆ create_active_message_impl() [2/4]

◆ create_active_message_impl() [3/4]

◆ create_active_message_impl() [4/4]

◆ create_memories()

◆ create_network_module()

◆ create_remote_ib_memory()

◆ create_remote_memory()

◆ detach()

◆ gather()

◆ get_shared_peers()

◆ max_payload_size()

◆ parse_command_line()

◆ quiescence_allreduce_sum()

◆ recommended_max_payload() [1/6]

◆ recommended_max_payload() [2/6]

◆ recommended_max_payload() [3/6]

◆ recommended_max_payload() [4/6]

◆ recommended_max_payload() [5/6]

◆ recommended_max_payload() [6/6]

◆ sample_quiescence_state()

Member Data Documentation

◆ g_am_bases

◆ g_am_win

◆ global_mem_size