diff options
| author | Judah Schvimer <judah@mongodb.com> | 2017-04-21 10:27:59 -0400 |
|---|---|---|
| committer | Benety Goh <benety@mongodb.com> | 2017-04-28 19:52:01 -0400 |
| commit | 7358c66cbf77203fa0803417a4442e35f11bf3f7 (patch) | |
| tree | 947ec510b25c7643e3eb8c9e948fdaa75c163888 /src/mongo/db/repl/storage_interface_impl.h | |
| parent | 60636b4d3ae60a24c080c7250459814eef5e7c87 (diff) | |
| download | mongo-7358c66cbf77203fa0803417a4442e35f11bf3f7.tar.gz | |
SERVER-27659 Persist Rollback Id
Diffstat (limited to 'src/mongo/db/repl/storage_interface_impl.h')
| -rw-r--r-- | src/mongo/db/repl/storage_interface_impl.h | 7 |
1 files changed, 7 insertions, 0 deletions
diff --git a/src/mongo/db/repl/storage_interface_impl.h b/src/mongo/db/repl/storage_interface_impl.h index adc372f23fd..f2f52ea4e5e 100644 --- a/src/mongo/db/repl/storage_interface_impl.h +++ b/src/mongo/db/repl/storage_interface_impl.h @@ -49,6 +49,9 @@ public: static const char kInitialSyncFlagFieldName[]; static const char kBeginFieldName[]; static const char kOplogDeleteFromPointFieldName[]; + static const char kDefaultRollbackIdNamespace[]; + static const char kRollbackIdFieldName[]; + static const char kRollbackIdDocumentId[]; StorageInterfaceImpl(); explicit StorageInterfaceImpl(const NamespaceString& minValidNss); @@ -67,6 +70,9 @@ public: OpTime getMinValid(OperationContext* opCtx) const override; void setMinValid(OperationContext* opCtx, const OpTime& minValid) override; void setMinValidToAtLeast(OperationContext* opCtx, const OpTime& endOpTime) 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; @@ -151,6 +157,7 @@ private: void updateMinValidDocument(OperationContext* opCtx, const BSONObj& updateSpec); const NamespaceString _minValidNss; + const NamespaceString _rollbackIdNss; }; } // namespace repl |