Realm
A distributed, event-based tasking library
Loading...
Searching...
No Matches
Realm::Network Namespace Reference

Functions

NetworkModuleget_network (NodeID node)
 
void barrier (void)
 
bool check_for_quiescence (IncomingMessageManager *message_manager)
 
template<typename T >
broadcast (NodeID root, T val)
 
template<typename T >
void gather (NodeID root, T val, std::vector< T > &result)
 
template<typename T >
void gather (NodeID root, T val)
 
void broadcast (NodeID root, const void *val_in, void *val_out, size_t bytes)
 
void gather (NodeID root, const void *val_in, void *vals_out, size_t bytes)
 
ActiveMessageImplcreate_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)
 
ActiveMessageImplcreate_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)
 
ActiveMessageImplcreate_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)
 
ActiveMessageImplcreate_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)
 
size_t recommended_max_payload (NodeID target, bool with_congestion, size_t header_size)
 
size_t recommended_max_payload (const NodeSet &targets, bool with_congestion, size_t header_size)
 
size_t recommended_max_payload (NodeID target, const RemoteAddress &dest_payload_addr, bool with_congestion, size_t header_size)
 
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)
 
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)
 
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)
 

Variables

NodeID my_node_id
 
NodeID max_node_id
 
NodeSet all_peers
 
NodeSet shared_peers
 
NetworkModulesingle_network
 

Function Documentation

◆ barrier()

void Realm::Network::barrier ( void  )

◆ broadcast() [1/2]

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

◆ broadcast() [2/2]

template<typename T >
T Realm::Network::broadcast ( NodeID  root,
val 
)

◆ check_for_quiescence()

bool Realm::Network::check_for_quiescence ( IncomingMessageManager message_manager)

◆ create_active_message_impl() [1/4]

ActiveMessageImpl * Realm::Network::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 
)

◆ create_active_message_impl() [2/4]

ActiveMessageImpl * Realm::Network::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 
)

◆ create_active_message_impl() [3/4]

ActiveMessageImpl * Realm::Network::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 
)

◆ create_active_message_impl() [4/4]

ActiveMessageImpl * Realm::Network::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 
)

◆ gather() [1/3]

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

◆ gather() [2/3]

template<typename T >
void Realm::Network::gather ( NodeID  root,
val 
)

◆ gather() [3/3]

template<typename T >
void Realm::Network::gather ( NodeID  root,
val,
std::vector< T > &  result 
)

◆ get_network()

NetworkModule * Realm::Network::get_network ( NodeID  node)

◆ recommended_max_payload() [1/6]

size_t Realm::Network::recommended_max_payload ( const NodeSet targets,
bool  with_congestion,
size_t  header_size 
)

◆ recommended_max_payload() [2/6]

size_t Realm::Network::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 
)

◆ recommended_max_payload() [3/6]

size_t Realm::Network::recommended_max_payload ( NodeID  target,
bool  with_congestion,
size_t  header_size 
)

◆ recommended_max_payload() [4/6]

size_t Realm::Network::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 
)

◆ recommended_max_payload() [5/6]

size_t Realm::Network::recommended_max_payload ( NodeID  target,
const RemoteAddress dest_payload_addr,
bool  with_congestion,
size_t  header_size 
)

◆ recommended_max_payload() [6/6]

size_t Realm::Network::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 
)

Variable Documentation

◆ all_peers

NodeSet Realm::Network::all_peers
extern

◆ max_node_id

NodeID Realm::Network::max_node_id
extern

◆ my_node_id

NodeID Realm::Network::my_node_id
extern

◆ shared_peers

NodeSet Realm::Network::shared_peers
extern

◆ single_network

NetworkModule* Realm::Network::single_network
extern