mirror of
https://github.com/ClickHouse/ClickHouse.git
synced 2024-12-15 19:02:04 +00:00
109 lines
2.4 KiB
C++
109 lines
2.4 KiB
C++
#if defined(OS_LINUX)
|
|
|
|
#include <sys/types.h>
|
|
#include <sys/stat.h>
|
|
#include <fcntl.h>
|
|
#include <unistd.h>
|
|
#include <cassert>
|
|
|
|
#include "MemoryStatisticsOS.h"
|
|
|
|
#include <common/logger_useful.h>
|
|
#include <common/getPageSize.h>
|
|
#include <Common/Exception.h>
|
|
#include <IO/ReadBufferFromMemory.h>
|
|
#include <IO/ReadHelpers.h>
|
|
|
|
|
|
namespace DB
|
|
{
|
|
|
|
namespace ErrorCodes
|
|
{
|
|
extern const int FILE_DOESNT_EXIST;
|
|
extern const int CANNOT_OPEN_FILE;
|
|
extern const int CANNOT_READ_FROM_FILE_DESCRIPTOR;
|
|
extern const int CANNOT_CLOSE_FILE;
|
|
}
|
|
|
|
static constexpr auto filename = "/proc/self/statm";
|
|
|
|
MemoryStatisticsOS::MemoryStatisticsOS()
|
|
{
|
|
fd = ::open(filename, O_RDONLY | O_CLOEXEC);
|
|
|
|
if (-1 == fd)
|
|
throwFromErrno("Cannot open file " + std::string(filename), errno == ENOENT ? ErrorCodes::FILE_DOESNT_EXIST : ErrorCodes::CANNOT_OPEN_FILE);
|
|
}
|
|
|
|
MemoryStatisticsOS::~MemoryStatisticsOS()
|
|
{
|
|
if (0 != ::close(fd))
|
|
{
|
|
try
|
|
{
|
|
throwFromErrno(
|
|
"File descriptor for \"" + std::string(filename) + "\" could not be closed. "
|
|
"Something seems to have gone wrong. Inspect errno.", ErrorCodes::CANNOT_CLOSE_FILE);
|
|
}
|
|
catch (const ErrnoException &)
|
|
{
|
|
DB::tryLogCurrentException(__PRETTY_FUNCTION__);
|
|
}
|
|
}
|
|
}
|
|
|
|
MemoryStatisticsOS::Data MemoryStatisticsOS::get() const
|
|
{
|
|
Data data;
|
|
|
|
constexpr size_t buf_size = 1024;
|
|
char buf[buf_size];
|
|
|
|
ssize_t res = 0;
|
|
|
|
do
|
|
{
|
|
res = ::pread(fd, buf, buf_size, 0);
|
|
|
|
if (-1 == res)
|
|
{
|
|
if (errno == EINTR)
|
|
continue;
|
|
|
|
throwFromErrno("Cannot read from file " + std::string(filename), ErrorCodes::CANNOT_READ_FROM_FILE_DESCRIPTOR);
|
|
}
|
|
|
|
assert(res >= 0);
|
|
break;
|
|
} while (true);
|
|
|
|
ReadBufferFromMemory in(buf, res);
|
|
|
|
uint64_t unused;
|
|
readIntText(data.virt, in);
|
|
skipWhitespaceIfAny(in);
|
|
readIntText(data.resident, in);
|
|
skipWhitespaceIfAny(in);
|
|
readIntText(data.shared, in);
|
|
skipWhitespaceIfAny(in);
|
|
readIntText(data.code, in);
|
|
skipWhitespaceIfAny(in);
|
|
readIntText(unused, in);
|
|
skipWhitespaceIfAny(in);
|
|
readIntText(data.data_and_stack, in);
|
|
|
|
size_t page_size = static_cast<size_t>(::getPageSize());
|
|
data.virt *= page_size;
|
|
data.resident *= page_size;
|
|
data.shared *= page_size;
|
|
data.code *= page_size;
|
|
data.data_and_stack *= page_size;
|
|
|
|
return data;
|
|
}
|
|
|
|
}
|
|
|
|
#endif
|