Class: DRbQS::ServerDefinition

Inherits:
Object
  • Object
show all
Defined in:
lib/drbqs/server_define.rb

Constant Summary collapse

HELP_MESSAGE = 
<<HELP
[Server specific options]
  These options are separated by '--' from command options.

HELP

Instance Method Summary collapse

Constructor Details

#initialize ⇒ ServerDefinition

Returns a new instance of ServerDefinition.



10
11
12
13
14
15
16
 
# File 'lib/drbqs/server_define.rb', line 10

def initialize
  @server_create = nil
  @option_parse = nil
  @opts = {}
  @argv = nil
  @default_server_opts = nil
end

Instance Method Details

#define_server(default_opts = {}, &block) ⇒ Object 



18
19
20
21
22
23
24
 
# File 'lib/drbqs/server_define.rb', line 18

def define_server(default_opts = {}, &block)
  @default_server_opts = default_opts
  if @server_create
    raise ArgumentError, "The server has already defined."
  end
  @server_create = block
end

#option_parser(&block) ⇒ Object 



26
27
28
29
30
31
 
# File 'lib/drbqs/server_define.rb', line 26

def option_parser(&block)
  if @option_parse
    raise ArgumentError, "The options parser has already defined."
  end
  @option_parse = block
end

#parse_option(opt_argv) ⇒ Object 



33
34
35
36
37
38
39
40
41
 
# File 'lib/drbqs/server_define.rb', line 33

def parse_option(opt_argv)
  if @option_parse
    OptionParser.new(HELP_MESSAGE) do |opt|
      @option_parse.call(opt, @opts)
      opt.parse!(opt_argv)
    end
  end
  @argv = opt_argv  
end

#start_server(options) ⇒ Object 



51
52
53
54
55
56
57
58
 
# File 'lib/drbqs/server_define.rb', line 51

def start_server(options)
  unless @server_create
    raise "Can not get server definition."
  end
  server = create_server(options)
  server.start
  server.wait
end

#test_server(options, type, arg = [], test_opts = {}) ⇒ Object 



60
61
62
63
64
65
66
67
68
69
70
71
 
# File 'lib/drbqs/server_define.rb', line 60

def test_server(options, type, arg = [], test_opts = {})
  server = create_server(options)
  case type
  when :task
    puts "*** Test of Task Generators ***"
    server.test_task_generator(:limit => arg[0] ? arg[0].to_i : nil, :progress => true)
  when :exec
    server.test_exec(:limit => arg[0] ? arg[0].to_i : nil, :profile => test_opts[:profile])
  else
    puts "*** Not be yet implemented ***"
  end
end