diff options
author | Evan Weaver <eweaver@twitter.com> | 2009-01-31 14:32:44 -0800 |
---|---|---|
committer | Evan Weaver <eweaver@twitter.com> | 2009-01-31 14:32:44 -0800 |
commit | 395faff00940c80ac5c366ea16f18e3790b9ef63 (patch) | |
tree | 70629969cf13b095902b9da092dc5f217f163b53 /test/unit/test_ws.rb | |
parent | 88cf1846c3b0b408ee9e0df5558a9b4b2f8e64dd (diff) | |
download | unicorn-395faff00940c80ac5c366ea16f18e3790b9ef63.tar.gz |
Diffstat (limited to 'test/unit/test_ws.rb')
-rw-r--r-- | test/unit/test_ws.rb | 112 |
1 files changed, 0 insertions, 112 deletions
diff --git a/test/unit/test_ws.rb b/test/unit/test_ws.rb deleted file mode 100644 index 2510c3a..0000000 --- a/test/unit/test_ws.rb +++ /dev/null @@ -1,112 +0,0 @@ -# Copyright (c) 2005 Zed A. Shaw -# You can redistribute it and/or modify it under the same terms as Ruby. -# -# Additional work donated by contributors. See http://mongrel.rubyforge.org/attributions.html -# for more information. - -require 'test/test_helper' - -include Mongrel - -class TestHandler - attr_reader :ran_test - - def call(env) - @ran_test = true - # response.socket.write("HTTP/1.1 200 OK\r\nContent-Type: text/plain\r\n\r\nhello!\n") - [200, { 'Content-Type' => 'text/plain' }, ['hello!\n']] - end -end - - -class WebServerTest < Test::Unit::TestCase - - def setup - @valid_request = "GET / HTTP/1.1\r\nHost: www.zedshaw.com\r\nContent-Type: text/plain\r\n\r\n" - @port = process_based_port - @tester = TestHandler.new - @app = Rack::URLMap.new('/test' => @tester) - redirect_test_io do - # We set max_queued_threads=1 so that we can test the reaping code - @server = HttpServer.new("127.0.0.1", @port, @app, :max_queued_threads => 1) - end - end - - def teardown - redirect_test_io do - @server.stop(true) - end - end - - def test_simple_server - hit(["http://localhost:#{@port}/test"]) - assert @tester.ran_test, "Handler didn't really run" - end - - - def do_test(string, chunk, close_after=nil, shutdown_delay=0) - # Do not use instance variables here, because it needs to be thread safe - socket = TCPSocket.new("127.0.0.1", @port); - request = StringIO.new(string) - chunks_out = 0 - - while data = request.read(chunk) - chunks_out += socket.write(data) - socket.flush - sleep 0.2 - if close_after and chunks_out > close_after - socket.close - sleep 1 - end - end - sleep(shutdown_delay) - socket.write(" ") # Some platforms only raise the exception on attempted write - socket.flush - end - - def test_trickle_attack - do_test(@valid_request, 3) - end - - def test_close_client - assert_raises IOError do - do_test(@valid_request, 10, 20) - end - end - - def test_bad_client - redirect_test_io do - do_test("GET /test HTTP/BAD", 3) - end - end - - def test_header_is_too_long - redirect_test_io do - long = "GET /test HTTP/1.1\r\n" + ("X-Big: stuff\r\n" * 15000) + "\r\n" - assert_raises Errno::ECONNRESET, Errno::EPIPE, Errno::ECONNABORTED, Errno::EINVAL, IOError do - do_test(long, long.length/2, 10) - end - end - end - - def test_max_queued_threads_overload - redirect_test_io do - assert_raises Errno::ECONNRESET, Errno::EPIPE, Errno::ECONNABORTED, Errno::EINVAL, IOError do - tests = [ - Thread.new { do_test(@valid_request, 1) }, - Thread.new { do_test(@valid_request, 10) }, - ] - - tests.each {|t| t.join} - end - end - end - - def test_file_streamed_request - body = "a" * (Mongrel::Const::MAX_BODY * 2) - long = "GET /test HTTP/1.1\r\nContent-length: #{body.length}\r\n\r\n" + body - do_test(long, Mongrel::Const::CHUNK_SIZE * 2 -400) - end - -end - |