Realm::ActiveMessage< T, INLINE_STORAGE > Class Template Reference

#include <activemsg.h>

Collaboration diagram for Realm::ActiveMessage< T, INLINE_STORAGE >:

Public Member Functions
	ActiveMessage ()
	ActiveMessage (NodeID _target, size_t _max_payload_size=0)
	ActiveMessage (NodeID _target, size_t _max_payload_size, const RemoteAddress &_dest_payload_addr)
	ActiveMessage (const Realm::NodeSet &_targets, size_t _max_payload_size=0)
	ActiveMessage (NodeID _target, const void *_data, size_t _datalen)
	ActiveMessage (NodeID _target, const LocalAddress &_src_payload_addr, size_t _datalen, const RemoteAddress &_dest_payload_addr)
	ActiveMessage (const Realm::NodeSet &_targets, const void *_data, size_t _datalen)
	ActiveMessage (NodeID _target, const void *_data, size_t _bytes_per_line, size_t _lines, size_t _line_stride)
	ActiveMessage (NodeID _target, const LocalAddress &_src_payload_addr, size_t _bytes_per_line, size_t _lines, size_t _line_stride, const RemoteAddress &_dest_payload_addr)
	ActiveMessage (const Realm::NodeSet &_targets, const void *_data, size_t _bytes_per_line, size_t _lines, size_t _line_stride)
	~ActiveMessage (void)
void	init (NodeID _target, size_t _max_payload_size=0)
void	init (NodeID _target, size_t _max_payload_size, const RemoteAddress &_dest_payload_addr)
void	init (const Realm::NodeSet &_targets, size_t _max_payload_size=0)
void	init (NodeID _target, const void *_data, size_t _datalen)
void	init (NodeID _target, const LocalAddress &_src_payload_addr, size_t _datalen, const RemoteAddress &_dest_payload_addr)
void	init (const Realm::NodeSet &_targets, const void *_data, size_t _datalen)
void	init (NodeID _target, const void *_data, size_t _bytes_per_line, size_t _lines, size_t _line_stride)
void	init (NodeID _target, const LocalAddress &_src_payload_addr, size_t _bytes_per_line, size_t _lines, size_t _line_stride, const RemoteAddress &_dest_payload_addr)
void	init (const Realm::NodeSet &_targets, const void *_data, size_t _bytes_per_line, size_t _lines, size_t _line_stride)
T *	operator-> (void)
T &	operator* (void)
template<typename T2 >
bool	operator<< (const T2 &to_append)
void	add_payload (const void *data, size_t datalen, int payload_mode=PAYLOAD_COPY)
void	add_payload (const void *data, size_t bytes_per_line, size_t lines, size_t line_stride, int payload_mode=PAYLOAD_COPY)
void *	payload_ptr (size_t datalen)
template<typename CALLABLE >
void	add_local_completion (const CALLABLE &callable)
template<typename CALLABLE >
void	add_remote_completion (const CALLABLE &callable)
void	commit (void)
void	cancel (void)

Static Public Member Functions
static size_t	recommended_max_payload (NodeID target, bool with_congestion)
static size_t	recommended_max_payload (const NodeSet &targets, bool with_congestion)
static size_t	recommended_max_payload (NodeID target, const RemoteAddress &dest_payload_addr, bool with_congestion)
static 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)
static 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)
static 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)

Protected Attributes
ActiveMessageImpl *	impl
T *	header
Realm::Serialization::FixedBufferSerializer	fbs
uint64_t	inline_capacity [INLINE_STORAGE/sizeof(uint64_t)]

Constructor & Destructor Documentation

ActiveMessage() [1/10]

template<typename T , size_t INLINE_STORAGE = 256>

Realm::ActiveMessage< T, INLINE_STORAGE >::ActiveMessage

(

)

ActiveMessage() [2/10]

template<typename T , size_t INLINE_STORAGE = 256>

Realm::ActiveMessage< T, INLINE_STORAGE >::ActiveMessage	(	NodeID	_target,
		size_t	_max_payload_size = 0
	)

ActiveMessage() [3/10]

template<typename T , size_t INLINE_STORAGE = 256>

Realm::ActiveMessage< T, INLINE_STORAGE >::ActiveMessage	(	NodeID	_target,
		size_t	_max_payload_size,
		const RemoteAddress &	_dest_payload_addr
	)

ActiveMessage() [4/10]

template<typename T , size_t INLINE_STORAGE = 256>

Realm::ActiveMessage< T, INLINE_STORAGE >::ActiveMessage	(	const Realm::NodeSet &	_targets,
		size_t	_max_payload_size = 0
	)

ActiveMessage() [5/10]

template<typename T , size_t INLINE_STORAGE = 256>

