diff options
author | Eric Wong <normalperson@yhbt.net> | 2010-07-10 08:04:48 +0000 |
---|---|---|
committer | Eric Wong <normalperson@yhbt.net> | 2010-07-10 08:04:48 +0000 |
commit | d3b97d1114e2d23a9231fe889cd5bf6927d451ba (patch) | |
tree | 6c4d7a033dad1edc91b72a9e7fa36203c60c8116 /lib/rainbows/writer_thread_pool.rb | |
parent | 9838b614621bbbff27a91166406d833be85adbbd (diff) | |
download | rainbows-d3b97d1114e2d23a9231fe889cd5bf6927d451ba.tar.gz |
Since we suck at building websites, we just rely on RDoc as a website builder. And since Rainbows! is an application server (and not a programming library), our internal API should be of little interest to end users. Anybody interested in Rainbows! (or any other project) internals should be reading the source.
Diffstat (limited to 'lib/rainbows/writer_thread_pool.rb')
-rw-r--r-- | lib/rainbows/writer_thread_pool.rb | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/lib/rainbows/writer_thread_pool.rb b/lib/rainbows/writer_thread_pool.rb index 84b750b..4050af9 100644 --- a/lib/rainbows/writer_thread_pool.rb +++ b/lib/rainbows/writer_thread_pool.rb @@ -24,7 +24,7 @@ module Rainbows # used to wrap a BasicSocket to use with +q+ for all writes # this is compatible with IO.select - class QueueSocket < Struct.new(:to_io, :q) + class QueueSocket < Struct.new(:to_io, :q) # :nodoc: def readpartial(size, buf = "") to_io.readpartial(size, buf) end @@ -46,7 +46,7 @@ module Rainbows end end - module Response + module Response # :nodoc: def write_body(qclient, body) qclient.q << [ qclient.to_io, :body, body ] end @@ -55,12 +55,12 @@ module Rainbows @@nr = 0 @@q = nil - def process_client(client) + def process_client(client) # :nodoc: @@nr += 1 super(QueueSocket[client, @@q[@@nr %= @@q.size]]) end - def worker_loop(worker) + def worker_loop(worker) # :nodoc: Rainbows::Response.setup(self.class) self.class.__send__(:alias_method, :sync_write_body, :write_body) self.class.__send__(:include, Response) |