diff options
author | Eric Wong <normalperson@yhbt.net> | 2009-02-06 18:14:47 -0800 |
---|---|---|
committer | Eric Wong <normalperson@yhbt.net> | 2009-02-09 19:52:10 -0800 |
commit | 64e45d14ba2d2ee2f96635939f1e3aed5911e792 (patch) | |
tree | 6a514c358a69b68c0f37f74afb4c0ff24ff0cedb /lib/unicorn.rb | |
parent | 1fe42f0f8e7f0902eb02860fb098cbd73ddf4e5d (diff) | |
download | unicorn-64e45d14ba2d2ee2f96635939f1e3aed5911e792.tar.gz |
This allows us to avoid the overhead of allocating a new buffer each and every time we call sysread (even when just parsing headers for GET requests).
Diffstat (limited to 'lib/unicorn.rb')
-rw-r--r-- | lib/unicorn.rb | 16 |
1 files changed, 7 insertions, 9 deletions
diff --git a/lib/unicorn.rb b/lib/unicorn.rb index bc940f0..aec69fb 100644 --- a/lib/unicorn.rb +++ b/lib/unicorn.rb @@ -83,7 +83,8 @@ module Unicorn parser, params = @parser, @params parser.reset params.clear - data = client.sysread(Const::CHUNK_SIZE) + buffer = @request.buffer + data = String.new(client.sysread(Const::CHUNK_SIZE, buffer)) nparsed = 0 # Assumption: nparsed will always be less since data will get filled with more @@ -101,7 +102,7 @@ module Unicorn end raise "No REQUEST PATH" if !params[Const::REQUEST_PATH] - + params[Const::PATH_INFO] = params[Const::REQUEST_PATH] params[Const::SCRIPT_NAME] = "" @@ -113,17 +114,14 @@ module Unicorn # or other intermediary acting on behalf of the actual source client." params[Const::REMOTE_ADDR] = client.unicorn_peeraddr.last - # Select handlers that want more detailed request notification env = @request.consume(params, client) or break app_response = @app.call(env) HttpResponse.write(client, app_response) - break #done + break #done else - # Parser is not done, queue up more data to read and continue parsing - chunk = client.sysread(Const::CHUNK_SIZE) - break if !chunk or chunk.length == 0 # read failed, stop processing - - data << chunk + # Parser is not done, queue up more data to read and continue + # parsing + data << client.sysread(Const::CHUNK_SIZE, buffer) if data.length >= Const::MAX_HEADER raise HttpParserError.new("HEADER is longer than allowed, aborting client early.") end |