lib/rainbows/client.rb

   1 # -*- encoding: binary -*-
   2 # :enddoc:
   3 require "io/wait"
   4
   5 # this class is used for most synchronous concurrency models
   6 class Rainbows::Client < Kgio::Socket
   7   include Rainbows::ProcessClient
   8   Rainbows.config!(self, :keepalive_timeout)
   9
  10   def read_expire
  11     Time.now + KEEPALIVE_TIMEOUT
  12   end
  13
  14   def kgio_wait_readable
  15     wait KEEPALIVE_TIMEOUT
  16   end
  17
  18   # used for reading headers (respecting keepalive_timeout)
  19   def timed_read(buf)
  20     expire = nil
  21     begin
  22       case rv = kgio_tryread(CLIENT_HEADER_BUFFER_SIZE, buf)
  23       when :wait_readable
  24         return if expire && expire < Time.now
  25         expire ||= read_expire
  26         kgio_wait_readable
  27       else
  28         return rv
  29       end
  30     end while true
  31   end
  32
  33   alias write kgio_write
  34 end