#include <addrsplit_channel.h>

Inheritance diagram for Realm::AddressSplitXferDes< N, T >:

Collaboration diagram for Realm::AddressSplitXferDes< N, T >:

Public Member Functions
	AddressSplitXferDes (uintptr_t _dma_op, Channel *_channel, NodeID _launch_node, XferDesID _guid, const std::vector< XferDesPortInfo > &inputs_info, const std::vector< XferDesPortInfo > &outputs_info, int _priority, size_t _element_size, const std::vector< IndexSpace< N, T > > &_spaces)

	~AddressSplitXferDes ()=default

virtual Event	request_metadata ()

virtual bool	progress_xd (AddressSplitChannel *channel, TimeLimit work_until)

Public Member Functions inherited from Realm::AddressSplitXferDesBase
long	get_requests (Request **requests, long nr)

void	notify_request_read_done (Request *req)

void	notify_request_write_done (Request *req)

void	flush ()

Public Member Functions inherited from Realm::XferDes
	REALM_ALIGNED_TYPE_CONST (AlignedStorage, UnalignedStorage, 16)

	REALM_PMTA_DEFN (XferDes, IntrusivePriorityListLink< XferDes >, xd_link)

	REALM_PMTA_DEFN (XferDes, int, priority)

	XferDes (uintptr_t _dma_op, Channel _channel, NodeID _launch_node, XferDesID _guid, const std::vector< XferDesPortInfo > &inputs_info, const std::vector< XferDesPortInfo > &outputs_info, int _priority, const void _fill_data, size_t fill_size)

void	add_reference (void)

void	remove_reference (void)

void	add_update_pre_bytes_total_received (void)

long	default_get_requests (Request **requests, long nr, unsigned flags=0)

void	default_notify_request_read_done (Request *req)

void	default_notify_request_write_done (Request *req)

virtual void	update_bytes_read (int port_idx, size_t offset, size_t size)

virtual void	update_bytes_write (int port_idx, size_t offset, size_t size)

void	update_pre_bytes_write (int port_idx, size_t offset, size_t size)

void	update_pre_bytes_total (int port_idx, size_t pre_bytes_total)

void	update_next_bytes_read (int port_idx, size_t offset, size_t size)

void	begin_completion ()

void	mark_completed ()

unsigned	current_progress (void)

bool	check_for_progress (unsigned last_counter)

void	update_progress (void)

virtual bool	request_available ()

virtual Request *	dequeue_request ()

virtual void	enqueue_request (Request *req)

size_t	update_control_info (ReadSequenceCache *rseqcache)

size_t	get_addresses (size_t min_xfer_size, ReadSequenceCache *rseqcache)

size_t	get_addresses (size_t min_xfer_size, ReadSequenceCache rseqcache, const InstanceLayoutPieceBase &in_nonaffine, const InstanceLayoutPieceBase *&out_nonaffine)

bool	record_address_consumption (size_t total_read_bytes, size_t total_write_bytes)

void	replicate_fill_data (size_t new_size)

Protected Member Functions
int	find_point_in_spaces (Point< N, T > p, int guess_idx) const

Protected Member Functions inherited from Realm::AddressSplitXferDesBase
	AddressSplitXferDesBase (uintptr_t dma_op, Channel *_channel, NodeID _launch_node, XferDesID _guid, const std::vector< XferDesPortInfo > &inputs_info, const std::vector< XferDesPortInfo > &outputs_info, int _priority)

Protected Member Functions inherited from Realm::XferDes
virtual	~XferDes ()

Protected Attributes
std::vector< IndexSpace< N, T > >	spaces

size_t	element_size

size_t	point_index

size_t	point_count

Point< N, T >	points [MAX_POINTS]

int	output_space_id

unsigned	output_count

ControlPort::Encoder	ctrl_encoder

Protected Attributes inherited from Realm::XferDes
Mutex	available_req_mutex

std::queue< Request * >	available_reqs

Static Protected Attributes
static constexpr size_t	MAX_POINTS = 64

Additional Inherited Members
Public Types inherited from Realm::XferDes
enum	{ XFERDES_NO_GUID = 0 }

typedef IntrusivePriorityList< XferDes, int, REALM_PMTA_USE(XferDes, xd_link), REALM_PMTA_USE(XferDes, priority), DummyLock >	XferDesList

typedef SequenceCache<&XferDes::update_bytes_read >	ReadSequenceCache

typedef SequenceCache<&XferDes::update_bytes_write >	WriteSequenceCache

Public Attributes inherited from Realm::XferDes
uintptr_t	dma_op

