SST
14.0.0
StructuralSimulationToolkit
|
Data Structures | |
struct | comm_recv_pair |
struct | comm_send_pair |
Public Types | |
typedef std::map< RankInfo, comm_send_pair > | comm_send_map_t |
typedef std::map< RankInfo, comm_recv_pair > | comm_recv_map_t |
typedef std::map< std::string, uintptr_t > | link_map_t |
Public Member Functions | |
RankSyncParallelSkip (RankInfo num_ranks, TimeConverter *minPartTC) | |
Create a new Sync object which fires with a specified period. | |
ActivityQueue * | registerLink (const RankInfo &to_rank, const RankInfo &from_rank, const std::string &name, Link *link) override |
Register a Link which this Sync Object is responsible for. | |
void | execute (int thread) override |
void | exchangeLinkUntimedData (int thread, std::atomic< int > &msg_count) override |
Cause an exchange of Untimed Data to occur. | |
void | finalizeLinkConfigurations () override |
Finish link configuration. | |
void | prepareForComplete () override |
Prepare for complete() stage. | |
SimTime_t | getNextSyncTime () override |
uint64_t | getDataSize () const override |
void | serialize_order (SST::Core::Serialization::serializer &ser) override |
ImplementSerializable(SST::RankSyncParallelSkip) private void | exchange_master (int thread) |
void | exchange_slave (int thread) |
void | deserializeMessage (comm_recv_pair *msg) |
![]() | |
RankSync (RankInfo num_ranks) | |
void | exchangeLinkInfo (uint32_t my_rank) |
TimeConverter * | getMaxPeriod () |
void | serialize_order (SST::Core::Serialization::serializer &ser) override |
void | finalizeConfiguration (Link *link) |
void | prepareForCompleteInt (Link *link) |
void | sendUntimedData_sync (Link *link, Event *data) |
void | setLinkDeliveryInfo (Link *link, uintptr_t info) |
Link * | getDeliveryLink (Event *ev) |
![]() | |
virtual const char * | cls_name () const =0 |
virtual uint32_t | cls_id () const =0 |
virtual std::string | serialization_name () const =0 |
Data Fields | |
comm_send_map_t | comm_send_map |
comm_recv_map_t | comm_recv_map |
link_map_t | link_map |
double | mpiWaitTime |
double | deserializeTime |
int * | recv_count |
int | send_count |
std::atomic< int32_t > | remaining_deser |
SST::Core::ThreadSafe::BoundedQueue< comm_recv_pair * > | deserialize_queue |
SST::Core::ThreadSafe::UnboundedQueue< comm_recv_pair * > * | link_send_queue |
SST::Core::ThreadSafe::BoundedQueue< comm_send_pair * > | serialize_queue |
SST::Core::ThreadSafe::BoundedQueue< comm_send_pair * > | send_queue |
Core::ThreadSafe::Barrier | serializeReadyBarrier |
Core::ThreadSafe::Barrier | slaveExchangeDoneBarrier |
Core::ThreadSafe::Barrier | allDoneBarrier |
Core::ThreadSafe::Spinlock | lock |
![]() | |
ImplementVirtualSerializable(SST::RankSync) protected TimeConverter * | max_period |
const RankInfo | num_ranks |
std::vector< std::map< std::string, uintptr_t > > | link_maps |
Additional Inherited Members | |
![]() | |
static constexpr uint32_t | NullClsId = std::numeric_limits<uint32_t>::max() |
![]() | |
enum | cxn_flag_t { ConstructorFlag } |
![]() | |
static void | serializable_abort (uint32_t line, const char *file, const char *func, const char *obj) |