diff options
Diffstat (limited to 'lib')
-rw-r--r-- | lib/rainbows/coolio.rb | 4 | ||||
-rw-r--r-- | lib/rainbows/coolio/client.rb | 12 | ||||
-rw-r--r-- | lib/rainbows/coolio/response_chunk_pipe.rb (renamed from lib/rainbows/coolio/deferred_chunk_response.rb) | 3 | ||||
-rw-r--r-- | lib/rainbows/coolio/response_pipe.rb (renamed from lib/rainbows/coolio/deferred_response.rb) | 2 |
4 files changed, 10 insertions, 11 deletions
diff --git a/lib/rainbows/coolio.rb b/lib/rainbows/coolio.rb index a9075cc..463bf0a 100644 --- a/lib/rainbows/coolio.rb +++ b/lib/rainbows/coolio.rb @@ -33,13 +33,13 @@ module Rainbows::Coolio autoload :Master, 'rainbows/coolio/master' autoload :ThreadClient, 'rainbows/coolio/thread_client' - autoload :DeferredChunkResponse, 'rainbows/coolio/deferred_chunk_response' + autoload :ResponsePipe, 'rainbows/coolio/response_pipe' + autoload :ResponseChunkPipe, 'rainbows/coolio/response_chunk_pipe' # :startdoc: end # :enddoc: require 'rainbows/coolio/heartbeat' require 'rainbows/coolio/server' require 'rainbows/coolio/core' -require 'rainbows/coolio/deferred_response' require 'rainbows/coolio/client' Rainbows::Coolio.__send__ :include, Rainbows::Coolio::Core diff --git a/lib/rainbows/coolio/client.rb b/lib/rainbows/coolio/client.rb index 7b41026..6360e2d 100644 --- a/lib/rainbows/coolio/client.rb +++ b/lib/rainbows/coolio/client.rb @@ -6,8 +6,8 @@ class Rainbows::Coolio::Client < Coolio::IO SF = Rainbows::StreamFile CONN = Rainbows::Coolio::CONN KATO = Rainbows::Coolio::KATO - DeferredResponse = Rainbows::Coolio::DeferredResponse - DeferredChunkResponse = Rainbows::Coolio::DeferredChunkResponse + ResponsePipe = Rainbows::Coolio::ResponsePipe + ResponseChunkPipe = Rainbows::Coolio::ResponseChunkPipe def initialize(io) CONN[self] = false @@ -61,7 +61,7 @@ class Rainbows::Coolio::Client < Coolio::IO # queued, optional response bodies, it should only be unpollable "fast" # devices where read(2) is uninterruptable. Unfortunately, NFS and ilk - # are also part of this. We'll also stick DeferredResponse bodies in + # are also part of this. We'll also stick ResponsePipe bodies in # here to prevent connections from being closed on us. def defer_body(io) @deferred = io @@ -88,7 +88,7 @@ class Rainbows::Coolio::Client < Coolio::IO c = stream_response_headers(status, headers) if headers # we only want to attach to the Coolio::Loop belonging to the # main thread in Ruby 1.9 - io = (c ? DeferredChunkResponse : DeferredResponse).new(io, self, body) + io = (c ? ResponseChunkPipe : ResponsePipe).new(io, self, body) defer_body(io.attach(LOOP)) end @@ -133,7 +133,7 @@ class Rainbows::Coolio::Client < Coolio::IO def on_write_complete case @deferred - when DeferredResponse then return + when ResponsePipe then return when NilClass # fall through else begin @@ -172,7 +172,7 @@ class Rainbows::Coolio::Client < Coolio::IO def close_deferred case @deferred - when DeferredResponse, NilClass + when ResponsePipe, NilClass else begin @deferred.close diff --git a/lib/rainbows/coolio/deferred_chunk_response.rb b/lib/rainbows/coolio/response_chunk_pipe.rb index 6ced2e6..5e456e9 100644 --- a/lib/rainbows/coolio/deferred_chunk_response.rb +++ b/lib/rainbows/coolio/response_chunk_pipe.rb @@ -2,8 +2,7 @@ # :enddoc: # # this is class is specific to Coolio for proxying IO-derived objects -class Rainbows::Coolio::DeferredChunkResponse < - Rainbows::Coolio::DeferredResponse +class Rainbows::Coolio::ResponseChunkPipe < Rainbows::Coolio::ResponsePipe def on_read(data) @client.write("#{data.size.to_s(16)}\r\n") @client.write(data) diff --git a/lib/rainbows/coolio/deferred_response.rb b/lib/rainbows/coolio/response_pipe.rb index 2f6f965..42483c2 100644 --- a/lib/rainbows/coolio/deferred_response.rb +++ b/lib/rainbows/coolio/response_pipe.rb @@ -3,7 +3,7 @@ # # this is class is specific to Coolio for writing large static files # or proxying IO-derived objects -class Rainbows::Coolio::DeferredResponse < Coolio::IO +class Rainbows::Coolio::ResponsePipe < Coolio::IO def initialize(io, client, body) super(io) @client, @body = client, body |