/*
    Copyright (c) 2019-2021 Intel Corporation

    Licensed under the Apache License, Version 2.0 (the "License");
    you may not use this file except in compliance with the License.
    You may obtain a copy of the License at

        http://www.apache.org/licenses/LICENSE-2.0

    Unless required by applicable law or agreed to in writing, software
    distributed under the License is distributed on an "AS IS" BASIS,
    WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
    See the License for the specific language governing permissions and
    limitations under the License.
*/

//! \file conformance_arena_constraints.cpp
//! \brief Test for [info_namespace scheduler.task_arena] specifications

#include "common/common_arena_constraints.h"

#if __TBB_HWLOC_VALID_ENVIRONMENT

//! Testing all NUMA aware arenas can successfully execute tasks
//! \brief \ref interface \ref requirement
TEST_CASE("NUMA aware arenas task execution test") {
    system_info::initialize();
    for(auto& numa_index: oneapi::tbb::info::numa_nodes()) {
        oneapi::tbb::task_arena arena(oneapi::tbb::task_arena::constraints{numa_index});

        std::atomic<bool> task_done{false};
        arena.execute([&]{ task_done = true; });
        REQUIRE_MESSAGE(task_done, "Execute was performed but task was not executed.");

        task_done = false;
        arena.enqueue([&]{ task_done = true; });
        while(!task_done) { utils::yield(); }
    }
}

//! Testing NUMA topology traversal correctness
//! \brief \ref interface \ref requirement
TEST_CASE("Test NUMA topology traversal correctness") {
    system_info::initialize();
    std::vector<index_info> numa_nodes_info = system_info::get_numa_nodes_info();

    std::vector<oneapi::tbb::numa_node_id> numa_indexes = oneapi::tbb::info::numa_nodes();
    for (const auto& numa_id: numa_indexes) {
        auto pos = std::find_if(numa_nodes_info.begin(), numa_nodes_info.end(),
            [&](const index_info& numa_info){ return numa_info.index == numa_id; }
        );

        REQUIRE_MESSAGE(pos != numa_nodes_info.end(), "Wrong, extra or repeated NUMA node index detected.");
        numa_nodes_info.erase(pos);
    }

    REQUIRE_MESSAGE(numa_nodes_info.empty(), "Some available NUMA nodes indexes were not detected.");
}

#else /*!__TBB_HWLOC_VALID_ENVIRONMENT*/

//! Testing NUMA support interfaces validity when HWLOC is not presented on system
//! \brief \ref interface \ref requirement
TEST_CASE("Test validity of NUMA interfaces when HWLOC is not present on the system") {
    std::vector<oneapi::tbb::numa_node_id> numa_indexes = oneapi::tbb::info::numa_nodes();

    REQUIRE_MESSAGE(numa_indexes.size() == 1,
        "Number of NUMA nodes must be pinned to 1, if we have no HWLOC on the system.");
    REQUIRE_MESSAGE(numa_indexes[0] == -1,
        "Index of NUMA node must be pinned to -1, if we have no HWLOC on the system.");
    REQUIRE_MESSAGE(oneapi::tbb::info::default_concurrency(numa_indexes[0]) == utils::get_platform_max_threads(),
        "Concurrency for NUMA node must be equal to default_num_threads(), if we have no HWLOC on the system.");
}

#endif /*__TBB_HWLOC_VALID_ENVIRONMENT*/