hpx/resiliency/resiliency_cpos.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

Variables

hpx::resiliency::experimental::async_replay_validate_t async_replay_validate
hpx::resiliency::experimental::async_replay_t async_replay
hpx::resiliency::experimental::dataflow_replay_validate_t dataflow_replay_validate
hpx::resiliency::experimental::dataflow_replay_t dataflow_replay
hpx::resiliency::experimental::async_replicate_vote_validate_t async_replicate_vote_validate
hpx::resiliency::experimental::async_replicate_vote_t async_replicate_vote
hpx::resiliency::experimental::async_replicate_validate_t async_replicate_validate
hpx::resiliency::experimental::async_replicate_t async_replicate
hpx::resiliency::experimental::dataflow_replicate_vote_validate_t dataflow_replicate_vote_validate
hpx::resiliency::experimental::dataflow_replicate_vote_t dataflow_replicate_vote
hpx::resiliency::experimental::dataflow_replicate_validate_t dataflow_replicate_validate
hpx::resiliency::experimental::dataflow_replicate_t dataflow_replicate
struct async_replay_t : public hpx::functional::tag<async_replay_t>
#include <resiliency_cpos.hpp>

Customization point for asynchronously launching given function f repeatedly. Repeat launching on error exactly n times (except if abort_replay_exception is thrown).

struct async_replay_validate_t : public hpx::functional::tag<async_replay_validate_t>
#include <resiliency_cpos.hpp>

Customization point for asynchronously launching the given function f. repeatedly. Verify the result of those invocations using the given predicate pred. Repeat launching on error exactly n times (except if abort_replay_exception is thrown).

struct async_replicate_t : public hpx::functional::tag<async_replicate_t>
#include <resiliency_cpos.hpp>

Customization point for asynchronously launching the given function f exactly n times concurrently. Verify the result of those invocations by checking for exception. Return the first valid result.

struct async_replicate_validate_t : public hpx::functional::tag<async_replicate_validate_t>
#include <resiliency_cpos.hpp>

Customization point for asynchronously launching the given function f exactly n times concurrently. Verify the result of those invocations using the given predicate pred. Return the first valid result.

struct async_replicate_vote_t : public hpx::functional::tag<async_replicate_vote_t>
#include <resiliency_cpos.hpp>

Customization point for asynchronously launching the given function f exactly n times concurrently. Verify the result of those invocations using the given predicate pred. Run all the valid results against a user provided voting function. Return the valid output.

struct async_replicate_vote_validate_t : public hpx::functional::tag<async_replicate_vote_validate_t>
#include <resiliency_cpos.hpp>

Customization point for asynchronously launching the given function f exactly n times concurrently. Verify the result of those invocations using the given predicate pred. Run all the valid results against a user provided voting function. Return the valid output.

struct dataflow_replay_t : public hpx::resiliency::experimental::tag_deferred<dataflow_replay_t, async_replay_t>
#include <resiliency_cpos.hpp>

Customization point for asynchronously launching the given function f. repeatedly. Repeat launching on error exactly n times.

Delay the invocation of f if any of the arguments to f are futures.

struct dataflow_replay_validate_t : public hpx::resiliency::experimental::tag_deferred<dataflow_replay_validate_t, async_replay_validate_t>
#include <resiliency_cpos.hpp>

Customization point for asynchronously launching the given function f. repeatedly. Verify the result of those invocations using the given predicate pred. Repeat launching on error exactly n times.

Delay the invocation of f if any of the arguments to f are futures.

struct dataflow_replicate_t : public hpx::resiliency::experimental::tag_deferred<dataflow_replicate_t, async_replicate_t>
#include <resiliency_cpos.hpp>

Customization point for asynchronously launching the given function f exactly n times concurrently. Return the first valid result.

Delay the invocation of f if any of the arguments to f are futures.

struct dataflow_replicate_validate_t : public hpx::resiliency::experimental::tag_deferred<dataflow_replicate_validate_t, async_replicate_validate_t>
#include <resiliency_cpos.hpp>

Customization point for asynchronously launching the given function f exactly n times concurrently. Verify the result of those invocations using the given predicate pred. Return the first valid result.

Delay the invocation of f if any of the arguments to f are futures.

struct dataflow_replicate_vote_t : public hpx::resiliency::experimental::tag_deferred<dataflow_replicate_vote_t, async_replicate_vote_t>
#include <resiliency_cpos.hpp>

Customization point for asynchronously launching the given function f exactly n times concurrently. Run all the valid results against a user provided voting function. Return the valid output.

Delay the invocation of f if any of the arguments to f are futures.

struct dataflow_replicate_vote_validate_t : public hpx::resiliency::experimental::tag_deferred<dataflow_replicate_vote_validate_t, async_replicate_vote_validate_t>
#include <resiliency_cpos.hpp>

Customization point for asynchronously launching the given function f exactly n times concurrently. Run all the valid results against a user provided voting function. Return the valid output.

Delay the invocation of f if any of the arguments to f are futures.

template<typename Tag, typename BaseTag>
struct tag_deferred : public hpx::functional::tag<Tag>

Friends

template<typename ...Args>
auto tag_invoke(Tag, Args&&... args)