mirror of
https://github.com/puma/puma.git
synced 2022-11-09 13:48:40 -05:00
bbbdfb8f4c
* Update runner.rb * Update server.rb * Update test_busy_worker.rb * Update test_out_of_band_server.rb * Update test_persistent.rb * Update test_puma_server.rb * test_pumactl.rb - Fix CI warning: assigned but unused variable * test_integration_pumactl.rb - Fix CI warning: assigned but unused variable * Update History.md
106 lines
2.8 KiB
Ruby
106 lines
2.8 KiB
Ruby
require_relative "helper"
|
|
require "puma/events"
|
|
|
|
class TestBusyWorker < Minitest::Test
|
|
parallelize_me!
|
|
|
|
def setup
|
|
@ios = []
|
|
@server = nil
|
|
end
|
|
|
|
def teardown
|
|
@server.stop(true) if @server
|
|
@ios.each {|i| i.close unless i.closed?}
|
|
end
|
|
|
|
def new_connection
|
|
TCPSocket.new('127.0.0.1', @port).tap {|s| @ios << s}
|
|
rescue IOError
|
|
Thread.current.purge_interrupt_queue if Thread.current.respond_to? :purge_interrupt_queue
|
|
retry
|
|
end
|
|
|
|
def send_http(req)
|
|
new_connection << req
|
|
end
|
|
|
|
def send_http_and_read(req)
|
|
send_http(req).read
|
|
end
|
|
|
|
def with_server(**options, &app)
|
|
@requests_count = 0 # number of requests processed
|
|
@requests_running = 0 # current number of requests running
|
|
@requests_max_running = 0 # max number of requests running in parallel
|
|
@mutex = Mutex.new
|
|
|
|
request_handler = ->(env) do
|
|
@mutex.synchronize do
|
|
@requests_count += 1
|
|
@requests_running += 1
|
|
if @requests_running > @requests_max_running
|
|
@requests_max_running = @requests_running
|
|
end
|
|
end
|
|
|
|
begin
|
|
yield(env)
|
|
ensure
|
|
@mutex.synchronize do
|
|
@requests_running -= 1
|
|
end
|
|
end
|
|
end
|
|
|
|
@server = Puma::Server.new request_handler, Puma::Events.strings, **options
|
|
@server.instance_variable_set :@min_threads, options[:min_threads] || 0
|
|
@server.instance_variable_set :@max_threads, options[:max_threads] || 10
|
|
@port = (@server.add_tcp_listener '127.0.0.1', 0).addr[1]
|
|
@server.run
|
|
end
|
|
|
|
# Multiple concurrent requests are not processed
|
|
# sequentially as a small delay is introduced
|
|
def test_multiple_requests_waiting_on_less_busy_worker
|
|
skip_unless :mri
|
|
|
|
with_server(wait_for_less_busy_worker: 1.0) do |_|
|
|
sleep(0.1)
|
|
|
|
[200, {}, [""]]
|
|
end
|
|
|
|
n = 2
|
|
|
|
Array.new(n) do
|
|
Thread.new { send_http_and_read "GET / HTTP/1.0\r\n\r\n" }
|
|
end.each(&:join)
|
|
|
|
assert_equal n, @requests_count, "number of requests needs to match"
|
|
assert_equal 0, @requests_running, "none of requests needs to be running"
|
|
assert_equal 1, @requests_max_running, "maximum number of concurrent requests needs to be 1"
|
|
end
|
|
|
|
# Multiple concurrent requests are processed
|
|
# in parallel as a delay is disabled
|
|
def test_multiple_requests_processing_in_parallel
|
|
skip_unless :mri
|
|
|
|
with_server(wait_for_less_busy_worker: 0.0) do |_|
|
|
sleep(0.1)
|
|
|
|
[200, {}, [""]]
|
|
end
|
|
|
|
n = 4
|
|
|
|
Array.new(n) do
|
|
Thread.new { send_http_and_read "GET / HTTP/1.0\r\n\r\n" }
|
|
end.each(&:join)
|
|
|
|
assert_equal n, @requests_count, "number of requests needs to match"
|
|
assert_equal 0, @requests_running, "none of requests needs to be running"
|
|
assert_equal n, @requests_max_running, "maximum number of concurrent requests needs to match"
|
|
end
|
|
end
|