/usr/lib/ruby/vendor_ruby/amqp/ext/emfork.rb is in ruby-amqp 0.9.5-2.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 | # encoding: utf-8
# @private
EMFORK = $0 == __FILE__
#if EMFORK
# require 'rubygems'
#end
require 'eventmachine'
# helper to fork off EM reactors
# @private
def EM.fork num = 1, &blk
unless @forks
trap('CHLD') {
pid = Process.wait
p [:pid, pid, :died] if EMFORK
block = @forks.delete(pid)
EM.fork(1, &block)
}
trap('EXIT') {
p [:pid, Process.pid, :exit] if EMFORK
@forks.keys.each { |pid|
p [:pid, Process.pid, :killing, pid] if EMFORK
Process.kill('USR1', pid)
}
}
@forks = {}
end
num.times do
pid = EM.fork_reactor do
p [:pid, Process.pid, :started] if EMFORK
trap('USR1') { EM.stop_event_loop }
trap('CHLD') {}
trap('EXIT') {}
blk.call
end
@forks[pid] = blk
p [:children, EM.forks] if EMFORK
end
end
# @private
def EM.forks
@forks ? @forks.keys : []
end
if EMFORK
p 'starting reactor'
trap('INT') { EM.stop_event_loop }
EM.run {
p [:parent, Process.pid]
EM.fork(2) {
EM.add_periodic_timer(1) do
p [:fork, Process.pid, :ping]
end
}
}
p 'reactor stopped'
end
|