// Copyright 2022 Huawei Cloud Computing Technology Co., Ltd. // // 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. #include "src/buildtool/multithreading/async_map.hpp" #include #include "catch2/catch_test_macros.hpp" #include "src/buildtool/multithreading/task_system.hpp" TEST_CASE("Single-threaded: nodes only created once", "[async_map]") { AsyncMap map; auto* key_node = map.GetOrCreateNode("key"); CHECK(key_node != nullptr); auto* other_node = map.GetOrCreateNode("otherkey"); CHECK(other_node != nullptr); auto* should_be_key_node = map.GetOrCreateNode("key"); CHECK(should_be_key_node != nullptr); CHECK(key_node != other_node); CHECK(key_node == should_be_key_node); } TEST_CASE("Nodes only created once and survive the map destruction", "[async_map]") { using NodePtr = typename AsyncMap::NodePtr; NodePtr key_node{nullptr}; NodePtr other_node{nullptr}; NodePtr should_be_key_node{nullptr}; { AsyncMap map; { TaskSystem ts; ts.QueueTask([&key_node, &map]() { auto* node = map.GetOrCreateNode("key"); CHECK(node != nullptr); key_node = node; }); ts.QueueTask([&other_node, &map]() { auto* node = map.GetOrCreateNode("otherkey"); CHECK(node != nullptr); other_node = node; }); ts.QueueTask([&should_be_key_node, &map]() { auto* node = map.GetOrCreateNode("key"); CHECK(node != nullptr); should_be_key_node = node; }); } } CHECK(key_node != nullptr); CHECK(other_node != nullptr); CHECK(should_be_key_node != nullptr); CHECK(key_node != other_node); CHECK(key_node == should_be_key_node); }