//
// any_completion_executor.cpp
// ~~~~~~~~~~~~~~~~~~~~~~~~~~~
//
// Copyright (c) 2003-2025 Christopher M. Kohlhoff (chris at kohlhoff dot com)
//
// Distributed under the Boost Software License, Version 1.0. (See accompanying
// file LICENSE_1_0.txt or copy at http://www.boost.org/LICENSE_1_0.txt)
//

// Disable autolinking for unit tests.
#if !defined(BOOST_ALL_NO_LIB)
#define BOOST_ALL_NO_LIB 1
#endif // !defined(BOOST_ALL_NO_LIB)

// Test that header file is self-contained.
#include <boost/asio/any_completion_executor.hpp>

#include <cstring>
#include <functional>
#include <boost/asio/system_executor.hpp>
#include <boost/asio/thread_pool.hpp>
#include "unit_test.hpp"

using namespace boost::asio;
namespace bindns = std;

static bool next_nothrow_new_fails = false;

void* operator new(std::size_t n,
    const std::nothrow_t&) noexcept
{
  if (next_nothrow_new_fails)
  {
    next_nothrow_new_fails = false;
    return 0;
  }
  return ::operator new(n);
}

struct fat_executor
{
  fat_executor(int id)
    : id_(id)
  {
    std::memset(data_, 0, sizeof(data_));
  }

  template <typename F>
  void execute(const F&) const
  {
  }

  friend bool operator==(const fat_executor& a,
      const fat_executor& b) noexcept
  {
    return a.id_ == b.id_;
  }

  friend bool operator!=(const fat_executor& a,
      const fat_executor& b) noexcept
  {
    return a.id_ != b.id_;
  }

  int id_;
  unsigned char data_[1024];
};

namespace boost {
namespace asio {
namespace traits {

#if !defined(BOOST_ASIO_HAS_DEDUCED_EXECUTE_MEMBER_TRAIT)

template <typename F>
struct execute_member<fat_executor, F>
{
  static constexpr bool is_valid = true;
  static constexpr bool is_noexcept = false;
  typedef void result_type;
};

#endif // !defined(BOOST_ASIO_HAS_DEDUCED_EXECUTE_MEMBER_TRAIT)

#if !defined(BOOST_ASIO_HAS_DEDUCED_EQUALITY_COMPARABLE_TRAIT)

template <>
struct equality_comparable<fat_executor>
{
  static constexpr bool is_valid = true;
  static constexpr bool is_noexcept = true;
};

#endif // !defined(BOOST_ASIO_HAS_DEDUCED_EQUALITY_COMPARABLE_TRAIT)

} // namespace traits
} // namespace asio
} // namespace boost

void increment(int* count)
{
  ++(*count);
}

