Method: DRbQS::Server#initialize

Defined in:
lib/drbqs/server.rb

#initialize(opts = {}) ⇒ Server

:port

Set the port of server.

:acl

Set the ACL instance.

:log_file

Set the path of log files.

:log_level

Set the level of logging.

:check_alive

Set the time interval of checking alive nodes.

:finish_exit

Exit programs in finish_hook.

:signal_trap

Set trapping signal.

:scp_user

Set user of scp.

:scp_host

Set host of scp.

:file_directory

Set the setting of file directory.



56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
 
# File 'lib/drbqs/server.rb', line 56

def initialize(opts = {})
  @port = opts[:port] || ROOT_DEFAULT_PORT
  @acl = acl_init(opts[:acl])
  @ts = {
    :message => Rinda::TupleSpace.new,
    :queue => Rinda::TupleSpace.new,
    :result => Rinda::TupleSpace.new,
    :transfer => nil
  }
  @logger = DRbQS::Utils.create_logger(opts[:log_file], opts[:log_level])
  @message = MessageServer.new(@ts[:message], @logger)
  @queue= QueueServer.new(@ts[:queue], @ts[:result], @logger)
  @check_alive = CheckAlive.new(opts[:check_alive])
  @task_generator = []
  hook_init(opts[:finish_exit])
  set_signal_trap if opts[:signal_trap]
  @finalization_task = nil
  @transfer_setting = get_transfer_setting(opts[:scp_host], opts[:scp_user], opts[:file_directory])
end