Contents

module DeepTest
  class SimpleTestBlackboard
    attr_accessor :debug, :simulate_result_overdue_error

    def initialize
      @work_units = []
      @test_results = []
      @semaphore = Mutex.new
    end

    def take_result
      raise DeepTest::Server::ResultOverdueError if @simulate_result_overdue_error
      @semaphore.synchronize do
        log_and_return "take_result", @test_results.shift
      end
    end

    def take_work
      @semaphore.synchronize do
        log_and_return "take_work", @work_units.shift
      end
    end

    def write_result(result)
      @semaphore.synchronize do
        log_and_return "write_result", result
        @test_results.push result
      end
    end

    def write_work(work_unit)
      @semaphore.synchronize do
        log_and_return "write_work", work_unit
        @work_units.push work_unit
      end
    end

    def log_and_return(message, object)
      if debug && object
        puts "* #{message} #{object.inspect}"
      end
      object
    end
  end
end

Version data entries

24 entries across 24 versions & 4 rubygems

Version	Path
jstorimer-deep-test-1.0.0	test/simple_test_blackboard.rb
deep_test-1.2.1	test/simple_test_blackboard.rb
deep_test-1.2.2	test/simple_test_blackboard.rb
deep_test-1.2.0	test/simple_test_blackboard.rb