summaryrefslogtreecommitdiff
path: root/src/third_party/wiredtiger/test/cppsuite/test_harness/thread_manager.h
diff options
context:
space:
mode:
Diffstat (limited to 'src/third_party/wiredtiger/test/cppsuite/test_harness/thread_manager.h')
-rw-r--r--src/third_party/wiredtiger/test/cppsuite/test_harness/thread_manager.h7
1 files changed, 4 insertions, 3 deletions
diff --git a/src/third_party/wiredtiger/test/cppsuite/test_harness/thread_manager.h b/src/third_party/wiredtiger/test/cppsuite/test_harness/thread_manager.h
index 749f5c1d8f3..b7f736c169d 100644
--- a/src/third_party/wiredtiger/test/cppsuite/test_harness/thread_manager.h
+++ b/src/third_party/wiredtiger/test/cppsuite/test_harness/thread_manager.h
@@ -31,7 +31,8 @@
#include <thread>
-#include "thread_context.h"
+#include "workload/database_operation.h"
+#include "workload/thread_context.h"
namespace test_harness {
/* Class that handles threads, from their initialization to their deletion. */
@@ -56,10 +57,10 @@ class thread_manager {
*/
template <typename Callable>
void
- add_thread(thread_context *tc, Callable &&fct)
+ add_thread(thread_context *tc, database_operation *db_operation, Callable &&fct)
{
tc->set_running(true);
- std::thread *t = new std::thread(fct, std::ref(*tc));
+ std::thread *t = new std::thread(fct, std::ref(*tc), std::ref(*db_operation));
_workers.push_back(t);
}