void any_completion_executor_construction_test()
{
  thread_pool pool(1);
  boost::asio::nullptr_t null_ptr = boost::asio::nullptr_t();

  boost::asio::any_completion_executor ex1;

  BOOST_ASIO_CHECK(ex1.target<void>() == 0);
  BOOST_ASIO_CHECK(ex1 == null_ptr);

  boost::asio::any_completion_executor ex2(null_ptr);

  BOOST_ASIO_CHECK(ex2.target<void>() == 0);
  BOOST_ASIO_CHECK(ex2 == null_ptr);
  BOOST_ASIO_CHECK(ex2 == ex1);

  boost::asio::any_completion_executor ex3(pool.executor());

  BOOST_ASIO_CHECK(ex3.target<void>() != 0);
  BOOST_ASIO_CHECK(ex3 != null_ptr);
  BOOST_ASIO_CHECK(ex3 != ex1);

  boost::asio::any_completion_executor ex4(ex1);

  BOOST_ASIO_CHECK(ex4.target<void>() == 0);
  BOOST_ASIO_CHECK(ex4 == null_ptr);
  BOOST_ASIO_CHECK(ex4 == ex1);

  boost::asio::any_completion_executor ex5(ex3);

  BOOST_ASIO_CHECK(ex5.target<void>() != 0);
  BOOST_ASIO_CHECK(ex5 != null_ptr);
  BOOST_ASIO_CHECK(ex5 == ex3);

  boost::asio::any_completion_executor ex6 = fat_executor(1);

  BOOST_ASIO_CHECK(ex6.target<void>() != 0);
  BOOST_ASIO_CHECK(ex6 != null_ptr);
  BOOST_ASIO_CHECK(ex6 != ex1);

  boost::asio::any_completion_executor ex7 = fat_executor(1);

  BOOST_ASIO_CHECK(ex7.target<void>() != 0);
  BOOST_ASIO_CHECK(ex7 != null_ptr);
  BOOST_ASIO_CHECK(ex7 != ex1);
  BOOST_ASIO_CHECK(ex7 == ex6);

  boost::asio::any_completion_executor ex8 = fat_executor(2);

  BOOST_ASIO_CHECK(ex8.target<void>() != 0);
  BOOST_ASIO_CHECK(ex8 != null_ptr);
  BOOST_ASIO_CHECK(ex8 != ex1);
  BOOST_ASIO_CHECK(ex8 != ex6);
  BOOST_ASIO_CHECK(ex8 != ex7);

  boost::asio::any_completion_executor ex9(ex6);

  BOOST_ASIO_CHECK(ex9.target<void>() != 0);
  BOOST_ASIO_CHECK(ex9 != null_ptr);
  BOOST_ASIO_CHECK(ex9 != ex1);
  BOOST_ASIO_CHECK(ex9 == ex6);
  BOOST_ASIO_CHECK(ex9 == ex7);
  BOOST_ASIO_CHECK(ex9 != ex8);

  boost::asio::any_completion_executor ex10(std::move(ex1));

  BOOST_ASIO_CHECK(ex10.target<void>() == 0);
  BOOST_ASIO_CHECK(ex10 == null_ptr);
  BOOST_ASIO_CHECK(ex1.target<void>() == 0);
  BOOST_ASIO_CHECK(ex1 == null_ptr);

  boost::asio::any_completion_executor ex11(std::move(ex3));

  BOOST_ASIO_CHECK(ex11.target<void>() != 0);
  BOOST_ASIO_CHECK(ex11 != null_ptr);
  BOOST_ASIO_CHECK(ex3.target<void>() == 0);
  BOOST_ASIO_CHECK(ex3 == null_ptr);
  BOOST_ASIO_CHECK(ex11 == ex5);

  boost::asio::any_completion_executor ex12(std::move(ex7));

  BOOST_ASIO_CHECK(ex12.target<void>() != 0);
  BOOST_ASIO_CHECK(ex12 != null_ptr);
  BOOST_ASIO_CHECK(ex7.target<void>() == 0);
  BOOST_ASIO_CHECK(ex7 == null_ptr);
  BOOST_ASIO_CHECK(ex12 == ex6);
  BOOST_ASIO_CHECK(ex12 != ex8);
}

