2003-06-18 11:45:12 -04:00
|
|
|
=begin
|
|
|
|
external service
|
2011-05-18 20:07:25 -04:00
|
|
|
Copyright (c) 2000,2002 Masatoshi SEKI
|
2003-06-18 11:45:12 -04:00
|
|
|
=end
|
|
|
|
|
|
|
|
require 'drb/drb'
|
2007-11-26 09:24:29 -05:00
|
|
|
require 'monitor'
|
2003-06-18 11:45:12 -04:00
|
|
|
|
|
|
|
module DRb
|
|
|
|
class ExtServ
|
2007-11-26 09:24:29 -05:00
|
|
|
include MonitorMixin
|
2003-06-18 11:45:12 -04:00
|
|
|
include DRbUndumped
|
|
|
|
|
|
|
|
def initialize(there, name, server=nil)
|
2007-11-26 09:24:29 -05:00
|
|
|
super()
|
2003-06-18 11:45:12 -04:00
|
|
|
@server = server || DRb::primary_server
|
|
|
|
@name = name
|
|
|
|
ro = DRbObject.new(nil, there)
|
2007-11-26 09:24:29 -05:00
|
|
|
synchronize do
|
|
|
|
@invoker = ro.regist(name, DRbObject.new(self, @server.uri))
|
|
|
|
end
|
2003-06-18 11:45:12 -04:00
|
|
|
end
|
|
|
|
attr_reader :server
|
|
|
|
|
|
|
|
def front
|
|
|
|
DRbObject.new(nil, @server.uri)
|
|
|
|
end
|
|
|
|
|
|
|
|
def stop_service
|
2007-11-26 09:24:29 -05:00
|
|
|
synchronize do
|
|
|
|
@invoker.unregist(@name)
|
|
|
|
server = @server
|
|
|
|
@server = nil
|
|
|
|
server.stop_service
|
|
|
|
true
|
|
|
|
end
|
2003-06-18 11:45:12 -04:00
|
|
|
end
|
|
|
|
|
|
|
|
def alive?
|
|
|
|
@server ? @server.alive? : false
|
|
|
|
end
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
2013-01-24 22:25:39 -05:00
|
|
|
# :stopdoc:
|
|
|
|
|
2003-06-18 11:45:12 -04:00
|
|
|
if __FILE__ == $0
|
|
|
|
class Foo
|
|
|
|
include DRbUndumped
|
|
|
|
|
|
|
|
def initialize(str)
|
|
|
|
@str = str
|
|
|
|
end
|
|
|
|
|
|
|
|
def hello(it)
|
|
|
|
"#{it}: #{self}"
|
|
|
|
end
|
|
|
|
|
|
|
|
def to_s
|
|
|
|
@str
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|
|
|
|
cmd = ARGV.shift
|
|
|
|
case cmd
|
|
|
|
when 'itest1', 'itest2'
|
|
|
|
front = Foo.new(cmd)
|
|
|
|
manager = DRb::DRbServer.new(nil, front)
|
2004-01-21 09:05:09 -05:00
|
|
|
es = DRb::ExtServ.new(ARGV.shift, ARGV.shift, manager)
|
2003-06-18 11:45:12 -04:00
|
|
|
es.server.thread.join
|
|
|
|
end
|
|
|
|
end
|
|
|
|
|