123456789_123456789_123456789_123456789_123456789_

Class: DRb::ExtServManager

Relationships & Source Files
Super Chains via Extension / Inclusion / Inheritance
Instance Chain:
self, MonitorMixin, DRbUndumped
Inherits: Object
Defined in: lib/drb/extservm.rb

Class Attribute Summary

Class Method Summary

Instance Attribute Summary

Instance Method Summary

DRbUndumped - Included

#_dump

Constructor Details

.new ⇒ ExtServManager

[ GitHub ] 

  


# File 'lib/drb/extservm.rb', line 25



def initialize
  super()
  @cond = new_cond
  @servers = {}
  @waiting = []
  @queue = Thread::Queue.new
  @thread = invoke_thread
  @uri = nil
end


  







Class Attribute Details



  

    .command   (rw)
  

  [ GitHub ]


  

  


# File 'lib/drb/extservm.rb', line 17



def self.command
  @@command
end


  








  

    .command=(cmd)   (rw)
  

  [ GitHub ]


  

  


# File 'lib/drb/extservm.rb', line 21



def self.command=(cmd)
  @@command = cmd
end


  







Instance Attribute Details



  

    #uri   (rw)
  

  [ GitHub ]


  

  


# File 'lib/drb/extservm.rb', line 34



attr_accessor :uri


  







Instance Method Details



  

    #invoke_service(name)   (private)
  

  [ GitHub ]


  

  


# File 'lib/drb/extservm.rb', line 71



def invoke_service(name)
  @queue.push(name)
end


  








  

    #invoke_service_command(name, command)   (private)
  

  [ GitHub ]


  

  


# File 'lib/drb/extservm.rb', line 75



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


  








  

    #invoke_thread   (private)
  

  [ GitHub ]


  

  


# File 'lib/drb/extservm.rb', line 62



def invoke_thread
  Thread.new do
    while true
      name = @queue.pop
      invoke_service_command(name, @@command[name])
    end
  end
end


  








  

    #regist(name, ro)  
  

  [ GitHub ]


  

  


# File 'lib/drb/extservm.rb', line 47



def regist(name, ro)
  synchronize do
    @servers[name] = ro
    @cond.signal
  end
  self
end


  








  

    #service(name)  
  

  [ GitHub ]


  

  


# File 'lib/drb/extservm.rb', line 36



def service(name)
  synchronize do
    while true
      server = @servers[name]
      return server if server && server.alive? # server may be `false'
      invoke_service(name)
      @cond.wait
    end
  end
end


  








  

    #unregist(name)  
  

  [ GitHub ]


  

  


# File 'lib/drb/extservm.rb', line 55



def unregist(name)
  synchronize do
    @servers.delete(name)
  end
end