class MessageBus::Diagnostics
Public Class Methods
enable()
click to toggle source
# File lib/message_bus/diagnostics.rb, line 26 def self.enable full_path = full_process_path start_time = Time.now.to_f hostname = self.hostname # it may make sense to add a channel per machine/host to streamline # process to process comms MessageBus.subscribe('/_diagnostics/hup') do |msg| if Process.pid == msg.data["pid"] && hostname == msg.data["hostname"] $shutdown = true sleep 4 Process.kill("HUP", $$) end end MessageBus.subscribe('/_diagnostics/discover') do |msg| MessageBus.on_connect.call msg.site_id if MessageBus.on_connect MessageBus.publish '/_diagnostics/process-discovery', { pid: Process.pid, process_name: $0, full_path: full_path, uptime: (Time.now.to_f - start_time).to_i, hostname: hostname }, user_ids: [msg.data["user_id"]] MessageBus.on_disconnect.call msg.site_id if MessageBus.on_disconnect end end
full_process_path()
click to toggle source
# File lib/message_bus/diagnostics.rb, line 2 def self.full_process_path begin system = %x`uname`.strip if system == "Darwin" %x`ps -o "comm=" -p #{Process.pid}` elsif system == "FreeBSD" %x`ps -o command -p #{Process.pid}`.split("\n",2)[1].strip() else info = %x`ps -eo "%p|$|%a" | grep '^\\s*#{Process.pid}'` info.strip.split('|$|')[1] end rescue # skip it ... not linux or something weird end end
hostname()
click to toggle source
# File lib/message_bus/diagnostics.rb, line 18 def self.hostname begin %x`hostname`.strip rescue # skip it end end