12 #ifndef SST_CORE_SHARED_SHAREDOBJECT_H 13 #define SST_CORE_SHARED_SHAREDOBJECT_H 15 #include "sst/core/output.h" 16 #include "sst/core/rankInfo.h" 17 #include "sst/core/serialization/serializable.h" 18 #include "sst/core/sst_types.h" 25 class Simulation_impl;
30 Output& getSimulationOutput();
31 RankInfo getNumRanks();
37 class SharedObjectDataManager;
64 virtual void clear() = 0;
72 const std::string&
getName() {
return name; }
77 ImplementVirtualSerializable(SharedObjectChangeSet);
99 const std::string&
getName() {
return name; }
130 bool fully_published;
134 mutable std::mutex mtx;
137 inline void check_lock_for_write(
const std::string& obj)
140 Private::getSimulationOutput().fatal(
141 CALL_INFO_LONG, 1,
"ERROR: attempt to write to %s %s after init phase\n", obj.c_str(), name.c_str());
153 std::lock_guard<std::mutex>
lock(mtx);
154 int ret = share_count;
164 std::lock_guard<std::mutex>
lock(mtx);
197 fully_published(false),
210 ImplementVirtualSerializable(SharedObjectData);
216 std::map<std::string, SharedObjectData*> shared_data;
219 static std::mutex mtx;
220 static std::mutex update_mtx;
229 for (
auto x : shared_data ) {
234 template <
typename T>
235 T* getSharedObjectData(
const std::string name)
239 std::lock_guard<std::mutex> lock(mtx);
241 Private::getSimulationOutput().fatal(
242 CALL_INFO, 1,
"Attempting to initialize SharedObject %s after the init() phase\n", name.c_str());
244 auto obj = shared_data.find(name);
245 if ( obj == shared_data.end() ) {
247 auto ret =
new T(name);
248 shared_data[name] = ret;
253 auto obj_cast =
dynamic_cast<T*
>(obj->second);
255 if ( obj_cast ==
nullptr ) {
256 Private::getSimulationOutput().fatal(
257 CALL_INFO, 1,
"ERROR: Shared object %s requested with two different types\n", name.c_str());
263 void updateState(
bool finalize);
276 enum verify_type { VERIFY_UNINITIALIZED, FE_VERIFY, INIT_VERIFY, NO_VERIFY };
279 virtual ~SharedObject() {}
286 static SharedObjectDataManager manager;
288 void incPublishCount(SharedObjectData* data) { data->incPublishCount(); }
290 int incShareCount(SharedObjectData* data) {
return data->incShareCount(); }
296 #endif // SST_CORE_SHARED_SHAREDOBJECT_H This class is basically a wrapper for objects to declare the order in which their members should be s...
Definition: serializer.h:43
Definition: sharedObject.h:269
virtual SharedObjectChangeSet * getChangeSet()=0
Gets the changeset for this data on this rank.
virtual int getShareCount()
Get the number of sharers for this data.
Definition: sharedObject.h:116
void lock()
Called by the core when writing to shared regions is no longer allowed.
Definition: sharedObject.h:186
bool isFullyPublished()
Checks to see if all instances of this SharedObject have called publish().
Definition: sharedObject.h:109
const std::string & getName()
Get the name of the shared data the changeset should be applied to.
Definition: sharedObject.h:72
SharedObjectData(const std::string &name)
Constructor for SharedObjectData.
Definition: sharedObject.h:193
verify_type
Enum of verify types.
Definition: sharedObject.h:276
Definition: serializable.h:24
virtual void incPublishCount()
Increment the count of instances that have called publish.
Definition: sharedObject.h:162
Definition: sharedObject.h:213
Main control class for a SST Simulation.
Definition: simulation_impl.h:76
virtual int getPublishCount()
Get the number of instances that have called publish() on their instance of the shared object...
Definition: sharedObject.h:124
virtual int incShareCount()
Increment the count of sharers.
Definition: sharedObject.h:151
const std::string & getName()
Get the name of the SharedObject for this data.
Definition: sharedObject.h:99
virtual void clear()=0
Clears the data.
virtual void applyChanges(SharedObjectDataManager *UNUSED(manager))=0
Apply the changes to the name shared data.
virtual void resetChangeSet()=0
Resets the changeset for this data on this rank.
This is the base class for holding data on changes made to the shared data on each rank...
Definition: sharedObject.h:44
Base class for holding SharedObject data.
Definition: sharedObject.h:87
virtual ~SharedObjectData()
Destructor for SharedObjectData.
Definition: sharedObject.h:206