Linux specific tests.

Author: samuel-williams-shopify

lib/process/metrics/general/linux.rb

@@ -51,38 +51,38 @@ def self.capture(pid: nil, ppid: nil, memory: Memory.supported?)
 
 					comm = stat[1...rparen]
 					fields = stat[(rparen + 2)..].split(/\s+/)
-					# After comm: state(3), ppid(4), pgrp(5), ... utime(14), stime(15), ... starttime(22), vsz(23), rss(24). 0-based: ppid=1, pgrp=2, utime=11, stime=12, starttime=20, vsz=21, rss=22
+					# After comm: state(3), ppid(4), pgrp(5), ... utime(14), stime(15), ... starttime(22), vsz(23), rss(24). 0-based: ppid=1, pgrp=2, utime=11, stime=12, starttime=19, vsz=20, rss=21.
 					ppid_val = fields[1].to_i
 					pgrp = fields[2].to_i
 					utime = fields[11].to_i
 					stime = fields[12].to_i
-					starttime = fields[20].to_i
-					vsz = fields[21].to_i
-					rss_pages = fields[22].to_i
-					
-					# Read /proc/uptime once per capture and reuse for every process (starttime is in jiffies since boot).
-					uptime_jiffies ||= begin
-						uptime_seconds = File.read("/proc/uptime").split(/\s+/).first.to_f
-						(uptime_seconds * CLK_TCK).to_i
-					end
-					
-					processor_time = (utime + stime).to_f / CLK_TCK
-					elapsed_time = [(uptime_jiffies - starttime).to_f / CLK_TCK, 0.0].max
-					
-					command = read_command(p, comm)
-					
-					processes[p] = General.new(
-						p,
-						ppid_val,
-						pgrp,
-						0.0, # processor_utilization: would need two samples; not available from single stat read
-						vsz,
-						rss_pages * PAGE_SIZE,
-						processor_time,
-						elapsed_time,
-						command,
-						nil
-					)
+					starttime = fields[19].to_i
+					vsz = fields[20].to_i
+					rss_pages = fields[21].to_i
+				
+				# Read /proc/uptime once per capture and reuse for every process (starttime is in jiffies since boot).
+				uptime_jiffies ||= begin
+					uptime_seconds = File.read("/proc/uptime").split(/\s+/).first.to_f
+					(uptime_seconds * CLK_TCK).to_i
+				end
+				
+				processor_time = (utime + stime).to_f / CLK_TCK
+				elapsed_time = [(uptime_jiffies - starttime).to_f / CLK_TCK, 0.0].max
+				
+				command = read_command(p, comm)
+				
+				processes[p] = General.new(
+					p,
+					ppid_val,
+					pgrp,
+					0.0, # processor_utilization: would need two samples; not available from single stat read
+					vsz,
+					rss_pages * PAGE_SIZE,
+					processor_time,
+					elapsed_time,
+					command,
+					nil
+				)
 				rescue Errno::ENOENT, Errno::ESRCH, Errno::EACCES
 					# Process disappeared or we can't read it.
 					next

test/process/general.rb

@@ -28,29 +28,29 @@
 		it "can extract memory usage" do
 			expect(capture[pid].memory_usage).to be > 0.0
 		end
-
+		
 		it "sets parent_process_id and process_group_id" do
 			process = capture[pid]
 			expect(process.process_id).to be == pid
 			expect(process.parent_process_id).to be_a(Integer)
 			expect(process.process_group_id).to be_a(Integer)
 		end
 	end
-
+	
 	with ".capture with ppid only" do
 		def before
 			super
 			@child_pid = Process.spawn("sleep 10")
 		end
-
+		
 		def after(error = nil)
 			super
 			Process.kill(:TERM, @child_pid) if @child_pid
 			Process.wait(@child_pid) if @child_pid
 		end
-
-		let(:capture) { Process::Metrics::General.capture(ppid: Process.pid) }
-
+		
+		let(:capture) {Process::Metrics::General.capture(ppid: Process.pid)}
+		
 		it "includes descendants of the given ppid" do
 			expect(capture).to be(:include?, @child_pid)
 			child = capture[@child_pid]
@@ -59,7 +59,7 @@ def after(error = nil)
 			expect(child.parent_process_id).to be == Process.pid
 		end
 	end
-
+	
 	with ".capture with parent pid" do
 		def before
 			super
@@ -92,7 +92,7 @@ def after(error = nil)
 			expect(command[:processor_time]).to be >= 0.0
 			expect(command[:processor_utilization]).to be >= 0.0
 		end
-
+		
 		it "sets parent_process_id and process_group_id on child" do
 			child = capture[@pid]
 			expect(child).not.to be_nil

test/process/general/linux.rb

@@ -0,0 +1,57 @@
+# frozen_string_literal: true
+
+# Released under the MIT License.
+# Copyright, 2024-2025, by Samuel Williams.
+
+require "process/metrics"
+# Load ProcessStatus backend so we can compare General (Linux) vs General::ProcessStatus.
+require "process/metrics/general/process_status"
+
+describe Process::Metrics::General do
+	with "Linux backend matches ProcessStatus backend" do
+		def assert_backends_match(linux, ps)
+			expect(linux.keys.sort).to be == ps.keys.sort
+			
+			linux.each_key do |pid|
+				linux_process = linux[pid]
+				ps_process = ps[pid]
+				
+				expect(ps_process).not.to be_nil
+				expect(linux_process.process_id).to be == ps_process.process_id
+				expect(linux_process.parent_process_id).to be == ps_process.parent_process_id
+				expect(linux_process.process_group_id).to be == ps_process.process_group_id
+				
+				# VSZ and RSS differ because ps excludes device mappings while /proc/stat includes them.
+				expect(linux_process.virtual_size).to be_within(10.0).percent_of(ps_process.virtual_size)
+				expect(linux_process.resident_size).to be_within(10.0).percent_of(ps_process.resident_size)
+				
+				expect(linux_process.command).to be == ps_process.command
+				expect((linux_process.processor_time - ps_process.processor_time).abs).to be < 1.0
+				expect((linux_process.elapsed_time - ps_process.elapsed_time).abs).to be < 1.0
+			end
+		end
+		
+		it "single pid capture matches" do
+			skip "Linux with ps required" unless RUBY_PLATFORM.include?("linux") && Process::Metrics::General::ProcessStatus.supported?
+			
+			pid = Process.pid
+			linux = Process::Metrics::General.capture(pid: pid, memory: false)
+			ps = Process::Metrics::General::ProcessStatus.capture(pid: pid, memory: false)
+			assert_backends_match(linux, ps)
+		end
+		
+		it "pid and ppid capture matches" do
+			skip "Linux with ps required" unless RUBY_PLATFORM.include?("linux") && Process::Metrics::General::ProcessStatus.supported?
+			
+			child_pid = Process.spawn("sleep 10")
+			begin
+				linux = Process::Metrics::General.capture(pid: child_pid, ppid: child_pid, memory: false)
+				ps = Process::Metrics::General::ProcessStatus.capture(pid: child_pid, ppid: child_pid, memory: false)
+				assert_backends_match(linux, ps)
+			ensure
+				Process.kill(:TERM, child_pid)
+				Process.wait(child_pid)
+			end
+		end
+	end
+end