initial commit

procio.cr

@@ -0,0 +1,26 @@
+dir = ENV.fetch("PROCIO_DIR", "/proc")
+hostname = ENV.fetch("PROCIO_HOSTNAME", "/proc")
+result = {} of String => Hash(Symbol, UInt64)
+
+Dir.entries(dir).each do |entry|
+  entry =~ /^\d+$/ || next 
+
+  comm = File.read("#{dir}/#{entry}/comm").chomp
+  result[comm] ||= {r: 0.to_u64, w: 0.to_u64}.to_h
+
+  File.read_lines("#{dir}/#{entry}/io").each do |line|
+    if line.starts_with?("read_bytes: ")
+      result[comm][:r] += line.split(" ").last.to_u64
+    elsif line.starts_with?("write_bytes: ")
+      result[comm][:w] += line.split(" ").last.to_u64
+    end
+  end
+end
+
+time = Time.local.to_s("%s%9N")
+
+result.each do |comm, v|
+  if v[:r] + v[:w] > 0
+    puts %(procio comm="#{comm}" read_bytes=#{v[:r]},write_bytes=#{v[:w]} #{time})
+  end
+end

test/12/comm

@@ -0,0 +1 @@
+multi

test/12/io

@@ -0,0 +1,7 @@
+rchar: 0
+wchar: 0
+syscr: 0
+syscw: 0
+read_bytes: 100000
+write_bytes: 0
+cancelled_write_bytes: 0

test/13/comm

@@ -0,0 +1 @@
+multi

test/13/io

@@ -0,0 +1,7 @@
+rchar: 0
+wchar: 0
+syscr: 0
+syscw: 0
+read_bytes: 100000
+write_bytes: 100000
+cancelled_write_bytes: 0

test/3/comm

@@ -0,0 +1 @@
+nothinghere

test/3/io

@@ -0,0 +1,7 @@
+rchar: 0
+wchar: 0
+syscr: 0
+syscw: 0
+read_bytes: 0
+write_bytes: 0
+cancelled_write_bytes: 0

test/452/comm

@@ -0,0 +1 @@
+alotgoingon

test/452/io

@@ -0,0 +1,7 @@
+rchar: 0
+wchar: 0
+syscr: 0
+syscw: 0
+read_bytes: 82546474
+write_bytes: 34637376
+cancelled_write_bytes: 0