Realm::ActiveMessage< T, INLINE_STORAGE >::ActiveMessage	(	NodeID	_target,
		const void *	_data,
		size_t	_datalen
	)

ActiveMessage() [6/10]

template<typename T , size_t INLINE_STORAGE = 256>

Realm::ActiveMessage< T, INLINE_STORAGE >::ActiveMessage	(	NodeID	_target,
		const LocalAddress &	_src_payload_addr,
		size_t	_datalen,
		const RemoteAddress &	_dest_payload_addr
	)

ActiveMessage() [7/10]

template<typename T , size_t INLINE_STORAGE = 256>

Realm::ActiveMessage< T, INLINE_STORAGE >::ActiveMessage	(	const Realm::NodeSet &	_targets,
		const void *	_data,
		size_t	_datalen
	)

ActiveMessage() [8/10]

template<typename T , size_t INLINE_STORAGE = 256>

Realm::ActiveMessage< T, INLINE_STORAGE >::ActiveMessage	(	NodeID	_target,
		const void *	_data,
		size_t	_bytes_per_line,
		size_t	_lines,
		size_t	_line_stride
	)

ActiveMessage() [9/10]

template<typename T , size_t INLINE_STORAGE = 256>

Realm::ActiveMessage< T, INLINE_STORAGE >::ActiveMessage	(	NodeID	_target,
		const LocalAddress &	_src_payload_addr,
		size_t	_bytes_per_line,
		size_t	_lines,
		size_t	_line_stride,
		const RemoteAddress &	_dest_payload_addr
	)

ActiveMessage() [10/10]

template<typename T , size_t INLINE_STORAGE = 256>

Realm::ActiveMessage< T, INLINE_STORAGE >::ActiveMessage	(	const Realm::NodeSet &	_targets,
		const void *	_data,
		size_t	_bytes_per_line,
		size_t	_lines,
		size_t	_line_stride
	)

~ActiveMessage()

template<typename T , size_t INLINE_STORAGE = 256>

Realm::ActiveMessage< T, INLINE_STORAGE >::~ActiveMessage

(

void

)

Member Function Documentation

add_local_completion()

template<typename T , size_t INLINE_STORAGE = 256>

template<typename CALLABLE >

void Realm::ActiveMessage< T, INLINE_STORAGE >::add_local_completion

(

const CALLABLE &

callable

)

add_payload() [1/2]

template<typename T , size_t INLINE_STORAGE = 256>

void Realm::ActiveMessage< T, INLINE_STORAGE >::add_payload	(	const void *	data,
		size_t	bytes_per_line,
		size_t	lines,
		size_t	line_stride,
		int	payload_mode = PAYLOAD_COPY
	)

add_payload() [2/2]

template<typename T , size_t INLINE_STORAGE = 256>

void Realm::ActiveMessage< T, INLINE_STORAGE >::add_payload	(	const void *	data,
		size_t	datalen,
		int	payload_mode = PAYLOAD_COPY
	)

add_remote_completion()

template<typename T , size_t INLINE_STORAGE = 256>

template<typename CALLABLE >

void Realm::ActiveMessage< T, INLINE_STORAGE >::add_remote_completion

(

const CALLABLE &

callable

)

cancel()

template<typename T , size_t INLINE_STORAGE = 256>

void Realm::ActiveMessage< T, INLINE_STORAGE >::cancel

(

void

)

commit()

template<typename T , size_t INLINE_STORAGE = 256>

void Realm::ActiveMessage< T, INLINE_STORAGE >::commit

(

void

)

init() [1/9]

template<typename T , size_t INLINE_STORAGE = 256>

void Realm::ActiveMessage< T, INLINE_STORAGE >::init	(	const Realm::NodeSet &	_targets,
		const void *	_data,
		size_t	_bytes_per_line,
		size_t	_lines,
		size_t	_line_stride
	)

init() [2/9]

template<typename T , size_t INLINE_STORAGE = 256>

void Realm::ActiveMessage< T, INLINE_STORAGE >::init	(	const Realm::NodeSet &	_targets,
		const void *	_data,
		size_t	_datalen
	)

init() [3/9]

template<typename T , size_t INLINE_STORAGE = 256>

void Realm::ActiveMessage< T, INLINE_STORAGE >::init	(	const Realm::NodeSet &	_targets,
		size_t	_max_payload_size = 0
	)

init() [4/9]

template<typename T , size_t INLINE_STORAGE = 256>

void Realm::ActiveMessage< T, INLINE_STORAGE >::init	(	NodeID	_target,
		const LocalAddress &	_src_payload_addr,
		size_t	_bytes_per_line,
		size_t	_lines,
		size_t	_line_stride,
		const RemoteAddress &	_dest_payload_addr
	)

