diff options
Diffstat (limited to 'src/mongo/db/repl/read_after_optime_args.cpp')
-rw-r--r-- | src/mongo/db/repl/read_after_optime_args.cpp | 94 |
1 files changed, 43 insertions, 51 deletions
diff --git a/src/mongo/db/repl/read_after_optime_args.cpp b/src/mongo/db/repl/read_after_optime_args.cpp index 2a7c7817662..e3dcd87274b 100644 --- a/src/mongo/db/repl/read_after_optime_args.cpp +++ b/src/mongo/db/repl/read_after_optime_args.cpp @@ -41,70 +41,62 @@ using std::string; namespace mongo { namespace repl { - const string ReadAfterOpTimeArgs::kRootFieldName("$readConcern"); - const string ReadAfterOpTimeArgs::kOpTimeFieldName("afterOpTime"); - const string ReadAfterOpTimeArgs::kOpTimestampFieldName("ts"); - const string ReadAfterOpTimeArgs::kOpTermFieldName("term"); +const string ReadAfterOpTimeArgs::kRootFieldName("$readConcern"); +const string ReadAfterOpTimeArgs::kOpTimeFieldName("afterOpTime"); +const string ReadAfterOpTimeArgs::kOpTimestampFieldName("ts"); +const string ReadAfterOpTimeArgs::kOpTermFieldName("term"); - ReadAfterOpTimeArgs::ReadAfterOpTimeArgs(): ReadAfterOpTimeArgs(OpTime()) { - } +ReadAfterOpTimeArgs::ReadAfterOpTimeArgs() : ReadAfterOpTimeArgs(OpTime()) {} - ReadAfterOpTimeArgs::ReadAfterOpTimeArgs(OpTime opTime): - _opTime(std::move(opTime)) { - } +ReadAfterOpTimeArgs::ReadAfterOpTimeArgs(OpTime opTime) : _opTime(std::move(opTime)) {} - const OpTime& ReadAfterOpTimeArgs::getOpTime() const { - return _opTime; - } +const OpTime& ReadAfterOpTimeArgs::getOpTime() const { + return _opTime; +} - Status ReadAfterOpTimeArgs::initialize(const BSONObj& cmdObj) { - auto afterElem = cmdObj[ReadAfterOpTimeArgs::kRootFieldName]; +Status ReadAfterOpTimeArgs::initialize(const BSONObj& cmdObj) { + auto afterElem = cmdObj[ReadAfterOpTimeArgs::kRootFieldName]; - if (afterElem.eoo()) { - return Status::OK(); - } + if (afterElem.eoo()) { + return Status::OK(); + } - if (!afterElem.isABSONObj()) { - return Status(ErrorCodes::FailedToParse, "'after' field should be an object"); - } + if (!afterElem.isABSONObj()) { + return Status(ErrorCodes::FailedToParse, "'after' field should be an object"); + } - BSONObj readAfterObj = afterElem.Obj(); - BSONElement opTimeElem; - auto opTimeStatus = bsonExtractTypedField(readAfterObj, - ReadAfterOpTimeArgs::kOpTimeFieldName, - Object, - &opTimeElem); + BSONObj readAfterObj = afterElem.Obj(); + BSONElement opTimeElem; + auto opTimeStatus = bsonExtractTypedField( + readAfterObj, ReadAfterOpTimeArgs::kOpTimeFieldName, Object, &opTimeElem); - if (!opTimeStatus.isOK()) { - return opTimeStatus; - } + if (!opTimeStatus.isOK()) { + return opTimeStatus; + } - BSONObj opTimeObj = opTimeElem.Obj(); - BSONElement timestampElem; + BSONObj opTimeObj = opTimeElem.Obj(); + BSONElement timestampElem; - Timestamp timestamp; - auto timestampStatus = - bsonExtractTimestampField(opTimeObj, - ReadAfterOpTimeArgs::kOpTimestampFieldName, - ×tamp); + Timestamp timestamp; + auto timestampStatus = bsonExtractTimestampField( + opTimeObj, ReadAfterOpTimeArgs::kOpTimestampFieldName, ×tamp); - if (!timestampStatus.isOK()) { - return timestampStatus; - } + if (!timestampStatus.isOK()) { + return timestampStatus; + } - long long termNumber; - auto termStatus = bsonExtractIntegerField(opTimeObj, - ReadAfterOpTimeArgs::kOpTermFieldName, - &termNumber); + long long termNumber; + auto termStatus = + bsonExtractIntegerField(opTimeObj, ReadAfterOpTimeArgs::kOpTermFieldName, &termNumber); - if (!termStatus.isOK()) { - return termStatus; - } + if (!termStatus.isOK()) { + return termStatus; + } - _opTime = OpTime(timestamp, termNumber); + _opTime = OpTime(timestamp, termNumber); - return Status::OK(); - } + return Status::OK(); +} -} // namespace repl -} // namespace mongo +} // namespace repl +} // namespace mongo |