diff options
author | William Schultz <william.schultz@mongodb.com> | 2017-11-28 16:20:05 -0500 |
---|---|---|
committer | William Schultz <william.schultz@mongodb.com> | 2017-11-28 16:20:05 -0500 |
commit | 48c4e4eb48e7994a78bee8f3384df2963a1ea407 (patch) | |
tree | 0bae29d3a511e2d8cb9030ec023119be884276ef /src/mongo/db/repl/storage_interface_mock.cpp | |
parent | a25df7d03ac286f28eadebdd361802ad522e74e9 (diff) | |
download | mongo-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.cpp | 8 |
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) { |