diff options
author | seki <seki@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2012-05-08 19:35:07 +0000 |
---|---|---|
committer | seki <seki@b2dd03c8-39d4-4d8f-98ff-823fe69b080e> | 2012-05-08 19:35:07 +0000 |
commit | 113b94e1452048cb88d512d3ab22dfa5f7c2930e (patch) | |
tree | 1c922bf7af00a65284efd8aecb4cfbbdbdf227c4 /lib/rinda/ring.rb | |
parent | a089fe010e673d2579250e3f0dc41ec89b2f8d26 (diff) | |
download | ruby-113b94e1452048cb88d512d3ab22dfa5f7c2930e.tar.gz |
* lib/rinda/ring.rb (lookup_ring_any): fix Rinda::RingFinger.primary
hungs forever. [ruby-talk:395364]
git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@35597 b2dd03c8-39d4-4d8f-98ff-823fe69b080e
Diffstat (limited to 'lib/rinda/ring.rb')
-rw-r--r-- | lib/rinda/ring.rb | 8 |
1 files changed, 6 insertions, 2 deletions
diff --git a/lib/rinda/ring.rb b/lib/rinda/ring.rb index 3ff4606e2a..8a2a201c8a 100644 --- a/lib/rinda/ring.rb +++ b/lib/rinda/ring.rb @@ -203,13 +203,17 @@ module Rinda queue.push(ts) end queue.push(nil) + end + + @primary = queue.pop + raise('RingNotFound') if @primary.nil? + + Thread.new do while it = queue.pop @rings.push(it) end end - @primary = queue.pop - raise('RingNotFound') if @primary.nil? @primary end |