apollo::resource_statistic::DiskResourceStatistic类 参考

#include <disk_resource_statistic.h>

apollo::resource_statistic::DiskResourceStatistic 的协作图:

Public 成员函数
void	SetInterval (uint32_t interval)
	Set timer component interval.
void	LoadDiskConf (const ResourceStatisticConf_DiskConf &disk_conf)
	Load disk conf.
bool	GetDiskMetric (DiskMetric *disk_metric)
	Get Disk metric and write it into disk_metric.

详细描述

在文件 disk_resource_statistic.h 第 33 行定义.

成员函数说明

GetDiskMetric()

bool apollo::resource_statistic::DiskResourceStatistic::GetDiskMetric

(

DiskMetric *

disk_metric

)

Get Disk metric and write it into disk_metric.

参数

disk_metric

Disk metric proto message

返回

If get metric successfully.

在文件 disk_resource_statistic.cc 第 73 行定义.

                                                                 {
    static const std::string disks_stat_file = "/proc/diskstats";
    const int device_index = 2, in_out_ms = 12;
    static constexpr int kDiskInfo = 128;
 
    auto devices = disk_metric->mutable_devices();
    const auto stat_lines = GetStatsLines(disks_stat_file, kDiskInfo);
    uint64_t disk_stats = 0;
    for (const auto& line : stat_lines) {
        const std::vector<std::string> stats = absl::StrSplit(line, ' ', absl::SkipWhitespace());
        auto& device = stats[device_index];
        if (disk_load_device_set_.find(device) == disk_load_device_set_.end()) {
            continue;
        }
        disk_stats = std::stoll(stats[in_out_ms]);
        if (disk_load_pre_stat_map_.find(device) == disk_load_pre_stat_map_.end()) {
            disk_load_pre_stat_map_[device] = disk_stats;
            continue;
        }
 
        auto metric = devices->Add();
        metric->set_name(device);
        // add disk load
        metric->set_load(
                100.f
                * (static_cast<float>(disk_stats - disk_load_pre_stat_map_[device]) / static_cast<float>(interval_)));
        disk_load_pre_stat_map_[device] = disk_stats;
        // add disk usage
        const auto space = boost::filesystem::space(disk_usage_path_map_[device]);
        const auto used_gb = static_cast<uint32_t>((space.capacity - space.available) >> 30);
        const auto total_gb = static_cast<uint32_t>(space.capacity >> 30);
        metric->set_used_gb(used_gb);
        metric->set_available_gb(static_cast<uint32_t>(space.available >> 30));
        metric->set_total_gb(total_gb);
        if (total_gb > 0) {
            metric->set_usage(100.f * used_gb / total_gb);
        }
    }
    return true;
}

LoadDiskConf()

void apollo::resource_statistic::DiskResourceStatistic::LoadDiskConf

(

const ResourceStatisticConf_DiskConf &

disk_conf

)

Load disk conf.

参数

disk_conf

Disk conf message

在文件 disk_resource_statistic.cc 第 30 行定义.

                                                                                        {
    if (disk_conf.device().size() == 0) {
        return;
    }
    // get all load regexes
    std::vector<std::regex> regex_list;
    static const std::string device_prefix = "/dev/";
    for (auto& pattern : disk_conf.device()) {
        if (pattern.empty()) {
            continue;
        }
        auto pattern_ = pattern;
        if (pattern[0] != '/') {
            // add default /dev/
            pattern_ = device_prefix + pattern;
        }
        try {
            regex_list.emplace_back(std::regex(pattern_));
        } catch (std::regex_error& e) {
            AERROR << "error disk conf: " << pattern << ", regex_error caught: " << e.what();
        }
    }
 
    // find all avaliable disks
    static const std::string mounts_file = "/proc/mounts";
    static constexpr size_t kMaxMounts = 500, kDevice = 0, kPath = 1, kSize = 6;
    const auto mount_lines = GetStatsLines(mounts_file, kMaxMounts);
    for (const auto& line : mount_lines) {
        const std::vector<std::string> mounts = absl::StrSplit(line, ' ', absl::SkipWhitespace());
        // must starts with /dev/
        if (mounts.size() < kSize || mounts[kDevice].substr(0, device_prefix.size()) != device_prefix) {
            continue;
        }
        for (auto& regex_ : regex_list) {
            if (std::regex_match(mounts[kDevice], regex_)) {
                auto device = mounts[kDevice].substr(device_prefix.size());
                disk_load_device_set_.insert(device);
                disk_usage_path_map_.insert({device, mounts[kPath]});
            }
        }
    }
}

SetInterval()

void apollo::resource_statistic::DiskResourceStatistic::SetInterval ( uint32_t  interval )

inline

Set timer component interval.

参数

interval

The time interval

在文件 disk_resource_statistic.h 第 39 行定义.

                                        {
        interval_ = interval;
    }

---

该类的文档由以下文件生成:

• modules/statistics/resource/disk_resource_statistic.h
• modules/statistics/resource/disk_resource_statistic.cc