diff options
author | Judah Schvimer <judah@mongodb.com> | 2017-06-15 10:41:37 -0400 |
---|---|---|
committer | Judah Schvimer <judah@mongodb.com> | 2017-06-15 10:41:37 -0400 |
commit | 9f9ee7c6d3551980a0cc0d164b5deaa08c06c785 (patch) | |
tree | 776b7bb19d7e9cf556e3d017d92230e8a7ea6500 /src/mongo/db/repl/replication_consistency_markers_impl.h | |
parent | f39cdb6b207f8b2e855b3b89cc060c833bb45372 (diff) | |
download | mongo-9f9ee7c6d3551980a0cc0d164b5deaa08c06c785.tar.gz |
SERVER-29254 parse MinValid document with IDL
Diffstat (limited to 'src/mongo/db/repl/replication_consistency_markers_impl.h')
-rw-r--r-- | src/mongo/db/repl/replication_consistency_markers_impl.h | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/mongo/db/repl/replication_consistency_markers_impl.h b/src/mongo/db/repl/replication_consistency_markers_impl.h index fd8a6dc9d26..6ca4a315f5c 100644 --- a/src/mongo/db/repl/replication_consistency_markers_impl.h +++ b/src/mongo/db/repl/replication_consistency_markers_impl.h @@ -31,6 +31,7 @@ #include "mongo/base/disallow_copying.h" #include "mongo/db/namespace_string.h" #include "mongo/db/repl/replication_consistency_markers.h" +#include "mongo/db/repl/replication_consistency_markers_gen.h" namespace mongo { @@ -48,14 +49,13 @@ class ReplicationConsistencyMarkersImpl : public ReplicationConsistencyMarkers { public: static constexpr StringData kDefaultMinValidNamespace = "local.replset.minvalid"_sd; - static constexpr StringData kInitialSyncFlagFieldName = "doingInitialSync"_sd; - static constexpr StringData kBeginFieldName = "begin"_sd; - static constexpr StringData kOplogDeleteFromPointFieldName = "oplogDeleteFromPoint"_sd; explicit ReplicationConsistencyMarkersImpl(StorageInterface* storageInterface); ReplicationConsistencyMarkersImpl(StorageInterface* storageInterface, NamespaceString minValidNss); + void initializeMinValidDocument(OperationContext* opCtx) override; + bool getInitialSyncFlag(OperationContext* opCtx) const override; void setInitialSyncFlag(OperationContext* opCtx) override; void clearInitialSyncFlag(OperationContext* opCtx) override; @@ -73,9 +73,9 @@ public: private: /** * Reads the MinValid document from disk. - * Returns an empty document if not present. + * Returns boost::none if not present. */ - BSONObj _getMinValidDocument(OperationContext* opCtx) const; + boost::optional<MinValidDocument> _getMinValidDocument(OperationContext* opCtx) const; /** * Updates the MinValid document according to the provided update spec. If the collection does |