diff options
author | Håvard Pettersen <havardpe@yahooinc.com> | 2023-02-22 09:18:36 +0000 |
---|---|---|
committer | Håvard Pettersen <havardpe@yahooinc.com> | 2023-02-22 10:43:14 +0000 |
commit | ed321ca9a3d53acf088cd88d19e6ccf107bd0e76 (patch) | |
tree | e65b39fe9a8ff9852c78219b43d275650b28ebaf /searchcore/src/tests/proton | |
parent | 6c4c2f2a432896ee5ae2f6f8320342627840dab8 (diff) |
stop using FastOS_ThreadId
Diffstat (limited to 'searchcore/src/tests/proton')
-rw-r--r-- | searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp b/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp index 0234d5fbedf..6f034161ac4 100644 --- a/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp +++ b/searchcore/src/tests/proton/documentdb/maintenancecontroller/maintenancecontroller_test.cpp @@ -82,9 +82,9 @@ namespace { VESPA_THREAD_STACK_TAG(my_executor_init); void -sampleThreadId(FastOS_ThreadId *threadId) +sampleThreadId(std::thread::id *threadId) { - *threadId = FastOS_Thread::GetCurrentThreadId(); + *threadId = std::this_thread::get_id(); } } // namespace @@ -207,12 +207,12 @@ class MyFeedHandler : public IDocumentMoveHandler, public IHeartBeatHandler, public IOperationStorer { - FastOS_ThreadId _executorThreadId; + std::thread::id _executorThreadId; std::vector<MyDocumentSubDB *> _subDBs; SerialNum _serialNum; std::atomic<uint32_t> _heartBeats; public: - explicit MyFeedHandler(FastOS_ThreadId &executorThreadId); + explicit MyFeedHandler(std::thread::id executorThreadId); ~MyFeedHandler() override; @@ -241,7 +241,7 @@ public: class MyExecutor : public vespalib::ThreadStackExecutorBase { public: - FastOS_ThreadId _threadId; + std::thread::id _threadId; MyExecutor(); bool acceptNewTask(unique_lock &, std::condition_variable &) override { @@ -604,7 +604,7 @@ MyDocumentSubDB::getNumUsedLids() const } -MyFeedHandler::MyFeedHandler(FastOS_ThreadId &executorThreadId) +MyFeedHandler::MyFeedHandler(std::thread::id executorThreadId) : IDocumentMoveHandler(), IPruneRemovedDocumentsHandler(), IHeartBeatHandler(), @@ -622,8 +622,7 @@ MyFeedHandler::~MyFeedHandler() = default; bool MyFeedHandler::isExecutorThread() const { - FastOS_ThreadId threadId(FastOS_Thread::GetCurrentThreadId()); - return FastOS_Thread::CompareThreadIds(_executorThreadId, threadId); + return (_executorThreadId == std::this_thread::get_id()); } |