about summary refs log tree commit homepage
path: root/lib/rainbows/writer_thread_spawn.rb
diff options
context:
space:
mode:
authorEric Wong <normalperson@yhbt.net>2010-07-10 08:04:48 +0000
committerEric Wong <normalperson@yhbt.net>2010-07-10 08:04:48 +0000
commitd3b97d1114e2d23a9231fe889cd5bf6927d451ba (patch)
tree6c4d7a033dad1edc91b72a9e7fa36203c60c8116 /lib/rainbows/writer_thread_spawn.rb
parent9838b614621bbbff27a91166406d833be85adbbd (diff)
downloadrainbows-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_spawn.rb')
-rw-r--r--lib/rainbows/writer_thread_spawn.rb10
1 files changed, 5 insertions, 5 deletions
diff --git a/lib/rainbows/writer_thread_spawn.rb b/lib/rainbows/writer_thread_spawn.rb
index b9bbad2..cbe7765 100644
--- a/lib/rainbows/writer_thread_spawn.rb
+++ b/lib/rainbows/writer_thread_spawn.rb
@@ -23,11 +23,11 @@ module Rainbows
   module WriterThreadSpawn
     include Base
 
-    CUR = {}
+    CUR = {} # :nodoc:
 
     # used to wrap a BasicSocket to use with +q+ for all writes
     # this is compatible with IO.select
-    class MySocket < Struct.new(:to_io, :q, :thr)
+    class MySocket < Struct.new(:to_io, :q, :thr)  # :nodoc: all
       include Rainbows::Response
 
       def readpartial(size, buf = "")
@@ -90,15 +90,15 @@ module Rainbows
       end
     end
 
-    def write_body(my_sock, body)
+    def write_body(my_sock, body) # :nodoc:
       my_sock.queue_body(body)
     end
 
-    def process_client(client)
+    def process_client(client) # :nodoc:
       super(MySocket[client])
     end
 
-    def worker_loop(worker)
+    def worker_loop(worker)  # :nodoc:
       MySocket.const_set(:MAX, worker_connections)
       Rainbows::Response.setup(MySocket)
       super(worker) # accept loop from Unicorn