summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/replication_consistency_markers_impl.h
diff options
context:
space:
mode:
authorJudah Schvimer <judah@mongodb.com>2017-06-15 10:41:37 -0400
committerJudah Schvimer <judah@mongodb.com>2017-06-15 10:41:37 -0400
commit9f9ee7c6d3551980a0cc0d164b5deaa08c06c785 (patch)
tree776b7bb19d7e9cf556e3d017d92230e8a7ea6500 /src/mongo/db/repl/replication_consistency_markers_impl.h
parentf39cdb6b207f8b2e855b3b89cc060c833bb45372 (diff)
downloadmongo-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.h10
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