Source: show | on GitHub
# File ruby/lib/drb/extservm.rb, line 17 def self.command @@command end
# File ruby/lib/drb/extservm.rb, line 21 def self.command=(cmd) @@command = cmd end
# File ruby/lib/drb/extservm.rb, line 25 def initialize super() @cond = new_cond @servers = {} @waiting = [] @queue = Thread::Queue.new @thread = invoke_thread @uri = nil end
# File ruby/lib/drb/extservm.rb, line 47 def register(name, ro) synchronize do @servers[name] = ro @cond.signal end self end
# File ruby/lib/drb/extservm.rb, line 36 def service(name) synchronize do while true server = @servers[name] return server if server && server.alive? # server may be `false' invoke_service(name) @cond.wait end end end
# File ruby/lib/drb/extservm.rb, line 56 def unregister(name) synchronize do @servers.delete(name) end end