1 files changed, 306 insertions, 309 deletions
diff --git a/src/mongo/db/repl/replication_coordinator_mock.cpp b/src/mongo/db/repl/replication_coordinator_mock.cpp
index 9d739707925..19ee9730cae 100644
--- a/src/mongo/db/repl/replication_coordinator_mock.cpp
+++ b/src/mongo/db/repl/replication_coordinator_mock.cpp
@@ -41,315 +41,312 @@
 namespace mongo {
 namespace repl {
 
-    using std::vector;
+using std::vector;
+
+ReplicationCoordinatorMock::ReplicationCoordinatorMock(const ReplSettings& settings)
+    : _settings(settings) {}
+ReplicationCoordinatorMock::~ReplicationCoordinatorMock() {}
+
+void ReplicationCoordinatorMock::startReplication(OperationContext* txn) {
+    // TODO
+}
+
+void ReplicationCoordinatorMock::shutdown() {
+    // TODO
+}
+
+const ReplSettings& ReplicationCoordinatorMock::getSettings() const {
+    return _settings;
+}
+
+bool ReplicationCoordinatorMock::isReplEnabled() const {
+    return _settings.usingReplSets() || _settings.master || _settings.slave;
+}
+
+ReplicationCoordinator::Mode ReplicationCoordinatorMock::getReplicationMode() const {
+    if (_settings.usingReplSets()) {
+        return modeReplSet;
+    }
+    if (_settings.master || _settings.slave) {
+        return modeMasterSlave;
+    }
+    return modeNone;
+}
+
+MemberState ReplicationCoordinatorMock::getMemberState() const {
+    return _memberState;
+}
+
+bool ReplicationCoordinatorMock::isInPrimaryOrSecondaryState() const {
+    invariant(false);
+}
+
+Seconds ReplicationCoordinatorMock::getSlaveDelaySecs() const {
+    return Seconds(0);
+}
+
+void ReplicationCoordinatorMock::clearSyncSourceBlacklist() {}
+
+ReplicationCoordinator::StatusAndDuration ReplicationCoordinatorMock::awaitReplication(
+    OperationContext* txn, const OpTime& opTime, const WriteConcernOptions& writeConcern) {
+    // TODO
+    return StatusAndDuration(Status::OK(), Milliseconds(0));
+}
+
+ReplicationCoordinator::StatusAndDuration
+ReplicationCoordinatorMock::awaitReplicationOfLastOpForClient(
+    OperationContext* txn, const WriteConcernOptions& writeConcern) {
+    return StatusAndDuration(Status::OK(), Milliseconds(0));
+}
+
+Status ReplicationCoordinatorMock::stepDown(OperationContext* txn,
+                                            bool force,
+                                            const Milliseconds& waitTime,
+                                            const Milliseconds& stepdownTime) {
+    return Status::OK();
+}
 
-    ReplicationCoordinatorMock::ReplicationCoordinatorMock(const ReplSettings& settings) :
-            _settings(settings) {}
-    ReplicationCoordinatorMock::~ReplicationCoordinatorMock() {}
+bool ReplicationCoordinatorMock::isMasterForReportingPurposes() {
+    // TODO
+    return true;
+}
 
-    void ReplicationCoordinatorMock::startReplication(OperationContext* txn) {
-        // TODO
-    }
-
-    void ReplicationCoordinatorMock::shutdown() {
-        // TODO
-    }
-
-    const ReplSettings& ReplicationCoordinatorMock::getSettings() const {
-        return _settings;
-    }
-
-    bool ReplicationCoordinatorMock::isReplEnabled() const {
-        return _settings.usingReplSets() || _settings.master || _settings.slave;
-    }
-
-    ReplicationCoordinator::Mode ReplicationCoordinatorMock::getReplicationMode() const {
-        if (_settings.usingReplSets()) {
-            return modeReplSet;
-        }
-        if (_settings.master || _settings.slave) {
-            return modeMasterSlave;
-        }
-        return modeNone;
-    }
-
-    MemberState ReplicationCoordinatorMock::getMemberState() const {
-        return _memberState;
-    }
-
-    bool ReplicationCoordinatorMock::isInPrimaryOrSecondaryState() const {
-        invariant(false);
-    }
-
-    Seconds ReplicationCoordinatorMock::getSlaveDelaySecs() const {
-        return Seconds(0);
-    }
-
-    void ReplicationCoordinatorMock::clearSyncSourceBlacklist() {}
-
-    ReplicationCoordinator::StatusAndDuration ReplicationCoordinatorMock::awaitReplication(
-            OperationContext* txn,
-            const OpTime& opTime,
-            const WriteConcernOptions& writeConcern) {
-        // TODO
-        return StatusAndDuration(Status::OK(), Milliseconds(0));
-    }
-
-    ReplicationCoordinator::StatusAndDuration
-            ReplicationCoordinatorMock::awaitReplicationOfLastOpForClient(
-                    OperationContext* txn,
-                    const WriteConcernOptions& writeConcern) {
-        return StatusAndDuration(Status::OK(), Milliseconds(0));
-    }
-
-    Status ReplicationCoordinatorMock::stepDown(OperationContext* txn,
-                                                bool force,
-                                                const Milliseconds& waitTime,
-                                                const Milliseconds& stepdownTime) {
-        return Status::OK();
-    }
-
-    bool ReplicationCoordinatorMock::isMasterForReportingPurposes() {
-        // TODO
-        return true;
-    }
-
-    bool ReplicationCoordinatorMock::canAcceptWritesForDatabase(StringData dbName) {
-        // TODO
-        return true;
-    }
-
-    bool ReplicationCoordinatorMock::canAcceptWritesFor(const NamespaceString& ns) {
-        // TODO
-        return canAcceptWritesForDatabase(ns.db());
-    }
-
-    Status ReplicationCoordinatorMock::checkCanServeReadsFor(OperationContext* txn,
-                                                             const NamespaceString& ns,
-                                                             bool slaveOk) {
-        // TODO
-        return Status::OK();
-    }
-
-    bool ReplicationCoordinatorMock::shouldIgnoreUniqueIndex(const IndexDescriptor* idx) {
-        // TODO
-        return false;
-    }
-
-    Status ReplicationCoordinatorMock::setLastOptimeForSlave(const OID& rid, const Timestamp& ts) {
-        return Status::OK();
-    }
-    
-    void ReplicationCoordinatorMock::setMyHeartbeatMessage(const std::string& msg) {
-        // TODO
-    }
-
-    void ReplicationCoordinatorMock::setMyLastOptime(const OpTime& opTime) {
-        _myLastOpTime = opTime;
-    }
-
-    void ReplicationCoordinatorMock::resetMyLastOptime() {
-        _myLastOpTime = OpTime();
-    }
-
-    OpTime ReplicationCoordinatorMock::getMyLastOptime() const {
-        return _myLastOpTime;
-    }
-
-    ReadAfterOpTimeResponse ReplicationCoordinatorMock::waitUntilOpTime(
-            OperationContext* txn,
-            const ReadAfterOpTimeArgs& settings) {
-        return ReadAfterOpTimeResponse();
-    }
-
-
-    OID ReplicationCoordinatorMock::getElectionId() {
-        // TODO
-        return OID();
-    }
-
-    OID ReplicationCoordinatorMock::getMyRID() const {
-        return OID();
-    }
-
-    int ReplicationCoordinatorMock::getMyId() const {
-        return 0;
-    }
-
-    bool ReplicationCoordinatorMock::setFollowerMode(const MemberState& newState) {
-        _memberState = newState;
-        return true;
-    }
-
-    bool ReplicationCoordinatorMock::isWaitingForApplierToDrain() {
-        return false;
-    }
-
-    void ReplicationCoordinatorMock::signalDrainComplete(OperationContext*) {}
-
-    void ReplicationCoordinatorMock::signalUpstreamUpdater() {}
-
-    bool ReplicationCoordinatorMock::prepareReplSetUpdatePositionCommand(
-            BSONObjBuilder* cmdBuilder) {
-        cmdBuilder->append("replSetUpdatePosition", 1);
-        return true;
-    }
-
-    ReplicaSetConfig ReplicationCoordinatorMock::getConfig() const {
-        return ReplicaSetConfig();
-    }
-
-    void ReplicationCoordinatorMock::processReplSetGetConfig(BSONObjBuilder* result) {
-        // TODO
-    }
-
-    Status ReplicationCoordinatorMock::processReplSetGetStatus(BSONObjBuilder* result) {
-        return Status::OK();
-    }
-
-    void ReplicationCoordinatorMock::fillIsMasterForReplSet(IsMasterResponse* result) {}
-
-    void ReplicationCoordinatorMock::appendSlaveInfoData(BSONObjBuilder* result) {}
-
-    Status ReplicationCoordinatorMock::setMaintenanceMode(bool activate) {
-        return Status::OK();
-    }
-
-    bool ReplicationCoordinatorMock::getMaintenanceMode() {
-        return false;
-    }
-
-    Status ReplicationCoordinatorMock::processReplSetSyncFrom(const HostAndPort& target,
-                                                              BSONObjBuilder* resultObj) {
-        // TODO
-        return Status::OK();
-    }
-
-    Status ReplicationCoordinatorMock::processReplSetFreeze(int secs, BSONObjBuilder* resultObj) {
-        // TODO
-        return Status::OK();
-    }
-
-    Status ReplicationCoordinatorMock::processHeartbeat(const ReplSetHeartbeatArgs& args,
-                                                        ReplSetHeartbeatResponse* response) {
-        return Status::OK();
-    }
-
-    Status ReplicationCoordinatorMock::processReplSetReconfig(OperationContext* txn,
-                                                              const ReplSetReconfigArgs& args,
-                                                              BSONObjBuilder* resultObj) {
-        return Status::OK();
-    }
-
-    Status ReplicationCoordinatorMock::processReplSetInitiate(OperationContext* txn,
-                                                              const BSONObj& configObj,
-                                                              BSONObjBuilder* resultObj) {
-        return Status::OK();
-    }
-
-    Status ReplicationCoordinatorMock::processReplSetGetRBID(BSONObjBuilder* resultObj) {
-        return Status::OK();
-    }
-
-    void ReplicationCoordinatorMock::incrementRollbackID() {}
-
-    Status ReplicationCoordinatorMock::processReplSetFresh(const ReplSetFreshArgs& args,
-                                                           BSONObjBuilder* resultObj) {
-        return Status::OK();
-    }
-
-    Status ReplicationCoordinatorMock::processReplSetElect(const ReplSetElectArgs& args,
-                                                           BSONObjBuilder* resultObj) {
-        // TODO
-        return Status::OK();
-    }
-
-    Status ReplicationCoordinatorMock::processReplSetUpdatePosition(
-            const UpdatePositionArgs& updates, long long* configVersion) {
-        // TODO
-        return Status::OK();
-    }
-
-    Status ReplicationCoordinatorMock::processHandshake(OperationContext* txn,  
-                                                        const HandshakeArgs& handshake) {
-        return Status::OK();
-    }
-
-    bool ReplicationCoordinatorMock::buildsIndexes() {
-        // TODO
-        return true;
-    }
-
-    std::vector<HostAndPort> ReplicationCoordinatorMock::getHostsWrittenTo(const OpTime& op) {
-        return std::vector<HostAndPort>();
-    }
-
-    vector<HostAndPort> ReplicationCoordinatorMock::getOtherNodesInReplSet() const {
-        return std::vector<HostAndPort>();
-    }
-
-    Status ReplicationCoordinatorMock::checkIfWriteConcernCanBeSatisfied(
-            const WriteConcernOptions& writeConcern) const {
-        return Status::OK();
-    }
-
-    WriteConcernOptions ReplicationCoordinatorMock::getGetLastErrorDefault() {
-        return WriteConcernOptions();
-    }
-
-    Status ReplicationCoordinatorMock::checkReplEnabledForCommand(BSONObjBuilder* result) {
-        // TODO
-        return Status::OK();
-    }
-
-    HostAndPort ReplicationCoordinatorMock::chooseNewSyncSource() {
-        return HostAndPort();
-    }
-
-    void ReplicationCoordinatorMock::blacklistSyncSource(const HostAndPort& host, Date_t until) {
-    }
-
-    void ReplicationCoordinatorMock::resetLastOpTimeFromOplog(OperationContext* txn) {
-        invariant(false);
-    }
-
-    bool ReplicationCoordinatorMock::shouldChangeSyncSource(const HostAndPort& currentSource) {
-        invariant(false);
-    }
-
-    OpTime ReplicationCoordinatorMock::getLastCommittedOpTime() const {
-        return OpTime();
-    }
-
-    Status ReplicationCoordinatorMock::processReplSetRequestVotes(
-            OperationContext* txn,
-            const ReplSetRequestVotesArgs& args,
-            ReplSetRequestVotesResponse* response) {
-        return Status::OK();
-    }
-
-    Status ReplicationCoordinatorMock::processReplSetDeclareElectionWinner(
-            const ReplSetDeclareElectionWinnerArgs& args,
-            long long* responseTerm) {
-        return Status::OK();
-    }
-
-    void ReplicationCoordinatorMock::prepareCursorResponseInfo(BSONObjBuilder* objBuilder) {}
-
-    Status ReplicationCoordinatorMock::processHeartbeatV1(const ReplSetHeartbeatArgsV1& args,
-                                                          ReplSetHeartbeatResponse* response) {
-        return Status::OK();
-    }
-
-    bool ReplicationCoordinatorMock::isV1ElectionProtocol() {
-        return true;
-    }
-
-    void ReplicationCoordinatorMock::summarizeAsHtml(ReplSetHtmlSummary* output) {}
-
-    long long ReplicationCoordinatorMock::getTerm() { return OpTime::kDefaultTerm; }
-
-    bool ReplicationCoordinatorMock::updateTerm(long long term) { return false; }
+bool ReplicationCoordinatorMock::canAcceptWritesForDatabase(StringData dbName) {
+    // TODO
+    return true;
+}
 
-} // namespace repl
-} // namespace mongo
+bool ReplicationCoordinatorMock::canAcceptWritesFor(const NamespaceString& ns) {
+    // TODO
+    return canAcceptWritesForDatabase(ns.db());
+}
+
+Status ReplicationCoordinatorMock::checkCanServeReadsFor(OperationContext* txn,
+                                                         const NamespaceString& ns,
+                                                         bool slaveOk) {
+    // TODO
+    return Status::OK();
+}
+
+bool ReplicationCoordinatorMock::shouldIgnoreUniqueIndex(const IndexDescriptor* idx) {
+    // TODO
+    return false;
+}
+
+Status ReplicationCoordinatorMock::setLastOptimeForSlave(const OID& rid, const Timestamp& ts) {
+    return Status::OK();
+}
+
+void ReplicationCoordinatorMock::setMyHeartbeatMessage(const std::string& msg) {
+    // TODO
+}
+
+void ReplicationCoordinatorMock::setMyLastOptime(const OpTime& opTime) {
+    _myLastOpTime = opTime;
+}
+
+void ReplicationCoordinatorMock::resetMyLastOptime() {
+    _myLastOpTime = OpTime();
+}
+
+OpTime ReplicationCoordinatorMock::getMyLastOptime() const {
+    return _myLastOpTime;
+}
+
+ReadAfterOpTimeResponse ReplicationCoordinatorMock::waitUntilOpTime(
+    OperationContext* txn, const ReadAfterOpTimeArgs& settings) {
+    return ReadAfterOpTimeResponse();
+}
+
+
+OID ReplicationCoordinatorMock::getElectionId() {
+    // TODO
+    return OID();
+}
+
+OID ReplicationCoordinatorMock::getMyRID() const {
+    return OID();
+}
+
+int ReplicationCoordinatorMock::getMyId() const {
+    return 0;
+}
+
+bool ReplicationCoordinatorMock::setFollowerMode(const MemberState& newState) {
+    _memberState = newState;
+    return true;
+}
+
+bool ReplicationCoordinatorMock::isWaitingForApplierToDrain() {
+    return false;
+}
+
+void ReplicationCoordinatorMock::signalDrainComplete(OperationContext*) {}
+
+void ReplicationCoordinatorMock::signalUpstreamUpdater() {}
+
+bool ReplicationCoordinatorMock::prepareReplSetUpdatePositionCommand(BSONObjBuilder* cmdBuilder) {
+    cmdBuilder->append("replSetUpdatePosition", 1);
+    return true;
+}
+
+ReplicaSetConfig ReplicationCoordinatorMock::getConfig() const {
+    return ReplicaSetConfig();
+}
+
+void ReplicationCoordinatorMock::processReplSetGetConfig(BSONObjBuilder* result) {
+    // TODO
+}
+
+Status ReplicationCoordinatorMock::processReplSetGetStatus(BSONObjBuilder* result) {
+    return Status::OK();
+}
+
+void ReplicationCoordinatorMock::fillIsMasterForReplSet(IsMasterResponse* result) {}
+
+void ReplicationCoordinatorMock::appendSlaveInfoData(BSONObjBuilder* result) {}
+
+Status ReplicationCoordinatorMock::setMaintenanceMode(bool activate) {
+    return Status::OK();
+}
+
+bool ReplicationCoordinatorMock::getMaintenanceMode() {
+    return false;
+}
+
+Status ReplicationCoordinatorMock::processReplSetSyncFrom(const HostAndPort& target,
+                                                          BSONObjBuilder* resultObj) {
+    // TODO
+    return Status::OK();
+}
+
+Status ReplicationCoordinatorMock::processReplSetFreeze(int secs, BSONObjBuilder* resultObj) {
+    // TODO
+    return Status::OK();
+}
+
+Status ReplicationCoordinatorMock::processHeartbeat(const ReplSetHeartbeatArgs& args,
+                                                    ReplSetHeartbeatResponse* response) {
+    return Status::OK();
+}
+
+Status ReplicationCoordinatorMock::processReplSetReconfig(OperationContext* txn,
+                                                          const ReplSetReconfigArgs& args,
+                                                          BSONObjBuilder* resultObj) {
+    return Status::OK();
+}
+
+Status ReplicationCoordinatorMock::processReplSetInitiate(OperationContext* txn,
+                                                          const BSONObj& configObj,
+                                                          BSONObjBuilder* resultObj) {
+    return Status::OK();
+}
+
+Status ReplicationCoordinatorMock::processReplSetGetRBID(BSONObjBuilder* resultObj) {
+    return Status::OK();
+}
+
+void ReplicationCoordinatorMock::incrementRollbackID() {}
+
+Status ReplicationCoordinatorMock::processReplSetFresh(const ReplSetFreshArgs& args,
+                                                       BSONObjBuilder* resultObj) {
+    return Status::OK();
+}
+
+Status ReplicationCoordinatorMock::processReplSetElect(const ReplSetElectArgs& args,
+                                                       BSONObjBuilder* resultObj) {
+    // TODO
+    return Status::OK();
+}
+
+Status ReplicationCoordinatorMock::processReplSetUpdatePosition(const UpdatePositionArgs& updates,
+                                                                long long* configVersion) {
+    // TODO
+    return Status::OK();
+}
+
+Status ReplicationCoordinatorMock::processHandshake(OperationContext* txn,
+                                                    const HandshakeArgs& handshake) {
+    return Status::OK();
+}
+
+bool ReplicationCoordinatorMock::buildsIndexes() {
+    // TODO
+    return true;
+}
+
+std::vector<HostAndPort> ReplicationCoordinatorMock::getHostsWrittenTo(const OpTime& op) {
+    return std::vector<HostAndPort>();
+}
+
+vector<HostAndPort> ReplicationCoordinatorMock::getOtherNodesInReplSet() const {
+    return std::vector<HostAndPort>();
+}
+
+Status ReplicationCoordinatorMock::checkIfWriteConcernCanBeSatisfied(
+    const WriteConcernOptions& writeConcern) const {
+    return Status::OK();
+}
+
+WriteConcernOptions ReplicationCoordinatorMock::getGetLastErrorDefault() {
+    return WriteConcernOptions();
+}
+
+Status ReplicationCoordinatorMock::checkReplEnabledForCommand(BSONObjBuilder* result) {
+    // TODO
+    return Status::OK();
+}
+
+HostAndPort ReplicationCoordinatorMock::chooseNewSyncSource() {
+    return HostAndPort();
+}
+
+void ReplicationCoordinatorMock::blacklistSyncSource(const HostAndPort& host, Date_t until) {}
+
+void ReplicationCoordinatorMock::resetLastOpTimeFromOplog(OperationContext* txn) {
+    invariant(false);
+}
+
+bool ReplicationCoordinatorMock::shouldChangeSyncSource(const HostAndPort& currentSource) {
+    invariant(false);
+}
+
+OpTime ReplicationCoordinatorMock::getLastCommittedOpTime() const {
+    return OpTime();
+}
+
+Status ReplicationCoordinatorMock::processReplSetRequestVotes(
+    OperationContext* txn,
+    const ReplSetRequestVotesArgs& args,
+    ReplSetRequestVotesResponse* response) {
+    return Status::OK();
+}
+
+Status ReplicationCoordinatorMock::processReplSetDeclareElectionWinner(
+    const ReplSetDeclareElectionWinnerArgs& args, long long* responseTerm) {
+    return Status::OK();
+}
+
+void ReplicationCoordinatorMock::prepareCursorResponseInfo(BSONObjBuilder* objBuilder) {}
+
+Status ReplicationCoordinatorMock::processHeartbeatV1(const ReplSetHeartbeatArgsV1& args,
+                                                      ReplSetHeartbeatResponse* response) {
+    return Status::OK();
+}
+
+bool ReplicationCoordinatorMock::isV1ElectionProtocol() {
+    return true;
+}
+
+void ReplicationCoordinatorMock::summarizeAsHtml(ReplSetHtmlSummary* output) {}
+
+long long ReplicationCoordinatorMock::getTerm() {
+    return OpTime::kDefaultTerm;
+}
+
+bool ReplicationCoordinatorMock::updateTerm(long long term) {
+    return false;
+}
+
+}  // namespace repl
+}  // namespace mongo