SST  11.1.0
StructuralSimulationToolkit
threadSyncDirectSkip.h
1 // Copyright 2009-2021 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-2021, 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(LinkId_t UNUSED(link_id), Link* UNUSED(link)) override {}
55  ActivityQueue* getQueueForThread(int tid) override;
56 
57  uint64_t getDataSize() const;
58 
59 private:
60  SimTime_t my_max_period;
61  int num_threads;
62  int thread;
63  static SimTime_t localMinimumNextActivityTime;
64  Simulation_impl* sim;
65  static Core::ThreadSafe::Barrier barrier[3];
66  double totalWaitTime;
67  bool single_rank;
68 };
69 
70 
71 } // namespace SST
72 
73 #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:67
Main control class for a SST Simulation.
Definition: simulation_impl.h:74
Definition: threadSyncDirectSkip.h:32
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
void registerLink(LinkId_t UNUSED(link_id), Link *UNUSED(link)) override
Register a Link which this Sync Object is responsible for.
Definition: threadSyncDirectSkip.h:54
Definition: threadsafe.h:47