c74cde918a
This is memory that's loaded from an inode (file) but not modified in memory, so still identical to what's on disk. This kind of memory can be freed and reloaded transparently from disk if needed.
91 lines
4.2 KiB
C++
91 lines
4.2 KiB
C++
#include <AK/JsonArray.h>
|
|
#include <AK/JsonObject.h>
|
|
#include <AK/JsonValue.h>
|
|
#include <LibCore/CFile.h>
|
|
#include <LibCore/CProcessStatisticsReader.h>
|
|
#include <pwd.h>
|
|
#include <stdio.h>
|
|
|
|
HashMap<uid_t, String> CProcessStatisticsReader::s_usernames;
|
|
|
|
HashMap<pid_t, CProcessStatistics> CProcessStatisticsReader::get_all()
|
|
{
|
|
auto file = CFile::construct("/proc/all");
|
|
if (!file->open(CIODevice::ReadOnly)) {
|
|
fprintf(stderr, "CProcessStatisticsReader: Failed to open /proc/all: %s\n", file->error_string());
|
|
return {};
|
|
}
|
|
|
|
HashMap<pid_t, CProcessStatistics> map;
|
|
|
|
auto file_contents = file->read_all();
|
|
auto json = JsonValue::from_string({ file_contents.data(), (size_t)file_contents.size() });
|
|
json.as_array().for_each([&](auto& value) {
|
|
const JsonObject& process_object = value.as_object();
|
|
CProcessStatistics process;
|
|
|
|
// kernel data first
|
|
process.pid = process_object.get("pid").to_u32();
|
|
process.pgid = process_object.get("pgid").to_u32();
|
|
process.pgp = process_object.get("pgp").to_u32();
|
|
process.sid = process_object.get("sid").to_u32();
|
|
process.uid = process_object.get("uid").to_u32();
|
|
process.gid = process_object.get("gid").to_u32();
|
|
process.ppid = process_object.get("ppid").to_u32();
|
|
process.nfds = process_object.get("nfds").to_u32();
|
|
process.name = process_object.get("name").to_string();
|
|
process.tty = process_object.get("tty").to_string();
|
|
process.amount_virtual = process_object.get("amount_virtual").to_u32();
|
|
process.amount_resident = process_object.get("amount_resident").to_u32();
|
|
process.amount_shared = process_object.get("amount_shared").to_u32();
|
|
process.amount_dirty_private = process_object.get("amount_dirty_private").to_u32();
|
|
process.amount_clean_inode = process_object.get("amount_clean_inode").to_u32();
|
|
process.amount_purgeable_volatile = process_object.get("amount_purgeable_volatile").to_u32();
|
|
process.amount_purgeable_nonvolatile = process_object.get("amount_purgeable_nonvolatile").to_u32();
|
|
process.icon_id = process_object.get("icon_id").to_int();
|
|
|
|
auto thread_array = process_object.get("threads").as_array();
|
|
thread_array.for_each([&](auto& value) {
|
|
auto& thread_object = value.as_object();
|
|
CThreadStatistics thread;
|
|
thread.tid = thread_object.get("tid").to_u32();
|
|
thread.times_scheduled = thread_object.get("times_scheduled").to_u32();
|
|
thread.name = thread_object.get("name").to_string();
|
|
thread.state = thread_object.get("state").to_string();
|
|
thread.ticks = thread_object.get("ticks").to_u32();
|
|
thread.priority = thread_object.get("priority").to_string();
|
|
thread.syscall_count = thread_object.get("syscall_count").to_u32();
|
|
thread.inode_faults = thread_object.get("inode_faults").to_u32();
|
|
thread.zero_faults = thread_object.get("zero_faults").to_u32();
|
|
thread.cow_faults = thread_object.get("cow_faults").to_u32();
|
|
thread.unix_socket_read_bytes = thread_object.get("unix_socket_read_bytes").to_u32();
|
|
thread.unix_socket_write_bytes = thread_object.get("unix_socket_write_bytes").to_u32();
|
|
thread.ipv4_socket_read_bytes = thread_object.get("ipv4_socket_read_bytes").to_u32();
|
|
thread.ipv4_socket_write_bytes = thread_object.get("ipv4_socket_write_bytes").to_u32();
|
|
thread.file_read_bytes = thread_object.get("file_read_bytes").to_u32();
|
|
thread.file_write_bytes = thread_object.get("file_write_bytes").to_u32();
|
|
process.threads.append(move(thread));
|
|
});
|
|
|
|
// and synthetic data last
|
|
process.username = username_from_uid(process.uid);
|
|
map.set(process.pid, process);
|
|
});
|
|
|
|
return map;
|
|
}
|
|
|
|
String CProcessStatisticsReader::username_from_uid(uid_t uid)
|
|
{
|
|
if (s_usernames.is_empty()) {
|
|
setpwent();
|
|
while (auto* passwd = getpwent())
|
|
s_usernames.set(passwd->pw_uid, passwd->pw_name);
|
|
endpwent();
|
|
}
|
|
|
|
auto it = s_usernames.find(uid);
|
|
if (it != s_usernames.end())
|
|
return (*it).value;
|
|
return String::number(uid);
|
|
}
|