Class: Rinda::RingFinger

Inherits:
Object
  • Object
show all
Defined in:
lib/guard/spork/rinda_ring_finger_patch.rb

Instance Method Summary collapse

Instance Method Details

#lookup_ring_any(timeout = 5) ⇒ Object 



7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
 
# File 'lib/guard/spork/rinda_ring_finger_patch.rb', line 7

def lookup_ring_any(timeout=5)
  queue = Queue.new

  Thread.new do
    self.lookup_ring(timeout) do |ts|
      queue.push(ts)
    end
    queue.push(nil)
  end

  @primary = queue.pop
  raise('RingNotFound') if @primary.nil?
  while it = queue.pop
    @rings.push(it)
  end

  @primary
end