init() [5/9]

template<typename T , size_t INLINE_STORAGE = 256>

void Realm::ActiveMessage< T, INLINE_STORAGE >::init	(	NodeID	_target,
		const LocalAddress &	_src_payload_addr,
		size_t	_datalen,
		const RemoteAddress &	_dest_payload_addr
	)

init() [6/9]

template<typename T , size_t INLINE_STORAGE = 256>

void Realm::ActiveMessage< T, INLINE_STORAGE >::init	(	NodeID	_target,
		const void *	_data,
		size_t	_bytes_per_line,
		size_t	_lines,
		size_t	_line_stride
	)

init() [7/9]

template<typename T , size_t INLINE_STORAGE = 256>

void Realm::ActiveMessage< T, INLINE_STORAGE >::init	(	NodeID	_target,
		const void *	_data,
		size_t	_datalen
	)

init() [8/9]

template<typename T , size_t INLINE_STORAGE = 256>

void Realm::ActiveMessage< T, INLINE_STORAGE >::init	(	NodeID	_target,
		size_t	_max_payload_size,
		const RemoteAddress &	_dest_payload_addr
	)

init() [9/9]

template<typename T , size_t INLINE_STORAGE = 256>

void Realm::ActiveMessage< T, INLINE_STORAGE >::init	(	NodeID	_target,
		size_t	_max_payload_size = 0
	)

operator*()

template<typename T , size_t INLINE_STORAGE = 256>

T & Realm::ActiveMessage< T, INLINE_STORAGE >::operator*

(

void

)

operator->()

template<typename T , size_t INLINE_STORAGE = 256>

T * Realm::ActiveMessage< T, INLINE_STORAGE >::operator->

(

void

)

operator<<()

template<typename T , size_t INLINE_STORAGE = 256>

template<typename T2 >

bool Realm::ActiveMessage< T, INLINE_STORAGE >::operator<<

(

const T2 &

to_append

)

payload_ptr()

template<typename T , size_t INLINE_STORAGE = 256>

void * Realm::ActiveMessage< T, INLINE_STORAGE >::payload_ptr

(

size_t

datalen

)

recommended_max_payload() [1/6]

template<typename T , size_t INLINE_STORAGE = 256>

static size_t Realm::ActiveMessage< T, INLINE_STORAGE >::recommended_max_payload ( const NodeSet &  targets, bool  with_congestion  )

static

recommended_max_payload() [2/6]

template<typename T , size_t INLINE_STORAGE = 256>

static size_t Realm::ActiveMessage< T, INLINE_STORAGE >::recommended_max_payload ( const NodeSet &  targets, const void *  data, size_t  bytes_per_line, size_t  lines, size_t  line_stride, bool  with_congestion  )

static

recommended_max_payload() [3/6]

template<typename T , size_t INLINE_STORAGE = 256>

static size_t Realm::ActiveMessage< T, INLINE_STORAGE >::recommended_max_payload ( NodeID  target, bool  with_congestion  )

static

recommended_max_payload() [4/6]

template<typename T , size_t INLINE_STORAGE = 256>

static size_t Realm::ActiveMessage< T, INLINE_STORAGE >::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  )

static

recommended_max_payload() [5/6]

template<typename T , size_t INLINE_STORAGE = 256>

static size_t Realm::ActiveMessage< T, INLINE_STORAGE >::recommended_max_payload ( NodeID  target, const RemoteAddress &  dest_payload_addr, bool  with_congestion  )

static

recommended_max_payload() [6/6]

template<typename T , size_t INLINE_STORAGE = 256>

static size_t Realm::ActiveMessage< T, INLINE_STORAGE >::recommended_max_payload ( NodeID  target, const void *  data, size_t  bytes_per_line, size_t  lines, size_t  line_stride, bool  with_congestion  )

static

Member Data Documentation

fbs

template<typename T , size_t INLINE_STORAGE = 256>

Realm::Serialization::FixedBufferSerializer Realm::ActiveMessage< T, INLINE_STORAGE >::fbs

protected

header

template<typename T , size_t INLINE_STORAGE = 256>

T* Realm::ActiveMessage< T, INLINE_STORAGE >::header

protected

impl

template<typename T , size_t INLINE_STORAGE = 256>

ActiveMessageImpl* Realm::ActiveMessage< T, INLINE_STORAGE >::impl

protected

inline_capacity

template<typename T , size_t INLINE_STORAGE = 256>

uint64_t Realm::ActiveMessage< T, INLINE_STORAGE >::inline_capacity[INLINE_STORAGE/sizeof(uint64_t)]

protected

---

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

• /home/runner/work/realm/realm/realm-src/src/realm/activemsg.h