summaryrefslogtreecommitdiff
path: root/src/mongo/db/repl/repl_set_heartbeat_args.cpp
diff options
context:
space:
mode:
authorMark Benvenuto <mark.benvenuto@mongodb.com>2015-06-20 00:22:50 -0400
committerMark Benvenuto <mark.benvenuto@mongodb.com>2015-06-20 10:56:02 -0400
commit9c2ed42daa8fbbef4a919c21ec564e2db55e8d60 (patch)
tree3814f79c10d7b490948d8cb7b112ac1dd41ceff1 /src/mongo/db/repl/repl_set_heartbeat_args.cpp
parent01965cf52bce6976637ecb8f4a622aeb05ab256a (diff)
downloadmongo-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.cpp245
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