Auxiliary functions and classes#

Integer types#

using mpl::size_t = std::size_t#: Unsigned integer type used for array indexing and address arithmetic.

using mpl::ssize_t = std::ptrdiff_t#: Signed integer type used for array indexing and address arithmetic.

Ranks#

class ranks : private std::vector<int>#

Represents a collection of ranks.

Types for probing messages#

The following types are used in the context of probing messages. See section Probing messages for an example.

using mpl::message_t = MPI_Message#: Status of a received message.

class status_t : private MPI_Status#

Class that represents the status of a received message.

Public Functions

inline int source() const#

Returns:: source of the message

inline mpl::tag_t tag() const#

Returns:: tag value of the message

inline int error() const#

Returns:: error code associated with the message

inline bool is_cancelled() const#

Returns:: true if associated request has been been canceled

inline bool is_canceled() const#

Returns:: true if associated request has been been canceled

template<typename T> inline int get_count() const#

Template Parameters:: T – received data type
Returns:: number of top level elements of type T received in associated message

template<typename T> inline int get_count(const layout<T> &l) const#

Template Parameters:: T – received data type
Parameters:: l – layout used in associated message
Returns:: number of top level elements of type T received in associated message

inline status_t()#: default constructor initializes source and tag with wildcards given by any_source and tag_t::any and no error

Friends

friend class impl::base_communicator

friend class impl::base_request

friend class impl::request_pool

friend class file

struct mprobe_status#

Return value of matching probe operations.

Public Members

message_t message#: message handle to be used in a matching receive operation

status_t status#: status of the pending incoming message

Memory displacements#

The mpl::displacements class is used in the context of various collective communication operations that send and/or receive an amount of data that varies over the set of participating processes.

class displacements : private std::vector<MPI_Aint>#

Indicates the beginning of data buffers in various collective communication operations.

Public Types

using size_type = base::size_type#

using value_type = base::value_type#

Public Functions

inline explicit displacements(size_type n = 0)#

Constructs a set of displacements with displacement zero.

Parameters:: n – number of displacements

inline explicit displacements(std::initializer_list<MPI_Aint> init)#

Constructs a set of displacements with given displacements.

Parameters:: init – initial displacements

displacements(const displacements &other) = default#

Copy constructor.

Parameters:: other – the other set of displacements to copy from

displacements(displacements &&other) = default#

Move constructor.

Parameters:: other – the other set of displacements to move from

inline const MPI_Aint *operator()() const#

Get raw displacement data.

Returns:: pointer to array of displacements

Requests#

Test status enum#

enum class mpl::test_result#

Indicates kind of outcome of test for request completion.

Values:

enumerator completed#: some request has been completed

enumerator no_completed#: no request has been completed

enumerator no_active_requests#: there is no request waiting for completion

Non-blocking communication requests#

class irequest : public base_request<impl::base_irequest>#

Represents a non-blocking communication request.

Public Functions

irequest(const irequest&) = delete#: Deleted copy constructor.

inline irequest(irequest &&other) noexcept#

Move constructor.

Parameters:: other – the request to move from

void operator=(const irequest&) = delete#: Deleted copy operator.

inline irequest &operator=(irequest &&other) noexcept#

Move operator.

Parameters:: other – the request to move from
Returns:: reference to the moved-to request

inline void cancel()#: Cancels the request if it is pending.

inline std::optional<status_t> test()#

Tests for the completion.

Returns:: the operation’s status if completed successfully

inline status_t wait()#

Wait for a pending communication operation.

Returns:: operation’s status after completion

inline std::optional<status_t> get_status()#

Access information associated with a request without freeing the request.

Returns:: the operation’s status if completed successfully

Friends

friend class impl::request_pool< irequest >

class irequest_pool : public request_pool<irequest>#

Container for managing a list of non-blocking communication requests.

Public Types

using size_type = std::vector<MPI_Request>::size_type#: Type used in all index-based operations.

Public Functions

irequest_pool() = default#: Constructs an empty pool of communication requests.

irequest_pool(const irequest_pool&) = delete#: Deleted copy constructor.

inline irequest_pool(irequest_pool &&other) noexcept#

Move constructor.

Parameters:: other – the request pool to move from

void operator=(const irequest_pool&) = delete#: Deleted copy operator.

inline irequest_pool &operator=(irequest_pool &&other) noexcept#

Move operator.

Parameters:: other – the request pool to move from
Returns:: reference to the moved-to request pool

inline size_type size() const#

Determine the size of request pool.

Returns:: number of requests currently in request pool

inline bool empty() const#

Determine if request pool is empty.

Returns:: true if number of requests currently in request pool is non-zero

inline const status_t &get_status(size_type i) const#

