diff options
Diffstat (limited to 'src/mongo/db/repl/oplog_buffer_collection.cpp')
-rw-r--r-- | src/mongo/db/repl/oplog_buffer_collection.cpp | 6 |
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()); |