hpx/resiliency/async_replay.hpp#

Defined in header hpx/resiliency/async_replay.hpp.

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

namespace hpx
namespace resiliency#
namespace experimental#

Functions

template<typename Pred, typename F, typename ...Ts>
hpx::future<hpx::util::detail::invoke_deferred_result_t<F, Ts...>> hpx_invoke(async_replay_validate_t, std::size_t n, Pred &&pred, F &&f, Ts&&... ts)#

ADL hook for async_replay_validate CPO.

Asynchronously launches f, validating results with pred. Repeats on error up to n times (aborts on abort_replay_exception).

Parameters

  • tag – CPO tag (async_replay_validate_t).

  • n – Maximum number of retry attempts.

  • pred – Predicate validating each invocation result.

  • f – Callable to invoke asynchronously.

  • ts – Arguments forwarded to f.

Returns

future with the first valid result of f.

template<typename F, typename ...Ts>
hpx::future<hpx::util::detail::invoke_deferred_result_t<F, Ts...>> hpx_invoke(async_replay_t, std::size_t n, F &&f, Ts&&... ts)#

ADL hook for async_replay CPO.

Asynchronously launches f, repeating on error up to n times (aborts on abort_replay_exception).

Parameters

  • tag – CPO tag (async_replay_t).

  • n – Maximum number of retry attempts.

  • f – Callable to invoke asynchronously.

  • ts – Arguments forwarded to f.

Returns

future with the first successful result of f.