@@ -44,22 +44,25 @@ namespace hpx::mpi::experimental {
4444
4545 // by convention the title is 7 chars (for alignment)
4646 HPX_CXX_EXPORT using print_on = debug::enable_print<false >;
47- HPX_CXX_EXPORT static constexpr print_on mpi_debug (" MPI_FUT" );
47+ HPX_CXX_EXPORT inline constexpr print_on mpi_debug (" MPI_FUT" );
4848
4949 namespace detail {
5050
5151 HPX_CXX_EXPORT using mutex_type = hpx::spinlock;
5252
5353 // mutex needed to protect mpi request vector, note that the
5454 // mpi poll function takes place inside the main scheduling loop
55- // of hpx and not on an hpx worker thread, so we must use std:mutex
55+ // of hpx and not on a hpx worker thread, so we must use std:mutex
5656 HPX_CXX_EXPORT HPX_CORE_EXPORT mutex_type& get_vector_mtx ();
5757
5858 // -----------------------------------------------------------------
5959 // An implementation of future_data for MPI
6060 HPX_CXX_EXPORT struct future_data : hpx::lcos::detail::future_data<int >
6161 {
62- HPX_NON_COPYABLE (future_data);
62+ future_data (future_data const &) = delete ;
63+ future_data (future_data&&) = delete ;
64+ future_data& operator =(future_data const &) = delete ;
65+ future_data& operator =(future_data&&) = delete ;
6366
6467 using init_no_addref =
6568 typename hpx::lcos::detail::future_data<int >::init_no_addref;
@@ -111,8 +114,8 @@ namespace hpx::mpi::experimental {
111114 HPX_CXX_EXPORT using future_data_ptr = hpx::intrusive_ptr<future_data>;
112115
113116 // -----------------------------------------------------------------
114- // a convenience structure to hold state vars
115- // used extensivey with debug::print to display rank etc
117+ // a convenience structure to hold state vars used extensively with
118+ // debug::print to display rank etc
116119 HPX_CXX_EXPORT struct mpi_info
117120 {
118121 bool error_handler_initialized_ = false ;
@@ -132,20 +135,20 @@ namespace hpx::mpi::experimental {
132135 std::ostream& os, mpi_info const & i);
133136
134137 // -----------------------------------------------------------------
135- // an MPI error handling type that we can use to intercept
136- // MPI errors is we enable the error handler
138+ // an MPI error handling type that we can use to intercept MPI errors is
139+ // we enable the error handler
137140 HPX_CXX_EXPORT HPX_CORE_EXPORT extern MPI_Errhandler hpx_mpi_errhandler;
138141
139142 // function that converts an MPI error into an exception
140143 HPX_CXX_EXPORT HPX_CORE_EXPORT void hpx_MPI_Handler (
141144 MPI_Comm*, int * errorcode, ...);
142145
143146 // -----------------------------------------------------------------
144- // we track requests and callbacks in two vectors even though
145- // we have the request stored in the request_callback vector already
146- // the reason for this is because we can use MPI_Testany
147- // with a vector of requests to save overheads compared
148- // to testing one by one every item (using a list)
147+ // we track requests and callbacks in two vectors even though we have
148+ // the request stored in the request_callback vector already the reason
149+ // for this is because we can use MPI_Testany with a vector of requests
150+ // to save overheads compared to testing one by one every item (using a
151+ // list)
149152 HPX_CXX_EXPORT HPX_CORE_EXPORT std::vector<MPI_Request>&
150153 get_requests_vector ();
151154
@@ -158,16 +161,16 @@ namespace hpx::mpi::experimental {
158161 concurrency::ConcurrentQueue<future_data_ptr>;
159162
160163 // -----------------------------------------------------------------
161- // used internally to query how many requests are 'in flight'
162- // these are requests that are being polled for actively
163- // and not the same as the requests enqueued
164+ // used internally to query how many requests are 'in flight' these are
165+ // requests that are being polled for actively and not the same as the
166+ // requests enqueued
164167 HPX_CXX_EXPORT HPX_CORE_EXPORT std::size_t
165168 get_number_of_active_requests ();
166169 } // namespace detail
167170
168171 // -----------------------------------------------------------------
169- // set an error handler for communicators that will be called
170- // on any error instead of the default behavior of program termination
172+ // set an error handler for communicators that will be called on any error
173+ // instead of the default behavior of program termination
171174 HPX_CXX_EXPORT HPX_CORE_EXPORT void set_error_handler ();
172175
173176 // -----------------------------------------------------------------
@@ -200,9 +203,9 @@ namespace hpx::mpi::experimental {
200203 } // namespace detail
201204
202205 // -----------------------------------------------------------------
203- // Background progress function for MPI async operations
204- // Checks for completed MPI_Requests and sets mpi::experimental::future ready
205- // when found
206+ // Background progress function for MPI async operations. Checks for
207+ // completed MPI_Requests and sets mpi::experimental::future ready when
208+ // found
206209 HPX_CXX_EXPORT HPX_CORE_EXPORT
207210 hpx::threads::policies::detail::polling_status
208211 poll ();
@@ -238,9 +241,8 @@ namespace hpx::mpi::experimental {
238241 });
239242 }
240243
241- // initialize the hpx::mpi background request handler
242- // All ranks should call this function,
243- // but only one thread per rank needs to do so
244+ // initialize the hpx::mpi background request handler All ranks should call
245+ // this function, but only one thread per rank needs to do so
244246 HPX_CXX_EXPORT HPX_CORE_EXPORT void init (bool init_mpi = false ,
245247 std::string const & pool_name = " " , bool init_errorhandler = false );
246248
0 commit comments