Class: Riser::DRbServices

Inherits:
Object
  • Object
show all
Extended by:
Forwardable
Defined in:
lib/riser/services.rb

Instance Method Summary collapse

Constructor Details

#initialize(druby_process_num = 0) ⇒ DRbServices

Returns a new instance of DRbServices.



586
587
588
589
590
591
592
593
594
595
596
597
598
 
# File 'lib/riser/services.rb', line 586

def initialize(druby_process_num=0)
  if (druby_process_num > 0) then
    @server = DRbServiceServer.new
    @call = DRbServiceCall.new
    druby_process_num.times do
      drb_uri = Riser::TemporaryPath.make_drbunix_uri
      @server.add_druby_process(drb_uri, UNIXFileMode: 0600)
      @call.add_druby_call(drb_uri)
    end
  else
    @server, @call = LocalServiceServerClient.make_pair
  end
end

Instance Method Details

#add_any_process_service(name, front) ⇒ Object 



600
601
602
603
604
 
# File 'lib/riser/services.rb', line 600

def add_any_process_service(name, front)
  @server.add_service(name, front)
  @call.add_any_process_service_with_type(name, front)
  nil
end

#add_single_process_service(name, front) ⇒ Object 



606
607
608
609
610
 
# File 'lib/riser/services.rb', line 606

def add_single_process_service(name, front)
  @server.add_service(name, front)
  @call.add_single_process_service_with_type(name, front)
  nil
end

#add_sticky_process_service(name, front) ⇒ Object 



612
613
614
615
616
 
# File 'lib/riser/services.rb', line 612

def add_sticky_process_service(name, front)
  @server.add_service(name, front)
  @call.add_sticky_process_service_with_type(name, front)
  nil
end