2019-06-29 10:12:40 +02:00
|
|
|
#include <AK/JsonArray.h>
|
|
|
|
#include <AK/JsonObject.h>
|
|
|
|
#include <AK/JsonValue.h>
|
|
|
|
#include <LibCore/CFile.h>
|
|
|
|
#include <LibCore/CProcessStatisticsReader.h>
|
2019-05-16 18:47:47 +02:00
|
|
|
#include <pwd.h>
|
2019-05-28 11:53:16 +02:00
|
|
|
#include <stdio.h>
|
2019-05-16 18:47:47 +02:00
|
|
|
|
|
|
|
CProcessStatisticsReader::CProcessStatisticsReader()
|
|
|
|
{
|
|
|
|
setpwent();
|
|
|
|
while (auto* passwd = getpwent())
|
|
|
|
m_usernames.set(passwd->pw_uid, passwd->pw_name);
|
|
|
|
endpwent();
|
|
|
|
}
|
|
|
|
|
|
|
|
HashMap<pid_t, CProcessStatistics> CProcessStatisticsReader::get_map()
|
|
|
|
{
|
|
|
|
HashMap<pid_t, CProcessStatistics> res;
|
|
|
|
update_map(res);
|
|
|
|
return res;
|
|
|
|
}
|
|
|
|
|
|
|
|
void CProcessStatisticsReader::update_map(HashMap<pid_t, CProcessStatistics>& map)
|
|
|
|
{
|
|
|
|
CFile file("/proc/all");
|
|
|
|
if (!file.open(CIODevice::ReadOnly)) {
|
|
|
|
fprintf(stderr, "CProcessHelper : failed to open /proc/all: %s\n", file.error_string());
|
|
|
|
return;
|
|
|
|
}
|
|
|
|
|
2019-06-29 10:12:40 +02:00
|
|
|
auto file_contents = file.read_all();
|
|
|
|
auto json = JsonValue::from_string({ file_contents.data(), file_contents.size() });
|
|
|
|
json.as_array().for_each([&](auto& value) {
|
|
|
|
const JsonObject& process_object = value.as_object();
|
2019-05-16 18:47:47 +02:00
|
|
|
CProcessStatistics process;
|
2019-07-03 21:17:35 +02:00
|
|
|
process.pid = process_object.get("pid").to_u32();
|
|
|
|
process.nsched = process_object.get("times_scheduled").to_u32();
|
|
|
|
process.uid = process_object.get("uid").to_u32();
|
2019-06-29 10:12:40 +02:00
|
|
|
process.username = get_username_from_uid(process.uid);
|
|
|
|
process.priority = process_object.get("priority").to_string();
|
2019-07-03 21:17:35 +02:00
|
|
|
process.syscalls = process_object.get("syscall_count").to_u32();
|
2019-06-29 10:12:40 +02:00
|
|
|
process.state = process_object.get("state").to_string();
|
|
|
|
process.name = process_object.get("name").to_string();
|
2019-07-03 21:17:35 +02:00
|
|
|
process.virtual_size = process_object.get("amount_virtual").to_u32();
|
|
|
|
process.physical_size = process_object.get("amount_resident").to_u32();
|
2019-05-16 18:47:47 +02:00
|
|
|
map.set(process.pid, process);
|
2019-06-29 10:12:40 +02:00
|
|
|
});
|
2019-05-16 18:47:47 +02:00
|
|
|
}
|
|
|
|
|
|
|
|
String CProcessStatisticsReader::get_username_from_uid(const uid_t uid)
|
|
|
|
{
|
|
|
|
auto it = m_usernames.find(uid);
|
|
|
|
if (it != m_usernames.end())
|
|
|
|
return (*it).value;
|
|
|
|
else
|
2019-07-03 14:56:27 +02:00
|
|
|
return String::number(uid);
|
2019-05-16 18:47:47 +02:00
|
|
|
}
|