# frozen_string_literal: true
# rubocop:todo all

require 'lite_spec_helper'

describe Mongo::ConditionVariable do
  let(:lock) { Mutex.new }
  let(:condition_variable) do
    described_class.new(lock)
  end

  it 'waits until signaled' do
    result = nil

    consumer = Thread.new do
      lock.synchronize do
        result = condition_variable.wait(3)
      end
    end

    # Context switch to start the thread
    sleep 0.1

    start_time = Mongo::Utils.monotonic_time
    lock.synchronize do
      condition_variable.signal
    end
    consumer.join

    (Mongo::Utils.monotonic_time - start_time).should < 1
  end

  it 'waits until broadcast' do
    result = nil

    consumer = Thread.new do
      lock.synchronize do
        result = condition_variable.wait(3)
      end
    end

    # Context switch to start the thread
    sleep 0.1

    start_time = Mongo::Utils.monotonic_time
    lock.synchronize do
      condition_variable.broadcast
    end
    consumer.join

    (Mongo::Utils.monotonic_time - start_time).should < 1
  end

  it 'times out' do
    result = nil

    consumer = Thread.new do
      lock.synchronize do
        result = condition_variable.wait(2)
      end
    end

    # Context switch to start the thread
    sleep 0.1

    start_time = Mongo::Utils.monotonic_time
    consumer.join

    (Mongo::Utils.monotonic_time - start_time).should > 1
  end

  context "when acquiring the lock and waiting" do

    it "releases the lock while waiting" do

      lock_acquired = false
      Timeout::timeout(1) do
        thread = Thread.new do
          until lock_acquired
            sleep 0.1
          end
          lock.synchronize do
            condition_variable.signal
          end
        end
        lock.synchronize do
          lock_acquired = true
          condition_variable.wait(10)
        end
      end
    end
  end

  context "when waiting but not signaling" do
    it "waits until timeout" do
      lock.synchronize do
        start = Mongo::Utils.monotonic_time
        condition_variable.wait(1)
        duration = Mongo::Utils.monotonic_time - start
        expect(duration).to be > 1
      end
    end
  end
end