hpx/runtime_distributed/applier.hpp

hpx/runtime_distributed/applier.hpp#

Defined in header hpx/runtime_distributed/applier.hpp.

See Public API for a list of names and headers that are part of the public HPX API.

namespace hpx
namespace applier#
class applier#
#include <applier.hpp>

The applier class is used to decide whether a particular action has to be issued on a local or a remote resource. If the target component is local a new thread will be created, if the target is remote a parcel will be sent.

Public Functions

applier(applier const&) = delete#
applier(applier&&) = delete#
applier &operator=(applier const&) = delete#
applier &operator=(applier&&) = delete#
applier()#
void init(threads::threadmanager &tm)#
~applier() = default#
void initialize(std::uint64_t rts)#
threads::threadmanager &get_thread_manager()#

Access the thread-manager instance associated with this applier.

This function returns a reference to the thread manager this applier instance has been created with.

naming::gid_type const &get_raw_locality(error_code &ec = throws) const#

Allow access to the locality of the locality this applier instance is associated with.

This function returns a reference to the locality this applier instance is associated with.

std::uint32_t get_locality_id(error_code &ec = throws) const#

Allow access to the id of the locality this applier instance is associated with.

This function returns a reference to the id of the locality this applier instance is associated with.

bool get_raw_remote_localities(std::vector<naming::gid_type> &locality_ids, components::component_type type = to_int(hpx::components::component_enum_type::invalid), error_code &ec = throws) const#

Return list of localities of all remote localities registered with the AGAS service for a specific component type.

This function returns a list of all remote localities (all localities known to AGAS except the local one) supporting the given component type.

Parameters:

  • locality_ids – [out] The reference to a vector of id_types filled by the function.

  • type – [in] The type of the component which needs to exist on the returned localities.

Returns:

The function returns true if there is at least one remote locality known to the AGAS service (!prefixes.empty()).

bool get_remote_localities(std::vector<hpx::id_type> &locality_ids, components::component_type type = to_int(hpx::components::component_enum_type::invalid), error_code &ec = throws) const#
bool get_raw_localities(std::vector<naming::gid_type> &locality_ids, components::component_type type = to_int(hpx::components::component_enum_type::invalid)) const#

Return list of locality_ids of all localities registered with the AGAS service for a specific component type.

This function returns a list of all localities (all localities known to AGAS except the local one) supporting the given component type.

Parameters:

  • locality_ids – [out] The reference to a vector of id_types filled by the function.

  • type – [in] The type of the component which needs to exist on the returned localities.

Returns:

The function returns true if there is at least one remote locality known to the AGAS service (!prefixes.empty()).

bool get_localities(std::vector<hpx::id_type> &locality_ids, error_code &ec = throws) const#
bool get_localities(std::vector<hpx::id_type> &locality_ids, components::component_type type, error_code &ec = throws) const#
inline naming::gid_type const &get_runtime_support_raw_gid() const#

By convention the runtime_support has a gid identical to the prefix of the locality the runtime_support is responsible for

inline hpx::id_type const &get_runtime_support_gid() const#

By convention the runtime_support has a gid identical to the prefix of the locality the runtime_support is responsible for

Private Members

threads::threadmanager *thread_manager_#
hpx::id_type runtime_support_id_#
Contents