aboutsummaryrefslogtreecommitdiffhomepage
path: root/test/test_deadlock.cpp
diff options
context:
space:
mode:
authorPaul Adenot <[email protected]>2023-11-10 14:14:22 +0100
committerPaul Adenot <[email protected]>2023-11-10 15:31:52 +0100
commit687b1e34468cc0cd265dd95564d306371e269bca (patch)
tree8d7d78eb372313b3beabc14450203cba54338277 /test/test_deadlock.cpp
parent8b4721e51eb36b66a1a80e858639d4dfb537945a (diff)
downloadcubeb-687b1e34468cc0cd265dd95564d306371e269bca.tar.gz
cubeb-687b1e34468cc0cd265dd95564d306371e269bca.zip
Non-functional change: clang-format tests
Diffstat (limited to 'test/test_deadlock.cpp')
-rw-r--r--test/test_deadlock.cpp87
1 files changed, 51 insertions, 36 deletions
diff --git a/test/test_deadlock.cpp b/test/test_deadlock.cpp
index 373ba6a..8684881 100644
--- a/test/test_deadlock.cpp
+++ b/test/test_deadlock.cpp
@@ -43,18 +43,18 @@
*/
#include "gtest/gtest.h"
-//#define ENABLE_NORMAL_LOG
-//#define ENABLE_VERBOSE_LOG
-#include "common.h" // for layout_infos
-#include "cubeb/cubeb.h" // for cubeb utils
-#include "cubeb_utils.h" // for owned_critical_section, auto_lock
-#include <iostream> // for fprintf
-#include <pthread.h> // for pthread
-#include <signal.h> // for signal
-#include <stdexcept> // for std::logic_error
-#include <string> // for std::string
-#include <unistd.h> // for sleep, usleep
-#include <atomic> // for std::atomic
+// #define ENABLE_NORMAL_LOG
+// #define ENABLE_VERBOSE_LOG
+#include "common.h" // for layout_infos
+#include "cubeb/cubeb.h" // for cubeb utils
+#include "cubeb_utils.h" // for owned_critical_section, auto_lock
+#include <atomic> // for std::atomic
+#include <iostream> // for fprintf
+#include <pthread.h> // for pthread
+#include <signal.h> // for signal
+#include <stdexcept> // for std::logic_error
+#include <string> // for std::string
+#include <unistd.h> // for sleep, usleep
// The signal alias for calling our thread killer.
#define CALL_THREAD_KILLER SIGUSR1
@@ -64,7 +64,7 @@
bool killed = false;
// This indicator will become true when the assigned task is done.
-std::atomic<bool> task_done{ false };
+std::atomic<bool> task_done{false};
// Indicating the data callback is fired or not.
bool called = false;
@@ -72,12 +72,13 @@ bool called = false;
// Toggle to true when running data callback. Before data callback gets
// the mutex for cubeb context, it toggles back to false.
// The task to get channel layout should be executed when this is true.
-std::atomic<bool> callbacking_before_getting_context{ false };
+std::atomic<bool> callbacking_before_getting_context{false};
owned_critical_section context_mutex;
cubeb * context = nullptr;
-cubeb * get_cubeb_context_unlocked()
+cubeb *
+get_cubeb_context_unlocked()
{
if (context) {
return context;
@@ -92,21 +93,25 @@ cubeb * get_cubeb_context_unlocked()
return context;
}
-cubeb * get_cubeb_context()
+cubeb *
+get_cubeb_context()
{
auto_lock lock(context_mutex);
return get_cubeb_context_unlocked();
}
-void state_cb_audio(cubeb_stream * /*stream*/, void * /*user*/, cubeb_state /*state*/)
+void
+state_cb_audio(cubeb_stream * /*stream*/, void * /*user*/,
+ cubeb_state /*state*/)
{
}
// Fired by coreaudio's rendering mechanism. It holds a mutex shared with the
// current used AudioUnit.
-template<typename T>
-long data_cb(cubeb_stream * /*stream*/, void * /*user*/,
- const void * /*inputbuffer*/, void * outputbuffer, long nframes)
+template <typename T>
+long
+data_cb(cubeb_stream * /*stream*/, void * /*user*/,
+ const void * /*inputbuffer*/, void * outputbuffer, long nframes)
{
called = true;
@@ -137,7 +142,8 @@ long data_cb(cubeb_stream * /*stream*/, void * /*user*/,
}
// Called by wait_to_get_layout, which is run out of main thread.
-void get_preferred_channel_layout()
+void
+get_preferred_channel_layout()
{
auto_lock lock(context_mutex);
cubeb * context = get_cubeb_context_unlocked();
@@ -151,12 +157,13 @@ void get_preferred_channel_layout()
fprintf(stderr, "layout is %s\n", layout_infos[layout].name);
}
-void * wait_to_get_layout(void *)
+void *
+wait_to_get_layout(void *)
{
uint64_t tid; // Current thread id.
pthread_threadid_np(NULL, &tid);
- while(!callbacking_before_getting_context) {
+ while (!callbacking_before_getting_context) {
fprintf(stderr, "[%llu] waiting for data callback ...\n", tid);
usleep(1000); // Force to switch threads by sleeping 1 ms.
}
@@ -168,17 +175,20 @@ void * wait_to_get_layout(void *)
return NULL;
}
-void * watchdog(void * s)
+void *
+watchdog(void * s)
{
uint64_t tid; // Current thread id.
pthread_threadid_np(NULL, &tid);
- pthread_t subject = *((pthread_t *) s);
+ pthread_t subject = *((pthread_t *)s);
uint64_t stid; // task thread id.
pthread_threadid_np(subject, &stid);
unsigned int sec = 2;
- fprintf(stderr, "[%llu] sleep %d seconds before checking task for thread %llu\n", tid, sec, stid);
+ fprintf(stderr,
+ "[%llu] sleep %d seconds before checking task for thread %llu\n", tid,
+ sec, stid);
sleep(sec); // Force to switch threads.
fprintf(stderr, "[%llu] check task for thread %llu now\n", tid, stid);
@@ -190,12 +200,14 @@ void * watchdog(void * s)
// so we need to unlock it manually.
context_mutex.unlock();
}
- fprintf(stderr, "[%llu] the assigned task for thread %llu is %sdone\n", tid, stid, (task_done) ? "" : "not ");
+ fprintf(stderr, "[%llu] the assigned task for thread %llu is %sdone\n", tid,
+ stid, (task_done) ? "" : "not ");
return NULL;
}
-void thread_killer(int signal)
+void
+thread_killer(int signal)
{
ASSERT_EQ(signal, CALL_THREAD_KILLER);
fprintf(stderr, "task thread is killed!\n");
@@ -211,8 +223,8 @@ TEST(cubeb, run_deadlock_test)
cubeb * ctx = get_cubeb_context();
ASSERT_TRUE(!!ctx);
- std::unique_ptr<cubeb, decltype(&cubeb_destroy)>
- cleanup_cubeb_at_exit(ctx, cubeb_destroy);
+ std::unique_ptr<cubeb, decltype(&cubeb_destroy)> cleanup_cubeb_at_exit(
+ ctx, cubeb_destroy);
cubeb_stream_params params;
params.format = CUBEB_SAMPLE_FLOAT32NE;
@@ -222,24 +234,26 @@ TEST(cubeb, run_deadlock_test)
params.prefs = CUBEB_STREAM_PREF_NONE;
cubeb_stream * stream = NULL;
- int r = cubeb_stream_init(ctx, &stream, "test deadlock", NULL, NULL, NULL,
- &params, 512, &data_cb<float>, state_cb_audio, NULL);
+ int r =
+ cubeb_stream_init(ctx, &stream, "test deadlock", NULL, NULL, NULL,
+ &params, 512, &data_cb<float>, state_cb_audio, NULL);
ASSERT_EQ(r, CUBEB_OK);
std::unique_ptr<cubeb_stream, decltype(&cubeb_stream_destroy)>
- cleanup_stream_at_exit(stream, cubeb_stream_destroy);
+ cleanup_stream_at_exit(stream, cubeb_stream_destroy);
// Install signal handler.
signal(CALL_THREAD_KILLER, thread_killer);
pthread_t subject, detector;
pthread_create(&subject, NULL, wait_to_get_layout, NULL);
- pthread_create(&detector, NULL, watchdog, (void *) &subject);
+ pthread_create(&detector, NULL, watchdog, (void *)&subject);
uint64_t stid, dtid;
pthread_threadid_np(subject, &stid);
pthread_threadid_np(detector, &dtid);
- fprintf(stderr, "task thread %llu, monitor thread %llu are created\n", stid, dtid);
+ fprintf(stderr, "task thread %llu, monitor thread %llu are created\n", stid,
+ dtid);
cubeb_stream_start(stream);
@@ -248,7 +262,8 @@ TEST(cubeb, run_deadlock_test)
ASSERT_TRUE(called);
- fprintf(stderr, "\n%sDeadlock detected!\n", (called && !task_done.load()) ? "" : "No ");
+ fprintf(stderr, "\n%sDeadlock detected!\n",
+ (called && !task_done.load()) ? "" : "No ");
// Check the task is killed by ourselves if deadlock happends.
// Otherwise, thread_killer should not be triggered.