2019-04-24 12:08:54 -04:00
|
|
|
require 'test/unit'
|
|
|
|
require 'drb'
|
|
|
|
require 'drb/timeridconv'
|
2019-05-04 06:28:57 -04:00
|
|
|
require 'drb/weakidconv'
|
2019-04-24 12:08:54 -04:00
|
|
|
|
|
|
|
module DRbObjectTest
|
|
|
|
class Foo
|
|
|
|
def initialize
|
|
|
|
@foo = 'foo'
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
def teardown
|
|
|
|
DRb.stop_service
|
2019-12-09 22:41:09 -05:00
|
|
|
DRb::DRbConn.stop_pool
|
2019-04-24 12:08:54 -04:00
|
|
|
end
|
|
|
|
|
|
|
|
def drb_eq(obj)
|
|
|
|
proxy = DRbObject.new(obj)
|
|
|
|
assert_equal(obj, DRb.to_obj(proxy.__drbref))
|
|
|
|
end
|
|
|
|
|
|
|
|
def test_DRbObject_id_dereference
|
|
|
|
drb_eq(Foo.new)
|
|
|
|
drb_eq(Foo)
|
|
|
|
drb_eq(File)
|
|
|
|
drb_eq(Enumerable)
|
|
|
|
drb_eq(nil)
|
|
|
|
drb_eq(1)
|
|
|
|
drb_eq($stdout)
|
|
|
|
drb_eq([])
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
class TestDRbObject < Test::Unit::TestCase
|
|
|
|
include DRbObjectTest
|
|
|
|
|
|
|
|
def setup
|
|
|
|
DRb.start_service
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
class TestDRbObjectTimerIdConv < Test::Unit::TestCase
|
|
|
|
include DRbObjectTest
|
|
|
|
|
|
|
|
def setup
|
2019-12-09 22:41:09 -05:00
|
|
|
@idconv = DRb::TimerIdConv.new
|
|
|
|
DRb.start_service(nil, nil, {:idconv => @idconv})
|
|
|
|
end
|
|
|
|
|
|
|
|
def teardown
|
|
|
|
super
|
|
|
|
# stop DRb::TimerIdConv::TimerHolder2#on_gc
|
|
|
|
@idconv.instance_eval do
|
|
|
|
@holder.instance_eval do
|
|
|
|
@expires = nil
|
|
|
|
end
|
|
|
|
end
|
|
|
|
GC.start
|
2019-04-24 12:08:54 -04:00
|
|
|
end
|
|
|
|
end
|
2019-05-04 06:28:57 -04:00
|
|
|
|
|
|
|
class TestDRbObjectWeakIdConv < Test::Unit::TestCase
|
|
|
|
include DRbObjectTest
|
|
|
|
|
|
|
|
def setup
|
|
|
|
DRb.start_service(nil, nil, {:idconv => DRb::WeakIdConv.new})
|
|
|
|
end
|
|
|
|
end
|