Function TEST_F

bolt/expression/tests/ExprTest.cpp:423–455

This test shows resolverHook_ is not thread safe

#define INT64N std::optional<int64_t>()
// This test shows resolverHook_ is not thread safe
TEST_F(ExprTest, resolverHookNotThreadSafe) {
  std::vector<std::string> names{"resolverHookNotThreadSafeTest"};
  std::vector<std::shared_ptr<const Type>> types{BigintType::create()};
  auto rowTypePtr =
      std::make_shared<RowType>(std::move(names), std::move(types));
  std::atomic<int> flag{0};

  std::thread thread1([this]() {
    core::Expressions::setTypeResolverHook(&dummyIntegerResolver);
    auto resolver = core::Expressions::getResolverHook();
    EXPECT_TRUE(resolver({}, nullptr, false)
                    ->kindEquals(dummyIntegerResolver({}, nullptr, false)));
    std::this_thread::sleep_for(std::chrono::milliseconds(200));

    // resolverHook_ has been updated by thread2
    resolver = core::Expressions::getResolverHook();
    EXPECT_FALSE(resolver({}, nullptr, false)
                     ->kindEquals(dummyIntegerResolver({}, nullptr, false)));
    EXPECT_TRUE(resolver({}, nullptr, false)
                    ->kindEquals(dummyBigIntResolver({}, nullptr, false)));
  });

  std::thread thread2([this]() {
    std::this_thread::sleep_for(std::chrono::milliseconds(100));
    core::Expressions::setTypeResolverHook(&dummyBigIntResolver);
    auto resolver = core::Expressions::getResolverHook();
    EXPECT_TRUE(resolver({}, nullptr, false)
                    ->kindEquals(dummyBigIntResolver({}, nullptr, false)));
  });

  thread1.join();
  thread2.join();
}

TEST_F(ExprTest, customResolverHook) {
  auto expectedExpr =