#856

Committed 28 Dec 2022 02:00AM UTC coverage: 86.602% (+0.05%) from 86.55%

Build # #856

Build Type

push

Committed by StellarBot

Commit Message

Merge #6119

6119: Update CMakeLists.txt r=hkaiser a=khuck

updating the default APEX version


Co-authored-by: Kevin Huck <khuck@cs.uoregon.edu>

Run Details

174566 of 201573 relevant lines covered (86.6%)

1876093.78 hits per line

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

77.14

/libs/core/execution_base/src/agent_ref.cpp

//  Copyright (c) 2019 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)

#include <hpx/assert.hpp>
#include <hpx/execution_base/agent_ref.hpp>
#include <hpx/execution_base/this_thread.hpp>
#include <hpx/lock_registration/detail/register_locks.hpp>
#include <hpx/modules/format.hpp>

#include <cstddef>
#include <ostream>

namespace hpx::execution_base {

    void agent_ref::yield(const char* desc)
    {
        HPX_ASSERT(*this == hpx::execution_base::this_thread::agent());

        // verify that there are no more registered locks for this OS-thread
        util::verify_no_locks();
        impl_->yield(desc);
    }

    void agent_ref::yield_k(std::size_t k, const char* desc)
    {
        HPX_ASSERT(*this == hpx::execution_base::this_thread::agent());

        // verify that there are no more registered locks for this OS-thread
        util::verify_no_locks();
        impl_->yield_k(k, desc);
    }

    void agent_ref::suspend(const char* desc)
    {
        HPX_ASSERT(*this == hpx::execution_base::this_thread::agent());

        // verify that there are no more registered locks for this OS-thread
        util::verify_no_locks();
        impl_->suspend(desc);
    }

    void agent_ref::resume(const char* desc)
    {
        HPX_ASSERT(*this != hpx::execution_base::this_thread::agent());
        impl_->resume(desc);
    }

    void agent_ref::abort(const char* desc)
    {
        HPX_ASSERT(*this != hpx::execution_base::this_thread::agent());
        impl_->abort(desc);
    }

    void agent_ref::sleep_for(
        hpx::chrono::steady_duration const& sleep_duration, const char* desc)
    {
        HPX_ASSERT(*this == hpx::execution_base::this_thread::agent());
        impl_->sleep_for(sleep_duration, desc);
    }

    void agent_ref::sleep_until(
        hpx::chrono::steady_time_point const& sleep_time, const char* desc)
    {
        HPX_ASSERT(*this == hpx::execution_base::this_thread::agent());
        impl_->sleep_until(sleep_time, desc);
    }

    std::ostream& operator<<(std::ostream& os, agent_ref const& a)
    {
        hpx::util::format_to(os, "agent_ref{{{}}}", a.impl_->description());
        return os;
    }
}    // namespace hpx::execution_base

1	// Copyright (c) 2019 Thomas Heller
2	//
3	// SPDX-License-Identifier: BSL-1.0
4	// Distributed under the Boost Software License, Version 1.0. (See accompanying
5	// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
6
7	#include <hpx/assert.hpp>
8	#include <hpx/execution_base/agent_ref.hpp>
9	#include <hpx/execution_base/this_thread.hpp>
10	#include <hpx/lock_registration/detail/register_locks.hpp>
11	#include <hpx/modules/format.hpp>
12
13	#include <cstddef>
14	#include <ostream>
15
16	namespace hpx::execution_base {
17
18	void agent_ref::yield(const char* desc)	73,504,820✔
19	{
20	HPX_ASSERT(*this == hpx::execution_base::this_thread::agent());	73,504,820✔
21
22	// verify that there are no more registered locks for this OS-thread
23	util::verify_no_locks();	73,407,079✔
24	impl_->yield(desc);	73,407,079✔
25	}	73,407,079✔
26
27	void agent_ref::yield_k(std::size_t k, const char* desc)	8,432,105✔
28	{
29	HPX_ASSERT(*this == hpx::execution_base::this_thread::agent());	8,432,105✔
30
31	// verify that there are no more registered locks for this OS-thread
32	util::verify_no_locks();	8,435,883✔
33	impl_->yield_k(k, desc);	8,435,883✔
34	}	8,435,883✔
35
36	void agent_ref::suspend(const char* desc)	1,116,099✔
37	{
38	HPX_ASSERT(*this == hpx::execution_base::this_thread::agent());	1,116,099✔
39
40	// verify that there are no more registered locks for this OS-thread
41	util::verify_no_locks();	1,116,100✔
42	impl_->suspend(desc);	1,116,100✔
43	}	1,116,100✔
44
45	void agent_ref::resume(const char* desc)	1,116,116✔
46	{
47	HPX_ASSERT(*this != hpx::execution_base::this_thread::agent());	1,116,116✔
48	impl_->resume(desc);	1,116,111✔
49	}	1,116,111✔
50
51	void agent_ref::abort(const char* desc)	×
52	{
53	HPX_ASSERT(*this != hpx::execution_base::this_thread::agent());	×
54	impl_->abort(desc);	×
55	}	×
56
57	void agent_ref::sleep_for(	1✔
58	hpx::chrono::steady_duration const& sleep_duration, const char* desc)
59	{
60	HPX_ASSERT(*this == hpx::execution_base::this_thread::agent());	1✔
61	impl_->sleep_for(sleep_duration, desc);	1✔
62	}	1✔
63
64	void agent_ref::sleep_until(	63✔
65	hpx::chrono::steady_time_point const& sleep_time, const char* desc)
66	{
67	HPX_ASSERT(*this == hpx::execution_base::this_thread::agent());	63✔
68	impl_->sleep_until(sleep_time, desc);	63✔
69	}	63✔
70
71	std::ostream& operator<<(std::ostream& os, agent_ref const& a)	×
72	{
73	hpx::util::format_to(os, "agent_ref{{{}}}", a.impl_->description());	×
74	return os;	×
75	}	×
76	} // namespace hpx::execution_base

STEllAR-GROUP / hpx / #856

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