diff options
| author | Judah Schvimer <judah@mongodb.com> | 2017-04-21 10:27:59 -0400 |
|---|---|---|
| committer | Judah Schvimer <judah@mongodb.com> | 2017-04-21 10:27:59 -0400 |
| commit | ac6f185017f76cc7124373e97a2c55291d5c8956 (patch) | |
| tree | 7fbdfea067a5f43e18942cedb25a8d4fa0410e94 /src/mongo/db/repl/storage_interface_impl.h | |
| parent | 1b386fef6773133a17f1fb1f33a254780c47ab04 (diff) | |
| download | mongo-ac6f185017f76cc7124373e97a2c55291d5c8956.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 |