XferDesQueue *	xferDes_queue

NodeID	launch_node

atomic< bool >	iteration_completed

atomic< int64_t >	bytes_write_pending

atomic< bool >	transfer_completed

uint64_t	current_in_port_mask

uint64_t	current_out_port_mask

uint64_t	current_in_port_remain

uint64_t	current_out_port_remain

std::vector< XferPort >	input_ports

std::vector< XferPort >	output_ports

ControlPortState	input_control

ControlPortState	output_control

uint64_t	max_req_size

int	priority

XferDesID	guid

XferDesKind	kind

Channel *	channel

void *	fill_data

size_t	fill_size

size_t	orig_fill_size

AlignedStorage	inline_fill_storage

Mutex	xd_lock

Mutex	update_read_lock

Mutex	update_write_lock

atomic< unsigned >	progress_counter

atomic< unsigned >	reference_count

unsigned	nb_update_pre_bytes_total_calls_expected

atomic< unsigned >	nb_update_pre_bytes_total_calls_received

IntrusivePriorityListLink< XferDes >	xd_link

DeferredXDEnqueue	deferred_enqueue

Static Public Attributes inherited from Realm::XferDes
static const size_t	ALIGNED_FILL_STORAGE_SIZE = 32

Constructor & Destructor Documentation

◆ AddressSplitXferDes()

template<int N, typename T >

Realm::AddressSplitXferDes< N, T >::AddressSplitXferDes	(	uintptr_t	_dma_op,
		Channel *	_channel,
		NodeID	_launch_node,
		XferDesID	_guid,
		const std::vector< XferDesPortInfo > &	inputs_info,
		const std::vector< XferDesPortInfo > &	outputs_info,
		int	_priority,
		size_t	_element_size,
		const std::vector< IndexSpace< N, T > > &	_spaces
	)

◆ ~AddressSplitXferDes()

template<int N, typename T >

Realm::AddressSplitXferDes< N, T >::~AddressSplitXferDes ( )

default

Member Function Documentation

◆ find_point_in_spaces()

template<int N, typename T >

int Realm::AddressSplitXferDes< N, T >::find_point_in_spaces	(	Point< N, T >	p,
		int	guess_idx
	)		const

protected

◆ progress_xd()

template<int N, typename T >

virtual bool Realm::AddressSplitXferDes< N, T >::progress_xd	(	AddressSplitChannel *	channel,
		TimeLimit	work_until
	)

virtual

Implements Realm::AddressSplitXferDesBase.

◆ request_metadata()

template<int N, typename T >

virtual Event Realm::AddressSplitXferDes< N, T >::request_metadata ( )

virtual

Reimplemented from Realm::XferDes.

Member Data Documentation

◆ ctrl_encoder

template<int N, typename T >

ControlPort::Encoder Realm::AddressSplitXferDes< N, T >::ctrl_encoder

protected

◆ element_size

template<int N, typename T >

size_t Realm::AddressSplitXferDes< N, T >::element_size

protected

◆ MAX_POINTS

template<int N, typename T >

constexpr size_t Realm::AddressSplitXferDes< N, T >::MAX_POINTS = 64

staticconstexprprotected

◆ output_count

template<int N, typename T >

unsigned Realm::AddressSplitXferDes< N, T >::output_count

protected

◆ output_space_id

template<int N, typename T >

int Realm::AddressSplitXferDes< N, T >::output_space_id

protected

◆ point_count

template<int N, typename T >

size_t Realm::AddressSplitXferDes< N, T >::point_count

protected

◆ point_index

template<int N, typename T >

size_t Realm::AddressSplitXferDes< N, T >::point_index

protected

◆ points

template<int N, typename T >

Point<N, T> Realm::AddressSplitXferDes< N, T >::points[MAX_POINTS]

protected

◆ spaces

template<int N, typename T >

std::vector<IndexSpace<N, T> > Realm::AddressSplitXferDes< N, T >::spaces

protected

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

/home/runner/work/realm/realm/realm-src/src/realm/transfer/addrsplit_channel.h

Public Member Functions

Protected Member Functions

Protected Attributes

Static Protected Attributes

Additional Inherited Members

Constructor & Destructor Documentation

◆ AddressSplitXferDes()

◆ ~AddressSplitXferDes()

Member Function Documentation

◆ find_point_in_spaces()

◆ progress_xd()

◆ request_metadata()

Member Data Documentation

◆ ctrl_encoder

◆ element_size

◆ MAX_POINTS

◆ output_count

◆ output_space_id

◆ point_count

◆ point_index

◆ points

◆ spaces