I/O counter for bytes read. Attempt to count the number of bytes which this process really did cause to be fetched from the storage layer. Done at the submit_bio() level, so it is accurate for block-backed filesystems. More...

#include "timemory/components/io/components.hpp"

Collaboration diagram for tim::component::read_bytes:

Public Types
using	this_type = read_bytes

using	value_type = std::pair< int64_t, int64_t >

using	base_type = base< this_type, value_type >

using	result_type = std::pair< double, double >

using	unit_type = typename trait::units< this_type >::type

using	display_unit_type = typename trait::units< this_type >::display_type

using	storage_type = empty_storage

Public Member Functions
std::string	get_display () const

result_type	get () const

void	start ()

void	stop ()

void	sample ()
	sample a measurement More...

void	sample (const cache_type &_cache)
	sample a measurement from cached data More...

void	start (const cache_type &_cache)
	start a measurement using the cached data More...

void	stop (const cache_type &_cache)
	stop a measurement using the cached data More...

Static Public Member Functions
static std::string	label ()

static std::string	description ()

static std::pair< double, double >	unit ()

static std::vector< std::string >	display_unit_array ()

static std::vector< std::string >	label_array ()

static display_unit_type	display_unit ()

static std::pair< double, double >	unit_array ()

static std::vector< std::string >	description_array ()

static auto	get_timestamp ()

static value_type	record ()

static auto	get_timing_unit ()

static unit_type	get_unit ()

static display_unit_type	get_display_unit ()

static value_type	record (const cache_type &_cache)
	read the value from the cache More...

template<typename... Args>
static opaque	get_opaque (Args &&...)

Detailed Description

I/O counter for bytes read. Attempt to count the number of bytes which this process really did cause to be fetched from the storage layer. Done at the submit_bio() level, so it is accurate for block-backed filesystems.

Definition at line 465 of file components.hpp.

Member Typedef Documentation

◆ base_type

using tim::component::read_bytes::base_type = base<this_type, value_type>

Definition at line 469 of file components.hpp.

◆ display_unit_type

using tim::component::read_bytes::display_unit_type = typename trait::units<this_type>::display_type

Definition at line 472 of file components.hpp.

◆ result_type

using tim::component::read_bytes::result_type = std::pair<double, double>

Definition at line 470 of file components.hpp.

◆ storage_type

using tim::component::empty_base::storage_type = empty_storage

inherited

Definition at line 66 of file declaration.hpp.

◆ this_type

using tim::component::read_bytes::this_type = read_bytes

Definition at line 467 of file components.hpp.

◆ unit_type

using tim::component::read_bytes::unit_type = typename trait::units<this_type>::type

Definition at line 471 of file components.hpp.

◆ value_type

using tim::component::read_bytes::value_type = std::pair<int64_t, int64_t>

Definition at line 468 of file components.hpp.

Member Function Documentation

◆ description()

static std::string tim::component::read_bytes::description ( )

inlinestatic

Definition at line 475 of file components.hpp.

    {
        return "Number of bytes which this process really did cause to be fetched from "
               "the storage layer";
    }

◆ description_array()

static std::vector< std::string > tim::component::read_bytes::description_array ( )

inlinestatic

Definition at line 506 of file components.hpp.

    {
        return std::vector<std::string>{ "Number of bytes read", "Rate of bytes read" };
    }

◆ display_unit()

static display_unit_type tim::component::read_bytes::display_unit ( )

inlinestatic

Definition at line 499 of file components.hpp.

    {
        return display_unit_type{ "MB", "MB/sec" };
    }

Referenced by get_display_unit().

◆ display_unit_array()

static std::vector< std::string > tim::component::read_bytes::display_unit_array ( )

inlinestatic

Definition at line 488 of file components.hpp.

    {
        return std::vector<std::string>{ std::get<0>(get_display_unit()),
                                         std::get<1>(get_display_unit()) };
    }

References get_display_unit().

◆ get()

result_type tim::component::read_bytes::get ( ) const

inline

Definition at line 550 of file components.hpp.

    {
        auto val = base_type::load();
 
        double data  = std::get<0>(val);
        double delta = std::get<1>(val);
 
        delta /= static_cast<double>(std::nano::den);
        delta *= get_timing_unit();
 
        double rate = 0.0;
        if(delta != 0.0)
            rate = data / delta;
 
        if(laps > 0)
            rate *= laps;
 
        data /= std::get<0>(get_unit());
        rate /= std::get<0>(get_unit());
 
        if(!std::isfinite(rate))
            rate = 0.0;
 
        return result_type(data, rate);
    }