Get status of a request.

Parameters:: i – index of the request for which the status will be returned
Returns:: status of request

inline void cancel(size_type i)#

Cancels a pending request in the pool.

Parameters:: i – index of the request for which shall be cancelled

inline void cancelall()#: Cancels all requests in the pool.

inline void push(irequest &&request)#

Move a request into the request pool.

Parameters:: request – request to move into the pool

inline std::pair<test_result, size_type> waitany()#

Wait for completion of any pending communication operation.

Returns:: pair containing the outcome of the wait operation and an index to the completed request if there was any pending request

inline std::pair<test_result, size_type> testany()#

Test for completion of any pending communication operation.

Returns:: pair containing the outcome of the test and an index to the completed request if there was any pending request

inline void waitall()#: Waits for completion of all pending requests.

inline bool testall()#

Tests for completion of all pending requests.

Returns:: true if all pending requests have completed

inline std::pair<test_result, std::vector<size_type>> waitsome()#

Waits until one or more pending requests have finished.

Returns:: pair containing the outcome of the wait operation and a list of indices to the completed requests if there was any pending request

inline std::pair<test_result, std::vector<size_type>> testsome()#

Tests if one or more pending requests have finished.

Returns:: pair containing the outcome of the test and a list of indices to the completed requests if there was any pending request

Persistent communication requests#

class prequest : public base_request<impl::base_prequest>#

Represents a persistent communication request.

Public Functions

prequest(const prequest&) = delete#: Deleted copy constructor.

inline prequest(prequest &&other) noexcept#

Move constructor.

Parameters:: other – the request to move from

void operator=(const prequest&) = delete#: Deleted copy operator.

inline prequest &operator=(prequest &&other) noexcept#

Move operator.

Parameters:: other – the request to move from
Returns:: reference to the moved-to request

inline void start()#: Start communication operation.

inline void cancel()#: Cancels the request if it is pending.

inline std::optional<status_t> test()#

Tests for the completion.

Returns:: the operation’s status if completed successfully

inline status_t wait()#

Wait for a pending communication operation.

Returns:: operation’s status after completion

inline std::optional<status_t> get_status()#

Access information associated with a request without freeing the request.

Returns:: the operation’s status if completed successfully

Friends

friend class impl::request_pool< prequest >

class prequest_pool : public request_pool<prequest>#

Container for managing a list of persisting communication requests.

Public Types

using size_type = std::vector<MPI_Request>::size_type#: Type used in all index-based operations.

Public Functions

prequest_pool() = default#: Constructs an empty pool of persistent communication requests.

prequest_pool(const prequest_pool&) = delete#: Deleted copy constructor.

inline prequest_pool(prequest_pool &&other) noexcept#

Move constructor.

Parameters:: other – the request pool to move from

void operator=(const prequest_pool&) = delete#: Deleted copy constructor.

inline prequest_pool &operator=(prequest_pool &&other) noexcept#

Move operator.

Parameters:: other – the request pool to move from

inline void startall()#: Start all persistent requests in the pool.

inline size_type size() const#

Determine the size of request pool.

Returns:: number of requests currently in request pool

inline bool empty() const#

Determine if request pool is empty.

Returns:: true if number of requests currently in request pool is non-zero

inline const status_t &get_status(size_type i) const#

Get status of a request.

Parameters:: i – index of the request for which the status will be returned
Returns:: status of request

inline void cancel(size_type i)#

Cancels a pending request in the pool.

Parameters:: i – index of the request for which shall be cancelled

inline void cancelall()#: Cancels all requests in the pool.

inline void push(prequest &&request)#

Move a request into the request pool.

Parameters:: request – request to move into the pool

inline std::pair<test_result, size_type> waitany()#

Wait for completion of any pending communication operation.

Returns:: pair containing the outcome of the wait operation and an index to the completed request if there was any pending request

inline std::pair<test_result, size_type> testany()#

Test for completion of any pending communication operation.

Returns:: pair containing the outcome of the test and an index to the completed request if there was any pending request

inline void waitall()#: Waits for completion of all pending requests.

inline bool testall()#

Tests for completion of all pending requests.

Returns:: true if all pending requests have completed

inline std::pair<test_result, std::vector<size_type>> waitsome()#

Waits until one or more pending requests have finished.

Returns:: pair containing the outcome of the wait operation and a list of indices to the completed requests if there was any pending request

inline std::pair<test_result, std::vector<size_type>> testsome()#

Tests if one or more pending requests have finished.

Returns:: pair containing the outcome of the test and a list of indices to the completed requests if there was any pending request

Command-line arguments#

class command_line : private std::vector<std::string>#

Represents a set of command-line arguments.