void any_completion_executor_nothrow_construction_test()
{
  thread_pool pool(1);
  boost::asio::nullptr_t null_ptr = boost::asio::nullptr_t();

  boost::asio::any_completion_executor ex1;

  BOOST_ASIO_CHECK(ex1.target<void>() == 0);
  BOOST_ASIO_CHECK(ex1 == null_ptr);

  boost::asio::any_completion_executor ex2(null_ptr);

  BOOST_ASIO_CHECK(ex2.target<void>() == 0);
  BOOST_ASIO_CHECK(ex2 == null_ptr);
  BOOST_ASIO_CHECK(ex2 == ex1);

  boost::asio::any_completion_executor ex3(std::nothrow, pool.executor());

  BOOST_ASIO_CHECK(ex3.target<void>() != 0);
  BOOST_ASIO_CHECK(ex3 != null_ptr);
  BOOST_ASIO_CHECK(ex3 != ex1);

  boost::asio::any_completion_executor ex4(std::nothrow, ex1);

  BOOST_ASIO_CHECK(ex4.target<void>() == 0);
  BOOST_ASIO_CHECK(ex4 == null_ptr);
  BOOST_ASIO_CHECK(ex4 == ex1);

  boost::asio::any_completion_executor ex5(std::nothrow, ex3);

  BOOST_ASIO_CHECK(ex5.target<void>() != 0);
  BOOST_ASIO_CHECK(ex5 != null_ptr);
  BOOST_ASIO_CHECK(ex5 == ex3);

  boost::asio::any_completion_executor ex6(std::nothrow, fat_executor(1));

  BOOST_ASIO_CHECK(ex6.target<void>() != 0);
  BOOST_ASIO_CHECK(ex6 != null_ptr);
  BOOST_ASIO_CHECK(ex6 != ex1);

  boost::asio::any_completion_executor ex7(std::nothrow, fat_executor(1));

  BOOST_ASIO_CHECK(ex7.target<void>() != 0);
  BOOST_ASIO_CHECK(ex7 != null_ptr);
  BOOST_ASIO_CHECK(ex7 != ex1);
  BOOST_ASIO_CHECK(ex7 == ex6);

  boost::asio::any_completion_executor ex8(std::nothrow, fat_executor(2));

  BOOST_ASIO_CHECK(ex8.target<void>() != 0);
  BOOST_ASIO_CHECK(ex8 != null_ptr);
  BOOST_ASIO_CHECK(ex8 != ex1);
  BOOST_ASIO_CHECK(ex8 != ex6);
  BOOST_ASIO_CHECK(ex8 != ex7);

  boost::asio::any_completion_executor ex9(std::nothrow, ex6);

  BOOST_ASIO_CHECK(ex9.target<void>() != 0);
  BOOST_ASIO_CHECK(ex9 != null_ptr);
  BOOST_ASIO_CHECK(ex9 != ex1);
  BOOST_ASIO_CHECK(ex9 == ex6);
  BOOST_ASIO_CHECK(ex9 == ex7);
  BOOST_ASIO_CHECK(ex9 != ex8);

  boost::asio::any_completion_executor ex10(std::nothrow, std::move(ex1));

  BOOST_ASIO_CHECK(ex10.target<void>() == 0);
  BOOST_ASIO_CHECK(ex10 == null_ptr);
  BOOST_ASIO_CHECK(ex1.target<void>() == 0);
  BOOST_ASIO_CHECK(ex1 == null_ptr);

  boost::asio::any_completion_executor ex11(std::nothrow, std::move(ex3));

  BOOST_ASIO_CHECK(ex11.target<void>() != 0);
  BOOST_ASIO_CHECK(ex11 != null_ptr);
  BOOST_ASIO_CHECK(ex3.target<void>() == 0);
  BOOST_ASIO_CHECK(ex3 == null_ptr);
  BOOST_ASIO_CHECK(ex11 == ex5);

  boost::asio::any_completion_executor ex12(std::nothrow, std::move(ex7));

  BOOST_ASIO_CHECK(ex12.target<void>() != 0);
  BOOST_ASIO_CHECK(ex12 != null_ptr);
  BOOST_ASIO_CHECK(ex7.target<void>() == 0);
  BOOST_ASIO_CHECK(ex7 == null_ptr);
  BOOST_ASIO_CHECK(ex12 == ex6);
  BOOST_ASIO_CHECK(ex12 != ex8);

  next_nothrow_new_fails = true;
  boost::asio::any_completion_executor ex13(std::nothrow, fat_executor(3));

  BOOST_ASIO_CHECK(ex13.target<void>() == 0);
  BOOST_ASIO_CHECK(ex13 == null_ptr);
  BOOST_ASIO_CHECK(ex13 == ex1);
}

void any_completion_executor_assignment_test()
{
  thread_pool pool(1);
  boost::asio::nullptr_t null_ptr = boost::asio::nullptr_t();

  boost::asio::any_completion_executor ex1;

  boost::asio::any_completion_executor ex2;
  ex2 = null_ptr;

  BOOST_ASIO_CHECK(ex2.target<void>() == 0);

  boost::asio::any_completion_executor ex3;
  ex3 = pool.executor();

  BOOST_ASIO_CHECK(ex3.target<void>() != 0);

  boost::asio::any_completion_executor ex4;
  ex4 = ex1;

  BOOST_ASIO_CHECK(ex4.target<void>() == 0);
  BOOST_ASIO_CHECK(ex4 == ex1);

  ex4 = ex3;

  BOOST_ASIO_CHECK(ex4.target<void>() != 0);
  BOOST_ASIO_CHECK(ex4 == ex3);

  boost::asio::any_completion_executor ex5;
  ex5 = fat_executor(1);

  BOOST_ASIO_CHECK(ex5.target<void>() != 0);
  BOOST_ASIO_CHECK(ex5 != null_ptr);
  BOOST_ASIO_CHECK(ex5 != ex1);

  boost::asio::any_completion_executor ex6;
  ex6 = fat_executor(1);

  BOOST_ASIO_CHECK(ex6.target<void>() != 0);
  BOOST_ASIO_CHECK(ex6 != null_ptr);
  BOOST_ASIO_CHECK(ex6 != ex1);
  BOOST_ASIO_CHECK(ex6 == ex5);

  ex6 = fat_executor(2);

  BOOST_ASIO_CHECK(ex6.target<void>() != 0);
  BOOST_ASIO_CHECK(ex6 != null_ptr);
  BOOST_ASIO_CHECK(ex6 != ex1);
  BOOST_ASIO_CHECK(ex6 != ex5);

  boost::asio::any_completion_executor ex7;
  ex7 = ex5;

  BOOST_ASIO_CHECK(ex7.target<void>() != 0);
  BOOST_ASIO_CHECK(ex7 != null_ptr);
  BOOST_ASIO_CHECK(ex7 != ex1);
  BOOST_ASIO_CHECK(ex7 == ex5);
  BOOST_ASIO_CHECK(ex7 != ex6);

  boost::asio::any_completion_executor ex8;
  ex8 = std::move(ex1);

  BOOST_ASIO_CHECK(ex8.target<void>() == 0);
  BOOST_ASIO_CHECK(ex1.target<void>() == 0);

  ex8 = std::move(ex3);

  BOOST_ASIO_CHECK(ex8.target<void>() != 0);
  BOOST_ASIO_CHECK(ex3.target<void>() == 0);
  BOOST_ASIO_CHECK(ex8 == ex4);

  ex8 = std::move(ex5);

  BOOST_ASIO_CHECK(ex8.target<void>() != 0);
  BOOST_ASIO_CHECK(ex5.target<void>() == 0);
  BOOST_ASIO_CHECK(ex8 == ex7);
}

