Sha256: 7e795d86fc825a1bde8c09a7f792b65e12df7aebb7d1008fa51998c9673cf7e7
Contents?: true
Size: 1.69 KB
Versions: 11
Compression:
Stored size: 1.69 KB
Contents
require 'celluloid'
class Eye::SystemResources
# cached system resources
class << self
def memory(pid)
cache.proc_mem(pid).try(:resident)
end
def cpu(pid)
if cpu = cache.proc_cpu(pid)
cpu.percent * 100
end
end
def children(parent_pid)
cache.children(parent_pid)
end
def start_time(pid) # unixtime
if cpu = cache.proc_cpu(pid)
cpu.start_time.to_i / 1000
end
end
# total cpu usage in seconds
def cputime(pid)
if cpu = cache.proc_cpu(pid)
cpu.total.to_f / 1000
end
end
# last child in a children tree
def leaf_child(pid)
c = children(pid)
return if c.empty?
c += children(c.shift) while c.size > 1
c[0]
end
def resources(pid)
{ :memory => memory(pid),
:cpu => cpu(pid),
:start_time => start_time(pid),
:pid => pid
}
end
def cache
@cache ||= Cache.new
end
end
class Cache
include Celluloid
attr_reader :expire
def initialize
clear
setup_expire
end
def setup_expire(expire = 5)
@expire = expire
@timer.cancel if @timer
@timer = every(@expire) { clear }
end
def clear
@memory = {}
@cpu = {}
@ppids = {}
end
def proc_mem(pid)
@memory[pid] ||= Eye::Sigar.proc_mem(pid) if pid
rescue ArgumentError # when incorrect PID
end
def proc_cpu(pid)
@cpu[pid] ||= Eye::Sigar.proc_cpu(pid) if pid
rescue ArgumentError # when incorrect PID
end
def children(pid)
if pid
@ppids[pid] ||= Eye::Sigar.proc_list("State.Ppid.eq=#{pid}")
else
[]
end
end
end
end
Version data entries
11 entries across 11 versions & 2 rubygems