summaryrefslogtreecommitdiff
path: root/lib/drb/extserv.rb
diff options
context:
space:
mode:
Diffstat (limited to 'lib/drb/extserv.rb')
-rw-r--r--lib/drb/extserv.rb67
1 files changed, 67 insertions, 0 deletions
diff --git a/lib/drb/extserv.rb b/lib/drb/extserv.rb
new file mode 100644
index 00000000000..f05bae5264d
--- /dev/null
+++ b/lib/drb/extserv.rb
@@ -0,0 +1,67 @@
+=begin
+ external service
+ Copyright (c) 2000,2002 Masatoshi SEKI
+=end
+
+require 'drb/drb'
+
+module DRb
+ class ExtServ
+ include DRbUndumped
+
+ def initialize(there, name, server=nil)
+ @server = server || DRb::primary_server
+ @name = name
+ ro = DRbObject.new(nil, there)
+ @invoker = ro.regist(name, DRbObject.new(self, @server.uri))
+ end
+ attr_reader :server
+
+ def front
+ DRbObject.new(nil, @server.uri)
+ end
+
+ def stop_service
+ @invoker.unregist(@name)
+ server = @server
+ @server = nil
+ Thread.new do
+ sleep 1
+ server.stop_service
+ end
+ true
+ end
+
+ def alive?
+ @server ? @server.alive? : false
+ end
+ end
+end
+
+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)
+ es = DRb::ExtService.new(ARGV.shift, ARGV.shift, manager)
+ es.server.thread.join
+ end
+end
+