mirror of
https://github.com/puma/puma.git
synced 2022-11-09 13:48:40 -05:00
544bb7ae81
* PluginRegistry#fire_background - Close #1972 * add test/test_plugin.rb, test/config/plugin1.rb
39 lines
1.1 KiB
Ruby
39 lines
1.1 KiB
Ruby
require_relative "helper"
|
|
require_relative "helpers/integration"
|
|
|
|
class TestPlugin < TestIntegration
|
|
def test_plugin
|
|
skip "Skipped on Windows Ruby < 2.5.0, Ruby bug" if windows? && RUBY_VERSION < '2.5.0'
|
|
@tcp_bind = UniquePort.call
|
|
@tcp_ctrl = UniquePort.call
|
|
|
|
Dir.mkdir("tmp") unless Dir.exist?("tmp")
|
|
|
|
cli_server "-b tcp://#{HOST}:#{@tcp_bind} --control-url tcp://#{HOST}:#{@tcp_ctrl} --control-token #{TOKEN} -C test/config/plugin1.rb test/rackup/hello.ru"
|
|
File.open('tmp/restart.txt', mode: 'wb') { |f| f.puts "Restart #{Time.now}" }
|
|
|
|
true while (l = @server.gets) !~ /Restarting\.\.\./
|
|
assert_match(/Restarting\.\.\./, l)
|
|
|
|
true while (l = @server.gets) !~ /Ctrl-C/
|
|
assert_match(/Ctrl-C/, l)
|
|
|
|
out = StringIO.new
|
|
|
|
cli_pumactl "-C tcp://#{HOST}:#{@tcp_ctrl} -T #{TOKEN} stop"
|
|
true while (l = @server.gets) !~ /Goodbye/
|
|
|
|
@server.close
|
|
@server = nil
|
|
out.close
|
|
end
|
|
|
|
private
|
|
|
|
def cli_pumactl(argv)
|
|
pumactl = IO.popen("#{BASE} bin/pumactl #{argv}", "r")
|
|
@ios_to_close << pumactl
|
|
Process.wait pumactl.pid
|
|
pumactl
|
|
end
|
|
end
|