summaryrefslogtreecommitdiff
path: root/jni/ruby/lib/drb/extservm.rb
diff options
context:
space:
mode:
authorJari Vetoniemi <jari.vetoniemi@indooratlas.com>2020-03-16 18:49:26 +0900
committerJari Vetoniemi <jari.vetoniemi@indooratlas.com>2020-03-30 00:39:06 +0900
commitfcbf63e62c627deae76c1b8cb8c0876c536ed811 (patch)
tree64cb17de3f41a2b6fef2368028fbd00349946994 /jni/ruby/lib/drb/extservm.rb
Fresh start
Diffstat (limited to 'jni/ruby/lib/drb/extservm.rb')
-rw-r--r--jni/ruby/lib/drb/extservm.rb93
1 files changed, 93 insertions, 0 deletions
diff --git a/jni/ruby/lib/drb/extservm.rb b/jni/ruby/lib/drb/extservm.rb
new file mode 100644
index 0000000..8a7fc31
--- /dev/null
+++ b/jni/ruby/lib/drb/extservm.rb
@@ -0,0 +1,93 @@
+=begin
+ external service manager
+ Copyright (c) 2000 Masatoshi SEKI
+=end
+
+require 'drb/drb'
+require 'thread'
+require 'monitor'
+
+module DRb
+ class ExtServManager
+ include DRbUndumped
+ include MonitorMixin
+
+ @@command = {}
+
+ def self.command
+ @@command
+ end
+
+ def self.command=(cmd)
+ @@command = cmd
+ end
+
+ def initialize
+ super()
+ @cond = new_cond
+ @servers = {}
+ @waiting = []
+ @queue = Queue.new
+ @thread = invoke_thread
+ @uri = nil
+ end
+ attr_accessor :uri
+
+ def service(name)
+ synchronize do
+ while true
+ server = @servers[name]
+ return server if server && server.alive?
+ invoke_service(name)
+ @cond.wait
+ end
+ end
+ end
+
+ def regist(name, ro)
+ synchronize do
+ @servers[name] = ro
+ @cond.signal
+ end
+ self
+ end
+
+ def unregist(name)
+ synchronize do
+ @servers.delete(name)
+ end
+ end
+
+ private
+ def invoke_thread
+ Thread.new do
+ while true
+ name = @queue.pop
+ invoke_service_command(name, @@command[name])
+ end
+ end
+ end
+
+ def invoke_service(name)
+ @queue.push(name)
+ end
+
+ def invoke_service_command(name, command)
+ raise "invalid command. name: #{name}" unless command
+ synchronize do
+ return if @servers.include?(name)
+ @servers[name] = false
+ end
+ uri = @uri || DRb.uri
+ if command.respond_to? :to_ary
+ command = command.to_ary + [uri, name]
+ pid = spawn(*command)
+ else
+ pid = spawn("#{command} #{uri} #{name}")
+ end
+ th = Process.detach(pid)
+ th[:drb_service] = name
+ th
+ end
+ end
+end