#include <ucp_module.h>

Inheritance diagram for Realm::UCPModule:

Collaboration diagram for Realm::UCPModule:

Public Member Functions
virtual	~UCPModule ()

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	detach (RuntimeImpl runtime, std::vector< NetworkSegment > &segments)

virtual void	create_memories (RuntimeImpl *runtime)

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 size_t	sample_messages_received_count (void)

virtual bool	check_for_quiescence (size_t sampled_receive_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)

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
	UCPModule (Realm::RuntimeImpl *runtime)

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
Realm::UCP::UCPInternal *	internal

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

Constructor & Destructor Documentation

◆ UCPModule()

Realm::UCPModule::UCPModule ( Realm::RuntimeImpl * runtime )

protected

◆ ~UCPModule()

virtual Realm::UCPModule::~UCPModule ( )

virtual

Member Function Documentation

◆ allgatherv()

virtual void Realm::UCPModule::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::UCPModule::attach	(	RuntimeImpl *	runtime,
		std::vector< NetworkSegment * > &	segments
	)

virtual

Implements Realm::NetworkModule.

◆ barrier()

virtual void Realm::UCPModule::barrier ( void )

virtual

Implements Realm::NetworkModule.

◆ broadcast()

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

virtual

Implements Realm::NetworkModule.

◆ check_for_quiescence()

virtual bool Realm::UCPModule::check_for_quiescence ( size_t sampled_receive_count )

virtual

Implements Realm::NetworkModule.

◆ create_active_message_impl() [1/4]

virtual ActiveMessageImpl * Realm::UCPModule::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::UCPModule::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::UCPModule::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::UCPModule::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::UCPModule::create_memories ( RuntimeImpl * runtime )

virtual

Reimplemented from Realm::Module.

◆ create_network_module()

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

static

◆ create_remote_ib_memory()

virtual IBMemory * Realm::UCPModule::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::UCPModule::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::UCPModule::detach	(	RuntimeImpl *	runtime,
		std::vector< NetworkSegment * > &	segments
	)

virtual

Implements Realm::NetworkModule.

◆ gather()

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

virtual

Implements Realm::NetworkModule.

◆ get_shared_peers()

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

virtual

Implements Realm::NetworkModule.

◆ parse_command_line()

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

virtual

Reimplemented from Realm::NetworkModule.

◆ recommended_max_payload() [1/6]

virtual size_t Realm::UCPModule::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::UCPModule::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::UCPModule::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::UCPModule::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::UCPModule::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::UCPModule::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_messages_received_count()

virtual size_t Realm::UCPModule::sample_messages_received_count ( void )

virtual

Implements Realm::NetworkModule.

Member Data Documentation

◆ internal

Realm::UCP::UCPInternal* Realm::UCPModule::internal

protected

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

/home/runner/work/realm/realm/realm-src/src/realm/ucx/ucp_module.h

Public Member Functions

Static Public Member Functions

Protected Member Functions

Protected Attributes

Constructor & Destructor Documentation

◆ UCPModule()

◆ ~UCPModule()

Member Function Documentation

◆ allgatherv()

◆ attach()

◆ barrier()

◆ broadcast()

◆ check_for_quiescence()

◆ 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()

◆ parse_command_line()

◆ 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_messages_received_count()

Member Data Documentation

◆ internal