summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/storage_interface_mock.h
diff options
context:
space:
mode:
authorJudah Schvimer <judah@mongodb.com>2017-04-21 10:27:59 -0400
committerBenety Goh <benety@mongodb.com>2017-04-28 19:52:01 -0400
commit7358c66cbf77203fa0803417a4442e35f11bf3f7 (patch)
tree947ec510b25c7643e3eb8c9e948fdaa75c163888 /src/mongo/db/repl/storage_interface_mock.h
parent60636b4d3ae60a24c080c7250459814eef5e7c87 (diff)
downloadmongo-7358c66cbf77203fa0803417a4442e35f11bf3f7.tar.gz
SERVER-27659 Persist Rollback Id
Diffstat (limited to 'src/mongo/db/repl/storage_interface_mock.h')
-rw-r--r--src/mongo/db/repl/storage_interface_mock.h7
1 files changed, 6 insertions, 1 deletions
diff --git a/src/mongo/db/repl/storage_interface_mock.h b/src/mongo/db/repl/storage_interface_mock.h
index 33b25731dcb..17a17b20b87 100644
--- a/src/mongo/db/repl/storage_interface_mock.h
+++ b/src/mongo/db/repl/storage_interface_mock.h
@@ -129,6 +129,9 @@ public:
OpTime getMinValid(OperationContext* opCtx) const override;
void setMinValid(OperationContext* opCtx, const OpTime& minValid) override;
void setMinValidToAtLeast(OperationContext* opCtx, const OpTime& minValid) override;
+ StatusWith<int> getRollbackID(OperationContext* opCtx) override;
+ Status initializeRollbackID(OperationContext* opCtx) override;
+ Status incrementRollbackID(OperationContext* opCtx) override;
void setOplogDeleteFromPoint(OperationContext* opCtx, const Timestamp& timestamp) override;
Timestamp getOplogDeleteFromPoint(OperationContext* opCtx) override;
void setAppliedThrough(OperationContext* opCtx, const OpTime& optime) override;
@@ -215,7 +218,7 @@ public:
const NamespaceString& nss,
const BSONElement& idKey,
const BSONObj& update) override {
- return Status{ErrorCodes::IllegalOperation, "upsertbyId not implemented."};
+ return Status{ErrorCodes::IllegalOperation, "upsertById not implemented."};
}
Status deleteByFilter(OperationContext* opCtx,
@@ -298,6 +301,8 @@ private:
mutable stdx::mutex _minValidBoundariesMutex;
OpTime _appliedThrough;
OpTime _minValid;
+ int _rbid;
+ bool _rbidInitialized = false;
Timestamp _oplogDeleteFromPoint;
};