summaryrefslogtreecommitdiff
path: root/src/mongo/db/pipeline/process_interface/common_mongod_process_interface.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/pipeline/process_interface/common_mongod_process_interface.cpp')
-rw-r--r--src/mongo/db/pipeline/process_interface/common_mongod_process_interface.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/pipeline/process_interface/common_mongod_process_interface.cpp b/src/mongo/db/pipeline/process_interface/common_mongod_process_interface.cpp
index d90d2049c7b..576f6015eba 100644
--- a/src/mongo/db/pipeline/process_interface/common_mongod_process_interface.cpp
+++ b/src/mongo/db/pipeline/process_interface/common_mongod_process_interface.cpp
@@ -836,7 +836,7 @@ void CommonMongodProcessInterface::writeRecordsToRecordStore(
const std::vector<Timestamp>& ts) const {
tassert(5643012, "Attempted to write to record store with nullptr", records);
assertIgnorePrepareConflictsBehavior(expCtx);
- writeConflictRetry(expCtx->opCtx, "MPI::writeRecordsToRecordStore", expCtx->ns.ns(), [&] {
+ writeConflictRetry(expCtx->opCtx, "MPI::writeRecordsToRecordStore", expCtx->ns, [&] {
Lock::GlobalLock lk(expCtx->opCtx, MODE_IS);
WriteUnitOfWork wuow(expCtx->opCtx);
auto writeResult = rs->insertRecords(expCtx->opCtx, records, ts);
@@ -866,7 +866,7 @@ Document CommonMongodProcessInterface::readRecordFromRecordStore(
void CommonMongodProcessInterface::deleteRecordFromRecordStore(
const boost::intrusive_ptr<ExpressionContext>& expCtx, RecordStore* rs, RecordId rID) const {
assertIgnorePrepareConflictsBehavior(expCtx);
- writeConflictRetry(expCtx->opCtx, "MPI::deleteFromRecordStore", expCtx->ns.ns(), [&] {
+ writeConflictRetry(expCtx->opCtx, "MPI::deleteFromRecordStore", expCtx->ns, [&] {
Lock::GlobalLock lk(expCtx->opCtx, MODE_IS);
WriteUnitOfWork wuow(expCtx->opCtx);
rs->deleteRecord(expCtx->opCtx, rID);
@@ -877,7 +877,7 @@ void CommonMongodProcessInterface::deleteRecordFromRecordStore(
void CommonMongodProcessInterface::truncateRecordStore(
const boost::intrusive_ptr<ExpressionContext>& expCtx, RecordStore* rs) const {
assertIgnorePrepareConflictsBehavior(expCtx);
- writeConflictRetry(expCtx->opCtx, "MPI::truncateRecordStore", expCtx->ns.ns(), [&] {
+ writeConflictRetry(expCtx->opCtx, "MPI::truncateRecordStore", expCtx->ns, [&] {
Lock::GlobalLock lk(expCtx->opCtx, MODE_IS);
WriteUnitOfWork wuow(expCtx->opCtx);
auto status = rs->truncate(expCtx->opCtx);