ActiveSupport::Testing::Parallelization::Worker < Object

# File activesupport/lib/active_support/testing/parallelization/worker.rb, line 7
        def initialize(number, url)
          @id = SecureRandom.uuid
          @number = number
          @url = url
          @setup_exception = nil
        end

# File activesupport/lib/active_support/testing/parallelization/worker.rb, line 77
        def after_fork
          Parallelization.after_fork_hooks.each do |cb|
            cb.call(@number)
          end
        end

# File activesupport/lib/active_support/testing/parallelization/worker.rb, line 42
        def perform_job(job)
          klass    = job[0]
          method   = job[1]
          reporter = job[2]

          set_process_title("#{klass}##{method}")

          result = klass.with_info_handler reporter do
            Minitest.run_one_method(klass, method)
          end

          safe_record(reporter, result)
        end

# File activesupport/lib/active_support/testing/parallelization/worker.rb, line 83
        def run_cleanup
          Parallelization.run_cleanup_hooks.each do |cb|
            cb.call(@number)
          end
        end

# File activesupport/lib/active_support/testing/parallelization/worker.rb, line 56
        def safe_record(reporter, result)
          add_setup_exception(result) if @setup_exception

          begin
            @queue.record(reporter, result)
          rescue DRb::DRbConnError
            result.failures.map! do |failure|
              if failure.respond_to?(:error)
                # minitest >5.14.0
                error = DRb::DRbRemoteError.new(failure.error)
              else
                error = DRb::DRbRemoteError.new(failure.exception)
              end
              Minitest::UnexpectedError.new(error)
            end
            @queue.record(reporter, result)
          end

          set_process_title("(idle)")
        end

# File activesupport/lib/active_support/testing/parallelization/worker.rb, line 14
        def start
          fork do
            set_process_title("(starting)")

            DRb.stop_service

            @queue = DRbObject.new_with_uri(@url)
            @queue.start_worker(@id)

            begin
              after_fork
            rescue => @setup_exception; end

            work_from_queue
          ensure
            set_process_title("(stopping)")

            run_cleanup
            @queue.stop_worker(@id)
          end
        end

# File activesupport/lib/active_support/testing/parallelization/worker.rb, line 36
        def work_from_queue
          while job = @queue.pop
            perform_job(job)
          end
        end