Sha256: ffc6c5bc33e7cb2ce4c2affb701378c1c32c5f63a819fee310eb2b37a64136ae

Contents?: true

Size: 1.39 KB

Versions: 2

Compression:

Stored size: 1.39 KB

Contents

require 'parallel'
require 'parallel_tests/version'
require 'parallel_tests/grouper'
require 'parallel_tests/railtie' if defined? Rails::Railtie

module ParallelTests
  GREP_PROCESSES_COMMAND = "ps -ef | grep [T]EST_ENV_NUMBER= 2>&1"

  def self.determine_number_of_processes(count)
    [
      count,
      ENV['PARALLEL_TEST_PROCESSORS'],
      Parallel.processor_count
    ].detect{|c| not c.to_s.strip.empty? }.to_i
  end

  # copied from http://github.com/carlhuda/bundler Bundler::SharedHelpers#find_gemfile
  def self.bundler_enabled?
    return true if Object.const_defined?(:Bundler)

    previous = nil
    current = File.expand_path(Dir.pwd)

    until !File.directory?(current) || current == previous
      filename = File.join(current, "Gemfile")
      return true if File.exists?(filename)
      current, previous = File.expand_path("..", current), current
    end

    false
  end

  def self.first_process?
    !ENV["TEST_ENV_NUMBER"] || ENV["TEST_ENV_NUMBER"].to_i == 0
  end

  def self.wait_for_other_processes_to_finish
    return unless ENV["TEST_ENV_NUMBER"]
    sleep 1 until number_of_running_processes <= 1
  end

  # Fun fact: this includes the current process if it's run via parallel_tests
  def self.number_of_running_processes
    result = `#{GREP_PROCESSES_COMMAND}`
    raise "Could not grep for processes -> #{result}" if result.strip != "" && !$?.success?
    result.split("\n").size
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version Path
parallel_tests-0.9.4 lib/parallel_tests.rb
parallel_tests-0.9.3 lib/parallel_tests.rb