diff options
author | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-13 12:15:43 +0000 |
---|---|---|
committer | Daniel Baumann <daniel.baumann@progress-linux.org> | 2024-04-13 12:15:43 +0000 |
commit | f5f56e1a1c4d9e9496fcb9d81131066a964ccd23 (patch) | |
tree | 49e44c6f87febed37efb953ab5485aa49f6481a7 /src/lib/testutils/threaded_test.h | |
parent | Initial commit. (diff) | |
download | isc-kea-f5f56e1a1c4d9e9496fcb9d81131066a964ccd23.tar.xz isc-kea-f5f56e1a1c4d9e9496fcb9d81131066a964ccd23.zip |
Adding upstream version 2.4.1.upstream/2.4.1upstream
Signed-off-by: Daniel Baumann <daniel.baumann@progress-linux.org>
Diffstat (limited to 'src/lib/testutils/threaded_test.h')
-rw-r--r-- | src/lib/testutils/threaded_test.h | 88 |
1 files changed, 88 insertions, 0 deletions
diff --git a/src/lib/testutils/threaded_test.h b/src/lib/testutils/threaded_test.h new file mode 100644 index 0000000..6f430e4 --- /dev/null +++ b/src/lib/testutils/threaded_test.h @@ -0,0 +1,88 @@ +// Copyright (C) 2018-2019,2021 Internet Systems Consortium, Inc. ("ISC") +// +// This Source Code Form is subject to the terms of the Mozilla Public +// License, v. 2.0. If a copy of the MPL was not distributed with this +// file, You can obtain one at http://mozilla.org/MPL/2.0/. + +#ifndef THREADED_TEST_H +#define THREADED_TEST_H + +#include <boost/shared_ptr.hpp> +#include <gtest/gtest.h> +#include <thread> +#include <mutex> +#include <condition_variable> + +namespace isc { +namespace test { + +/// @brief Base class for tests requiring threads. +/// +/// This class contains 3 flags to signal when the thread has +/// started, is stopping and when it is stopped. The flags +/// are accessed in thread safe manner. +class ThreadedTest : public ::testing::Test { +protected: + + /// @brief Constructor. + ThreadedTest(); + + /// @brief Sets selected flag to true and signals condition + /// variable. + /// + /// @param flag Reference to flag which should be set to true. + void doSignal(bool& flag); + + /// @brief Signal that thread is ready. + void signalReady(); + + /// @brief Signal that thread is stopping. + void signalStopping(); + + /// @brief Signal that thread is stopped. + void signalStopped(); + + /// @brief Wait for a selected flag to be set. + /// + /// @param flag Reference to a flag on which the thread is + /// waiting. + void doWait(bool& flag); + + /// @brief Wait for the thread to be ready. + void waitReady(); + + /// @brief Wait for the thread to be stopping. + void waitStopping(); + + /// @brief Wait for the thread to stop. + void waitStopped(); + + /// @brief Checks if the thread is stopping. + /// + /// @return true if the thread is stopping, false otherwise. + bool isStopping(); + + /// @brief Pointer to server thread. + boost::shared_ptr<std::thread> thread_; + + /// @brief Mutex used to synchronize threads. + std::mutex mutex_; + + /// Conditional variable for thread waits. + std::condition_variable condvar_; + + /// Flag indicating that the thread is ready. + bool ready_; + + /// Flag indicating that the thread is stopping. + bool stopping_; + + /// Flag indicating that the thread is stopped. + bool stopped_; +}; + + +} // end of namespace isc::test +} // end of namespace isc + +#endif |