Rainbows! Rack HTTP server user/dev discussion
 help / color / mirror / code / Atom feed
blob 6b1e4f9620dc3c3069fdc4d4da85ee8598d4dc86 427 bytes (raw)

 1
 2
 3
 4
 5
 6
 7
 8
 9
10
11
12
13
 
# -*- encoding: binary -*-
# :enddoc:
class Rainbows::Fiber::Coolio::Heartbeat < Coolio::TimerWatcher
  # ZZ gets populated by read_expire in rainbows/fiber/io/methods
  ZZ = Rainbows::Fiber::ZZ
  def on_timer
    exit if (! Rainbows.tick && Rainbows.cur <= 0)
    now = Time.now
    fibs = []
    ZZ.delete_if { |fib, time| now >= time ? fibs << fib : ! fib.alive? }
    fibs.each { |fib| fib.resume if fib.alive? }
  end
end

debug log:

solving 6b1e4f9 ...
found 6b1e4f9 in https://yhbt.net/rainbows.git

Code repositories for project(s) associated with this public inbox

	https://yhbt.net/rainbows.git

This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox;
as well as URLs for read-only IMAP folder(s) and NNTP newsgroup(s).