1
Fork 0
mirror of https://github.com/RGBCube/serenity synced 2025-05-31 04:18:12 +00:00

CProcessStatisticsReader: Be consistent about terminology from the kernel down

This commit is contained in:
Robin Burchell 2019-07-17 22:22:22 +02:00 committed by Andreas Kling
parent 9724d540b6
commit a9d1a86e6e
7 changed files with 74 additions and 48 deletions

View file

@ -120,16 +120,16 @@ GVariant ProcessModel::data(const GModelIndex& index, Role role) const
ASSERT_NOT_REACHED(); ASSERT_NOT_REACHED();
return 3; return 3;
case Column::Virtual: case Column::Virtual:
return (int)process.current_state.virtual_size; return (int)process.current_state.amount_virtual;
case Column::Physical: case Column::Physical:
return (int)process.current_state.physical_size; return (int)process.current_state.amount_resident;
case Column::CPU: case Column::CPU:
return process.current_state.cpu_percent; return process.current_state.cpu_percent;
case Column::Name: case Column::Name:
return process.current_state.name; return process.current_state.name;
// FIXME: GVariant with unsigned? // FIXME: GVariant with unsigned?
case Column::Syscalls: case Column::Syscalls:
return (int)process.current_state.syscalls; return (int)process.current_state.syscall_count;
} }
ASSERT_NOT_REACHED(); ASSERT_NOT_REACHED();
return {}; return {};
@ -156,16 +156,16 @@ GVariant ProcessModel::data(const GModelIndex& index, Role role) const
return *m_normal_priority_icon; return *m_normal_priority_icon;
return process.current_state.priority; return process.current_state.priority;
case Column::Virtual: case Column::Virtual:
return pretty_byte_size(process.current_state.virtual_size); return pretty_byte_size(process.current_state.amount_virtual);
case Column::Physical: case Column::Physical:
return pretty_byte_size(process.current_state.physical_size); return pretty_byte_size(process.current_state.amount_resident);
case Column::CPU: case Column::CPU:
return process.current_state.cpu_percent; return process.current_state.cpu_percent;
case Column::Name: case Column::Name:
return process.current_state.name; return process.current_state.name;
// FIXME: It's weird that GVariant doesn't support unsigned ints. Should it? // FIXME: It's weird that GVariant doesn't support unsigned ints. Should it?
case Column::Syscalls: case Column::Syscalls:
return (int)process.current_state.syscalls; return (int)process.current_state.syscall_count;
} }
} }
@ -176,24 +176,24 @@ void ProcessModel::update()
{ {
auto all_processes = CProcessStatisticsReader::get_all(); auto all_processes = CProcessStatisticsReader::get_all();
unsigned last_sum_nsched = 0; unsigned last_sum_times_scheduled = 0;
for (auto& it : m_processes) for (auto& it : m_processes)
last_sum_nsched += it.value->current_state.nsched; last_sum_times_scheduled += it.value->current_state.times_scheduled;
HashTable<pid_t> live_pids; HashTable<pid_t> live_pids;
unsigned sum_nsched = 0; unsigned sum_times_scheduled = 0;
for (auto& it : all_processes) { for (auto& it : all_processes) {
ProcessState state; ProcessState state;
state.pid = it.value.pid; state.pid = it.value.pid;
state.nsched = it.value.nsched; state.times_scheduled = it.value.times_scheduled;
state.user = it.value.username; state.user = it.value.username;
state.priority = it.value.priority; state.priority = it.value.priority;
state.syscalls = it.value.syscalls; state.syscall_count = it.value.syscall_count;
state.state = it.value.state; state.state = it.value.state;
state.name = it.value.name; state.name = it.value.name;
state.virtual_size = it.value.virtual_size; state.amount_virtual = it.value.amount_virtual;
state.physical_size = it.value.physical_size; state.amount_resident = it.value.amount_resident;
sum_nsched += it.value.nsched; sum_times_scheduled += it.value.times_scheduled;
{ {
auto pit = m_processes.find(it.value.pid); auto pit = m_processes.find(it.value.pid);
if (pit == m_processes.end()) if (pit == m_processes.end())
@ -216,8 +216,8 @@ void ProcessModel::update()
continue; continue;
} }
auto& process = *it.value; auto& process = *it.value;
u32 nsched_diff = process.current_state.nsched - process.previous_state.nsched; u32 times_scheduled_diff = process.current_state.times_scheduled - process.previous_state.times_scheduled;
process.current_state.cpu_percent = ((float)nsched_diff * 100) / (float)(sum_nsched - last_sum_nsched); process.current_state.cpu_percent = ((float)times_scheduled_diff * 100) / (float)(sum_times_scheduled - last_sum_times_scheduled);
if (it.key != 0) { if (it.key != 0) {
total_cpu_percent += process.current_state.cpu_percent; total_cpu_percent += process.current_state.cpu_percent;
m_pids.append(it.key); m_pids.append(it.key);

View file

@ -41,14 +41,14 @@ private:
struct ProcessState { struct ProcessState {
pid_t pid; pid_t pid;
unsigned nsched; unsigned times_scheduled;
String name; String name;
String state; String state;
String user; String user;
String priority; String priority;
size_t virtual_size; size_t amount_virtual;
size_t physical_size; size_t amount_resident;
unsigned syscalls; unsigned syscall_count;
float cpu_percent; float cpu_percent;
}; };

View file

@ -585,6 +585,8 @@ ByteBuffer procfs$all(InodeIdentifier)
InterruptDisabler disabler; InterruptDisabler disabler;
auto processes = Process::all_processes(); auto processes = Process::all_processes();
JsonArray array; JsonArray array;
// Keep this in sync with CProcessStatistics.
auto build_process = [&](const Process& process) { auto build_process = [&](const Process& process) {
JsonObject process_object; JsonObject process_object;
process_object.set("pid", process.pid()); process_object.set("pid", process.pid());

View file

@ -23,16 +23,28 @@ HashMap<pid_t, CProcessStatistics> CProcessStatisticsReader::get_all()
json.as_array().for_each([&](auto& value) { json.as_array().for_each([&](auto& value) {
const JsonObject& process_object = value.as_object(); const JsonObject& process_object = value.as_object();
CProcessStatistics process; CProcessStatistics process;
// kernel data first
process.pid = process_object.get("pid").to_u32(); process.pid = process_object.get("pid").to_u32();
process.nsched = process_object.get("times_scheduled").to_u32(); process.times_scheduled = process_object.get("times_scheduled").to_u32();
process.pgid = process_object.get("pgid").to_u32();
process.sid = process_object.get("sid").to_u32();
process.uid = process_object.get("uid").to_u32(); process.uid = process_object.get("uid").to_u32();
process.username = username_from_uid(process.uid); process.gid = process_object.get("gid").to_u32();
process.priority = process_object.get("priority").to_string();
process.syscalls = process_object.get("syscall_count").to_u32();
process.state = process_object.get("state").to_string(); process.state = process_object.get("state").to_string();
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.name = process_object.get("name").to_string();
process.virtual_size = process_object.get("amount_virtual").to_u32(); process.tty = process_object.get("tty").to_string();
process.physical_size = process_object.get("amount_resident").to_u32(); 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.ticks = process_object.get("ticks").to_u32();
process.priority = process_object.get("priority").to_string();
process.syscall_count = process_object.get("syscall_count").to_u32();
// and synthetic data last
process.username = username_from_uid(process.uid);
map.set(process.pid, process); map.set(process.pid, process);
}); });

View file

@ -4,16 +4,28 @@
#include <AK/HashMap.h> #include <AK/HashMap.h>
struct CProcessStatistics { struct CProcessStatistics {
// Keep this in sync with /proc/all.
// From the kernel side:
pid_t pid; pid_t pid;
unsigned nsched; unsigned times_scheduled;
String name; unsigned pgid;
String state; unsigned sid;
String username;
uid_t uid; uid_t uid;
gid_t gid;
String state;
pid_t ppid;
unsigned nfds;
String name;
String tty;
size_t amount_virtual;
size_t amount_resident;
size_t amount_shared;
unsigned ticks;
String priority; String priority;
size_t virtual_size; unsigned syscall_count;
size_t physical_size;
unsigned syscalls; // synthetic
String username;
}; };
class CProcessStatisticsReader { class CProcessStatisticsReader {

View file

@ -40,9 +40,9 @@ void WSCPUMonitor::get_cpu_usage(unsigned& busy, unsigned& idle)
for (auto& it : all_processes) { for (auto& it : all_processes) {
if (it.value.pid == 0) if (it.value.pid == 0)
idle += it.value.nsched; idle += it.value.times_scheduled;
else else
busy += it.value.nsched; busy += it.value.times_scheduled;
} }
} }

View file

@ -13,14 +13,14 @@
struct ProcessData { struct ProcessData {
CProcessStatistics stats; CProcessStatistics stats;
unsigned nsched_since_prev { 0 }; unsigned times_scheduled_since_prev { 0 };
unsigned cpu_percent { 0 }; unsigned cpu_percent { 0 };
unsigned cpu_percent_decimal { 0 }; unsigned cpu_percent_decimal { 0 };
}; };
struct Snapshot { struct Snapshot {
HashMap<unsigned, ProcessData> map; HashMap<unsigned, ProcessData> map;
u32 sum_nsched { 0 }; u32 sum_times_scheduled { 0 };
}; };
static Snapshot get_snapshot() static Snapshot get_snapshot()
@ -31,7 +31,7 @@ static Snapshot get_snapshot()
for (auto& it : all_processes) { for (auto& it : all_processes) {
auto& stats = it.value; auto& stats = it.value;
snapshot.sum_nsched += stats.nsched; snapshot.sum_times_scheduled += stats.times_scheduled;
ProcessData process_data; ProcessData process_data;
process_data.stats = stats; process_data.stats = stats;
snapshot.map.set(stats.pid, move(process_data)); snapshot.map.set(stats.pid, move(process_data));
@ -47,7 +47,7 @@ int main(int, char**)
usleep(10000); usleep(10000);
for (;;) { for (;;) {
auto current = get_snapshot(); auto current = get_snapshot();
auto sum_diff = current.sum_nsched - prev.sum_nsched; auto sum_diff = current.sum_times_scheduled - prev.sum_times_scheduled;
printf("\033[3J\033[H\033[2J"); printf("\033[3J\033[H\033[2J");
printf("\033[47;30m%6s %3s %-8s %-8s %6s %6s %4s %s\033[K\033[0m\n", printf("\033[47;30m%6s %3s %-8s %-8s %6s %6s %4s %s\033[K\033[0m\n",
@ -63,20 +63,20 @@ int main(int, char**)
pid_t pid = it.key; pid_t pid = it.key;
if (pid == 0) if (pid == 0)
continue; continue;
u32 nsched_now = it.value.stats.nsched; u32 times_scheduled_now = it.value.stats.times_scheduled;
auto jt = prev.map.find(pid); auto jt = prev.map.find(pid);
if (jt == prev.map.end()) if (jt == prev.map.end())
continue; continue;
u32 nsched_before = (*jt).value.stats.nsched; u32 times_scheduled_before = (*jt).value.stats.times_scheduled;
u32 nsched_diff = nsched_now - nsched_before; u32 times_scheduled_diff = times_scheduled_now - times_scheduled_before;
it.value.nsched_since_prev = nsched_diff; it.value.times_scheduled_since_prev = times_scheduled_diff;
it.value.cpu_percent = ((nsched_diff * 100) / sum_diff); it.value.cpu_percent = ((times_scheduled_diff * 100) / sum_diff);
it.value.cpu_percent_decimal = (((nsched_diff * 1000) / sum_diff) % 10); it.value.cpu_percent_decimal = (((times_scheduled_diff * 1000) / sum_diff) % 10);
processes.append(&it.value); processes.append(&it.value);
} }
quick_sort(processes.begin(), processes.end(), [](auto* p1, auto* p2) { quick_sort(processes.begin(), processes.end(), [](auto* p1, auto* p2) {
return p2->nsched_since_prev < p1->nsched_since_prev; return p2->times_scheduled_since_prev < p1->times_scheduled_since_prev;
}); });
for (auto* process : processes) { for (auto* process : processes) {
@ -85,8 +85,8 @@ int main(int, char**)
process->stats.priority[0], process->stats.priority[0],
process->stats.username.characters(), process->stats.username.characters(),
process->stats.state.characters(), process->stats.state.characters(),
process->stats.virtual_size / 1024, process->stats.amount_virtual / 1024,
process->stats.physical_size / 1024, process->stats.amount_resident / 1024,
process->cpu_percent, process->cpu_percent,
process->cpu_percent_decimal, process->cpu_percent_decimal,
process->stats.name.characters()); process->stats.name.characters());