2015-12-16 00:07:31 -05:00
|
|
|
# frozen_string_literal: false
|
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
|
|
|
|
|
2018-11-02 13:52:33 -04:00
|
|
|
require_relative '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
|