References get_timing_unit(), get_unit(), tim::isfinite(), tim::component::base< read_bytes, std::pair< int64_t, int64_t > >::laps, and tim::component::base< Tp, Value >::load().

Referenced by get_display().

◆ get_display()

std::string tim::component::read_bytes::get_display ( ) const

inline

Definition at line 523 of file components.hpp.

    {
        std::stringstream ss;
        std::stringstream ssv;
        std::stringstream ssr;
        auto              _prec  = base_type::get_precision();
        auto              _width = base_type::get_width();
        auto              _flags = base_type::get_format_flags();
        auto              _disp  = get_display_unit();
 
        auto _val = get();
 
        ssv.setf(_flags);
        ssv << std::setw(_width) << std::setprecision(_prec) << std::get<0>(_val);
        if(!std::get<0>(_disp).empty())
            ssv << " " << std::get<0>(_disp);
 
        ssr.setf(_flags);
        ssr << std::setw(_width) << std::setprecision(_prec) << std::get<1>(_val);
        if(!std::get<1>(_disp).empty())
            ssr << " " << std::get<1>(_disp);
 
        ss << ssv.str() << ", " << ssr.str();
        ss << " read_bytes";
        return ss.str();
    }

References get(), get_display_unit(), tim::component::base< Tp, Value >::get_format_flags(), tim::component::base< Tp, Value >::get_precision(), and tim::component::base< Tp, Value >::get_width().

◆ get_display_unit()

static display_unit_type tim::component::read_bytes::get_display_unit ( )

inlinestatic

Definition at line 609 of file components.hpp.

    {
        static display_unit_type _instance = this_type::display_unit();
        static auto&             _mem      = std::get<0>(_instance);
        static auto&             _rate     = std::get<1>(_instance);
 
        if(settings::memory_units().length() > 0)
            _mem = std::get<0>(units::get_memory_unit(settings::memory_units()));
 
        if(settings::timing_units().length() > 0)
        {
            auto _tval = std::get<0>(units::get_timing_unit(settings::timing_units()));
            _rate      = mpl::apply<std::string>::join('/', _mem, _tval);
        }
        else if(settings::memory_units().length() > 0)
        {
            _rate = mpl::apply<std::string>::join('/', _mem, "sec");
        }
 
        return _instance;
    }

References display_unit(), tim::units::get_memory_unit(), tim::units::get_timing_unit(), tim::mpl::apply< Ret >::join(), tim::memory_units, and tim::timing_units.

Referenced by display_unit_array(), and get_display().

◆ get_opaque()

template<typename... Args>

static opaque tim::component::empty_base::get_opaque ( Args && ... )

inlinestaticinherited

Definition at line 72 of file declaration.hpp.

    {
        return opaque{};
    }

◆ get_timestamp()

static auto tim::component::read_bytes::get_timestamp ( )

inlinestatic

Definition at line 511 of file components.hpp.

511{ return tim::get_clock_real_now<int64_t, std::nano>(); }

Referenced by record().

◆ get_timing_unit()

static auto tim::component::read_bytes::get_timing_unit ( )

inlinestatic

Definition at line 515 of file components.hpp.

    {
        static auto _value = units::sec;
        if(settings::timing_units().length() > 0)
            _value = std::get<1>(units::get_timing_unit(settings::timing_units()));
        return _value;
    }

References tim::units::get_timing_unit(), and tim::timing_units.

Referenced by get().

◆ get_unit()

static unit_type tim::component::read_bytes::get_unit ( )

inlinestatic

Definition at line 586 of file components.hpp.

    {
        static auto  _instance = this_type::unit();
        static auto& _mem      = std::get<0>(_instance);
        static auto& _rate     = std::get<1>(_instance);
 
        if(settings::memory_units().length() > 0)
            _mem = std::get<1>(units::get_memory_unit(settings::memory_units()));
 
        if(settings::timing_units().length() > 0)
        {
            auto _timing_val =
                std::get<1>(units::get_timing_unit(settings::timing_units()));
            _rate = _mem / (_timing_val);
        }
 
        static const auto factor = static_cast<double>(std::nano::den);
        unit_type         _tmp   = _instance;
        std::get<1>(_tmp) *= factor;
 
        return _tmp;
    }

References tim::units::get_memory_unit(), tim::units::get_timing_unit(), tim::memory_units, tim::timing_units, and unit().

