//===----------------------------------------------------------------------===//
//
// Part of the LLVM Project, under the Apache License v2.0 with LLVM Exceptions.
// See https://llvm.org/LICENSE.txt for license information.
// SPDX-License-Identifier: Apache-2.0 WITH LLVM-exception
//
//===----------------------------------------------------------------------===//
//
// UNSUPPORTED: no-threads
// UNSUPPORTED: c++03, c++11, c++14, c++17
// XFAIL: availability-synchronization_library-missing

// [[nodiscard]] bool stop_requested() const noexcept;
// true if *this has ownership of a stop state that has received a stop request; otherwise, false.

#include <cassert>
#include <chrono>
#include <concepts>
#include <optional>
#include <stop_token>
#include <type_traits>

#include "make_test_thread.h"
#include "test_macros.h"

template <class T>
concept IsStopRequestedNoexcept = requires(const T& t) {
  { t.stop_requested() } noexcept;
};

static_assert(IsStopRequestedNoexcept<std::stop_source>);

int main(int, char**) {
  // no state
  {
    const std::stop_source ss{std::nostopstate};
    assert(!ss.stop_requested());
  }

  // has state
  {
    std::stop_source ss;
    assert(!ss.stop_requested());

    ss.request_stop();
    assert(ss.stop_requested());
  }

  // request from another instance with same state
  {
    std::stop_source ss1;
    auto ss2 = ss1;
    ss2.request_stop();
    assert(ss1.stop_requested());
  }

  // request from another instance with different state
  {
    std::stop_source ss1;
    std::stop_source ss2;

    ss2.request_stop();
    assert(!ss1.stop_requested());
  }

  // multiple threads
  {
    std::stop_source ss;

    std::thread t = support::make_test_thread([&]() { ss.request_stop(); });

    t.join();
    assert(ss.stop_requested());
  }

  // [thread.stopsource.intro] A call to request_stop that returns true
  // synchronizes with a call to stop_requested on an associated stop_source
  // or stop_source object that returns true.
  {
    std::stop_source ss;

    bool flag = false;

    std::thread t = support::make_test_thread([&]() {
      using namespace std::chrono_literals;
      std::this_thread::sleep_for(1ms);

      // happens-before request_stop
      flag   = true;
      auto b = ss.request_stop();
      assert(b);
    });

    while (!ss.stop_requested()) {
      std::this_thread::yield();
    }

    // write should be visible to the current thread
    assert(flag == true);

    t.join();
  }

  return 0;
}