#include <cuda_internal.h>

Inheritance diagram for Realm::Cuda::GPUfillXferDes:

Collaboration diagram for Realm::Cuda::GPUfillXferDes:

Public Member Functions
	GPUfillXferDes (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, size_t _fill_total)

long	get_requests (Request **requests, long nr)

bool	progress_xd (GPUfillChannel *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 ()

virtual void	notify_request_read_done (Request *req)

virtual void	notify_request_write_done (Request *req)

virtual void	flush ()

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 Attributes
size_t	reduced_fill_size

Protected Attributes inherited from Realm::XferDes
Mutex	available_req_mutex

std::queue< Request * >	available_reqs

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

Constructor & Destructor Documentation

◆ GPUfillXferDes()

Realm::Cuda::GPUfillXferDes::GPUfillXferDes	(	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,
		size_t	_fill_total
	)

Member Function Documentation

◆ get_requests()

long Realm::Cuda::GPUfillXferDes::get_requests	(	Request **	requests,
		long	nr
	)

virtual

Implements Realm::XferDes.

◆ progress_xd()

bool Realm::Cuda::GPUfillXferDes::progress_xd	(	GPUfillChannel *	channel,
		TimeLimit	work_until
	)

Member Data Documentation

◆ reduced_fill_size

size_t Realm::Cuda::GPUfillXferDes::reduced_fill_size

protected

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

/home/runner/work/realm/realm/realm-src/src/realm/cuda/cuda_internal.h

Public Member Functions

Protected Attributes