Derecho  0.9
Distributed systems toolkit for RDMA
Public Member Functions | Public Attributes | List of all members
sst::multicast_sst Class Reference

#include <multicast_sst.hpp>

Inheritance diagram for sst::multicast_sst:
Inheritance graph
[legend]
Collaboration diagram for sst::multicast_sst:
Collaboration graph
[legend]

Public Member Functions

 multicast_sst (const SSTParams &parameters, uint32_t window_size, uint32_t num_senders, uint64_t max_msg_size)
 
- Public Member Functions inherited from sst::SST< multicast_sst >
 SST (multicast_sst *derived_class_pointer, const SSTParams &params)
 
void SSTInit (Fields &... fields)
 
 ~SST ()
 Destructor for the SST object; sets thread_shutdown to true and waits for background threads to exit cleanly. More...
 
void start_predicate_evaluation ()
 Starts the predicate evaluation loop. More...
 
void sync_with_members () const
 Does a TCP sync with each member of the SST. More...
 
void sync_with_members (std::vector< uint32_t > row_indices) const
 Syncs with a subset of the members. More...
 
void freeze (int row_index)
 Marks a row as frozen, so it will no longer update, and its corresponding node will not receive writes. More...
 
unsigned int get_num_rows () const
 Returns the total number of rows in the table. More...
 
unsigned int get_local_index () const
 Gets the index of the local row in the table. More...
 
const char * getBaseAddress ()
 
void put ()
 Writes the entire local row to all remote nodes. More...
 
void put (const std::vector< uint32_t > receiver_ranks)
 Writes the entire local row to some of the remote nodes. More...
 
void put (size_t offset, size_t size)
 Writes a contiguous subset of the local row to all remote nodes. More...
 
void put (SSTField< T > &field)
 Writes a specific local field to all remote nodes. More...
 
void put (SSTFieldVector< T > &vec_field)
 Writes a specific local vector field to all remote nodes. More...
 
void put (SSTFieldVector< T > &vec_field, std::size_t index)
 Writes only a single element of a vector field to all remote nodes. More...
 
void put (const std::vector< uint32_t > receiver_ranks, SSTFieldVector< T > &vec_field, std::size_t index)
 Writes only a single element of a vector field to only some of the remote nodes. More...
 
void put (const std::vector< uint32_t > receiver_ranks, size_t offset, size_t size)
 Writes a contiguous subset of the local row to some of the remote nodes. More...
 
void put_with_completion ()
 
void put_with_completion (const std::vector< uint32_t > receiver_ranks)
 
void put_with_completion (size_t offset, size_t size)
 
void put_with_completion (const std::vector< uint32_t > receiver_ranks, size_t offset, size_t size)
 

Public Attributes

SSTFieldVector< char > slots
 
SSTFieldVector< int64_t > num_received_sst
 
SSTField< bool > heartbeat
 
- Public Attributes inherited from sst::SST< multicast_sst >
Predicates< multicast_sstpredicates
 

Detailed Description

Definition at line 4 of file multicast_sst.hpp.

Constructor & Destructor Documentation

◆ multicast_sst()

sst::multicast_sst::multicast_sst ( const SSTParams parameters,
uint32_t  window_size,
uint32_t  num_senders,
uint64_t  max_msg_size 
)
inline

Definition at line 9 of file multicast_sst.hpp.

Member Data Documentation

◆ heartbeat

SSTField<bool> sst::multicast_sst::heartbeat

Definition at line 8 of file multicast_sst.hpp.

◆ num_received_sst

SSTFieldVector<int64_t> sst::multicast_sst::num_received_sst

Definition at line 7 of file multicast_sst.hpp.

◆ slots

SSTFieldVector<char> sst::multicast_sst::slots

Definition at line 6 of file multicast_sst.hpp.


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