Sha256: 459cd826e08180c8c6326c4a49b443772c2eb495f5d67d623dfe3f9e81985669
Contents?: true
Size: 1.65 KB
Versions: 10
Compression:
Stored size: 1.65 KB
Contents
# This app is intended to test large HTTP responses with or without
# a fully-buffering reverse proxy such as nginx. Without a fully-buffering
# reverse proxy, unicorn will be unresponsive when client count exceeds
# worker_processes.
#
# To demonstrate how bad unicorn is at slowly reading clients:
#
# # in one terminal, start unicorn with one worker:
# unicorn -E none -l 127.0.0.1:8080 test/benchmark/ddstream.ru
#
# # in a different terminal, start more slow curl processes than
# # unicorn workers and watch time outputs
# curl --limit-rate 8K --trace-time -vsN http://127.0.0.1:8080/ >/dev/null &
# curl --limit-rate 8K --trace-time -vsN http://127.0.0.1:8080/ >/dev/null &
# wait
#
# The last client won't see a response until the first one is done reading
#
# nginx note: do not change the default "proxy_buffering" behavior.
# Setting "proxy_buffering off" prevents nginx from protecting unicorn.
# totally standalone rack app to stream a giant response
class BigResponse
def initialize(bs, count)
@buf = "#{bs.to_s(16)}\r\n#{' ' * bs}\r\n"
@count = count
@res = [ 200,
{ 'Transfer-Encoding' => -'chunked', 'Content-Type' => 'text/plain' },
self
]
end
# rack response body iterator
def each
(1..@count).each { yield @buf }
yield -"0\r\n\r\n"
end
# rack app entry endpoint
def call(_env)
@res
end
end
# default to a giant (128M) response because kernel socket buffers
# can be ridiculously large on some systems
bs = ENV['bs'] ? ENV['bs'].to_i : 65536
count = ENV['count'] ? ENV['count'].to_i : 2048
warn "serving response with bs=#{bs} count=#{count} (#{bs*count} bytes)"
run BigResponse.new(bs, count)
Version data entries
10 entries across 10 versions & 2 rubygems