void any_completion_executor_swap_test()
{
  thread_pool pool1(1);
  thread_pool pool2(1);

  boost::asio::any_completion_executor ex1(pool1.executor());
  boost::asio::any_completion_executor ex2(pool2.executor());

  boost::asio::any_completion_executor ex3(ex1);
  boost::asio::any_completion_executor ex4(ex2);

  BOOST_ASIO_CHECK(ex3 == ex1);
  BOOST_ASIO_CHECK(ex4 == ex2);

  ex3.swap(ex4);

  BOOST_ASIO_CHECK(ex3 == ex2);
  BOOST_ASIO_CHECK(ex4 == ex1);

  execution::swap(ex3, ex4);

  BOOST_ASIO_CHECK(ex3 == ex1);
  BOOST_ASIO_CHECK(ex4 == ex2);
}

void any_completion_executor_query_test()
{
  thread_pool pool(1);
  boost::asio::any_completion_executor ex(pool.executor());

  BOOST_ASIO_CHECK(
      boost::asio::query(ex, boost::asio::execution::blocking)
        == boost::asio::execution::blocking.possibly);

  BOOST_ASIO_CHECK(
      boost::asio::query(ex, boost::asio::execution::blocking.possibly)
        == boost::asio::execution::blocking.possibly);

  BOOST_ASIO_CHECK(
      boost::asio::query(ex, boost::asio::execution::outstanding_work)
        == boost::asio::execution::outstanding_work.untracked);

  BOOST_ASIO_CHECK(
      boost::asio::query(ex, boost::asio::execution::outstanding_work.untracked)
        == boost::asio::execution::outstanding_work.untracked);

  BOOST_ASIO_CHECK(
      boost::asio::query(ex, boost::asio::execution::relationship)
        == boost::asio::execution::relationship.fork);

  BOOST_ASIO_CHECK(
      boost::asio::query(ex, boost::asio::execution::relationship.fork)
        == boost::asio::execution::relationship.fork);
}

void any_completion_executor_execute_test()
{
  int count = 0;
  thread_pool pool(1);
  boost::asio::any_completion_executor ex(pool.executor());

  ex.execute(bindns::bind(increment, &count));

  boost::asio::prefer(ex, boost::asio::execution::blocking.possibly).execute(
      bindns::bind(increment, &count));

  boost::asio::prefer(ex,
      boost::asio::execution::blocking.possibly,
      boost::asio::execution::outstanding_work.tracked
    ).execute(bindns::bind(increment, &count));

  boost::asio::prefer(ex,
      boost::asio::execution::blocking.possibly,
      boost::asio::execution::outstanding_work.untracked
    ).execute(bindns::bind(increment, &count));

  boost::asio::prefer(ex,
      boost::asio::execution::blocking.possibly,
      boost::asio::execution::outstanding_work.untracked,
      boost::asio::execution::relationship.continuation
    ).execute(bindns::bind(increment, &count));

  pool.wait();

  BOOST_ASIO_CHECK(count == 5);
}

BOOST_ASIO_TEST_SUITE
(
  "any_completion_executor",
  BOOST_ASIO_TEST_CASE(any_completion_executor_construction_test)
  BOOST_ASIO_TEST_CASE(any_completion_executor_nothrow_construction_test)
  BOOST_ASIO_TEST_CASE(any_completion_executor_assignment_test)
  BOOST_ASIO_TEST_CASE(any_completion_executor_swap_test)
  BOOST_ASIO_TEST_CASE(any_completion_executor_query_test)
  BOOST_ASIO_TEST_CASE(any_completion_executor_execute_test)
)