SST  12.0.1
StructuralSimulationToolkit
threadSyncSimpleSkip.h
1 // Copyright 2009-2022 NTESS. Under the terms
2 // of Contract DE-NA0003525 with NTESS, the U.S.
3 // Government retains certain rights in this software.
4 //
5 // Copyright (c) 2009-2022, NTESS
6 // All rights reserved.
7 //
8 // This file is part of the SST software package. For license
9 // information, see the LICENSE file in the top level directory of the
10 // distribution.
11 
12 #ifndef SST_CORE_SYNC_THREADSYNCSIMPLESKIP_H
13 #define SST_CORE_SYNC_THREADSYNCSIMPLESKIP_H
14 
15 #include "sst/core/action.h"
16 #include "sst/core/sst_types.h"
17 #include "sst/core/sync/syncManager.h"
18 #include "sst/core/sync/threadSyncQueue.h"
19 
20 #include <unordered_map>
21 
22 namespace SST {
23 
24 class ActivityQueue;
25 class Link;
26 class TimeConverter;
27 class Exit;
28 class Event;
29 class Simulation_impl;
30 class ThreadSyncQueue;
31 
33 {
34 public:
35  /** Create a new ThreadSync object */
36  ThreadSyncSimpleSkip(int num_threads, int thread, Simulation_impl* sim);
38 
39  void setMaxPeriod(TimeConverter* period);
40 
41  void before() override;
42  void after() override;
43  void execute(void) override;
44 
45  /** Cause an exchange of Untimed Data to occur */
46  void processLinkUntimedData() override;
47  /** Finish link configuration */
48  void finalizeLinkConfigurations() override;
49  void prepareForComplete() override;
50 
51  /** Register a Link which this Sync Object is responsible for */
52  void registerLink(const std::string& name, Link* link) override;
53  ActivityQueue* registerRemoteLink(int tid, const std::string& name, Link* link) override;
54 
55  uint64_t getDataSize() const;
56 
57  // static void disable() { disabled = true; barrier.disable(); }
58 
59 private:
60  // Stores the links until they can be intialized with the right
61  // remote data. It will hold whichever thread registers the link
62  // first and will be removed after the second thread registers and
63  // the link is properly initialized with the remote data.
64  std::unordered_map<std::string, Link*> link_map;
65 
66  std::vector<ThreadSyncQueue*> queues;
67  SimTime_t my_max_period;
68  int num_threads;
69  int thread;
70  static SimTime_t localMinimumNextActivityTime;
71  Simulation_impl* sim;
72  static Core::ThreadSafe::Barrier barrier[3];
73  double totalWaitTime;
74  bool single_rank;
75 };
76 
77 } // namespace SST
78 
79 #endif // SST_CORE_SYNC_THREADSYNCSIMPLESKIP_H
A class to convert between a component&#39;s view of time and the core&#39;s view of time.
Definition: timeConverter.h:26
Definition: threadSyncSimpleSkip.h:32
Definition: syncManager.h:75
void registerLink(const std::string &name, Link *link) override
Register a Link which this Sync Object is responsible for.
Definition: threadSyncSimpleSkip.cc:65
void processLinkUntimedData() override
Cause an exchange of Untimed Data to occur.
Definition: threadSyncSimpleSkip.cc:140
Main control class for a SST Simulation.
Definition: simulation_impl.h:75
void finalizeLinkConfigurations() override
Finish link configuration.
Definition: threadSyncSimpleSkip.cc:156
Base Class for a queue of Activities.
Definition: activityQueue.h:21
ThreadSyncSimpleSkip(int num_threads, int thread, Simulation_impl *sim)
Create a new ThreadSync object.
Definition: threadSyncSimpleSkip.cc:27
Definition: threadsafe.h:47