From 54ec1c4fe81672ca66f327ef6ae170f458cd79e5 Mon Sep 17 00:00:00 2001 From: shyouhei Date: Wed, 15 Aug 2007 20:57:30 +0000 Subject: sorry. I made wrong tags. git-svn-id: svn+ssh://ci.ruby-lang.org/ruby/tags/v1_8_5_54@13009 b2dd03c8-39d4-4d8f-98ff-823fe69b080e --- ruby_1_8_5/lib/drb/extservm.rb | 96 ------------------------------------------ 1 file changed, 96 deletions(-) delete mode 100644 ruby_1_8_5/lib/drb/extservm.rb (limited to 'ruby_1_8_5/lib/drb/extservm.rb') diff --git a/ruby_1_8_5/lib/drb/extservm.rb b/ruby_1_8_5/lib/drb/extservm.rb deleted file mode 100644 index 7066f84c65..0000000000 --- a/ruby_1_8_5/lib/drb/extservm.rb +++ /dev/null @@ -1,96 +0,0 @@ -=begin - external service manager - Copyright (c) 2000 Masatoshi SEKI -=end - -require 'drb/drb' -require 'thread' - -module DRb - class ExtServManager - include DRbUndumped - - @@command = {} - - def self.command - @@command - end - - def self.command=(cmd) - @@command = cmd - end - - def initialize - @servers = {} - @waiting = [] - @queue = Queue.new - @thread = invoke_thread - @uri = nil - end - attr_accessor :uri - - def service(name) - while true - server = nil - Thread.exclusive do - server = @servers[name] if @servers[name] - end - return server if server && server.alive? - invoke_service(name) - end - end - - def regist(name, ro) - ary = nil - Thread.exclusive do - @servers[name] = ro - ary = @waiting - @waiting = [] - end - ary.each do |th| - begin - th.run - rescue ThreadError - end - end - self - end - - def unregist(name) - Thread.exclusive 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) - Thread.critical = true - @waiting.push Thread.current - @queue.push name - Thread.stop - end - - def invoke_service_command(name, command) - raise "invalid command. name: #{name}" unless command - Thread.exclusive do - return if @servers.include?(name) - @servers[name] = false - end - uri = @uri || DRb.uri - if RUBY_PLATFORM =~ /mswin32/ && /NT/ =~ ENV["OS"] - system(%Q'cmd /c start "ruby" /b #{command} #{uri} #{name}') - else - system("#{command} #{uri} #{name} &") - end - end - end -end -- cgit v1.2.3