don't use keeper thread. [Bug #12342]

git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/trunk@55008 b2dd03c8-39d4-4d8f-98ff-823fe69b080e

ChangeLog

@@ -1,3 +1,9 @@
+Sun May 15 20:55:31 2016  Masatoshi SEKI  <m_seki@mva.biglobe.ne.jp>
+
+	* lib/drb/timeridconv.rb: don't use keeper thread. [Bug #12342]
+
+	* test/drb/ut_timerholder.rb: ditto.
+
 Sun May 15 16:15:25 2016  NARUSE, Yui  <naruse@ruby-lang.org>
 
 	* array.c (rb_ary_entry): extract rb_ary_elt to organize if-conditions

lib/drb/timeridconv.rb

@@ -18,26 +18,27 @@ module DRb
 
       class InvalidIndexError < RuntimeError; end
 
-      def initialize(timeout=600)
+      def initialize(keeping=600)
         super()
         @sentinel = Object.new
         @gc = {}
-        @curr = {}
         @renew = {}
-        @timeout = timeout
+        @keeping = keeping
-        @keeper = keeper
+        @expires = Time.now + @keeping
       end
 
       def add(obj)
         synchronize do
+          rotate
           key = obj.__id__
-          @curr[key] = obj
+          @renew[key] = obj
           return key
         end
       end
 
       def fetch(key, dv=@sentinel)
         synchronize do
+          rotate
           obj = peek(key)
           if obj == @sentinel
             return dv unless dv == @sentinel
@@ -48,42 +49,35 @@ module DRb
         end
       end
 
-      def include?(key)
+      private
-        synchronize do
-          obj = peek(key)
-          return false if obj == @sentinel
-          true
-        end
-      end
-
       def peek(key)
         synchronize do
-          return @curr.fetch(key, @renew.fetch(key, @gc.fetch(key, @sentinel)))
+          return @renew.fetch(key) { @gc.fetch(key, @sentinel) }
         end
       end
 
-      private
+      def rotate
-      def alternate
         synchronize do
-          @gc = @curr       # GCed
+          return if @expires > Time.now
-          @curr = @renew
+          @gc = @renew      # GCed
           @renew = {}
+          @expires = Time.now + @keeping
         end
       end
 
       def keeper
         Thread.new do
           loop do
-            alternate
+            rotate
-            sleep(@timeout)
+            sleep(@keeping)
           end
         end
       end
     end
 
-    # Creates a new TimerIdConv which will hold objects for +timeout+ seconds.
+    # Creates a new TimerIdConv which will hold objects for +keeping+ seconds.
-    def initialize(timeout=600)
+    def initialize(keeping=600)
-      @holder = TimerHolder2.new(timeout)
+      @holder = TimerHolder2.new(keeping)
     end
 
     def to_obj(ref) # :nodoc:

test/drb/ut_timerholder.rb

@@ -1,54 +1,38 @@
 # frozen_string_literal: false
-require 'runit/testcase'
+require 'test/unit'
-require 'runit/cui/testrunner'
+require 'drb/timeridconv'
-require 'timerholder'
 
 module DRbTests
 
-class TimerHolderTest < RUNIT::TestCase
+class TimerIdConvTest < Test::Unit::TestCase
-  def do_test(timeout, keeper_sleep = nil)
+  def test_usecase_01
-    holder = TimerHolder.new(timeout)
+    keeping = 0.1
-    holder.keeper_sleep = keeper_sleep if keeper_sleep
+    idconv = DRb::TimerIdConv.new(keeping)
-    key = holder.add(self)
+
-    sleep(timeout * 0.5)
+    key = idconv.to_id(self)
-    assert_equal(holder.peek(key), self)
+    assert_equal(key, self.__id__)
-    holder.delete(key)
+    sleep(keeping)
-    assert(!holder.include?(key))
+
-    key = holder.add(self)
+    assert_equal(idconv.to_id(false), false.__id__)
-    sleep(timeout+0.5)
+    assert_equal(idconv.to_obj(key), self)
-    assert_equal(holder.fetch(key), nil)
+    sleep(keeping)
-    key = holder.add(self)
+
-    assert_equal(holder.fetch(key), self)
+    assert_equal(idconv.to_obj(key), self)
-    holder.store(key, true)
+    sleep(keeping)
-    assert_equal(holder.fetch(key), true)
+
-    assert_equal(holder.include?(key), true)
+    assert_equal(idconv.to_id(true), true.__id__)
-    sleep(timeout+0.5)
+    sleep(keeping)
-    assert_exception(TimerHolder::InvalidIndexError) do
+
-      holder.store(key, 1)
+    assert_raise do
+      assert_equal(idconv.to_obj(key))
     end
-    assert_equal(holder.include?(key), false)
-    key = holder.add(self)
-    sleep(timeout * 0.5)
-    assert(holder.include?(key))
-    holder.extend(key, timeout)
-    sleep(timeout * 0.5)
-    assert(holder.include?(key))
-    sleep(timeout * 0.6)
-    assert(!holder.include?(key))
-    holder.delete(key)
-  end
 
-  def test_00
+    assert_raise do
-    do_test(0.5)
+      assert_equal(idconv.to_obj(false.__id__))
-  end
+    end
-
-  def test_01
-    do_test(1, 0.5)
   end
 end
 
+
 end
 
-if __FILE__ == $0
-  RUNIT::CUI::TestRunner.run(DRbTests::TimerHolderTest.suite)
-end