класс DRb::DRbServer

# File lib/drb/drb.rb, line 1303
def self.default_acl(acl)
  @@acl = acl
end

# File lib/drb/drb.rb, line 1289
def self.default_argc_limit(argc)
  @@argc_limit = argc
end

# File lib/drb/drb.rb, line 1310
def self.default_id_conv(idconv)
  @@idconv = idconv
end

# File lib/drb/drb.rb, line 1296
def self.default_load_limit(sz)
  @@load_limit = sz
end

# File lib/drb/drb.rb, line 1317
def self.default_safe_level(level)
  @@safe_level = level
end

# File lib/drb/drb.rb, line 1391
def initialize(uri=nil, front=nil, config_or_acl=nil)
  if Hash === config_or_acl
    config = config_or_acl.dup
  else
    acl = config_or_acl || @@acl
    config = {
      :tcp_acl => acl
    }
  end

  @config = self.class.make_config(config)

  @protocol = DRbProtocol.open_server(uri, @config)
  @uri = @protocol.uri
  @exported_uri = [@uri]

  @front = front
  @idconv = @config[:idconv]
  @safe_level = @config[:safe_level]

  @grp = ThreadGroup.new
  @thread = run

  DRb.regist_server(self)
end

# File lib/drb/drb.rb, line 1329
def self.verbose
  @@verbose
end

# File lib/drb/drb.rb, line 1324
def self.verbose=(on)
  @@verbose = on
end

# File lib/drb/drb.rb, line 1453
def alive?
  @thread.alive?
end

# File lib/drb/drb.rb, line 1541
def check_insecure_method(obj, msg_id)
  return true if Proc === obj && msg_id == :__drb_yield
  raise(ArgumentError, "#{any_to_s(msg_id)} is not a symbol") unless Symbol == msg_id.class
  raise(SecurityError, "insecure method `#{msg_id}'") if insecure_method?(msg_id)

  if obj.private_methods.include?(msg_id)
    desc = any_to_s(obj)
    raise NoMethodError, "private method `#{msg_id}' called for #{desc}"
  elsif obj.protected_methods.include?(msg_id)
    desc = any_to_s(obj)
    raise NoMethodError, "protected method `#{msg_id}' called for #{desc}"
  else
    true
  end
end

# File lib/drb/drb.rb, line 1458
def here?(uri)
  @exported_uri.include?(uri)
end

# File lib/drb/drb.rb, line 1463
def stop_service
  DRb.remove_server(self)
  if  Thread.current['DRb'] && Thread.current['DRb']['server'] == self
    Thread.current['DRb']['stop_service'] = true
  else
    shutdown
  end
end

# File lib/drb/drb.rb, line 1480
def to_id(obj)
  return nil if obj.__id__ == front.__id__
  @idconv.to_id(obj)
end

# File lib/drb/drb.rb, line 1473
def to_obj(ref)
  return front if ref.nil?
  return front[ref.to_s] if DRbURIOption === ref
  @idconv.to_obj(ref)
end

# File lib/drb/drb.rb, line 1450
def verbose; @config[:verbose]; end

# File lib/drb/drb.rb, line 1445
def verbose=(v); @config[:verbose]=v; end

# File lib/drb/drb.rb, line 1527
def any_to_s(obj)
  obj.to_s + ":#{obj.class}"
rescue
  sprintf("#<%s:0x%lx>", obj.class, obj.__id__)
end

# File lib/drb/drb.rb, line 1646
def error_print(exception)
  exception.backtrace.inject(true) do |first, x|
    if first
      $stderr.puts "#{x}: #{exception} (#{exception.class})"
    else
      $stderr.puts "\tfrom #{x}"
    end
    false
  end
end

# File lib/drb/drb.rb, line 1521
def insecure_method?(msg_id)
  INSECURE_METHOD.include?(msg_id)
end

# File lib/drb/drb.rb, line 1664
def main_loop
  client0 = @protocol.accept
  return nil if !client0
  Thread.start(client0) do |client|
    @grp.add Thread.current
    Thread.current['DRb'] = { 'client' => client ,
                              'server' => self }
    DRb.mutex.synchronize do
      client_uri = client.uri
      @exported_uri << client_uri unless @exported_uri.include?(client_uri)
    end
    loop do
      begin
        succ = false
        invoke_method = InvokeMethod.new(self, client)
        succ, result = invoke_method.perform
        error_print(result) if !succ && verbose
        client.send_reply(succ, result)
      rescue Exception => e
        error_print(e) if verbose
      ensure
        client.close unless succ
        if Thread.current['DRb']['stop_service']
          shutdown
          break
        end
        break unless succ
      end
    end
  end
end

# File lib/drb/drb.rb, line 1502
def run
  Thread.start do
    begin
      while main_loop
      end
    ensure
      @protocol.close if @protocol
    end
  end
end

# File lib/drb/drb.rb, line 1487
def shutdown
  current = Thread.current
  if @protocol.respond_to? :shutdown
    @protocol.shutdown
  else
    [@thread, *@grp.list].each { |thread|
      thread.kill unless thread == current # xxx: Thread#kill
    }
  end
  @thread.join unless @thread == current
end