| // Copyright 2017 The Abseil Authors. |
| // |
| // 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 |
| // |
| // https://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 "absl/base/internal/sysinfo.h" |
| |
| #ifndef _WIN32 |
| #include <sys/types.h> |
| #include <unistd.h> |
| #endif |
| |
| #include <thread> // NOLINT(build/c++11) |
| #include <unordered_set> |
| #include <vector> |
| |
| #include "gtest/gtest.h" |
| #include "absl/synchronization/barrier.h" |
| #include "absl/synchronization/mutex.h" |
| |
| namespace absl { |
| ABSL_NAMESPACE_BEGIN |
| namespace base_internal { |
| namespace { |
| |
| TEST(SysinfoTest, NumCPUs) { |
| EXPECT_NE(NumCPUs(), 0) |
| << "NumCPUs() should not have the default value of 0"; |
| } |
| |
| // Ensure that NominalCPUFrequency returns a reasonable value, or 1.00 on |
| // platforms where the CPU frequency is not available through sysfs. |
| // |
| // POWER is particularly problematic here; some Linux kernels expose the CPU |
| // frequency, while others do not. Since we can't predict a priori what a given |
| // machine is going to do, just disable this test on POWER on Linux. |
| #if !(defined(__linux) && (defined(__ppc64__) || defined(__PPC64__))) |
| TEST(SysinfoTest, NominalCPUFrequency) { |
| // Linux only exposes the CPU frequency on certain architectures, and |
| // Emscripten doesn't expose it at all. |
| #if defined(__linux__) && \ |
| (defined(__aarch64__) || defined(__hppa__) || defined(__mips__) || \ |
| defined(__riscv) || defined(__s390x__)) || \ |
| defined(__EMSCRIPTEN__) |
| EXPECT_EQ(NominalCPUFrequency(), 1.0) |
| << "CPU frequency detection was fixed! Please update unittest."; |
| #else |
| EXPECT_GE(NominalCPUFrequency(), 1000.0) |
| << "NominalCPUFrequency() did not return a reasonable value"; |
| #endif |
| } |
| #endif |
| |
| TEST(SysinfoTest, GetTID) { |
| EXPECT_EQ(GetTID(), GetTID()); // Basic compile and equality test. |
| #ifdef __native_client__ |
| // Native Client has a race condition bug that leads to memory |
| // exaustion when repeatedly creating and joining threads. |
| // https://bugs.chromium.org/p/nativeclient/issues/detail?id=1027 |
| return; |
| #endif |
| // Test that TIDs are unique to each thread. |
| // Uses a few loops to exercise implementations that reallocate IDs. |
| for (int i = 0; i < 10; ++i) { |
| constexpr int kNumThreads = 10; |
| Barrier all_threads_done(kNumThreads); |
| std::vector<std::thread> threads; |
| |
| Mutex mutex; |
| std::unordered_set<pid_t> tids; |
| |
| for (int j = 0; j < kNumThreads; ++j) { |
| threads.push_back(std::thread([&]() { |
| pid_t id = GetTID(); |
| { |
| MutexLock lock(&mutex); |
| ASSERT_TRUE(tids.find(id) == tids.end()); |
| tids.insert(id); |
| } |
| // We can't simply join the threads here. The threads need to |
| // be alive otherwise the TID might have been reallocated to |
| // another live thread. |
| all_threads_done.Block(); |
| })); |
| } |
| for (auto& thread : threads) { |
| thread.join(); |
| } |
| } |
| } |
| |
| #ifdef __linux__ |
| TEST(SysinfoTest, LinuxGetTID) { |
| // On Linux, for the main thread, GetTID()==getpid() is guaranteed by the API. |
| EXPECT_EQ(GetTID(), getpid()); |
| } |
| #endif |
| |
| } // namespace |
| } // namespace base_internal |
| ABSL_NAMESPACE_END |
| } // namespace absl |