Referenced by get().

◆ label()

static std::string tim::component::read_bytes::label ( )

inlinestatic

Definition at line 474 of file components.hpp.

474{ return "read_bytes"; }

Referenced by label_array().

◆ label_array()

static std::vector< std::string > tim::component::read_bytes::label_array ( )

inlinestatic

Definition at line 494 of file components.hpp.

    {
        return std::vector<std::string>{ label(), "read_rate" };
    }

References label().

◆ record() [1/2]

static value_type tim::component::read_bytes::record ( )

inlinestatic

Definition at line 513 of file components.hpp.

513{ return value_type(get_bytes_read(), get_timestamp()); }

tim::component::read_bytes::get_timestamp

static auto get_timestamp()

Definition: components.hpp:511

tim::component::read_bytes::value_type

std::pair< int64_t, int64_t > value_type

Definition: components.hpp:468

References get_timestamp().

Referenced by start(), and stop().

◆ record() [2/2]

static value_type tim::component::read_bytes::record ( const cache_type & _cache )

inlinestatic

read the value from the cache

Definition at line 646 of file components.hpp.

    {
        return value_type{ _cache.get_bytes_read(), get_timestamp() };
    }

References get_timestamp().

◆ sample() [1/2]

void tim::component::read_bytes::sample ( )

inline

sample a measurement

Definition at line 632 of file components.hpp.

    {
        std::get<0>(accum) = std::get<0>(value) =
            std::max<int64_t>(std::get<0>(value), get_bytes_read());
    }

◆ sample() [2/2]

void tim::component::read_bytes::sample ( const cache_type & _cache )

inline

sample a measurement from cached data

Definition at line 639 of file components.hpp.

    {
        std::get<0>(accum) = std::get<0>(value) =
            std::max<int64_t>(std::get<0>(value), _cache.get_bytes_read());
    }

◆ start() [1/2]

void tim::component::read_bytes::start ( )

inline

Definition at line 576 of file components.hpp.

576{ value = record(); }

tim::component::read_bytes::record

static value_type record()

Definition: components.hpp:513

References record().

◆ start() [2/2]

void tim::component::read_bytes::start ( const cache_type & _cache )

inline

start a measurement using the cached data

Definition at line 652 of file components.hpp.

652{ value = record(_cache); }

References record().

◆ stop() [1/2]

void tim::component::read_bytes::stop ( )

inline

Definition at line 578 of file components.hpp.

    {
        using namespace tim::component::operators;
        auto diff         = (record() - value);
        std::get<0>(diff) = std::abs(std::get<0>(diff));
        accum += (value = diff);
    }

References tim::math::abs, and record().

◆ stop() [2/2]

void tim::component::read_bytes::stop ( const cache_type & _cache )

inline

stop a measurement using the cached data

Definition at line 655 of file components.hpp.

    {
        using namespace tim::component::operators;
        auto diff         = (record(_cache) - value);
        std::get<0>(diff) = std::abs(std::get<0>(diff));
        accum += (value = diff);
    }

References tim::math::abs, and record().

◆ unit()

static std::pair< double, double > tim::component::read_bytes::unit ( )

inlinestatic

Definition at line 481 of file components.hpp.

    {
        return std::pair<double, double>{
            units::megabyte, static_cast<double>(units::megabyte) / units::sec
        };
    }

Referenced by get_unit(), and unit_array().

◆ unit_array()

static std::pair< double, double > tim::component::read_bytes::unit_array ( )

inlinestatic

Definition at line 504 of file components.hpp.

504{ return unit(); }

References unit().

The documentation for this struct was generated from the following file:

timemory/components/io/components.hpp

Public Types

Public Member Functions

Static Public Member Functions

Detailed Description

Member Typedef Documentation

◆ base_type

◆ display_unit_type

◆ result_type

◆ storage_type

◆ this_type

◆ unit_type

◆ value_type

Member Function Documentation

◆ description()

◆ description_array()

◆ display_unit()

◆ display_unit_array()

◆ get()

◆ get_display()

◆ get_display_unit()

◆ get_opaque()

◆ get_timestamp()

◆ get_timing_unit()

◆ get_unit()

◆ label()

◆ label_array()

◆ record() [1/2]

◆ record() [2/2]

◆ sample() [1/2]

◆ sample() [2/2]

◆ start() [1/2]

◆ start() [2/2]

◆ stop() [1/2]

◆ stop() [2/2]

◆ unit()

◆ unit_array()