thevar1able/ClickHouse
1
0
Fork 0
mirror of https://github.com/ClickHouse/ClickHouse.git synced 2024-12-12 01:12:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

Simplify the code

Browse Source
This commit is contained in:
Alexey Milovidov 2023-04-23 09:01:21 +03:00 committed by GitHub
parent 1087c7361d
commit 1be5a20546
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 16 additions and 32 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

40
src/Common/AsynchronousMetrics.cpp
View File

@ -66,10 +66,15 @@ AsynchronousMetrics::AsynchronousMetrics(
openFileIfExists("/proc/uptime", uptime);
openFileIfExists("/proc/net/dev", net_dev);
/// CGroups v2
openFileIfExists("/sys/fs/cgroup/memory.max", cgroupmem_limit_in_bytes);
openFileIfExists("/sys/fs/cgroup/memory.current", cgroupmem_usage_in_bytes);
/// CGroups v1
if (!cgroupmem_limit_in_bytes)
openFileIfExists("/sys/fs/cgroup/memory/memory.limit_in_bytes", cgroupmem_limit_in_bytes);
if (!cgroupmem_usage_in_bytes)
openFileIfExists("/sys/fs/cgroup/memory/memory.usage_in_bytes", cgroupmem_usage_in_bytes);
openFileIfExists("/sys/fs/cgroup/memory.max", cgroupmem_v2_limit_in_bytes);
openFileIfExists("/sys/fs/cgroup/memory.current", cgroupmem_v2_usage_in_bytes);
openSensors();
openBlockDevices();
@ -896,11 +901,6 @@ void AsynchronousMetrics::update(TimePoint update_time)
updateCgroupMemoryMetrics(cgroupmem_limit_in_bytes, cgroupmem_usage_in_bytes);
}
if (cgroupmem_v2_limit_in_bytes && cgroupmem_v2_usage_in_bytes)
{
updateCgroupMemoryMetrics(cgroupmem_v2_limit_in_bytes, cgroupmem_v2_usage_in_bytes);
}
if (meminfo)
{
try
@ -1467,36 +1467,22 @@ void AsynchronousMetrics::update(TimePoint update_time)
values = new_values;
}
void AsynchronousMetrics::updateCgroupMemoryMetrics(std::optional<ReadBufferFromFilePRead> memoryLimitReadBuffer, std::optional<ReadBufferFromFilePRead> memoryUsageReadBuffer)
void AsynchronousMetrics::updateCgroupMemoryMetrics(std::optional<ReadBufferFromFilePRead> memory_limit_in, std::optional<ReadBufferFromFilePRead> memory_usage_in)
{
try
{
memoryLimitReadBuffer->rewind();
memoryUsageReadBuffer->rewind();
memory_limit_in->rewind();
memory_usage_in->rewind();
uint64_t cgroup_mem_limit_in_bytes = 0;
uint64_t cgroup_mem_usage_in_bytes = 0;
string cgroup_mem_limit_str = "";
readText(cgroup_mem_limit_str, *memoryLimitReadBuffer);
if (std::isdigit(cgroup_mem_limit_str))
{
memoryLimitReadBuffer->rewind();
readText(cgroup_mem_limit_in_bytes, *memoryLimitReadBuffer);
}
readText(cgroup_mem_usage_in_bytes, *memoryUsageReadBuffer);
tryReadText(cgroup_mem_limit_in_bytes, *memory_limit_in);
tryReadText(cgroup_mem_usage_in_bytes, *memory_usage_in);
if (cgroup_mem_limit_in_bytes || cgroup_mem_usage_in_bytes)
{
new_values["CgroupMemoryTotal"] = { cgroup_mem_limit_in_bytes, "The total amount of memory in cgroup, in bytes. If stated zero, CgroupMemoryTotal is the same as OSMemoryTotal." };
new_values["CgroupMemoryTotal"] = { cgroup_mem_limit_in_bytes, "The total amount of memory in cgroup, in bytes. If stated zero, the limit is the same as OSMemoryTotal." };
new_values["CgroupMemoryUsed"] = { cgroup_mem_usage_in_bytes, "The amount of memory used in cgroup, in bytes." };
}
else
{
LOG_DEBUG(log, "Cannot read statistics about the cgroup memory total and used. Total got '{}', Used got '{}'.",
cgroup_mem_limit_in_bytes, cgroup_mem_usage_in_bytes);
}
}
catch (...)
{
tryLogCurrentException(__PRETTY_FUNCTION__);

2
src/Common/AsynchronousMetrics.h
View File

@ -110,8 +110,6 @@ private:
std::optional<ReadBufferFromFilePRead> cgroupmem_limit_in_bytes;
std::optional<ReadBufferFromFilePRead> cgroupmem_usage_in_bytes;
std::optional<ReadBufferFromFilePRead> cgroupmem_v2_limit_in_bytes;
std::optional<ReadBufferFromFilePRead> cgroupmem_v2_usage_in_bytes;
std::vector<std::unique_ptr<ReadBufferFromFilePRead>> thermal;