# frozen_string_literal: false
require_relative 'drb'
require 'monitor'
module DRb
# To use WeakIdConv:
#
# DRb.start_service(nil, nil, {:idconv => DRb::WeakIdConv.new})
class WeakIdConv < DRbIdConv
class WeakSet
include MonitorMixin
def initialize
super()
@immutable = {}
@map = ObjectSpace::WeakMap.new
end
def add(obj)
synchronize do
begin
@map[obj] = self
rescue ArgumentError
@immutable[obj.__id__] = obj
end
return obj.__id__
end
end
def fetch(ref)
synchronize do
@immutable.fetch(ref) {
@map.each { |key, _|
return key if key.__id__ == ref
}
raise RangeError.new("invalid reference")
}
end
end
end
def initialize()
super()
@weak_set = WeakSet.new
end
def to_obj(ref) # :nodoc:
return super if ref.nil?
@weak_set.fetch(ref)
end
def to_id(obj) # :nodoc:
return @weak_set.add(obj)
end
end
end
# DRb.install_id_conv(WeakIdConv.new)
| Name | Type | Size | Permission | Actions |
|---|---|---|---|---|
| acl.rb | File | 4.61 KB | 0644 |
|
| drb.rb | File | 57.49 KB | 0644 |
|
| eq.rb | File | 275 B | 0644 |
|
| extserv.rb | File | 836 B | 0644 |
|
| extservm.rb | File | 1.75 KB | 0644 |
|
| gw.rb | File | 3 KB | 0644 |
|
| invokemethod.rb | File | 777 B | 0644 |
|
| observer.rb | File | 671 B | 0644 |
|
| ssl.rb | File | 11.52 KB | 0644 |
|
| timeridconv.rb | File | 2.16 KB | 0644 |
|
| unix.rb | File | 2.78 KB | 0644 |
|
| version.rb | File | 35 B | 0644 |
|
| weakidconv.rb | File | 1.12 KB | 0644 |
|