Sha256: e51b49ac41e292edad97246f94ab35695188445b7fb9725e5a09eb3d6aefa800
Contents?: true
Size: 1.78 KB
Versions: 8
Compression:
Stored size: 1.78 KB
Contents
# -*- encoding: binary -*-
# :enddoc:
require 'rainbows/fiber/io'
module Rainbows::Fiber::Base
include Rainbows::Base
# :stopdoc:
RD = Rainbows::Fiber::RD
WR = Rainbows::Fiber::WR
ZZ = Rainbows::Fiber::ZZ
# :startdoc:
# the scheduler method that powers both FiberSpawn and FiberPool
# concurrency models. It times out idle clients and attempts to
# schedules ones that were blocked on I/O. At most it'll sleep
# for one second (returned by the schedule_sleepers method) which
# will cause it.
def schedule
begin
Rainbows.tick
t = schedule_sleepers
ret = select(RD.compact.concat(LISTENERS), WR.compact, nil, t)
rescue Errno::EINTR
retry
rescue Errno::EBADF, TypeError
LISTENERS.compact!
raise
end or return
# active writers first, then readers
ret[1].concat(RD.compact & ret[0]).each { |c| c.f.resume }
# accept is an expensive syscall, filter out listeners we don't want
(ret[0] & LISTENERS).each { |x| yield x }
end
# wakes up any sleepers or keepalive-timeout violators that need to be
# woken and returns an interval to IO.select on
def schedule_sleepers
max = nil
now = Time.now
fibs = []
ZZ.delete_if { |fib, time|
if now >= time
fibs << fib
else
max = time
false
end
}
fibs.each { |fib| fib.resume }
now = Time.now
max.nil? || max > (now + 1) ? 1 : max - now
end
def process(client)
Rainbows.cur += 1
client.process_loop
ensure
Rainbows.cur -= 1
ZZ.delete(client.f)
end
def self.setup(klass, app)
Rainbows::Client.__send__(:include, Rainbows::Fiber::IO::Methods)
require 'rainbows/fiber/body'
Rainbows::Client.__send__(:include, Rainbows::Fiber::Body)
self.const_set(:APP, app)
end
end
Version data entries
8 entries across 8 versions & 1 rubygems