summaryrefslogtreecommitdiff
path: root/src/mongo/db/periodic_runner_job_abort_expired_transactions.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/periodic_runner_job_abort_expired_transactions.cpp')
-rw-r--r--src/mongo/db/periodic_runner_job_abort_expired_transactions.cpp22
1 files changed, 13 insertions, 9 deletions
diff --git a/src/mongo/db/periodic_runner_job_abort_expired_transactions.cpp b/src/mongo/db/periodic_runner_job_abort_expired_transactions.cpp
index 12d931edc4c..975a225a7fd 100644
--- a/src/mongo/db/periodic_runner_job_abort_expired_transactions.cpp
+++ b/src/mongo/db/periodic_runner_job_abort_expired_transactions.cpp
@@ -38,6 +38,7 @@
#include "mongo/db/service_context.h"
#include "mongo/db/transaction_participant.h"
#include "mongo/db/transaction_participant_gen.h"
+#include "mongo/logv2/log.h"
#include "mongo/util/log.h"
#include "mongo/util/periodic_runner.h"
@@ -108,15 +109,18 @@ void PeriodicThreadToAbortExpiredTransactions::_init(ServiceContext* serviceCont
_anchor = std::make_shared<PeriodicJobAnchor>(periodicRunner->makeJob(std::move(job)));
- TransactionParticipant::observeTransactionLifetimeLimitSeconds.addObserver(
- [anchor = _anchor](const Argument& secs) {
- try {
- anchor->setPeriod(getPeriod(secs));
- } catch (const DBException& ex) {
- log() << "Failed to update period of thread which aborts expired transactions "
- << ex.toStatus();
- }
- });
+ TransactionParticipant::observeTransactionLifetimeLimitSeconds.addObserver([anchor = _anchor](
+ const Argument&
+ secs) {
+ try {
+ anchor->setPeriod(getPeriod(secs));
+ } catch (const DBException& ex) {
+ LOGV2(
+ 20892,
+ "Failed to update period of thread which aborts expired transactions {ex_toStatus}",
+ "ex_toStatus"_attr = ex.toStatus());
+ }
+ });
}
} // namespace mongo