diff options
author | Håvard Pettersen <havardpe@yahooinc.com> | 2023-02-14 10:15:12 +0000 |
---|---|---|
committer | Håvard Pettersen <havardpe@yahooinc.com> | 2023-02-14 15:40:46 +0000 |
commit | 98e408c667e3dcda3dc177594ffa4c4d0d99a33e (patch) | |
tree | 8086fedd3c4c11ac51fa86f12f68cfe61095ee55 /storage | |
parent | 251bd6d0b21aa2ddac8ef82338f40d37ffc4990f (diff) |
stop using fastos thread more places
- also stop using std::jthread
- remove Active and Joinable interfaces
- remove stop, stopped and slumber
- remove currentThread
- make start function static
- override start for Runnable w/init or custom function
- explicit stop/slumber where needed
Diffstat (limited to 'storage')
-rw-r--r-- | storage/src/tests/persistence/filestorage/operationabortingtest.cpp | 4 |
1 files changed, 1 insertions, 3 deletions
diff --git a/storage/src/tests/persistence/filestorage/operationabortingtest.cpp b/storage/src/tests/persistence/filestorage/operationabortingtest.cpp index 000e1e1c155..d7ecb1f30f1 100644 --- a/storage/src/tests/persistence/filestorage/operationabortingtest.cpp +++ b/storage/src/tests/persistence/filestorage/operationabortingtest.cpp @@ -296,8 +296,7 @@ TEST_F(OperationAbortingTest, wait_for_current_operation_completion_for_aborted_ auto abortCmd = makeAbortCmd(abortSet); SendTask sendTask(abortCmd, *_queueBarrier, c.top); - vespalib::Thread thread(sendTask, test_thread); - thread.start(); + auto thread = vespalib::Thread::start(sendTask, test_thread); LOG(debug, "waiting for threads to reach barriers"); _queueBarrier->await(); @@ -306,7 +305,6 @@ TEST_F(OperationAbortingTest, wait_for_current_operation_completion_for_aborted_ LOG(debug, "waiting on completion barrier"); _completionBarrier->await(); - thread.stop(); thread.join(); // If waiting works, put reply shall always be ordered before the internal |