21static constexpr PDI_inout_t default_access_v
22 = (std::is_lvalue_reference_v<T> && !std::is_const_v<std::remove_reference_t<T>>)
27static constexpr PDI_inout_t chunk_default_access_v = is_writable_chunk_v<T> ? PDI_INOUT : PDI_OUT;
31 std::string m_event_name;
33 std::vector<std::string> m_names;
35 std::list<std::any> m_metadata;
37 char const* store_name(std::string&& name)
39 return m_names.emplace_back(std::move(name)).c_str();
42 char const* store_name(std::string
const& name)
44 return m_names.emplace_back(name).c_str();
50 std::any& ref = m_metadata.emplace_back(std::in_place_type<T>, std::move(t));
51 return std::any_cast<T>(&ref);
55 T* store_array(std::vector<T> v)
57 std::any& ref = m_metadata.emplace_back(std::in_place_type<std::vector<T>>, std::move(v));
58 return std::any_cast<std::vector<T>>(&ref)->data();
62 explicit PdiEvent(std::string
const& event_name) : m_event_name(event_name) {}
70 PDI_event(m_event_name.c_str());
71 for (std::string
const& one_name : m_names) {
72 PDI_reclaim(one_name.c_str());
86 std::enable_if_t<is_borrowed_chunk_v<BorrowedChunk>,
int> = 0>
87 PdiEvent&
with(std::string
const& name, BorrowedChunk&& data)
90 !(access & PDI_IN) || (chunk_default_access_v<BorrowedChunk> & PDI_IN),
91 "Invalid access for constant data");
92 std::array
const extents = detail::array(data.domain().extents());
93 PDI_share(store_name(name +
"_rank"), store_scalar(extents.size()), PDI_OUT);
95 store_name(name +
"_extents"),
96 store_array(std::vector<std::size_t>(extents.begin(), extents.end())),
100 const_cast<chunk_value_t<BorrowedChunk>*>(data.data_handle()),
108 std::enable_if_t<std::is_arithmetic_v<std::remove_reference_t<Arithmetic>>,
int> = 0>
109 PdiEvent&
with(std::string
const& name, Arithmetic&& data)
112 !(access & PDI_IN) || (default_access_v<Arithmetic> & PDI_IN),
113 "Invalid access for constant data");
114 using value_type = std::remove_cv_t<std::remove_reference_t<Arithmetic>>;
115 value_type* data_ptr =
const_cast<value_type*>(&data);
117 if constexpr (!(access & PDI_IN)) {
118 data_ptr = store_scalar(data);
120 PDI_share(store_name(name), data_ptr, access);
129 template <
class BorrowedChunk, std::enable_if_t<is_borrowed_chunk_v<BorrowedChunk>,
int> = 0>
130 PdiEvent&
with(std::string
const& name, BorrowedChunk&& data)
132 return with<chunk_default_access_v<BorrowedChunk>>(name, std::forward<BorrowedChunk>(data));
138 std::enable_if_t<std::is_arithmetic_v<std::remove_reference_t<Arithmetic>>,
int> = 0>
139 PdiEvent&
with(std::string
const& name, Arithmetic&& data)
141 return with<default_access_v<Arithmetic>>(name, std::forward<Arithmetic>(data));
147template <PDI_inout_t access,
class DataType>
150 PdiEvent(name
).with<access>(name, std::forward<DataType>(data));
153template <
class DataType>
156 PdiEvent(name
).with(name, std::forward<DataType>(data));
PdiEvent(PdiEvent const &rhs)=delete
PdiEvent & operator=(PdiEvent &&rhs) noexcept=delete
PdiEvent & operator=(PdiEvent const &rhs)=delete
PdiEvent(std::string const &event_name)
PdiEvent & with(std::string const &name, Arithmetic &&data)
Arithmetic overload.
PdiEvent & with(std::string const &name, BorrowedChunk &&data)
API with access deduction.
PdiEvent & with(std::string const &name, Arithmetic &&data)
PdiEvent & with(std::string const &name, BorrowedChunk &&data)
PdiEvent(PdiEvent &&rhs) noexcept=delete
The top-level namespace of DDC.
void expose_to_pdi(std::string const &name, DataType &&data)
void expose_to_pdi(std::string const &name, DataType &&data)