summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/storage_interface_mock.cpp
diff options
context:
space:
mode:
authorWilliam Schultz <william.schultz@mongodb.com>2017-11-28 16:20:05 -0500
committerWilliam Schultz <william.schultz@mongodb.com>2017-11-28 16:20:05 -0500
commit48c4e4eb48e7994a78bee8f3384df2963a1ea407 (patch)
tree0bae29d3a511e2d8cb9030ec023119be884276ef /src/mongo/db/repl/storage_interface_mock.cpp
parenta25df7d03ac286f28eadebdd361802ad522e74e9 (diff)
downloadmongo-48c4e4eb48e7994a78bee8f3384df2963a1ea407.tar.gz
SERVER-31662 Initialize rollback id to 1 and log when it changes
Diffstat (limited to 'src/mongo/db/repl/storage_interface_mock.cpp')
-rw-r--r--src/mongo/db/repl/storage_interface_mock.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/mongo/db/repl/storage_interface_mock.cpp b/src/mongo/db/repl/storage_interface_mock.cpp
index 01add91bd00..2282c7ca9ac 100644
--- a/src/mongo/db/repl/storage_interface_mock.cpp
+++ b/src/mongo/db/repl/storage_interface_mock.cpp
@@ -47,7 +47,7 @@ StatusWith<int> StorageInterfaceMock::getRollbackID(OperationContext* opCtx) {
return _rbid;
}
-Status StorageInterfaceMock::initializeRollbackID(OperationContext* opCtx) {
+StatusWith<int> StorageInterfaceMock::initializeRollbackID(OperationContext* opCtx) {
stdx::lock_guard<stdx::mutex> lock(_mutex);
if (_rbidInitialized) {
return Status(ErrorCodes::NamespaceExists, "Rollback ID already initialized");
@@ -56,16 +56,16 @@ Status StorageInterfaceMock::initializeRollbackID(OperationContext* opCtx) {
// Start the mock RBID at a very high number to differentiate it from uninitialized RBIDs.
_rbid = 100;
- return Status::OK();
+ return _rbid;
}
-Status StorageInterfaceMock::incrementRollbackID(OperationContext* opCtx) {
+StatusWith<int> StorageInterfaceMock::incrementRollbackID(OperationContext* opCtx) {
stdx::lock_guard<stdx::mutex> lock(_mutex);
if (!_rbidInitialized) {
return Status(ErrorCodes::NamespaceNotFound, "Rollback ID not initialized");
}
_rbid++;
- return Status::OK();
+ return _rbid;
}
void StorageInterfaceMock::setStableTimestamp(ServiceContext* serviceCtx, Timestamp snapshotName) {