SST  14.0.0
StructuralSimulationToolkit
Data Structures | Public Types | Public Member Functions | Data Fields
SST::RankSyncParallelSkip Class Reference
Inheritance diagram for SST::RankSyncParallelSkip:
SST::RankSync SST::Core::Serialization::serializable

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)
 
- Public Member Functions inherited from SST::RankSync
 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)
 
- Public Member Functions inherited from SST::Core::Serialization::serializable
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
 
- Data Fields inherited from SST::RankSync
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 Public Attributes inherited from SST::Core::Serialization::serializable
static constexpr uint32_t NullClsId = std::numeric_limits<uint32_t>::max()
 
- Protected Types inherited from SST::Core::Serialization::serializable
enum  cxn_flag_t { ConstructorFlag }
 
- Static Protected Member Functions inherited from SST::Core::Serialization::serializable
static void serializable_abort (uint32_t line, const char *file, const char *func, const char *obj)
 
The documentation for this class was generated from the following files: