diff options
author | Moustafa Maher <m.maher@10gen.com> | 2021-06-02 01:21:58 +0000 |
---|---|---|
committer | Evergreen Agent <no-reply@evergreen.mongodb.com> | 2021-06-04 19:07:24 +0000 |
commit | 914174babe1dc163615c0f031db8744aff7d2c8d (patch) | |
tree | 3147f74fb93bffa40c987f9e04143e365e40e1ea /src/mongo/db/write_concern_options.cpp | |
parent | b17e0a99632872e44684700978d55c01be1a7895 (diff) | |
download | mongo-914174babe1dc163615c0f031db8744aff7d2c8d.tar.gz |
SERVER-56694 implicit default majority write concern should set usedDefault=false
Diffstat (limited to 'src/mongo/db/write_concern_options.cpp')
-rw-r--r-- | src/mongo/db/write_concern_options.cpp | 18 |
1 files changed, 9 insertions, 9 deletions
diff --git a/src/mongo/db/write_concern_options.cpp b/src/mongo/db/write_concern_options.cpp index 0a09aa802ff..baf56a1a669 100644 --- a/src/mongo/db/write_concern_options.cpp +++ b/src/mongo/db/write_concern_options.cpp @@ -120,20 +120,20 @@ StatusWith<WriteConcernOptions> WriteConcernOptions::parse(const BSONObj& obj) { if (!jEl.isNumber() && jEl.type() != Bool) { return Status(ErrorCodes::FailedToParse, "j must be numeric or a boolean value"); } - writeConcern.usedDefault = false; + writeConcern.usedDefaultConstructedWC = false; } else if (fieldName == kFSyncFieldName) { fsyncEl = e; if (!fsyncEl.isNumber() && fsyncEl.type() != Bool) { return Status(ErrorCodes::FailedToParse, "fsync must be numeric or a boolean value"); } - writeConcern.usedDefault = false; + writeConcern.usedDefaultConstructedWC = false; } else if (fieldName == kWFieldName) { wEl = e; - writeConcern.usedDefault = false; + writeConcern.usedDefaultConstructedWC = false; } else if (fieldName == kWTimeoutFieldName) { wTimeout = e.safeNumberLong(); - writeConcern.usedDefault = false; + writeConcern.usedDefaultConstructedWC = false; } else if (fieldName == kWElectionIdFieldName) { // Ignore. } else if (fieldName == kWOpTimeFieldName) { @@ -176,11 +176,11 @@ StatusWith<WriteConcernOptions> WriteConcernOptions::parse(const BSONObj& obj) { << repl::ReplSetConfig::kMaxMembers); } writeConcern.wNumNodes = static_cast<decltype(writeConcern.wNumNodes)>(wNumNodes); - writeConcern.usedDefaultW = false; + writeConcern.notExplicitWValue = false; } else if (wEl.type() == String) { writeConcern.wNumNodes = 0; writeConcern.wMode = wEl.valuestrsafe(); - writeConcern.usedDefaultW = false; + writeConcern.notExplicitWValue = false; } else if (wEl.eoo() || wEl.type() == jstNULL || wEl.type() == Undefined) { writeConcern.wNumNodes = 1; } else { @@ -231,7 +231,7 @@ StatusWith<WriteConcernOptions> WriteConcernOptions::extractWCFromCommand(const return sw.getStatus(); } auto writeConcernOptions = sw.getValue(); - writeConcernOptions.usedDefault = false; + writeConcernOptions.usedDefaultConstructedWC = false; return writeConcernOptions; } catch (const DBException& ex) { return ex.toStatus(); @@ -242,8 +242,8 @@ StatusWith<WriteConcernOptions> WriteConcernOptions::convertFromIdl( const WriteConcernIdl& writeConcernIdl) { WriteConcernOptions writeConcern; auto parsedW = writeConcernIdl.getWriteConcernW(); - if (!parsedW.usedDefault()) { - writeConcern.usedDefaultW = false; + if (!parsedW.usedDefaultConstructedW1()) { + writeConcern.notExplicitWValue = false; auto wVal = parsedW.getValue(); if (auto wNum = stdx::get_if<std::int64_t>(&wVal)) { if (*wNum < 0 || |