Sha256: 7b27540307c3628c6acccf3a2cd67933dd07701a89b7077e86343536944392b7
Contents?: true
Size: 895 Bytes
Versions: 66
Compression:
Stored size: 895 Bytes
Contents
$:.unshift "../lib"
require 'eventmachine'
require 'test/unit'
class TestProcessWatch < Test::Unit::TestCase
module ParentProcessWatcher
def process_forked
$forked = true
end
end
module ChildProcessWatcher
def process_exited
$exited = true
end
def unbind
$unbind = true
EM.stop
end
end
def setup
EM.kqueue = true if EM.kqueue?
end
def teardown
EM.kqueue = false if EM.kqueue?
end
def test_events
EM.run{
# watch ourselves for a fork notification
EM.watch_process(Process.pid, ParentProcessWatcher)
$fork_pid = fork{ sleep }
child = EM.watch_process($fork_pid, ChildProcessWatcher)
$pid = child.pid
EM.add_timer(0.5){
Process.kill('TERM', $fork_pid)
}
}
assert_equal($pid, $fork_pid)
assert($forked)
assert($exited)
assert($unbind)
end
end
Version data entries
66 entries across 66 versions & 8 rubygems