diff options
author | Eric Wong <bofh@yhbt.net> | 2021-03-15 02:03:50 -0400 |
---|---|---|
committer | Eric Wong <bofh@yhbt.net> | 2021-03-15 02:03:50 -0400 |
commit | 9c4963c8b1f96fa6afcfa8ec61f81f9997e926e7 (patch) | |
tree | 0b024787954128ca4fc76d0d41dbdacf6254323d /test/unit/test_signals.rb | |
parent | 2c9038cdc129272161336c0bd4facf61a681062e (diff) | |
parent | ea5295e8e4dcfaec24efb5030557594aabe645cb (diff) | |
download | unicorn-v6-wip.tar.gz |
* origin/master: tests: force blocking I/O for Ruby 3.x
Diffstat (limited to 'test/unit/test_signals.rb')
-rw-r--r-- | test/unit/test_signals.rb | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/test/unit/test_signals.rb b/test/unit/test_signals.rb index 4d9fdc5..56a7dfc 100644 --- a/test/unit/test_signals.rb +++ b/test/unit/test_signals.rb @@ -52,7 +52,7 @@ class SignalsTest < Test::Unit::TestCase redirect_test_io { HttpServer.new(app, opts).start.join } } wait_workers_ready("test_stderr.#{pid}.log", 1) - sock = TCPSocket.new('127.0.0.1', @port) + sock = tcp_socket('127.0.0.1', @port) sock.syswrite("GET / HTTP/1.0\r\n\r\n") buf = sock.readpartial(4096) assert_nil sock.close @@ -79,7 +79,7 @@ class SignalsTest < Test::Unit::TestCase } wr.close wait_workers_ready("test_stderr.#{pid}.log", 1) - sock = TCPSocket.new('127.0.0.1', @port) + sock = tcp_socket('127.0.0.1', @port) sock.syswrite("GET / HTTP/1.0\r\n\r\n") buf = rd.readpartial(1) wait_master_ready("test_stderr.#{pid}.log") @@ -102,7 +102,7 @@ class SignalsTest < Test::Unit::TestCase } t0 = Time.now wait_workers_ready("test_stderr.#{pid}.log", 1) - sock = TCPSocket.new('127.0.0.1', @port) + sock = tcp_socket('127.0.0.1', @port) sock.syswrite("GET / HTTP/1.0\r\n\r\n") buf = nil @@ -125,7 +125,7 @@ class SignalsTest < Test::Unit::TestCase } redirect_test_io { @server = HttpServer.new(app, @server_opts).start } wait_workers_ready("test_stderr.#{$$}.log", 1) - sock = TCPSocket.new('127.0.0.1', @port) + sock = tcp_socket('127.0.0.1', @port) sock.syswrite("GET / HTTP/1.0\r\n\r\n") buf = '' header_len = pid = nil @@ -163,13 +163,13 @@ class SignalsTest < Test::Unit::TestCase redirect_test_io { @server = HttpServer.new(app, @server_opts).start } wait_workers_ready("test_stderr.#{$$}.log", 1) - sock = TCPSocket.new('127.0.0.1', @port) + sock = tcp_socket('127.0.0.1', @port) sock.syswrite("GET / HTTP/1.0\r\n\r\n") pid = sock.sysread(4096)[/\r\nX-Pid: (\d+)\r\n/, 1].to_i assert_nil sock.close assert pid > 0, "pid not positive: #{pid.inspect}" - sock = TCPSocket.new('127.0.0.1', @port) + sock = tcp_socket('127.0.0.1', @port) sock.syswrite("PUT / HTTP/1.0\r\n") sock.syswrite("Content-Length: #{@bs * @count}\r\n\r\n") 1000.times { Process.kill(:HUP, pid) } |