Realm::HDF5::HDF5XferDes Class Reference

#include <hdf5_internal.h>

Inheritance diagram for Realm::HDF5::HDF5XferDes:

Collaboration diagram for Realm::HDF5::HDF5XferDes:

Public Member Functions
	HDF5XferDes (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)
long	get_requests (Request **requests, long nr)
void	notify_request_read_done (Request *req)
void	notify_request_write_done (Request *req)
void	flush ()
virtual bool	request_available ()
virtual Request *	dequeue_request ()
virtual void	enqueue_request (Request *req)
bool	progress_xd (HDF5Channel *channel, TimeLimit work_until)
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)
virtual Event	request_metadata ()
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)
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)

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
Protected Member Functions inherited from Realm::XferDes
virtual	~XferDes ()
Protected Attributes inherited from Realm::XferDes
Mutex	available_req_mutex
std::queue< Request * >	available_reqs

Constructor & Destructor Documentation

HDF5XferDes()

Realm::HDF5::HDF5XferDes::HDF5XferDes	(	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
	)

Member Function Documentation

dequeue_request()

virtual Request * Realm::HDF5::HDF5XferDes::dequeue_request ( )

virtual

Reimplemented from Realm::XferDes.

enqueue_request()

virtual void Realm::HDF5::HDF5XferDes::enqueue_request ( Request *  req )

virtual

Reimplemented from Realm::XferDes.

flush()

void Realm::HDF5::HDF5XferDes::flush ( )

virtual

Reimplemented from Realm::XferDes.

get_requests()

long Realm::HDF5::HDF5XferDes::get_requests ( Request **  requests, long  nr  )

virtual

Implements Realm::XferDes.

notify_request_read_done()

void Realm::HDF5::HDF5XferDes::notify_request_read_done ( Request *  req )

virtual

Reimplemented from Realm::XferDes.

notify_request_write_done()

void Realm::HDF5::HDF5XferDes::notify_request_write_done ( Request *  req )

virtual

Reimplemented from Realm::XferDes.

progress_xd()

bool Realm::HDF5::HDF5XferDes::progress_xd	(	HDF5Channel *	channel,
		TimeLimit	work_until
	)

request_available()

virtual bool Realm::HDF5::HDF5XferDes::request_available ( )

virtual

Reimplemented from Realm::XferDes.

---

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

• /home/runner/work/realm/realm/realm-src/src/realm/hdf5/hdf5_internal.h