110 lines
2.9 KiB
C++
110 lines
2.9 KiB
C++
// This test is intended to create a situation in which one thread will exit
|
|
// while a breakpoint is being handled in another thread. This may not always
|
|
// happen because it's possible that the exiting thread will exit before the
|
|
// breakpoint is hit. The test case should be flexible enough to treat that
|
|
// as success.
|
|
|
|
#include "pseudo_barrier.h"
|
|
#include <chrono>
|
|
#include <thread>
|
|
|
|
volatile int g_test = 0;
|
|
|
|
// A barrier to synchronize all the threads except the one that will exit.
|
|
pseudo_barrier_t g_barrier1;
|
|
|
|
// A barrier to synchronize all the threads including the one that will exit.
|
|
pseudo_barrier_t g_barrier2;
|
|
|
|
// A barrier to keep the first group of threads from exiting until after the
|
|
// breakpoint has been passed.
|
|
pseudo_barrier_t g_barrier3;
|
|
|
|
void *
|
|
break_thread_func ()
|
|
{
|
|
// Wait until the entire first group of threads is running
|
|
pseudo_barrier_wait(g_barrier1);
|
|
|
|
// Wait for the exiting thread to start
|
|
pseudo_barrier_wait(g_barrier2);
|
|
|
|
// Do something
|
|
g_test++; // Set breakpoint here
|
|
|
|
// Synchronize after the breakpoint
|
|
pseudo_barrier_wait(g_barrier3);
|
|
|
|
// Return
|
|
return NULL;
|
|
}
|
|
|
|
void *
|
|
wait_thread_func ()
|
|
{
|
|
// Wait until the entire first group of threads is running
|
|
pseudo_barrier_wait(g_barrier1);
|
|
|
|
// Wait for the exiting thread to start
|
|
pseudo_barrier_wait(g_barrier2);
|
|
|
|
// Wait until the breakpoint has been passed
|
|
pseudo_barrier_wait(g_barrier3);
|
|
|
|
// Return
|
|
return NULL;
|
|
}
|
|
|
|
void *
|
|
exit_thread_func ()
|
|
{
|
|
// Sync up with the rest of the threads.
|
|
pseudo_barrier_wait(g_barrier2);
|
|
|
|
// Try to make sure this thread doesn't exit until the breakpoint is hit.
|
|
std::this_thread::sleep_for(std::chrono::microseconds(1));
|
|
|
|
// Return
|
|
return NULL;
|
|
}
|
|
|
|
int main ()
|
|
{
|
|
|
|
// The first barrier waits for the non-exiting threads to start.
|
|
// This thread will also participate in that barrier.
|
|
// The idea here is to guarantee that the exiting thread will be
|
|
// last in the internal list maintained by the debugger.
|
|
pseudo_barrier_init(g_barrier1, 5);
|
|
|
|
// The second break synchronizes thread execution with the breakpoint.
|
|
pseudo_barrier_init(g_barrier2, 5);
|
|
|
|
// The third barrier keeps the waiting threads around until the breakpoint
|
|
// has been passed.
|
|
pseudo_barrier_init(g_barrier3, 4);
|
|
|
|
// Create a thread to hit the breakpoint
|
|
std::thread thread_1(break_thread_func);
|
|
|
|
// Create more threads to slow the debugger down during processing.
|
|
std::thread thread_2(wait_thread_func);
|
|
std::thread thread_3(wait_thread_func);
|
|
std::thread thread_4(wait_thread_func);
|
|
|
|
// Wait for all these threads to get started.
|
|
pseudo_barrier_wait(g_barrier1);
|
|
|
|
// Create a thread to exit during the breakpoint
|
|
std::thread thread_5(exit_thread_func);
|
|
|
|
// Wait for the threads to finish
|
|
thread_5.join();
|
|
thread_4.join();
|
|
thread_3.join();
|
|
thread_2.join();
|
|
thread_1.join();
|
|
|
|
return 0;
|
|
}
|