about summary refs log tree commit homepage
path: root/lib/rainbows/client.rb
diff options
context:
space:
mode:
authorEric Wong <normalperson@yhbt.net>2011-06-28 08:17:01 +0000
committerEric Wong <normalperson@yhbt.net>2011-06-28 08:17:01 +0000
commit65f251070ce9b61a9049cb413fccffdfa11e7a70 (patch)
tree6cf5c9d0f63f84688e0f05f9ac88de339ce157b1 /lib/rainbows/client.rb
parent905f0ff393629ddb4d70e3dc221b016128c47415 (diff)
downloadrainbows-65f251070ce9b61a9049cb413fccffdfa11e7a70.tar.gz
This fixes up breakage introduced in commit
905f0ff393629ddb4d70e3dc221b016128c47415 to switch to
kgio for timed, synchronous waiting.
Diffstat (limited to 'lib/rainbows/client.rb')
-rw-r--r--lib/rainbows/client.rb20
1 files changed, 0 insertions, 20 deletions
diff --git a/lib/rainbows/client.rb b/lib/rainbows/client.rb
index d8a30b2..b456eca 100644
--- a/lib/rainbows/client.rb
+++ b/lib/rainbows/client.rb
@@ -4,26 +4,6 @@
 # this class is used for most synchronous concurrency models
 class Rainbows::Client < Kgio::Socket
   include Rainbows::ProcessClient
-  Rainbows.config!(self, :keepalive_timeout)
-
-  def read_expire
-    Time.now + KEEPALIVE_TIMEOUT
-  end
-
-  # used for reading headers (respecting keepalive_timeout)
-  def timed_read(buf)
-    expire = nil
-    begin
-      case rv = kgio_tryread(CLIENT_HEADER_BUFFER_SIZE, buf)
-      when :wait_readable
-        return if expire && expire < Time.now
-        expire ||= read_expire
-        kgio_wait_readable(KEEPALIVE_TIMEOUT)
-      else
-        return rv
-      end
-    end while true
-  end
 
   alias write kgio_write
 end