diff options
author | Mark Benvenuto <mark.benvenuto@mongodb.com> | 2015-06-20 00:22:50 -0400 |
---|---|---|
committer | Mark Benvenuto <mark.benvenuto@mongodb.com> | 2015-06-20 10:56:02 -0400 |
commit | 9c2ed42daa8fbbef4a919c21ec564e2db55e8d60 (patch) | |
tree | 3814f79c10d7b490948d8cb7b112ac1dd41ceff1 /src/mongo/db/repl/repl_set_heartbeat_args.cpp | |
parent | 01965cf52bce6976637ecb8f4a622aeb05ab256a (diff) | |
download | mongo-9c2ed42daa8fbbef4a919c21ec564e2db55e8d60.tar.gz |
SERVER-18579: Clang-Format - reformat code, no comment reflow
Diffstat (limited to 'src/mongo/db/repl/repl_set_heartbeat_args.cpp')
-rw-r--r-- | src/mongo/db/repl/repl_set_heartbeat_args.cpp | 245 |
1 files changed, 118 insertions, 127 deletions
diff --git a/src/mongo/db/repl/repl_set_heartbeat_args.cpp b/src/mongo/db/repl/repl_set_heartbeat_args.cpp index 75eee68348f..babca5a0dfa 100644 --- a/src/mongo/db/repl/repl_set_heartbeat_args.cpp +++ b/src/mongo/db/repl/repl_set_heartbeat_args.cpp @@ -39,142 +39,133 @@ namespace repl { namespace { - const std::string kCheckEmptyFieldName = "checkEmpty"; - const std::string kProtocolVersionFieldName = "pv"; - const std::string kConfigVersionFieldName = "v"; - const std::string kSenderIdFieldName = "fromId"; - const std::string kSetNameFieldName = "replSetHeartbeat"; - const std::string kSenderHostFieldName = "from"; - - const std::string kLegalHeartbeatFieldNames[] = { - kCheckEmptyFieldName, - kProtocolVersionFieldName, - kConfigVersionFieldName, - kSenderIdFieldName, - kSetNameFieldName, - kSenderHostFieldName - }; - -} // namespace - - ReplSetHeartbeatArgs::ReplSetHeartbeatArgs() : - _hasCheckEmpty(false), - _hasProtocolVersion(false), - _hasConfigVersion(false), - _hasSenderId(false), - _hasSetName(false), - _hasSenderHost(false), - _checkEmpty(false), - _protocolVersion(-1), - _configVersion(-1), - _senderId(-1), - _setName(""), - _senderHost(HostAndPort()) {} - - Status ReplSetHeartbeatArgs::initialize(const BSONObj& argsObj) { - Status status = bsonCheckOnlyHasFields("ReplSetHeartbeatArgs", - argsObj, - kLegalHeartbeatFieldNames); +const std::string kCheckEmptyFieldName = "checkEmpty"; +const std::string kProtocolVersionFieldName = "pv"; +const std::string kConfigVersionFieldName = "v"; +const std::string kSenderIdFieldName = "fromId"; +const std::string kSetNameFieldName = "replSetHeartbeat"; +const std::string kSenderHostFieldName = "from"; + +const std::string kLegalHeartbeatFieldNames[] = {kCheckEmptyFieldName, + kProtocolVersionFieldName, + kConfigVersionFieldName, + kSenderIdFieldName, + kSetNameFieldName, + kSenderHostFieldName}; + +} // namespace + +ReplSetHeartbeatArgs::ReplSetHeartbeatArgs() + : _hasCheckEmpty(false), + _hasProtocolVersion(false), + _hasConfigVersion(false), + _hasSenderId(false), + _hasSetName(false), + _hasSenderHost(false), + _checkEmpty(false), + _protocolVersion(-1), + _configVersion(-1), + _senderId(-1), + _setName(""), + _senderHost(HostAndPort()) {} + +Status ReplSetHeartbeatArgs::initialize(const BSONObj& argsObj) { + Status status = + bsonCheckOnlyHasFields("ReplSetHeartbeatArgs", argsObj, kLegalHeartbeatFieldNames); + if (!status.isOK()) + return status; + + status = bsonExtractBooleanFieldWithDefault(argsObj, kCheckEmptyFieldName, false, &_checkEmpty); + if (!status.isOK()) + return status; + _hasCheckEmpty = true; + + status = bsonExtractIntegerField(argsObj, kProtocolVersionFieldName, &_protocolVersion); + if (!status.isOK()) + return status; + _hasProtocolVersion = true; + + status = bsonExtractIntegerField(argsObj, kConfigVersionFieldName, &_configVersion); + if (!status.isOK()) + return status; + _hasConfigVersion = true; + + status = bsonExtractIntegerFieldWithDefault(argsObj, kSenderIdFieldName, -1, &_senderId); + if (!status.isOK()) + return status; + _hasSenderId = true; + + status = bsonExtractStringField(argsObj, kSetNameFieldName, &_setName); + if (!status.isOK()) + return status; + _hasSetName = true; + + std::string hostAndPortString; + status = + bsonExtractStringFieldWithDefault(argsObj, kSenderHostFieldName, "", &hostAndPortString); + if (!status.isOK()) + return status; + + if (!hostAndPortString.empty()) { + status = _senderHost.initialize(hostAndPortString); if (!status.isOK()) return status; - - status = bsonExtractBooleanFieldWithDefault(argsObj, - kCheckEmptyFieldName, - false, - &_checkEmpty); - if (!status.isOK()) - return status; - _hasCheckEmpty = true; - - status = bsonExtractIntegerField(argsObj, kProtocolVersionFieldName, &_protocolVersion); - if (!status.isOK()) - return status; - _hasProtocolVersion = true; - - status = bsonExtractIntegerField(argsObj, kConfigVersionFieldName, &_configVersion); - if (!status.isOK()) - return status; - _hasConfigVersion = true; - - status = bsonExtractIntegerFieldWithDefault(argsObj, kSenderIdFieldName, -1, &_senderId); - if (!status.isOK()) - return status; - _hasSenderId = true; - - status = bsonExtractStringField(argsObj, kSetNameFieldName, &_setName); - if (!status.isOK()) - return status; - _hasSetName = true; - - std::string hostAndPortString; - status = bsonExtractStringFieldWithDefault( - argsObj, - kSenderHostFieldName, - "", - &hostAndPortString); - if (!status.isOK()) - return status; - - if (!hostAndPortString.empty()) { - status = _senderHost.initialize(hostAndPortString); - if (!status.isOK()) - return status; - _hasSenderHost = true; - } - - return Status::OK(); - } - - bool ReplSetHeartbeatArgs::isInitialized() const { - return _hasProtocolVersion && _hasConfigVersion && _hasSetName; - } - - BSONObj ReplSetHeartbeatArgs::toBSON() const { - invariant(isInitialized()); - BSONObjBuilder builder; - builder.append("replSetHeartbeat", _setName); - builder.appendIntOrLL("pv", _protocolVersion); - builder.appendIntOrLL("v", _configVersion); - builder.append("from", _hasSenderHost ? _senderHost.toString() : ""); - - if (_hasSenderId) { - builder.appendIntOrLL("fromId", _senderId); - } - if (_hasCheckEmpty) { - builder.append("checkEmpty", _checkEmpty); - } - return builder.obj(); - } - - void ReplSetHeartbeatArgs::setCheckEmpty(bool newVal) { - _checkEmpty = newVal; - _hasCheckEmpty = true; + _hasSenderHost = true; } - void ReplSetHeartbeatArgs::setProtocolVersion(long long newVal) { - _protocolVersion = newVal; - _hasProtocolVersion = true; - } + return Status::OK(); +} - void ReplSetHeartbeatArgs::setConfigVersion(long long newVal) { - _configVersion = newVal; - _hasConfigVersion = true; - } +bool ReplSetHeartbeatArgs::isInitialized() const { + return _hasProtocolVersion && _hasConfigVersion && _hasSetName; +} - void ReplSetHeartbeatArgs::setSenderId(long long newVal) { - _senderId = newVal; - _hasSenderId = true; - } +BSONObj ReplSetHeartbeatArgs::toBSON() const { + invariant(isInitialized()); + BSONObjBuilder builder; + builder.append("replSetHeartbeat", _setName); + builder.appendIntOrLL("pv", _protocolVersion); + builder.appendIntOrLL("v", _configVersion); + builder.append("from", _hasSenderHost ? _senderHost.toString() : ""); - void ReplSetHeartbeatArgs::setSetName(std::string newVal) { - _setName = newVal; - _hasSetName = true; + if (_hasSenderId) { + builder.appendIntOrLL("fromId", _senderId); } - - void ReplSetHeartbeatArgs::setSenderHost(HostAndPort newVal) { - _senderHost = newVal; - _hasSenderHost = true; + if (_hasCheckEmpty) { + builder.append("checkEmpty", _checkEmpty); } + return builder.obj(); +} + +void ReplSetHeartbeatArgs::setCheckEmpty(bool newVal) { + _checkEmpty = newVal; + _hasCheckEmpty = true; +} + +void ReplSetHeartbeatArgs::setProtocolVersion(long long newVal) { + _protocolVersion = newVal; + _hasProtocolVersion = true; +} + +void ReplSetHeartbeatArgs::setConfigVersion(long long newVal) { + _configVersion = newVal; + _hasConfigVersion = true; +} + +void ReplSetHeartbeatArgs::setSenderId(long long newVal) { + _senderId = newVal; + _hasSenderId = true; +} + +void ReplSetHeartbeatArgs::setSetName(std::string newVal) { + _setName = newVal; + _hasSetName = true; +} + +void ReplSetHeartbeatArgs::setSenderHost(HostAndPort newVal) { + _senderHost = newVal; + _hasSenderHost = true; +} } // namespace repl } // namespace mongo |