summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/storage_interface_impl.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/repl/storage_interface_impl.cpp')
-rw-r--r--src/mongo/db/repl/storage_interface_impl.cpp7
1 files changed, 4 insertions, 3 deletions
diff --git a/src/mongo/db/repl/storage_interface_impl.cpp b/src/mongo/db/repl/storage_interface_impl.cpp
index a2dca57abdd..35e67cbbe9f 100644
--- a/src/mongo/db/repl/storage_interface_impl.cpp
+++ b/src/mongo/db/repl/storage_interface_impl.cpp
@@ -126,7 +126,8 @@ Status StorageInterfaceImpl::initializeRollbackID(OperationContext* opCtx) {
BSONObjBuilder bob;
rbid.serialize(&bob);
- return insertDocument(opCtx, _rollbackIdNss, bob.done());
+ SnapshotName noTimestamp; // This write is not replicated.
+ return insertDocument(opCtx, _rollbackIdNss, TimestampedBSONObj{bob.done(), noTimestamp});
}
Status StorageInterfaceImpl::incrementRollbackID(OperationContext* opCtx) {
@@ -263,8 +264,8 @@ StorageInterfaceImpl::createCollectionForBulkLoading(
Status StorageInterfaceImpl::insertDocument(OperationContext* opCtx,
const NamespaceString& nss,
- const BSONObj& doc) {
- return insertDocuments(opCtx, nss, {InsertStatement(doc)});
+ const TimestampedBSONObj& doc) {
+ return insertDocuments(opCtx, nss, {InsertStatement(doc.obj, doc.timestamp)});
}
namespace {