#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

0.0

/examples/performance_counters/access_counter_set.cpp

//  Copyright (c) 2017 Hartmut Kaiser
//
//  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)

// The purpose of this example is to demonstrate the simplest way to create and
// use a performance counter for HPX.

#include <hpx/config.hpp>
#if !defined(HPX_COMPUTE_DEVICE_CODE)
#include <hpx/hpx_init.hpp>
#include <hpx/include/performance_counters.hpp>
#include <hpx/iostream.hpp>

#include <hpx/modules/program_options.hpp>

#include <cstddef>
#include <iomanip>
#include <string>
#include <vector>

int hpx_main(hpx::program_options::variables_map& vm)
{
    // extract the counter name (pattern) from command line
    std::string name;
    if (vm.count("counter"))
    {
        name = vm["counter"].as<std::string>();
    }
    else
    {
        name = "/threads{locality#*/worker-thread#*}/count/cumulative";
    }

    // create the performance counter set from the given pattern (name)
    {
        using namespace hpx::performance_counters;
        performance_counter_set set(name);

        // retrieve the counter information for all attached counters
        std::vector<counter_info> infos = set.get_counter_infos();

        // retrieve the current counter values
        std::vector<double> values = set.get_values<double>(hpx::launch::sync);

        // print the values for all 'raw' (non-histogram) counters
        for (std::size_t i = 0, j = 0; i != infos.size(); ++i)
        {
            if (infos[i].type_ != counter_type::raw &&
                infos[i].type_ != counter_type::monotonically_increasing &&
                infos[i].type_ != counter_type::aggregating &&
                infos[i].type_ != counter_type::elapsed_time &&
                infos[i].type_ != counter_type::average_count &&
                infos[i].type_ != counter_type::average_timer)
            {
                continue;
            }

            if (infos[i].unit_of_measure_.empty())
            {
                hpx::cout << infos[i].fullname_ << ":" << values[j]
                          << std::endl;
            }
            else
            {
                hpx::cout << infos[i].fullname_ << ":" << values[j] << "["
                          << infos[i].unit_of_measure_ << "]" << std::endl;
            }
            ++j;
        }
    }

    return hpx::finalize();
}

int main(int argc, char* argv[])
{
    // Define application-specific command-line options.
    hpx::program_options::options_description cmdline(
        "usage: access_counter_set [options]");

    cmdline.add_options()("counter", hpx::program_options::value<std::string>(),
        "name (pattern) representing the of the performance counter(s) to "
        "query");

    hpx::init_params init_args;
    init_args.desc_cmdline = cmdline;

    // Initialize and run HPX.
    return hpx::init(argc, argv, init_args);
}

#endif

1	// Copyright (c) 2017 Hartmut Kaiser
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	// The purpose of this example is to demonstrate the simplest way to create and
8	// use a performance counter for HPX.
9
10	#include <hpx/config.hpp>
11	#if !defined(HPX_COMPUTE_DEVICE_CODE)
12	#include <hpx/hpx_init.hpp>
13	#include <hpx/include/performance_counters.hpp>
14	#include <hpx/iostream.hpp>
15
16	#include <hpx/modules/program_options.hpp>
17
18	#include <cstddef>
19	#include <iomanip>
20	#include <string>
21	#include <vector>
22
23	int hpx_main(hpx::program_options::variables_map& vm)	×
24	{
25	// extract the counter name (pattern) from command line
26	std::string name;
27	if (vm.count("counter"))	×
28	{
29	name = vm["counter"].as<std::string>();	×
30	}
31	else
32	{
33	name = "/threads{locality#/worker-thread#}/count/cumulative";
34	}
35
36	// create the performance counter set from the given pattern (name)
37	{
38	using namespace hpx::performance_counters;
39	performance_counter_set set(name);	×
40
41	// retrieve the counter information for all attached counters
42	std::vector<counter_info> infos = set.get_counter_infos();	×
43
44	// retrieve the current counter values
45	std::vector<double> values = set.get_values<double>(hpx::launch::sync);	×
46
47	// print the values for all 'raw' (non-histogram) counters
48	for (std::size_t i = 0, j = 0; i != infos.size(); ++i)	×
49	{
50	if (infos[i].type_ != counter_type::raw &&	×
51	infos[i].type_ != counter_type::monotonically_increasing &&	×
52	infos[i].type_ != counter_type::aggregating &&	×
53	infos[i].type_ != counter_type::elapsed_time &&	×
54	infos[i].type_ != counter_type::average_count &&	×
55	infos[i].type_ != counter_type::average_timer)
56	{
57	continue;	×
58	}
59
60	if (infos[i].unit_of_measure_.empty())	×
61	{
62	hpx::cout << infos[i].fullname_ << ":" << values[j]	×
63	<< std::endl;	×
64	}
65	else
66	{
67	hpx::cout << infos[i].fullname_ << ":" << values[j] << "["	×
68	<< infos[i].unit_of_measure_ << "]" << std::endl;	×
69	}
70	++j;	×
71	}
72	}	×
73
74	return hpx::finalize();	×
75	}
76
77	int main(int argc, char* argv[])	×
78	{
79	// Define application-specific command-line options.
80	hpx::program_options::options_description cmdline(
81	"usage: access_counter_set [options]");	×
82
83	cmdline.add_options()("counter", hpx::program_options::value<std::string>(),	×
84	"name (pattern) representing the of the performance counter(s) to "
85	"query");
86
87	hpx::init_params init_args;	×
88	init_args.desc_cmdline = cmdline;	×
89
90	// Initialize and run HPX.
91	return hpx::init(argc, argv, init_args);	×
92	}	×
93
94	#endif

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