SST  12.0.0
StructuralSimulationToolkit
threadSyncDirectSkip.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_THREADSYNCDIRECTSKIP_H
13 #define SST_CORE_SYNC_THREADSYNCDIRECTSKIP_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  ThreadSyncDirectSkip(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  SimTime_t getNextSyncTime() override { return nextSyncTime - 1; }
52 
53  /** Register a Link which this Sync Object is responsible for */
54  void registerLink(const std::string& UNUSED(name), Link* UNUSED(link)) override {}
55  ActivityQueue* registerRemoteLink(int UNUSED(id), const std::string& UNUSED(name), Link* UNUSED(link)) override
56  {
57  return nullptr;
58  }
59 
60  uint64_t getDataSize() const;
61 
62 private:
63  SimTime_t my_max_period;
64  int num_threads;
65  int thread;
66  static SimTime_t localMinimumNextActivityTime;
67  Simulation_impl* sim;
68  static Core::ThreadSafe::Barrier barrier[3];
69  double totalWaitTime;
70  bool single_rank;
71 };
72 
73 
74 } // namespace SST
75 
76 #endif // SST_CORE_SYNC_THREADSYNCDIRECTSKIP_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
void processLinkUntimedData() override
Cause an exchange of Untimed Data to occur.
Definition: threadSyncDirectSkip.h:46
Definition: syncManager.h:75
Main control class for a SST Simulation.
Definition: simulation_impl.h:75
Definition: threadSyncDirectSkip.h:32
void registerLink(const std::string &UNUSED(name), Link *UNUSED(link)) override
Register a Link which this Sync Object is responsible for.
Definition: threadSyncDirectSkip.h:54
ThreadSyncDirectSkip(int num_threads, int thread, Simulation_impl *sim)
Create a new ThreadSync object.
Definition: threadSyncDirectSkip.cc:28
void finalizeLinkConfigurations() override
Finish link configuration.
Definition: threadSyncDirectSkip.h:48
Base Class for a queue of Activities.
Definition: activityQueue.h:21