Class: Nitra::Master
- Inherits:
-
Object
- Object
- Nitra::Master
- Defined in:
- lib/nitra/master.rb
Instance Attribute Summary collapse
-
#configuration ⇒ Object
readonly
Returns the value of attribute configuration.
-
#current_framework ⇒ Object
readonly
Returns the value of attribute current_framework.
-
#files ⇒ Object
readonly
Returns the value of attribute files.
-
#frameworks ⇒ Object
readonly
Returns the value of attribute frameworks.
Instance Method Summary collapse
-
#initialize(configuration, files = nil) ⇒ Master
constructor
A new instance of Master.
- #run ⇒ Object
Constructor Details
#initialize(configuration, files = nil) ⇒ Master
Returns a new instance of Master.
4 5 6 7 8 9 10 11 12 13 14 |
# File 'lib/nitra/master.rb', line 4 def initialize(configuration, files = nil) @configuration = configuration @frameworks = configuration.frameworks if @frameworks.any? load_files_from_framework_list else map_files_to_frameworks(files) end @current_framework = @frameworks.shift @configuration.framework = @current_framework end |
Instance Attribute Details
#configuration ⇒ Object (readonly)
Returns the value of attribute configuration.
2 3 4 |
# File 'lib/nitra/master.rb', line 2 def configuration @configuration end |
#current_framework ⇒ Object (readonly)
Returns the value of attribute current_framework.
2 3 4 |
# File 'lib/nitra/master.rb', line 2 def current_framework @current_framework end |
#files ⇒ Object (readonly)
Returns the value of attribute files.
2 3 4 |
# File 'lib/nitra/master.rb', line 2 def files @files end |
#frameworks ⇒ Object (readonly)
Returns the value of attribute frameworks.
2 3 4 |
# File 'lib/nitra/master.rb', line 2 def frameworks @frameworks end |
Instance Method Details
#run ⇒ Object
16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 |
# File 'lib/nitra/master.rb', line 16 def run return if files_remaining == 0 progress = Nitra::Progress.new progress.file_count = files_remaining formatter = Nitra::Formatter.new(progress, configuration) runners = [] if configuration.process_count > 0 client, runner = Nitra::Channel.pipe fork do runner.close Nitra::Runner.new(configuration, client, "A").run end client.close runners << runner end slave = Nitra::Slave::Client.new(configuration) runners += slave.connect formatter.start while runners.length > 0 Nitra::Channel.read_select(runners).each do |channel| if data = channel.read case data["command"] when "next" if files_remaining == 0 channel.write "command" => "drain" elsif data["framework"] == current_framework channel.write "command" => "file", "filename" => next_file else channel.write "command" => "framework", "framework" => current_framework end when "result" examples = data["example_count"] || 0 failures = data["failure_count"] || 0 failure = data["return_code"].to_i != 0 progress.file_progress(examples, failures, failure, data["text"]) formatter.print_progress when "error" progress.fail("ERROR " + data["process"] + " " + data["text"]) formatter.progress runners.delete channel when "debug" if configuration.debug puts "[DEBUG] #{data["text"]}" end when "stdout" if configuration.debug puts "STDOUT for #{data["process"]} #{data["filename"]}:\n#{data["text"]}" unless data["text"].empty? end end else runners.delete channel end end end debug "waiting for all children to exit..." Process.waitall formatter.finish !$aborted && progress.files_completed == progress.file_count && progress.failure_count.zero? && !progress.failure end |