#882

Committed 31 Aug 2023 07:44PM UTC coverage: 41.798% (-44.7%) from 86.546%

Build # #882

Build Type

push

Committed by

Commit Message

Run Details

19442 of 46514 relevant lines covered (41.8%)

126375.38 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

58.33

/libs/full/async_distributed/include/hpx/async_distributed/trigger.hpp

//  Copyright (c) 2007-2020 Hartmut Kaiser
//  Copyright (c) 2016 Thomas Heller
//
//  SPDX-License-Identifier: BSL-1.0
//  Distributed under the Boost Software License, Version 1.0. (See accompanying
//  file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)

#pragma once

#include <hpx/config.hpp>
#include <hpx/async_distributed/continuation_fwd.hpp>
#include <hpx/modules/tag_invoke.hpp>
#include <hpx/modules/type_support.hpp>

#include <exception>
#include <utility>

namespace hpx { namespace actions {

    ///////////////////////////////////////////////////////////////////////////
    template <typename Result, typename RemoteResult, typename F,
        typename... Ts>
    void trigger(typed_continuation<Result, RemoteResult>&& cont, F&& f,
        Ts&&... vs) noexcept
    {
        try
        {
            cont.trigger_value(
                HPX_INVOKE(HPX_FORWARD(F, f), HPX_FORWARD(Ts, vs)...));
        }
        catch (...)
        {
            // make sure hpx::exceptions are propagated back to the client
            cont.trigger_error(std::current_exception());
        }
    }

    // Overload when return type is "void" aka util::unused_type
    template <typename Result, typename F, typename... Ts>
    void trigger(typed_continuation<Result, util::unused_type>&& cont, F&& f,
        Ts&&... vs) noexcept
    {
        try
        {
            HPX_INVOKE(HPX_FORWARD(F, f), HPX_FORWARD(Ts, vs)...);
            cont.trigger();
        }
        catch (...)
        {
            // make sure hpx::exceptions are propagated back to the client
            cont.trigger_error(std::current_exception());
        }
    }
}}    // namespace hpx::actions

1	// Copyright (c) 2007-2020 Hartmut Kaiser
2	// Copyright (c) 2016 Thomas Heller
3	//
4	// SPDX-License-Identifier: BSL-1.0
5	// Distributed under the Boost Software License, Version 1.0. (See accompanying
6	// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
7
8	#pragma once
9
10	#include <hpx/config.hpp>
11	#include <hpx/async_distributed/continuation_fwd.hpp>
12	#include <hpx/modules/tag_invoke.hpp>
13	#include <hpx/modules/type_support.hpp>
14
15	#include <exception>
16	#include <utility>
17
18	namespace hpx { namespace actions {
19
20	///////////////////////////////////////////////////////////////////////////
21	template <typename Result, typename RemoteResult, typename F,
22	typename... Ts>
23	void trigger(typed_continuation<Result, RemoteResult>&& cont, F&& f,	40,333✔
24	Ts&&... vs) noexcept
25	{
26	try
27	{
28	cont.trigger_value(	40,343✔
29	HPX_INVOKE(HPX_FORWARD(F, f), HPX_FORWARD(Ts, vs)...));	40,323✔
30	}
31	catch (...)	×
32	{
33	// make sure hpx::exceptions are propagated back to the client
34	cont.trigger_error(std::current_exception());	×
35	}
36	}	40,333✔
37
38	// Overload when return type is "void" aka util::unused_type
39	template <typename Result, typename F, typename... Ts>
40	void trigger(typed_continuation<Result, util::unused_type>&& cont, F&& f,	7✔
41	Ts&&... vs) noexcept
42	{
43	try
44	{
45	HPX_INVOKE(HPX_FORWARD(F, f), HPX_FORWARD(Ts, vs)...);	×
46	cont.trigger();	7✔
47	}
48	catch (...)	×
49	{
50	// make sure hpx::exceptions are propagated back to the client
51	cont.trigger_error(std::current_exception());	×
52	}
53	}	7✔
54	}} // namespace hpx::actions

STEllAR-GROUP / hpx / #882

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous