summaryrefslogtreecommitdiff
path: root/src/mongo/executor/thread_pool_mock.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/executor/thread_pool_mock.cpp')
-rw-r--r--src/mongo/executor/thread_pool_mock.cpp11
1 files changed, 6 insertions, 5 deletions
diff --git a/src/mongo/executor/thread_pool_mock.cpp b/src/mongo/executor/thread_pool_mock.cpp
index fb809990e49..5f2255af995 100644
--- a/src/mongo/executor/thread_pool_mock.cpp
+++ b/src/mongo/executor/thread_pool_mock.cpp
@@ -34,6 +34,7 @@
#include "mongo/executor/thread_pool_mock.h"
#include "mongo/executor/network_interface_mock.h"
+#include "mongo/logv2/log.h"
#include "mongo/util/log.h"
namespace mongo {
@@ -52,7 +53,7 @@ ThreadPoolMock::~ThreadPoolMock() {
}
void ThreadPoolMock::startup() {
- LOG(1) << "Starting pool";
+ LOGV2_DEBUG(22602, 1, "Starting pool");
stdx::lock_guard<Latch> lk(_mutex);
invariant(!_started);
invariant(!_worker.joinable());
@@ -61,7 +62,7 @@ void ThreadPoolMock::startup() {
_options.onCreateThread();
stdx::unique_lock<Latch> lk(_mutex);
- LOG(1) << "Starting to consume tasks";
+ LOGV2_DEBUG(22603, 1, "Starting to consume tasks");
while (!_joining) {
if (_tasks.empty()) {
lk.unlock();
@@ -72,7 +73,7 @@ void ThreadPoolMock::startup() {
_consumeOneTask(lk);
}
- LOG(1) << "Done consuming tasks";
+ LOGV2_DEBUG(22604, 1, "Done consuming tasks");
});
}
@@ -115,14 +116,14 @@ void ThreadPoolMock::_consumeOneTask(stdx::unique_lock<Latch>& lk) {
}
void ThreadPoolMock::_shutdown(stdx::unique_lock<Latch>& lk) {
- LOG(1) << "Shutting down pool";
+ LOGV2_DEBUG(22605, 1, "Shutting down pool");
_inShutdown = true;
_net->signalWorkAvailable();
}
void ThreadPoolMock::_join(stdx::unique_lock<Latch>& lk) {
- LOG(1) << "Joining pool";
+ LOGV2_DEBUG(22606, 1, "Joining pool");
_joining = true;
_net->signalWorkAvailable();