Sha256: 79a44a76d44f99ee1e5f8ec410f05813805771f139560746f469abc19e89301f
Contents?: true
Size: 1.8 KB
Versions: 13
Compression:
Stored size: 1.8 KB
Contents
# frozen_string_literal: true
# MessageBus diagnostics are used for troubleshooting the bus and optimising its configuration
# @see MessageBus::Rack::Diagnostics
class MessageBus::Diagnostics
class << self
# Enables diagnostics functionality
# @param [MessageBus::Instance] bus a specific instance of message_bus
# @return [void]
def enable(bus = MessageBus)
full_path = full_process_path
start_time = Time.now.to_f
hostname = get_hostname
# it may make sense to add a channel per machine/host to streamline
# process to process comms
bus.subscribe('/_diagnostics/hup') do |msg|
if Process.pid == msg.data["pid"] && hostname == msg.data["hostname"]
sleep 4
Process.kill("HUP", $$)
end
end
bus.subscribe('/_diagnostics/discover') do |msg|
bus.on_connect.call msg.site_id if bus.on_connect
bus.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"]]
bus.on_disconnect.call msg.site_id if bus.on_disconnect
end
end
private
def full_process_path
begin
system = `uname`.strip
if system == "Darwin"
`ps -o "comm=" -p #{Process.pid}`
elsif system == "FreeBSD"
`ps -o command -p #{Process.pid}`.split("\n", 2)[1].strip
else
info = `ps -eo "%p|$|%a" | grep '^\\s*#{Process.pid}'`
info.strip.split('|$|')[1]
end
rescue
# skip it ... not linux or something weird
end
end
def get_hostname
begin
`hostname`.strip
rescue
# skip it
end
end
end
end
Version data entries
13 entries across 13 versions & 1 rubygems