/usr/lib/ruby/vendor_ruby/concurrent/channel/buffer/timer.rb is in ruby-concurrent 1.0.0-3.
This file is owned by root:root, with mode 0o644.
The actual contents of the file can be viewed below.
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 | require 'concurrent/constants'
require 'concurrent/utility/monotonic_time'
require 'concurrent/channel/tick'
require 'concurrent/channel/buffer/base'
module Concurrent
class Channel
module Buffer
class Timer < Base
def put(item)
false
end
def offer(item)
false
end
def take
loop do
tick, _ = do_poll
if tick
return tick
else
Thread.pass
end
end
end
def next
loop do
tick, more = do_poll
return tick, more if tick
Thread.pass
end
end
def poll
tick, _ = do_poll
tick = Concurrent::NULL unless tick
tick
end
private
def ns_initialize(delay)
@tick = Concurrent.monotonic_time + delay.to_f
self.capacity = 1
end
def ns_size
0
end
def ns_empty?
false
end
def ns_full?
true
end
def do_poll
synchronize do
if ns_closed?
return Concurrent::NULL, false
elsif Concurrent.monotonic_time >= @tick
# only one listener gets notified
self.closed = true
return Concurrent::Channel::Tick.new(@tick), false
else
return nil, true
end
end
end
end
end
end
end
|