Class: DRbQS::ProcessDefinition

Inherits:
Object
  • Object
show all
Defined in:
lib/drbqs/execute/register.rb,
lib/drbqs/execute/process_define.rb

Defined Under Namespace

Classes: Register

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(server, node, port, io = nil) ⇒ ProcessDefinition

Returns a new instance of ProcessDefinition.



8
9
10
11
12
13
14
 
# File 'lib/drbqs/execute/process_define.rb', line 8

def initialize(server, node, port, io = nil)
  @server = server
  @node = node
  @port = port
  @register = DRbQS::ProcessDefinition::Register.new
  @io = io
end

Instance Attribute Details

#register ⇒ Object (readonly)

Returns the value of attribute register.



6
7
8
 
# File 'lib/drbqs/execute/process_define.rb', line 6

def register
  @register
end

Instance Method Details

#execute_node ⇒ Object 



186
187
188
189
190
191
 
# File 'lib/drbqs/execute/process_define.rb', line 186

def execute_node
  uri = server_uri(@server)
  each_node_to_execute do |name, data|
    execute_one_node(name, data, uri)
  end
end

#execute_server(server_args) ⇒ Object 



108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
 
# File 'lib/drbqs/execute/process_define.rb', line 108

def execute_server(server_args)
  if ary = get_server_setting(@server)
    name = ary[0].to_s
    data = ary[1]
    puts_progress "Execute server '#{name}' (#{data[:ssh] ? 'ssh' : 'local'})"
    setting = data[:setting]
    hostname = data[:args][0]
    type = data[:type]
    if data[:ssh]
      setting.value.connect name unless setting.set?(:connect)
      server_setting = setting.mode_setting
    else
      server_setting = setting
      server_setting.value.daemon FileName.create(local_log_directory, "server_execute.log", :position => :middle)
    end
    server_setting.set_server_argument(*server_args)
    server_setting.value.port server_port
    unless server_setting.set?(:sftp_host)
      server_setting.value.sftp_host hostname
    end
    setting.parse!
    unless data[:ssh]
      server_setting.value.argument.each do |path|
        unless File.exist?(path)
          raise "File '#{path}' does not exist."
        end
      end
    end
    setting.exec
  end
rescue Exception => err
  puts_progress "Fail to execute server '#{data[:name].to_s}'"
  mes = "Invalid server definition: #{err.to_s} (#{err.class.to_s})"
  begin
    mes = "#{setting.string_for_shell}; " << mes if setting.respond_to?(:string_for_shell)
  rescue
  end
  new_err = err.class.new(mes)
  new_err.set_backtrace(err.backtrace)
  raise new_err
end

#information ⇒ Object 



193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
 
# File 'lib/drbqs/execute/process_define.rb', line 193

def information
  info = {}
  info[:server] = @register.__server__.map do |name, data|
    new_data = data.dup
    new_data.delete(:setting)
    [name, new_data]
  end
  info[:node] = @register.__node__.map do |name, data|
    new_data = data.dup
    new_data.delete(:setting)
    [name, new_data]
  end
  if ary = get_server_setting(@server)
    default_server = ary[0]
  else
    default_server = nil
  end
  default_nodes = each_node_to_execute.map do |node_name, node_data|
    node_name
  end
  info[:default] = { :server => default_server, :node => default_nodes, :port => server_port }
  info
end

#information_string ⇒ Object 



217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
 
# File 'lib/drbqs/execute/process_define.rb', line 217

def information_string
  info = information
  str = "Server:\n"
  ary = (info[:server] + info[:node]).map do |name, data|
    name.size
  end
  string_name_size = ary.max
  info[:server].each do |name, data|
    prop = (data[:ssh] ? 'ssh' : 'local')
    prop << ',template' if data[:template]
    str << (data[:template] ? " - " : (info[:default][:server] == name ? " * " : "   "))
    str << sprintf("%- #{string_name_size}s  %s\n", name, prop)
  end
  str << "Node:\n"
  info[:node].each do |name, data|
    if data[:type] == :group
      prop = 'group: ' << data[:args].map(&:to_s).join(',')
    else
      prop = (data[:ssh] ? 'ssh' : 'local')
      if data[:template]
        prop << ',template'
      end
    end
    str << (data[:template] ? " - " : (info[:default][:node].include?(name) ? " * " : "   "))
    str << sprintf("%- #{string_name_size}s  %s\n", name, prop)
  end
  str << "Port: #{info[:default][:port]}"
end

#load(path) ⇒ Object 



27
28
29
 
# File 'lib/drbqs/execute/process_define.rb', line 27

def load(path)
  @register.__load__(path)
end

#local_log_directory ⇒ Object

Log directory for processes on localhost. Processes over ssh does not use this directory.



23
24
25
 
# File 'lib/drbqs/execute/process_define.rb', line 23

def local_log_directory
  @logal_log_directory ||= FileName.create(default_value(:log) || 'drbqs_execute_log')
end

#usage ⇒ Object 



246
247
248
249
250
251
252
253
254
255
256
257
258
259
 
# File 'lib/drbqs/execute/process_define.rb', line 246

def usage
  if data = @register.__usage__
    str = data[:message] ? "\nDescription:\n#{data[:message]}" : ""
    if (server_file = data[:server]) && File.exist?(server_file)
      Kernel.load(server_file)
      if server_help = DRbQS.option_help_message
        str << "\n\n" << server_help
      end
    end
    str
  else
    ''
  end
end