Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Adding new statistics performance counters:
- rolling_variance, rolling_max, rolling_min
- Loading branch information
Showing
7 changed files
with
524 additions
and
9 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,116 @@ | ||
| // Copyright (c) 2017 Hartmut Kaiser | ||
| // | ||
| // 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) | ||
|
|
||
| #ifndef ROLLING_MAX_HPP | ||
| #define ROLLING_MAX_HPP | ||
|
|
||
| #include <hpx/config.hpp> | ||
|
|
||
| #include <boost/accumulators/framework/accumulator_base.hpp> | ||
| #include <boost/accumulators/framework/extractor.hpp> | ||
| #include <boost/accumulators/numeric/functional.hpp> | ||
| #include <boost/accumulators/framework/parameters/sample.hpp> | ||
| #include <boost/accumulators/framework/depends_on.hpp> | ||
| #include <boost/accumulators/statistics_fwd.hpp> | ||
| #include <boost/accumulators/statistics/rolling_window.hpp> | ||
|
|
||
| namespace hpx { namespace util | ||
| { | ||
| namespace detail | ||
| { | ||
| template <typename Sample> | ||
| struct rolling_max_impl : boost::accumulators::accumulator_base | ||
| { | ||
| typedef Sample float_type; | ||
|
|
||
| // for boost::result_of | ||
| typedef float_type result_type; | ||
|
|
||
| template <typename Args> | ||
| rolling_max_impl(Args const& args) | ||
| : max_(boost::numeric::as_min(Sample())), | ||
| is_dirty_(false) | ||
| { | ||
| } | ||
|
|
||
| template <typename Args> | ||
| void operator()(Args const& args) | ||
| { | ||
| boost::accumulators::find_accumulator< | ||
| boost::accumulators::tag::rolling_window | ||
| >(args[boost::accumulators::accumulator])(args); | ||
| is_dirty_ = true; | ||
| } | ||
|
|
||
| template <typename Args> | ||
| result_type result(Args const &args) const | ||
| { | ||
| if (is_dirty_) | ||
| { | ||
| using namespace boost::accumulators; | ||
|
|
||
| max_ = boost::numeric::as_min(Sample()); | ||
|
|
||
| // work around problem in older Boost versions | ||
| auto r = rolling_window_plus1(args); | ||
| bool full = impl::is_rolling_window_plus1_full(args); | ||
|
|
||
| for (auto const& s : r.advance_begin(full ? 1 : 0)) | ||
| { | ||
| boost::numeric::max_assign(max_, s); | ||
| } | ||
|
|
||
| is_dirty_ = false; | ||
| } | ||
| return max_; | ||
| } | ||
|
|
||
| private: | ||
| mutable Sample max_; | ||
| mutable bool is_dirty_; | ||
| }; | ||
| } | ||
| }} | ||
|
|
||
| /////////////////////////////////////////////////////////////////////////////// | ||
| // tag::rolling_max | ||
| namespace boost { namespace accumulators | ||
| { | ||
| namespace tag | ||
| { | ||
| struct rolling_max | ||
| : depends_on<rolling_window> | ||
| { | ||
| struct impl | ||
| { | ||
| template <typename Sample, typename Weight> | ||
| struct apply | ||
| { | ||
| typedef hpx::util::detail::rolling_max_impl<Sample> type; | ||
| }; | ||
| }; | ||
| }; | ||
| } | ||
|
|
||
| /////////////////////////////////////////////////////////////////////////////// | ||
| // extract::rolling_max | ||
| namespace extract | ||
| { | ||
| extractor<tag::rolling_max> const rolling_max = {}; | ||
| } | ||
| }} // namespace boost::accumulators | ||
|
|
||
| namespace hpx { namespace util | ||
| { | ||
| namespace tag | ||
| { | ||
| using boost::accumulators::tag::rolling_max; | ||
| } | ||
|
|
||
| using boost::accumulators::extract::rolling_max; | ||
| }} | ||
|
|
||
| #endif | ||
|
|
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,116 @@ | ||
| // Copyright (c) 2017 Hartmut Kaiser | ||
| // | ||
| // 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) | ||
|
|
||
| #ifndef ROLLING_MIN_HPP | ||
| #define ROLLING_MIN_HPP | ||
|
|
||
| #include <hpx/config.hpp> | ||
|
|
||
| #include <boost/accumulators/framework/accumulator_base.hpp> | ||
| #include <boost/accumulators/framework/extractor.hpp> | ||
| #include <boost/accumulators/numeric/functional.hpp> | ||
| #include <boost/accumulators/framework/parameters/sample.hpp> | ||
| #include <boost/accumulators/framework/depends_on.hpp> | ||
| #include <boost/accumulators/statistics_fwd.hpp> | ||
| #include <boost/accumulators/statistics/rolling_window.hpp> | ||
|
|
||
| namespace hpx { namespace util | ||
| { | ||
| namespace detail | ||
| { | ||
| template <typename Sample> | ||
| struct rolling_min_impl : boost::accumulators::accumulator_base | ||
| { | ||
| typedef Sample float_type; | ||
|
|
||
| // for boost::result_of | ||
| typedef float_type result_type; | ||
|
|
||
| template <typename Args> | ||
| rolling_min_impl(Args const& args) | ||
| : min_(boost::numeric::as_max(Sample())), | ||
| is_dirty_(false) | ||
| { | ||
| } | ||
|
|
||
| template <typename Args> | ||
| void operator()(Args const& args) | ||
| { | ||
| boost::accumulators::find_accumulator< | ||
| boost::accumulators::tag::rolling_window | ||
| >(args[boost::accumulators::accumulator])(args); | ||
| is_dirty_ = true; | ||
| } | ||
|
|
||
| template <typename Args> | ||
| result_type result(Args const &args) const | ||
| { | ||
| if (is_dirty_) | ||
| { | ||
| using namespace boost::accumulators; | ||
|
|
||
| min_ = boost::numeric::as_max(Sample()); | ||
|
|
||
| // work around problem in older Boost versions | ||
| auto r = rolling_window_plus1(args); | ||
| bool full = impl::is_rolling_window_plus1_full(args); | ||
|
|
||
| for (auto const& s : r.advance_begin(full ? 1 : 0)) | ||
| { | ||
| boost::numeric::min_assign(min_, s); | ||
| } | ||
|
|
||
| is_dirty_ = false; | ||
| } | ||
| return min_; | ||
| } | ||
|
|
||
| private: | ||
| mutable Sample min_; | ||
| mutable bool is_dirty_; | ||
| }; | ||
| } | ||
| }} | ||
|
|
||
| /////////////////////////////////////////////////////////////////////////////// | ||
| // tag::rolling_min | ||
| namespace boost { namespace accumulators | ||
| { | ||
| namespace tag | ||
| { | ||
| struct rolling_min | ||
| : depends_on<rolling_window> | ||
| { | ||
| struct impl | ||
| { | ||
| template <typename Sample, typename Weight> | ||
| struct apply | ||
| { | ||
| typedef hpx::util::detail::rolling_min_impl<Sample> type; | ||
| }; | ||
| }; | ||
| }; | ||
| } | ||
|
|
||
| /////////////////////////////////////////////////////////////////////////////// | ||
| // extract::rolling_min | ||
| namespace extract | ||
| { | ||
| extractor<tag::rolling_min> const rolling_min = {}; | ||
| } | ||
| }} // namespace boost::accumulators | ||
|
|
||
| namespace hpx { namespace util | ||
| { | ||
| namespace tag | ||
| { | ||
| using boost::accumulators::tag::rolling_min; | ||
| } | ||
|
|
||
| using boost::accumulators::extract::rolling_min; | ||
| }} | ||
|
|
||
| #endif | ||
|
|
Oops, something went wrong.