summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/oplog_buffer_collection.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/oplog_buffer_collection.cpp')
-rw-r--r--src/mongo/db/repl/oplog_buffer_collection.cpp6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/mongo/db/repl/oplog_buffer_collection.cpp b/src/mongo/db/repl/oplog_buffer_collection.cpp
index 818a1e205fd..90a8f120c97 100644
--- a/src/mongo/db/repl/oplog_buffer_collection.cpp
+++ b/src/mongo/db/repl/oplog_buffer_collection.cpp
@@ -47,7 +47,7 @@ namespace {
const char kDefaultOplogCollectionNamespace[] = "local.temp_oplog_buffer";
const char kOplogEntryFieldName[] = "entry";
-const BSONObj kIdObj = BSON("_id" << 1);
+const StringData kIdIdxName = "_id_"_sd;
} // namespace
@@ -222,7 +222,7 @@ bool OplogBufferCollection::_doPop_inlock(OperationContext* txn, Value* value) {
return true;
}
auto scanDirection = StorageInterface::ScanDirection::kForward;
- auto result = _storageInterface->deleteOne(txn, _nss, kIdObj, scanDirection);
+ auto result = _storageInterface->deleteOne(txn, _nss, kIdIdxName, scanDirection);
if (!result.isOK()) {
if (result != ErrorCodes::CollectionIsEmpty) {
fassert(40162, result.getStatus());
@@ -249,7 +249,7 @@ bool OplogBufferCollection::_peekOneSide_inlock(OperationContext* txn,
}
auto scanDirection = front ? StorageInterface::ScanDirection::kForward
: StorageInterface::ScanDirection::kBackward;
- auto result = _storageInterface->findOne(txn, _nss, kIdObj, scanDirection);
+ auto result = _storageInterface->findOne(txn, _nss, kIdIdxName, scanDirection);
if (!result.isOK()) {
if (result != ErrorCodes::CollectionIsEmpty) {
fassert(40163, result.getStatus());