[pnnl#243] 2-step constructor for abstract data-structure

Author: Fardin Zaman

include/shad/data_structures/abstract_data_structure.h

@@ -64,6 +64,7 @@ class AbstractDataStructure {
   /// @brief Default constructor
   AbstractDataStructure() = default;
 
+
   /// @brief Create method.
   ///
   /// Creates a global instance of DataStructure, and associates to it a unique
@@ -85,7 +86,9 @@ class AbstractDataStructure {
     ObjectID id = catalogRef->GetNextID();
     std::tuple<ObjectID, Args...> tuple(id, args...);
     rt::executeOnAll(CreateFunWrapper<ObjectID, Args...>, tuple);
-    return catalogRef->GetPtr(id);
+    auto ret= catalogRef->GetPtr(id);
+    ret->DataStructurePointerCommunication();
+    return ret;
   }
 
   /// @brief Destroy method.
@@ -150,6 +153,8 @@ class AbstractDataStructure {
     CreateFunInnerWrapper(std::move(args), std::index_sequence_for<Args...>());
   }
 
+  void DataStructurePointerCommunication(){}
+  
   class Catalog {
    public:
     void Insert(const ObjectID &oid, const SharedPtr ce) {
@@ -196,6 +201,7 @@ class AbstractDataStructure {
     }
 
    private:
+
     Catalog() : register_(rt::numLocalities()), oidCache_(), registerLock_() {}
 
     /// The Type storing the counter to obtain new DataStructure object IDs.

include/shad/data_structures/array.h

@@ -701,6 +701,18 @@ void PrintAllElements() {
     }
   }
 
+   constexpr void DataStructurePointerCommunication() {
+    rt::executeOnAll([](const ObjectID &oid) {
+      auto This = Array<T>::GetPtr(oid);
+      rt::executeOnAll([](const std::tuple<ObjectID, rt::Locality, T*> &args) {
+          auto This = Array<T>::GetPtr(std::get<0>(args));
+
+          This->ptrs_[(uint32_t)std::get<1>(args)] = std::get<2>(args);
+        },
+        std::make_tuple(This->GetGlobalID(), rt::thisLocality(), This->data_.data()));
+      }, GetGlobalID());
+  }
+
  private:
   ObjectID oid_;
   size_t size_;
@@ -948,6 +960,9 @@ void PrintAllElements() {
   }
 };
 
+template <>
+constexpr void Array<bool>::DataStructurePointerCommunication() {}
+
 static std::pair<rt::Locality, size_t> getTargetLocalityFromTargePosition(
     const std::vector<std::pair<size_t, size_t>> &dataDistribution,
     size_t position) {