aboutsummaryrefslogtreecommitdiffstats
path: root/storage
diff options
context:
space:
mode:
authorHåvard Pettersen <havardpe@yahooinc.com>2023-02-14 10:15:12 +0000
committerHåvard Pettersen <havardpe@yahooinc.com>2023-02-14 15:40:46 +0000
commit98e408c667e3dcda3dc177594ffa4c4d0d99a33e (patch)
tree8086fedd3c4c11ac51fa86f12f68cfe61095ee55 /storage
parent251bd6d0b21aa2ddac8ef82338f40d37ffc4990f (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.cpp4
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